Promises

.gitignore

@@ -0,0 +1,3 @@
+node_modules
+*.log
+.DS_Store

lib/__snapshots__/dynamodb.test.js.snap

@@ -0,0 +1,23 @@
+// Jest Snapshot v1, https://goo.gl/fbAQLP
+
+exports[`dynamodb should be able to put an item 1`] = `
+Object {
+  "Item": Object {
+    "id": Object {
+      "S": "TEST",
+    },
+  },
+  "TableName": "TEST",
+}
+`;
+
+exports[`dynamodb should be able to put an item, with promise 1`] = `
+Object {
+  "Item": Object {
+    "id": Object {
+      "S": "TEST",
+    },
+  },
+  "TableName": "TEST",
+}
+`;

lib/__snapshots__/ses.test.js.snap

@@ -0,0 +1,49 @@
+// Jest Snapshot v1, https://goo.gl/fbAQLP
+
+exports[`ses should be able to send an email 1`] = `
+Object {
+  "Destination": Object {
+    "ToAddresses": Array [
+      "konsumer@jetboystudio.com",
+    ],
+  },
+  "Message": Object {
+    "Body": Object {
+      "Html": Object {
+        "Data": "<p>This is a test.</p>",
+      },
+      "Text": Object {
+        "Data": "This is a test.",
+      },
+    },
+    "Subject": Object {
+      "Data": "TESTING",
+    },
+  },
+  "Source": "konsumer@jetboystudio.com",
+}
+`;
+
+exports[`ses should be able to send an email, with a promise 1`] = `
+Object {
+  "Destination": Object {
+    "ToAddresses": Array [
+      "konsumer@jetboystudio.com",
+    ],
+  },
+  "Message": Object {
+    "Body": Object {
+      "Html": Object {
+        "Data": "<p>This is a test.</p>",
+      },
+      "Text": Object {
+        "Data": "This is a test.",
+      },
+    },
+    "Subject": Object {
+      "Data": "TESTING",
+    },
+  },
+  "Source": "konsumer@jetboystudio.com",
+}
+`;

lib/__snapshots__/sqs.test.js.snap

@@ -0,0 +1,15 @@
+// Jest Snapshot v1, https://goo.gl/fbAQLP
+
+exports[`sqs should be able to send a message 1`] = `
+Object {
+  "MessageBody": "testing",
+  "QueueUrl": "TEST",
+}
+`;
+
+exports[`sqs should be able to send a message, with a promise 1`] = `
+Object {
+  "MessageBody": "testing",
+  "QueueUrl": "TEST",
+}
+`;

lib/dynamodb.js

@@ -1,6 +1,7 @@
 var AWS = require('aws-sdk');
 var dynargs = require('dynargs');
 var common = require('./common');
+var promisify = require('util').promisify;
 
 var Type = dynargs.type;
 
