0
Suspend/resume a flow by sending approval URL via slack direct message Approval
One script reply has been approved by the moderators Verified

Using slack resource it sends a direct message with URL to approval page where you can resume or cancel the flow

Created by mrl5 537 days ago Viewed 4760 times
0
Submitted by mrl5 Deno
Verified 537 days ago
1
import { getResumeUrls } from "https://deno.land/x/windmill@v1.85.0/mod.ts";
2
import { WebClient } from "https://deno.land/x/slack_web_api@1.0.3/mod.ts";
3

4
type Slack = {
5
  token: string;
6
};
7
export async function main(approver_emails: string[], slack: Slack) {
8
  throwOnInvalidApprovers(approver_emails);
9

10
  const client = new WebClient(slack.token);
11
  const usersData = await Promise.all(
12
    approver_emails.map((email) => getUserData(client, email)),
13
  );
14
  console.log(usersData);
15
  const dmPromises = usersData.map((userData) =>
16
    sendDirectMessage(client, userData),
17
  );
18

19
  const results = await Promise.all(dmPromises);
20
  return results;
21
}
22

23
interface UserData {
24
  id: string;
25
  email: string;
26
  real_name: string;
27
}
28

29
async function getUserData(client: WebClient, email: string): UserData {
30
  try {
31
    const response = await client.users.lookupByEmail({ email: email });
32

33
    const { id, real_name } = response.user;
34
    return { id, email, real_name };
35
  } catch (err) {
36
    return handleApiResponse(email, err);
37
  }
38
}
39

40
async function sendDirectMessage(client: WebClient, userData: UserData) {
41
  const text = await getApprovalMsg(userData.email);
42

43
  const { ok, ts, channel } = await client.chat.postMessage({
44
    channel: userData.id,
45
    text,
46
  });
47
  return { ok, ts, channel, email: userData.email };
48
}
49

50
async function getApprovalMsg(to_email) {
51
  const { approvalPage } = await getResumeUrls(to_email);
52
  return `There is a Windmill flow at ${Deno.env.get(
53
    "WM_FLOW_PATH",
54
  )} run by ${Deno.env.get("WM_USERNAME")} waiting for your approval to resume.
55

56
In order to resume or cancel the flow go to ${approvalPage}`;
57
}
58

59
function throwOnInvalidApprovers(approvers: string[]) {
60
  if (!Array.isArray(approvers) || approvers.length === 0) {
61
    throw new Error("Expected at least one approver email");
62
  }
63
}
64

65
function handleApiResponse(email, error) {
66
  return Promise.reject({ email, err_msg: error.message });
67
}
68