Update

Author: seratch

README.md

@@ -29,7 +29,9 @@ slack deploy
 slack trigger create --trigger-def triggers/setup.ts
 ```
 
-You will get a URL (e.g., `https://slack.com/shortcuts/Ft***/****`) to invoke the setup workflow. Once you can share the URL in your Slack workspace, any users in the workspace can enable the translator app in any public channels.
+You will get a URL (e.g., `https://slack.com/shortcuts/Ft***/****`) to invoke
+the setup workflow. Once you can share the URL in your Slack workspace, any
+users in the workspace can enable the translator app in any public channels.
 
 ### 2. Set DeepL API key to the app
 

functions/maintain.ts

@@ -0,0 +1,58 @@
+import { DefineFunction, Schema, SlackFunction } from "deno-slack-sdk/mod.ts";
+import { SlackAPI } from "deno-slack-api/mod.ts";
+import { Logger } from "../utils/logger.ts";
+import { FunctionSourceFile } from "../utils/function_source_file.ts";
+
+export const def = DefineFunction({
+  callback_id: "maintain-channel-memberships",
+  title: "Maintain channel memberships for a trigger",
+  source_file: FunctionSourceFile(import.meta.url),
+  input_parameters: {
+    properties: {
+      workflowCallbackId: { type: Schema.types.string },
+    },
+    required: ["workflowCallbackId"],
+  },
+  output_parameters: {
+    properties: {},
+    required: [],
+  },
+});
+
+export default SlackFunction(def, async ({
+  inputs,
+  env,
+  token,
+}) => {
+  const logger = Logger(env.LOG_LEVEL);
+  const client = SlackAPI(token);
+  // Check the existing triggers for this workflow
+  const allTriggers = await client.workflows.triggers.list({});
+  let targetTrigger = undefined;
+  // find the trigger to maintain
+  if (allTriggers.triggers) {
+    for (const trigger of allTriggers.triggers) {
+      if (
+        trigger.workflow.callback_id === inputs.workflowCallbackId &&
+        trigger.event_type === "slack#/events/reaction_added"
+      ) {
+        targetTrigger = trigger;
+      }
+    }
+  }
+  if (
+    targetTrigger === undefined ||
+    targetTrigger.channel_ids === undefined
+  ) {
+    return { outputs: {} };
+  }
+  // This app's bot user joins all the channels
+  // to perform API calls for the channels
+  for (const channelId of targetTrigger.channel_ids) {
+    const joinResult = await client.conversations.join({
+      channel: channelId,
+    });
+    logger.debug(joinResult);
+  }
+  return { outputs: {} };
+});

manifest.ts

@@ -1,6 +1,7 @@
 import { Manifest } from "deno-slack-sdk/mod.ts";
 import reacjilator from "./workflows/reacjilator.ts";
 import setup from "./workflows/setup.ts";
+import maintenance from "./workflows/maintenance.ts";
 
 export default Manifest({
   name: "DeepL for Slack (beta)",
@@ -9,6 +10,7 @@ export default Manifest({
   workflows: [
     reacjilator,
     setup,
+    maintenance,
   ],
   outgoingDomains: [
     "api-free.deepl.com",

triggers/daily-maintenance.ts

@@ -0,0 +1,17 @@
+import { Trigger } from "deno-slack-api/types.ts";
+import workflowDef from "../workflows/maintenance.ts";
+
+const trigger: Trigger<typeof workflowDef.definition> = {
+  type: "scheduled",
+  name: "Trigger a scheduled maintenance job",
+  workflow: `#/workflows/${workflowDef.definition.callback_id}`,
+  inputs: {},
+  schedule: {
+    // TODO: adjust the start time to be a future date
+    start_time: "2022-10-01T00:00:00Z",
+    end_time: "2037-12-31T23:59:59Z",
+    frequency: { type: "daily", repeats_every: 1 },
+  },
+};
+
+export default trigger;

triggers/hard-code-example.ts triggers/hard-coding-example.ts

@@ -0,0 +1,21 @@
+import { DefineWorkflow } from "deno-slack-sdk/mod.ts";
+import { def as maintainDef } from "../functions/maintain.ts";
+import { default as reacjilatorDef } from "./reacjilator.ts";
+
+/**
+ * https://api.slack.com/future/workflows
+ */
+const workflow = DefineWorkflow({
+  callback_id: "reacjilator-maintenance",
+  title: "Maintain the configuration of the app (beta)",
+  input_parameters: {
+    properties: {},
+    required: [],
+  },
+});
+
+workflow.addStep(maintainDef, {
+  workflowCallbackId: reacjilatorDef.definition.callback_id,
+});
+
+export default workflow;