Delete item

README.md

@@ -199,6 +199,21 @@ dp.proc({
 });
 ```
 
+### deleteItem
+
+```
+dp.proc({
+  table: 'users',
+  action: 'delete',
+  key: {
+    id: 1
+  }
+})
+.then((item) => {
+  console.log(item); // null
+});
+```
+
 ### Multiple items
 
 #### getItems as Promise Array

lib/doc_client.js

@@ -23,6 +23,11 @@ class DocClient {
       .then(data => data.Attributes);
   }
 
+  delete(params) {
+    return this.client.delete(params).promise()
+      .then(data => null);
+  }
+
   batchWrite(params) {
     return this.client.batchWrite(params).promise()
       .then(data => data.UnprocessedItems);

lib/processor.js

@@ -113,6 +113,28 @@ class Processor {
     return this._wrapFunc ? f : f();
   }
 
+  /**
+   * deleteItem
+   * @param  {string} table - TableName
+   * @param  {object} key - Key
+   */
+  delete(table, key) {
+    const params = {
+      TableName: table,
+      Key: key
+    };
+
+    const f = () => {
+      return this.docClient.delete(params)
+        .then(data => {
+          this.logger.info('Deleted %s from %s table', getKey(key), table);
+          return null;
+        });
+    };
+
+    return this._wrapFunc ? f : f();
+  }
+
   /**
    * batchWriteItems
    * @param  {String} table - table name
@@ -267,7 +289,9 @@ class Processor {
     const useBatch = 'useBatch' in opts_ ? opts_.useBatch : true;
     const table = data.table || opts_.table;
 
-    if (data.action === 'put' || data.item || data.items) {
+    if (data.action === 'delete') {
+      return this.delete(table, data.key);
+    } else if (data.action === 'put' || data.item || data.items) {
       if (data.item) {
         return this.put(table, data.item);
       } else if (data.items) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "dynamo-processor",
-  "version": "0.7.0",
+  "version": "0.8.0",
   "description": "DynamoDB operation processor for Node.js",
   "main": "main.js",
   "scripts": {

test/helper.js

@@ -19,7 +19,7 @@ exports.getDoc = function(id) {
           TableName: TABLE,
           Key: { id }
         }).promise()
-        .then(data => data.Item)
+        .then(data => data.Item || null)
 }
 
 exports.putDoc = function(item) {

test/processor.test.js

@@ -95,6 +95,21 @@ describe('DynamoProcessor', () => {
         });
     });
 
+    it('deletes an item', () => {
+      return dp.proc({
+          action: 'delete',
+          table: 'tests',
+          key: { id: 2 }
+        })
+        .then(res => {
+          expect(res).to.be.null;
+          return helper.getDoc(2);
+        })
+        .then(dbItem => {
+          expect(dbItem).to.be.null
+        });
+    });
+
     context('with initFields', () => {
       it('updates an item with initial fields', () => {
         return dp.proc({