Slack Bot

api/directiveResolvers/index.js

@@ -0,0 +1,6 @@
+// @flow
+import isAuthed from './isAuthed';
+
+export default {
+  isAuthed,
+};

api/directiveResolvers/isAuthed.js

@@ -0,0 +1,8 @@
+// @flow
+import UserError from '../utils/UserError';
+import type { GraphQLContext } from '../';
+
+export default (next: Function, _: any, __: any, { user }: GraphQLContext) => {
+  if (user && user.id) return next();
+  throw new UserError(`You must be signed in to do this`);
+};

api/models/channelSettings.js

@@ -1,6 +1,6 @@
 // @flow
 const { db } = require('./db');
-import type { DBChannelSettings } from 'shared/types';
+import type { DBChannelSettings, DBChannel } from 'shared/types';
 import { getChannelById } from './channel';
 import shortid from 'shortid';
 
@@ -9,19 +9,36 @@ const defaultSettings = {
     tokenJoinEnabled: false,
     message: null,
   },
+  slackSettings: {
+    botConnection: {
+      threadCreated: null,
+    },
+  },
 };
 
-export const getChannelSettings = (id: string) => {
-  return db
+export const getOrCreateChannelSettings = async (
+  channelId: string
+): Promise<DBChannelSettings> => {
+  const settings = await db
     .table('channelSettings')
-    .getAll(id, { index: 'channelId' })
-    .run()
-    .then(data => {
-      if (!data || data.length === 0) {
-        return defaultSettings;
-      }
-      return data[0];
-    });
+    .getAll(channelId, { index: 'channelId' })
+    .run();
+
+  if (!settings || settings.length === 0) {
+    return await db
+      .table('channelSettings')
+      .insert(
+        {
+          ...defaultSettings,
+          channelId,
+        },
+        { returnChanges: true }
+      )
+      .run()
+      .then(results => results.changes[0].new_val);
+  }
+
+  return settings[0];
 };
 
 export const getChannelsSettings = (
@@ -50,20 +67,6 @@ export const getChannelsSettings = (
     });
 };
 