@@ -162,6 +163,16 @@ function formatKey(parsed) {
 function SimpleDynamoDB(options) {
   options = common.parseOptions(options);
   this.client = new AWS.DynamoDB.Client(options);
+  this.listTables = promisify(this.listTables)
+  this.createTable = promisify(this.createTable);
+  this.getItem = promisify(this.getItem);
+  this.putItem = promisify(this.putItem);
+  this.updateItem = promisify(this.updateItem);
+  this.deleteItem = promisify(this.deleteItem);
+  this.batchGetItem = promisify(this.batchGetItem);
+  this.batchWriteItem = promisify(this.batchWriteItem);
+  this.query = promisify(this.query);
+  this.queryCount = promisify(this.queryCount);
   return this;
 }
 

lib/dynamodb.test.js

@@ -0,0 +1,38 @@
+/* global describe, it, expect, jest */
+
+const { DynamoDB } = require('..')
+
+const ddb = new DynamoDB()
+
+describe('dynamodb', () => {
+  it('should have unit-tests', () => {
+    expect(1 + 1).toBe(2)
+  })
+
+  it('should be able to put an item', async () => {
+    ddb.client.putItem = jest.fn((params, cb) => {
+      expect(params).toMatchSnapshot()
+      cb(null, true)
+    })
+    await new Promise((resolve) => {
+      ddb.putItem('TEST', { id: 'TEST' }, (err, res) => {
+        expect(ddb.client.putItem.mock.calls.length).toBe(1)
+        expect(err).toBe(null)
+        expect(res).toBe(true)
+        ddb.client.putItem.mockReset()
+        resolve()
+      })
+    })
+  })
+
+  it('should be able to put an item, with promise', async () => {
+    ddb.client.putItem = jest.fn((params, cb) => {
+      expect(params).toMatchSnapshot()
+      cb(null, true)
+    })
+    const res = await ddb.putItem('TEST', { id: 'TEST' })
+    expect(ddb.client.putItem.mock.calls.length).toBe(1)
+    expect(res).toBe(true)
+    ddb.client.putItem.mockReset()
+  })
+})

lib/ses.js

@@ -1,6 +1,7 @@
 var AWS = require('aws-sdk');
 var dynargs = require('dynargs');
 var common = require('./common');
+var promisify = require('util').promisify;
 
 var Type = dynargs.type;
 
@@ -20,6 +21,7 @@ function tidy(json) {
 function SimpleSES(options) {
   options = common.parseOptions(options);
   this.client = new AWS.SES(options).client;
+  this.sendEmail = promisify(this.sendEmail)
   return this;
 }
 

lib/ses.test.js

@@ -0,0 +1,50 @@
+/* global describe, it, expect, jest */
+
+const { SES } = require('..')
+
+const ses = new SES()
+
+describe('ses', () => {
+  it('should have unit-tests', () => {
+    expect(1 + 1).toBe(2)
+  })
+
+  it('should be able to send an email', async () => {
+    ses.client.sendEmail = jest.fn((params, cb) => {
+      expect(params).toMatchSnapshot()
+      cb(null, true)
+    })
+    await new Promise((resolve) => {
+      ses.sendEmail(
+        'konsumer@jetboystudio.com',
+        'konsumer@jetboystudio.com',
+        'TESTING',
+        'This is a test.',
+        '<p>This is a test.</p>',
+        (err, res) => {
+          expect(ses.client.sendEmail.mock.calls.length).toBe(1)
+          expect(err).toBe(null)
+          expect(res).toBe(true)
+          resolve()
+        }
+      )
+    })
+  })
+
+  it('should be able to send an email, with a promise', async () => {
+    ses.client.sendEmail = jest.fn((params, cb) => {
+      expect(params).toMatchSnapshot()
+      cb(null, true)
+    })
+    const res = await ses.sendEmail(
+      'konsumer@jetboystudio.com',
+      'konsumer@jetboystudio.com',
+      'TESTING',
+      'This is a test.',
+      '<p>This is a test.</p>'
+    )
+    expect(ses.client.sendEmail.mock.calls.length).toBe(1)
+    expect(res).toBe(true)
+    ses.client.sendEmail.mockReset()
+  })
+})

lib/sqs.js

@@ -1,6 +1,7 @@
 var AWS = require('aws-sdk');
 var dynargs = require('dynargs');
 var common = require('./common');
+var promisify = require('util').promisify;
 
 var Type = dynargs.type;
 
@@ -17,6 +18,11 @@ function SimpleSQS(options) {
   options = common.parseOptions(options);
   var sqsi = new AWS.SQS(options);
   this.client = sqsi.client;
+  this.getQueueUrl = promisify(this.getQueueUrl)
+  this.sendMessage = promisify(this.sendMessage)
+  this.sendMessageBatch = promisify(this.sendMessageBatch)
+  this.deleteMessage = promisify(this.deleteMessage)
+  this.receiveMessage = promisify(this.receiveMessage)
   return this;
 }
 

lib/sqs.test.js

@@ -0,0 +1,38 @@
+/* global describe, it, expect, jest */
+
+const { SQS } = require('..')
+
+const sqs = new SQS()
+
+describe('sqs', () => {
+  it('should have unit-tests', () => {
+    expect(1 + 1).toBe(2)
+  })
+
+  it('should be able to send a message', async () => {
+    sqs.client.sendMessage = jest.fn((params, cb) => {
+      expect(params).toMatchSnapshot()
+      cb(null, true)
+    })
+    await new Promise((resolve) => {
+      sqs.sendMessage('TEST', 'testing', (err, res) => {
+        expect(sqs.client.sendMessage.mock.calls.length).toBe(1)
+        expect(err).toBe(null)
+        expect(res).toBe(true)
+        sqs.client.sendMessage.mockReset()
+        resolve()
+      })
+    })
+  })
+
+  it('should be able to send a message, with a promise', async () => {
+    sqs.client.sendMessage = jest.fn((params, cb) => {
+      expect(params).toMatchSnapshot()
+      cb(null, true)
+    })
+    const res = await sqs.sendMessage('TEST', 'testing')
+    expect(sqs.client.sendMessage.mock.calls.length).toBe(1)
+    expect(res).toBe(true)
+    sqs.client.sendMessage.mockReset()
+  })
+})