Merge pull request #5 from ioet/feature/send-slack-notifications-on-midnight-notifications

Feature/send slack notifications on midnight notifications

Author: enriquezrene

.gitignore

@@ -1,3 +1,4 @@
+AutomaticClockOuts/.env
 bin
 obj
 csx

.idea/codeStyles/codeStyleConfig.xml

@@ -0,0 +1,56 @@
+const CosmosClient = require("@azure/cosmos").CosmosClient;
+const config = require("./config");
+const TimeEntry = require('./time_entry');
+const axios = require('axios');
+const MsalClient = require('./msal_client')
+
+const doClockOut = async (context, timer) => {
+  context.log(`I am going to check how many entries were not clocked out ${new Date()}`);
+  const {endpoint, key, databaseId, containerId, slackWebHook} = config;
+  const client = new CosmosClient({endpoint, key});
+  const database = client.database(databaseId);
+  const container = database.container(containerId);
+  const response = await MsalClient.findUsersInMS();
+  const users = response.data.value;
+
+  const QUERY_WITHOUT_END_DATE =
+    "SELECT * FROM c WHERE (NOT IS_DEFINED(c.end_date) OR IS_NULL(c.end_date) = true)  AND IS_DEFINED(c.start_date)"
+
+  const {resources: entries} = await container.items
+    .query({query: QUERY_WITHOUT_END_DATE})
+    .fetchAll();
+
+  context.log(`Checking for time-entries that need to be clocked out`);
+  let totalClockOutsExecuted = 0;
+  const usersWithClockOut = []
+  await Promise.all(entries.map(async (timeEntryAsJson) => {
+    const timeEntry = new TimeEntry(timeEntryAsJson)
+    if (timeEntry.needsToBeClockedOut()) {
+      usersWithClockOut.push(findUser(users, timeEntry.timeEntry.owner_id))
+      timeEntryAsJson.end_date = timeEntry.getTimeToClockOut()
+      await container.item(timeEntryAsJson.id, timeEntryAsJson.tenant_id).replace(timeEntryAsJson)
+      totalClockOutsExecuted++
+    }
+  }));
+  if(totalClockOutsExecuted > 0){
+    axios.post(slackWebHook,
+      {
+        "text": `Hey guys, I did a clock out for you. \nVisit https://timetracker.ioet.com/ and set the right end time for your entries :pls: \n- ${usersWithClockOut.join('\n- ')}`
+      }
+    )
+      .then(function (response) {
+        // console.log(response);
+      })
+      .catch(function (error) {
+        context.log(error);
+      });
+  }
+  context.log(`I just clocked out ${totalClockOutsExecuted} entries, thanks are not needed...`);
+}
+
+const findUser = (users, id) => {
+  const user = users.find( user => user.objectId === id)
+  return user.displayName
+}
+
+module.exports = { doClockOut };

.idea/vcs.xml

@@ -1,9 +1,13 @@
 const config = {
-    endpoint: "https://time-tracker-db.documents.azure.com:443/",
-    key: process.env["COSMOS_DB_KEY"],
+    endpoint: "xxx",
+    key: "xxx",
     databaseId: "time-tracker-db",
     containerId: "time_entry",
-    partitionKey: { kind: "Hash", paths: ["/category"] }
+    partitionKey: { kind: "Hash", paths: ["/category"] },
+    clientId: "xxx",
+    authority: "xxx",
+    clientSecret: "xxx",
+    slackWebHook: "xxx"
 };
 
 module.exports = config;

AutomaticClockOuts/clock_out.js

@@ -1,33 +1,10 @@
 const CosmosClient = require("@azure/cosmos").CosmosClient;
-const moment = require("moment")
 const config = require("./config");
 const TimeEntry = require('./time_entry');
+const axios = require('axios');
+const MsalClient = require('./msal_client');
+const ClockOut = require('./clock_out');
 
 module.exports = async function (context, myTimer) {
-
-    context.log(`I am going to check how many entries were not clocked out ${new Date()}`);
-    const {endpoint, key, databaseId, containerId} = config;
-    const client = new CosmosClient({endpoint, key});
-    const database = client.database(databaseId);
-    const container = database.container(containerId);
-
-    const QUERY_WITHOUT_END_DATE =
-        "SELECT * FROM c WHERE (NOT IS_DEFINED(c.end_date) OR IS_NULL(c.end_date) = true)  AND IS_DEFINED(c.start_date)"
-
-    const {resources: entries} = await container.items
-        .query({query: QUERY_WITHOUT_END_DATE})
-        .fetchAll();
-
-    context.log(`Checking for time-entries that need to be clocked out`);
-    let totalClockOutsExecuted = 0;
-    await Promise.all(entries.map(async (timeEntryAsJson) => {
-        const timeEntry = new TimeEntry(timeEntryAsJson)
-        if (timeEntry.needsToBeClockedOut()) {
-            context.log(`I am going to clock out ${JSON.stringify(timeEntryAsJson.id)}`);
-            timeEntryAsJson.end_date = timeEntry.getTimeToClockOut()
-            await container.item(timeEntryAsJson.id, timeEntryAsJson.tenant_id).replace(timeEntryAsJson)
-            totalClockOutsExecuted++
-        }
-    }));
-    context.log(`I just clocked out ${totalClockOutsExecuted} entries, thanks are not needed...`);
+    await ClockOut.doClockOut(context, myTimer)
 };

AutomaticClockOuts/config.js

@@ -0,0 +1,27 @@
+const axios = require("axios")
+const msal = require('@azure/msal-node');
+const config = require("./config");
+
+const findUsersInMS = async() => {
+    const {clientId, authority, clientSecret} = config;
+    const endpoint = 'https://graph.windows.net/ioetec.onmicrosoft.com'
+    const configuration = {
+        auth: {
+            clientId: clientId,
+            authority: authority,
+            clientSecret: clientSecret
+        }
+    };
+
+    const cca = new msal.ConfidentialClientApplication(configuration);
+    const clientCredentialRequest = {
+        scopes: ['https://graph.windows.net/.default'],
+    };
+    const response = await cca.acquireTokenByClientCredential(clientCredentialRequest)
+    const token = response.accessToken
+    return axios.get(`${endpoint}/users?api-version=1.6&$select=displayName,otherMails,objectId`,
+      { 'headers': { 'Authorization': token } })
+}
+
+module.exports = { findUsersInMS };
+