-export const createChannelSettings = (id: string) => {
-  return db
-    .table('channelSettings')
-    .insert({
-      channelId: id,
-      joinSettings: {
-        token: null,
-        tokenJoinEnabled: false,
-      },
-    })
-    .run()
-    .then(async () => await getChannelById(id));
-};
-
 export const enableChannelTokenJoin = (id: string) => {
   return db
     .table('channelSettings')
@@ -104,3 +107,58 @@ export const resetChannelJoinToken = (id: string) => {
     .run()
     .then(async () => await getChannelById(id));
 };
+
+type UpdateInput = {
+  channelId: string,
+  slackChannelId: ?string,
+  eventType: 'THREAD_CREATED',
+};
+export const updateChannelSlackBotConnection = async ({
+  channelId,
+  slackChannelId,
+  eventType,
+}: UpdateInput): Promise<DBChannel> => {
+  const settings: DBChannelSettings = await getOrCreateChannelSettings(
+    channelId
+  );
+
+  const botConnectionKey = () => {
+    switch (eventType) {
+      case 'THREAD_CREATED': {
+        return 'threadCreated';
+      }
+      default: {
+        return '';
+      }
+    }
+  };
+
+  let newSettings;
+  if (!settings.slackSettings) {
+    settings.slackSettings = {
+      botConnection: {
+        [botConnectionKey()]:
+          slackChannelId && slackChannelId.length > 0 ? slackChannelId : null,
+      },
+    };
+    newSettings = Object.assign({}, settings);
+  } else {
+    newSettings = Object.assign({}, settings, {
+      slackSettings: {
+        botConnection: {
+          [botConnectionKey()]:
+            slackChannelId && slackChannelId.length > 0 ? slackChannelId : null,
+        },
+      },
+    });
+  }
+
+  return db
+    .table('channelSettings')
+    .getAll(channelId, { index: 'channelId' })
+    .update({
+      ...newSettings,
+    })
+    .run()
+    .then(() => getChannelById(channelId));
+};

api/models/communitySettings.js

@@ -1,16 +1,31 @@
 // @flow
 const { db } = require('./db');
-import type { DBCommunitySettings } from 'shared/types';
+import type { DBCommunitySettings, DBCommunity } from 'shared/types';
 import { getCommunityById } from './community';
+import axios from 'axios';
+const querystring = require('querystring');
 
 const defaultSettings = {
   brandedLogin: {
     isEnabled: false,
     message: null,
   },
+  slackSettings: {
+    connectedAt: null,
+    connectedBy: null,
+    teamName: null,
+    teamId: null,
+    scope: null,
+    token: null,
+    invitesSentAt: null,
+    invitesMemberCount: null,
+    invitesCustomMessage: null,
+  },
 };
 
-export const getCommunitySettings = (id: string) => {
+export const getCommunitySettings = (
+  id: string
+): Promise<DBCommunitySettings> => {
   return db
     .table('communitySettings')
     .getAll(id, { index: 'communityId' })
@@ -62,7 +77,7 @@ export const getCommunitiesSettings = (
     });
 };
 
-export const createCommunitySettings = (id: string) => {
+export const createCommunitySettings = (id: string): Promise<DBCommunity> => {
   return db
     .table('communitySettings')
     .insert({
@@ -71,12 +86,25 @@ export const createCommunitySettings = (id: string) => {
         isEnabled: false,
         message: null,
       },
+      slackSettings: {
+        connectedAt: null,
+        connectedBy: null,
+        invitesSentAt: null,
+        teamName: null,
+        teamId: null,
+        invitesMemberCount: null,
+        invitesCustomMessage: null,
+        scope: null,
+        token: null,
+      },
     })
     .run()
     .then(async () => await getCommunityById(id));
 };
 
-export const enableCommunityBrandedLogin = (id: string) => {
+export const enableCommunityBrandedLogin = (
+  id: string
+): Promise<DBCommunity> => {
   return db
     .table('communitySettings')
     .getAll(id, { index: 'communityId' })
@@ -89,7 +117,9 @@ export const enableCommunityBrandedLogin = (id: string) => {
     .then(async () => await getCommunityById(id));
 };
 
-export const disableCommunityBrandedLogin = (id: string) => {
+export const disableCommunityBrandedLogin = (
+  id: string
+): Promise<DBCommunity> => {
   return db
     .table('communitySettings')
     .getAll(id, { index: 'communityId' })
@@ -105,7 +135,7 @@ export const disableCommunityBrandedLogin = (id: string) => {
 export const updateCommunityBrandedLoginMessage = (
   id: string,
   message: ?string
-) => {
+): Promise<DBCommunity> => {
   return db
     .table('communitySettings')
     .getAll(id, { index: 'communityId' })
@@ -117,3 +147,157 @@ export const updateCommunityBrandedLoginMessage = (
     .run()
     .then(async () => await getCommunityById(id));
 };
+
+type UpdateSlackSettingsInput = {
+  token: string,
+  teamName: string,
+  teamId: string,
+  connectedBy: string,
+  scope: string,
+};
+export const updateSlackSettingsAfterConnection = async (
+  communityId: string,
+  input: UpdateSlackSettingsInput
+): Promise<DBCommunity> => {
+  const settings = await db
+    .table('communitySettings')
+    .getAll(communityId, { index: 'communityId' })
+    .run();
+
+  if (!settings || settings.length === 0) {
+    return await createCommunitySettings(communityId)
+      .then(() => {
+        return db
+          .table('communitySettings')
+          .getAll(communityId, { index: 'communityId' })
+          .update({
+            slackSettings: {
+              ...defaultSettings.slackSettings,
+              ...input,
+              connectedAt: new Date(),
+            },
+          })
+          .run();
+      })
+      .then(async () => await getCommunityById(communityId));
+  }
+
+  return await db
+    .table('communitySettings')
+    .getAll(communityId, { index: 'communityId' })
+    .update({
+      slackSettings: {
+        ...defaultSettings.slackSettings,
+        ...input,
+        connectedAt: new Date(),
+      },
+    })
+    .run()
+    .then(async () => await getCommunityById(communityId));
+};
+
+export const markInitialSlackInvitationsSent = async (
+  communityId: string,
+  inviteCustomMessage: ?string
+): Promise<DBCommunity> => {
+  return db
+    .table('communitySettings')
+    .getAll(communityId, { index: 'communityId' })
+    .update({
+      slackSettings: {
+        invitesSentAt: new Date(),
+        invitesCustomMessage: inviteCustomMessage,
+      },
+    })
+    .run()
+    .then(async () => await getCommunityById(communityId));
+};
+
+const resetSlackSettings = async (communityId: string) => {
+  return db
+    .table('communitySettings')
+    .getAll(communityId, { index: 'communityId' })
+    .update({
+      slackSettings: {
+        ...defaultSettings.slackSettings,
+      },
+    })
+    .run()
+    .then(() => []);
+};
+
+export const getSlackPublicChannelList = (
+  communityId: string,
+  token: string
+) => {
+  if (!token) return [];
+  return axios
+    .get(
+      `https://slack.com/api/channels.list?token=${token}&exclude_archived=true&exclude_members=true`
+    )
+    .then(response => {
+      return handleSlackChannelResponse(response.data, communityId);
+    })
+    .catch(error => {
+      console.error('\n\nerror', error);
+      return [];
+    });
+};
+
+export const getSlackPrivateChannelList = (
+  communityId: string,
+  token: ?string
+) => {
+  if (!token) return [];
+  return axios
+    .get(
+      `https://slack.com/api/groups.list?token=${token}&exclude_archived=true&exclude_members=true`
+    )
+    .then(response => {
+      return handleSlackChannelResponse(response.data, communityId);
+    })
+    .catch(error => {
+      console.error('\n\nerror', error);
+      return [];
+    });
+};
+
+const handleSlackChannelResponse = async (
+  data: Object,
+  communityId: string
+) => {
+  const mapData = (arr: Array<any>) =>
+    arr &&
+    arr.length > 0 &&
+    arr.map(
+      o =>
+        o && {
+          id: o.id,
+          name: o.name,
+        }
+    );
+
+  if (data && data.ok) {
+    if (data.groups) {
+      return mapData(data.groups) || [];
+    }
+
+    if (data.channels) {
+      return mapData(data.channels) || [];
+    }
+  }
+
+  const errorsToTriggerRest = [
+    'token_revoked',
+    'not_authed',
+    'invalid_auth',
+    'account_inactive',
+    'no_permission',
+  ];
+
+  if (data.error && errorsToTriggerRest.indexOf(data.error) >= 0) {
+    return resetSlackSettings(communityId);
+  }
+
+  return [];
+};