fix: update slack home with slackTeams collection

christophehurpeau · Oct 1, 2021 · d6f57d6 · d6f57d6
1 parent 708ddb2
commit d6f57d6
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 5 deletions.
diff --git a/dist/index-node12-dev.cjs.js b/dist/index-node12-dev.cjs.js
diff --git a/dist/index-node12.cjs.js b/dist/index-node12.cjs.js
diff --git a/src/slack/home.ts b/src/slack/home.ts
@@ -213,9 +213,22 @@ export const createSlackHomeWorker = (mongoStores: MongoStores) => {
   const scheduleUpdateOrg = async (
     github: Octokit,
     org: Org,
-    slackClient = new WebClient(org.slackToken),
   ): Promise<void> => {
-    const cursor = await mongoStores.orgMembers.cursor();
+    if (!org.slackTeamId || !org.slackToken) return;
+    const [slackClient, cursor] = await Promise.all([
+      org.slackToken
+        ? new WebClient(org.slackToken)
+        : mongoStores.slackTeams
+            .findByKey(org.slackTeamId)
+            .then((slackTeam) => {
+              if (!slackTeam || !slackTeam.botAccessToken) return undefined;
+              return new WebClient(slackTeam.botAccessToken);
+            }),
+      mongoStores.orgMembers.cursor(),
+    ]);
+
+    if (!slackClient) return;
+
     cursor.forEach((member) => {
       scheduleUpdateMember(github, slackClient, member);
     });
@@ -226,7 +239,7 @@ export const createSlackHomeWorker = (mongoStores: MongoStores) => {
   ): Promise<void> => {
     const cursor = await mongoStores.orgs.cursor();
     cursor.forEach(async (org) => {
-      if (!org.slackToken || !org.installationId) return;
+      if (!(org.slackToken || org.slackTeamId) || !org.installationId) return;
       const github = await auth(org.installationId);
       await scheduleUpdateOrg(github, org);
     });