progress

Author: ta-deployer

component.json

@@ -25,7 +25,12 @@
             "auth_uri": "https://login.microsoftonline.com/common/oauth2/v2.0/authorize",
             "token_uri": "https://login.microsoftonline.com/common/oauth2/v2.0/token",
             "scopes": [
-                "openid", "offline_access", "User.Read", "Contacts.Read", "Profile", "Calendars.ReadWrite"
+                "openid",
+                "offline_access",
+                "User.Read",
+                "Contacts.Read",
+                "Profile",
+                "Calendars.ReadWrite"
             ]
         }
     },
@@ -49,6 +54,14 @@
                 "out": "./lib/schemas/checkAvailability.out.json"
             }
         },
+        "findNextAvailableTime": {
+            "title": "Find Next Available Time",
+            "main": "./lib/actions/findNextAvailableTime.js",
+            "metadata": {
+                "in": "./lib/schemas/findNextAvailableTime.in.json",
+                "out": "./lib/schemas/findNextAvailableTime.out.json"
+            }
+        },
         "createEvent": {
             "title": "Create Event",
             "main": "./lib/actions/createEvent.js",

lib/actions/findNextAvailableTime.js

@@ -0,0 +1,26 @@
+const elasticio = require('elasticio-node');
+const messages = elasticio.messages;
+const ApiClient = require('../apiClient');
+
+module.exports.process = processAction;
+
+async function processAction(msg, cfg) {
+  try {
+    const client = ApiClient(cfg);
+    let time = msg.body.time || (new Date()).toISOString();
+    let events = await client.get(`/me/events?$filter=start/dateTime le '${time}' 
+          and end/dateTime ge '${time}'`);
+    if (events.value.length) {
+      time = events.value.pop().end.dateTime
+    }
+    this.emit('data', messages.newMessageWithBody({
+      time: time,
+      subject: msg.body.subject
+    }));
+  } catch (e) {
+    console.log(e.error);
+    this.emit('error', e);
+  } finally {
+    this.emit('end');
+  }
+}