diff --git a/bin/morgue.js b/bin/morgue.js index fbeea7b..bef2040 100755 --- a/bin/morgue.js +++ b/bin/morgue.js @@ -6343,10 +6343,8 @@ function coronerDelete(argv, config) { } if (aq && aq.query) { - coroner.promise('query', p.universe, p.project, aq.query).then(function(r) { - unpackQueryObjects(o, r); - return delete_fn(); - }).then(std_success_cb).catch(std_failure_cb); + coroner.promise('delete_query', p.universe, p.project, aq.query, + params).then(std_success_cb).catch(std_failure_cb); } else { delete_fn().then(std_success_cb).catch(std_failure_cb); } diff --git a/lib/coroner.js b/lib/coroner.js index 4addd78..5ca00c4 100644 --- a/lib/coroner.js +++ b/lib/coroner.js @@ -597,6 +597,16 @@ CoronerClient.prototype.delete_objects = function(universe, project, objects, pa this.post("/api/delete", { universe }, p, null, callback); }; +CoronerClient.prototype.delete_query = function(universe, project, query, params, callback) { + var p = Object.assign({ + universe: universe, + project: project, + query: query, + }, params); + + this.post("/api/delete", { universe }, p, null, callback); +}; + /* * Find a service from its name. */