aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Legler <alex@a3li.li>2015-02-23 01:05:20 +0100
committerAlex Legler <alex@a3li.li>2015-02-23 01:05:20 +0100
commitd3a8004768e26095748003e7932ea500b26eaa6a (patch)
tree98ab3c6ced02e5442ecbad5d9b7e3344ef78d95c
parentImplement --info (diff)
downloadbackend-d3a8004768e26095748003e7932ea500b26eaa6a.tar.gz
backend-d3a8004768e26095748003e7932ea500b26eaa6a.tar.bz2
backend-d3a8004768e26095748003e7932ea500b26eaa6a.zip
Implement --delete
TODO: Actually delete the message
-rwxr-xr-xag8
-rw-r--r--lib/storage.rb5
2 files changed, 12 insertions, 1 deletions
diff --git a/ag b/ag
index 29ee0f2..dbb1584 100755
--- a/ag
+++ b/ag
@@ -142,7 +142,13 @@ def do_incremental
end
def do_delete
- abort 'Come back later.'
+ id = Ag::Utils.resolve_id
+
+ begin
+ Ag::Storage.delete($options.name, id)
+ rescue => e
+ $stderr.puts "Cannot delete message: #{e}"
+ end
end
def do_reindex
diff --git a/lib/storage.rb b/lib/storage.rb
index b4a518e..f255633 100644
--- a/lib/storage.rb
+++ b/lib/storage.rb
@@ -220,6 +220,11 @@ module Ag::Storage
result['hits']['total']
end
+
+ def delete(list, id)
+ $es.delete(index: 'ml-' + list, type: 'message', id: id)
+ end
+
def get(list, id)
result = $es.search(
index: 'ml-' + list,