Heimdall prompts users of the zoom command to post meeting notes after the meeting

env-var.list

@@ -1,4 +1,6 @@
 HUBOT_HOST=$HUBOT_HOST
 GITHUB_CLIENT_ID=$GITHUB_CLIENT_ID
 GITHUB_CLIENT_SECRET=$GITHUB_CLIENT_SECRET
-HUBOT_FLOWDOCK_API_TOKEN=$HUBOT_FLOWDOCK_API_TOKEN
+HUBOT_FLOWDOCK_API_TOKEN=$HUBOT_FLOWDOCK_API_TOKEN
+ZOOM_API_KEY=$ZOOM_API_KEY
+ZOOM_API_SECRET=$ZOOM_API_SECRET

lib/zoom.ts

@@ -6,6 +6,7 @@ const API_BASE_URL = "https://api.zoom.us/v2",
   APP_BASE_URL = "zoommtg://zoom.us"
 const URLs = {
   meetings: `${API_BASE_URL}/users/{userId}/meetings`,
+  meetingDetail: `${API_BASE_URL}/meetings/{meetingId}`,
   users: `${API_BASE_URL}/users`,
   appJoin: `${APP_BASE_URL}/join?action=join&confno={meetingId}`,
 }
@@ -32,6 +33,18 @@ async function getSession(apiKey: string, apiSecret: string) {
   }
 }
 
+async function getMeetingDetails(sessionToken: string, meetingId: string) {
+  try {
+    const response = await axios.get(
+      URLs.meetingDetail.replace(/{meetingId}/, meetingId),
+      { params: { access_token: sessionToken } },
+    )
+    return response.data
+  } catch (err) {
+    throw `Something went wrong getting meeting details: ${util.inspect(err)}.`
+  }
+}
+
 enum UserType {
   Basic = 1,
   Pro,
@@ -144,4 +157,4 @@ class Account {
   }
 }
 
-export { getSession, Session }
+export { getSession, Session, getMeetingDetails }

scripts/zoom.js

@@ -15,6 +15,96 @@ const zoom = require("../lib/zoom"),
 /** @type zoom.Session */
 let ZOOM_SESSION = null
 
+const INTERVAL_DELAY = 15 * 1000
+const MEETING_START_TIMEOUT_DELAY = 10 * 60 * 1000 // we'll only watch this long if meeting doesn't start
+const MEETING_DURATION_TIMEOUT_DELAY = 60 * 60 * 1000 // max mtg watch duration
+
+function isMeetingStarted(meeting) {
+  return zoom
+    .getMeetingDetails(ZOOM_SESSION.token, meeting.id)
+    .then(meetingDetail => {
+      if ("status" in meetingDetail && meetingDetail.status === "started") {
+        return true
+      } else {
+        return false
+      }
+    })
+}
+
+function isMeetingFinished(meeting, meetingDidStart) {
+  return zoom
+    .getMeetingDetails(ZOOM_SESSION.token, meeting.id)
+    .then(meetingDetail => {
+      if (
+        "status" in meetingDetail &&
+        meetingDetail.status == "waiting" &&
+        meetingDidStart === true
+      ) {
+        return true
+      } else {
+        return false
+      }
+    })
+}
+
+function watchMeeting(meeting) {
+  let meetingStartedPromise = new Promise((resolve, reject) => {
+    let startIntervalId = setInterval(function() {
+      isMeetingStarted(meeting)
+        .then(isStarted => {
+          if (isStarted === true) {
+            clearInterval(startIntervalId)
+            clearTimeout(startTimeoutId)
+            resolve(true)
+          }
+        })
+        .catch(err => {
+          reject(
+            `Something went wrong setting up START watch interval: ${util.inspect(
+              err,
+            )}`,
+          )
+          return
+        })
+    }, INTERVAL_DELAY)
+    let startTimeoutId = setTimeout(() => {
+      clearInterval(startIntervalId)
+      resolve(false)
+    }, MEETING_START_TIMEOUT_DELAY)
+  })
+  return meetingStartedPromise.then(meetingStartStatus => {
+    let meetingFinishedPromise = new Promise((resolve, reject) => {
+      if (meetingStartStatus === false) {
+        resolve("never started")
+        return
+      }
+      let endIntervalId = setInterval(function() {
+        isMeetingFinished(meeting, meetingStartStatus)
+          .then(isFinished => {
+            if (isFinished === true) {
+              clearInterval(endIntervalId)
+              clearTimeout(endTimeoutId)
+              resolve(true)
+            }
+          })
+          .catch(err => {
+            reject(
+              `Something went wrong setting up END watch interval: ${util.inspect(
+                err,
+              )}`,
+            )
+            return
+          })
+      }, INTERVAL_DELAY)
+      let endTimeoutId = setTimeout(() => {
+        clearInterval(endIntervalId)
+        resolve(null)
+      }, MEETING_DURATION_TIMEOUT_DELAY)
+    })
+    return meetingFinishedPromise
+  })
+}
+
 module.exports = function(robot) {
   zoom
     .getSession(process.env["ZOOM_API_KEY"], process.env["ZOOM_API_SECRET"])
@@ -34,6 +124,7 @@ module.exports = function(robot) {
         res.send(
           `All set; open in [the app](${meeting.app_url}) or [your browser](${meeting.join_url})!`,
         )
+        return meeting
       })
       .catch(err => {
         robot.logger.error(
@@ -42,5 +133,45 @@ module.exports = function(robot) {
         )
         res.send("Uh-oh, there was an issue finding an available meeting :(")
       })
+      .then(meeting => {
+        robot.logger.info(`Start watching meeting: ${meeting.id}`)
+        return watchMeeting(meeting)
+          .then(finalMeetingStatus => {
+            if (!finalMeetingStatus) {
+              // if finalMeetingStatus is null, the meeting exceeded the timeout.
+              // We assume the meeting still happened, so we still want to reply
+              res.send(
+                `@${res.message.user.name} Don't forget to post meeting notes when your call ends!`,
+              )
+              robot.logger.info(
+                `Stopped watching, meeting still going: ${meeting.id}`,
+              )
+            } else if (finalMeetingStatus === "never started") {
+              // log, send flowdock note but no `@` mention
+              robot.logger.info(
+                `This meeting looks like it never started: ${meeting.id}`,
+              )
+              res.send(
+                `Looks like you didn't need this meeting, after all. If do you still need a zoom, please start a new one :)`,
+              )
+            } else {
+              // otherwise, send flowdock prompt
+              res.send(`@${res.message.user.name} Please post call notes!`)
+              robot.logger.info(
+                `Stopped watching, meeting ended: ${meeting.id}`,
+              )
+            }
+          })
+          .catch(err => {
+            robot.logger.error(
+              `Failed to fetch meeting details for ${meeting.id}. ERR:`,
+              util.inspect(err),
+            )
+            // We assume the meeting still happened, so reply (but without `@`)
+            res.send(
+              `Something went wrong watching the meeting; don't forget to post meeting notes when your call ends!`,
+            )
+          })
+      })
   })
 }