test for findNextAvailableTime.js

Author: Nazar910

lib/actions/checkAvailability.js

@@ -31,6 +31,7 @@ async function processAction(msg, cfg) {
     });
 
     const currentTime = msg.body.time || (new Date()).toISOString();
+
     const events = await client
         .api('/me/events')
         .filter(`start/dateTime le '${currentTime}' and end/dateTime ge '${currentTime}'`)

lib/actions/findNextAvailableTime.js

@@ -1,14 +1,43 @@
 const elasticio = require('elasticio-node');
 const messages = elasticio.messages;
+const MicrosoftGraph = require('msgraph-sdk-javascript');
 const ApiClient = require('../apiClient');
 
 module.exports.process = processAction;
 
 async function processAction(msg, cfg) {
-    const client = ApiClient(cfg);
+
+    console.log('Refreshing an OAuth Token');
+
+    const instance = new ApiClient(cfg, this);
+
+    //checking if refresh token was successful
+    let newAccessToken;
+    try {
+        newAccessToken = await instance.getRefreshedToken();
+    } catch (e) {
+        throw new Error('Failed to refresh token');
+    }
+
+    if (!newAccessToken) {
+        return;
+    }
+
+    const client = MicrosoftGraph.init({
+        defaultVersion: 'v1.0',
+        debugLogging: true,
+        authProvider: done => {
+            done(null, newAccessToken);
+        }
+    });
+
     let time = msg.body.time || (new Date()).toISOString();
-    const events = await client.get(`/me/events?$filter=start/dateTime le '${time}' 
-      and end/dateTime ge '${time}'`);
+
+    const events = await client
+        .api('/me/events')
+        .filter(`start/dateTime le '${time}' and end/dateTime ge '${time}'`)
+        .get();
+
     if (events.value.length) {
         time = events.value.pop().end.dateTime;
     }

spec/actions/findNextAvailableTime.spec.js

@@ -0,0 +1,81 @@
+'use strict';
+
+describe('Outlook Find next available time', function test() {
+
+    const nock = require('nock');
+    const action = require('../../lib/actions/findNextAvailableTime');
+
+    const cfg = require('../data/configuration.in.json');
+    const jsonIn = require('../data/findNextAvailableTime_test.in.json');
+    const jsonOut = require('../data/findNextAvailableTime_test.out.json');
+
+    const refreshTokenUri = 'https://login.microsoftonline.com';
+    const refreshTokenApi = '/common/oauth2/v2.0/token';
+    const microsoftGraphUri = 'https://graph.microsoft.com/v1.0';
+    const microsoftGraphApi = '/me/events';
+
+
+    var self;
+    beforeEach(function createSpy() {
+        self = jasmine.createSpyObj('self', ['emit']);
+    });
+
+    it('should return available=true on success request - case: http 200', done => {
+        const scope1 = nock(refreshTokenUri).post(refreshTokenApi)
+            .reply(200, {
+                access_token: 1
+            });
+
+        const scope2 = nock(microsoftGraphUri).get(microsoftGraphApi)
+            .query({
+                $filter: `start/dateTime le '${jsonIn.time}' and end/dateTime ge '${jsonIn.time}'`
+            })
+            .reply(200, jsonOut);
+
+        function checkResults(data) {
+            const calls = self.emit.calls;
+            expect(calls.count()).toEqual(1);
+            expect(calls.argsFor(0)[0]).toEqual('updateKeys');
+            expect(calls.argsFor(0)[1]).toEqual({
+                oauth: {
+                    access_token: 1
+                }
+            });
+
+            const { time, subject } = jsonIn;
+
+            expect(data.body).toEqual({
+                time,
+                subject
+            });
+            expect(scope1.isDone()).toBeTruthy();
+            expect(scope2.isDone()).toBeTruthy();
+        }
+
+        action.process.call(self, {
+            body: jsonIn
+        }, cfg, {})
+            .then(checkResults)
+            .then(done)
+            .catch(done.fail);
+    });
+
+    it('should throw error on unsuccessful refresh token request', done => {
+        const scope1 = nock(refreshTokenUri).post(refreshTokenApi)
+            .reply(401, {
+                access_token: 1
+            });
+
+        action.process.call(self, {
+            body: jsonIn
+        }, cfg, {})
+            .catch(err => {
+                expect(err).toEqual(jasmine.any(Error));
+                expect(err.message).toEqual('Failed to refresh token');
+                expect(scope1.isDone()).toBeTruthy();
+                done();
+            });
+
+    });
+
+});

spec/data/findNextAvailableTime_test.in.json

@@ -0,0 +1,4 @@
+{
+  "time": "2017-06-06T12:00:00",
+  "subject": "Some important meeting"
+}

spec/data/findNextAvailableTime_test.out.json

@@ -0,0 +1,3 @@
+{
+  "value": []
+}