Script 'Schedule recovery handler' for slack

Schedule recovery handler

Verified

Created by hugo697 458 days ago Viewed 18404 times

Submitted by hugo697 Bun

Verified 72 days ago

import { WebClient } from "@slack/web-api";
import dayjs from "dayjs";

type Slack = {
  token: string;
};

function formatError(error: any) {
  if (error.stack && error.name && error.message) {
    return `*${error.name}: ${error.message}*\`\`\`\n${error.stack}\n\`\`\``;
  } else {
    return `\`\`\`\n${JSON.stringify(error, null, 2)}\n\`\`\``;
  }
}

export async function main(
  path: string, // The path of the script or flow that errored
  is_flow: boolean, // Whether the runnable is a flow
  schedule_path: string, // The path of the schedule
  error: object, // The error details
  error_started_at: string, // The start datetime of the latest job that failed
  success_times: number, // The number of times the schedule succeeded before calling the recovery handler.
  success_result: object, // The result of the latest successful job
  success_started_at: string, // The start datetime of the latest successful job
  slack: Slack,
  channel: string,
) {
  const baseUrl = process.env["WM_BASE_URL"];
  const scheduleUrl = baseUrl + "/runs?schedule_path=" +
    encodeURIComponent(schedule_path);
  const runnableUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +
    path;
  const web = new WebClient(slack.token);

  await web.chat.postMessage({
    channel,
    text: `Schedule ${schedule_path} recovered ${
      success_times > 1 ? (success_times + " times in a row") : ""
    }`,
    blocks: [
      {
        "type": "section",
        "text": {
          "type": "mrkdwn",
          "text": `*Schedule <${scheduleUrl}|${schedule_path}> recovered*${
            success_times > 1 ? (" " + success_times + " times in a row") : ""
          }:\n- ${is_flow ? "Flow" : "Script"}: <${runnableUrl}|${path}>`,
        },
      },
    ],
    attachments: [
      {
        "blocks": [
          {
            "type": "section",
            "text": {
              "type": "mrkdwn",
              "text": `Last failure at: ${
                dayjs(error_started_at).format("DD.MM.YYYY HH:mm (Z)")
              }\n${formatError(error)}`,
            },
          },
        ],
      },
      {
        color: "#00ff00",
        "blocks": [
          {
            "type": "section",
            "text": {
              "type": "mrkdwn",
              "text": `Last success at: ${
                dayjs(success_started_at).format("DD.MM.YYYY HH:mm (Z)")
              }\n\`\`\`\n${JSON.stringify(success_result)}\n\`\`\``,
            },
          },
        ],
      },
    ],
  });
}


Other submissions

Submitted by hugo697 Deno

Created 458 days ago

All edits

Permalink

import { WebClient } from "@slack/web-api";
import dayjs from "dayjs";

type Slack = {
  token: string;
};

function formatError(error: any) {
  if (error.stack && error.name && error.message) {
    return `*${error.name}: ${error.message}*\`\`\`\n${error.stack}\n\`\`\``;
  } else {
    return `\`\`\`\n${JSON.stringify(error, null, 2)}\n\`\`\``;
  }
}

export async function main(
  path: string, // The path of the script or flow that errored
  is_flow: boolean, // Whether the runnable is a flow
  schedule_path: string, // The path of the schedule
  error: object, // The error details
  error_started_at: string, // The start datetime of the latest job that failed
  success_times: number, // The number of times the schedule succeeded before calling the recovery handler.
  success_result: object, // The result of the latest successful job
  success_started_at: string, // The start datetime of the latest successful job
  slack: Slack,
  channel: string,
) {
  const baseUrl = process.env["WM_BASE_URL"];
  const scheduleUrl = baseUrl + "/runs?schedule_path=" +
    encodeURIComponent(schedule_path);
  const runnableUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +
    path;
  const web = new WebClient(slack.token);

  await web.chat.postMessage({
    channel,
    text: `Schedule ${schedule_path} recovered ${
      success_times > 1 ? (success_times + " times in a row") : ""
    }`,
    blocks: [
      {
        "type": "section",
        "text": {
          "type": "mrkdwn",
          "text": `*Schedule <${scheduleUrl}|${schedule_path}> recovered*${
            success_times > 1 ? (" " + success_times + " times in a row") : ""
          }:\n- ${is_flow ? "Flow" : "Script"}: <${runnableUrl}|${path}>`,
        },
      },
    ],
    attachments: [
      {
        "blocks": [
          {
            "type": "section",
            "text": {
              "type": "mrkdwn",
              "text": `Last failure at: ${
                dayjs(error_started_at).format("DD.MM.YYYY HH:mm (Z)")
              }\n${formatError(error)}`,
            },
          },
        ],
      },
      {
        color: "#00ff00",
        "blocks": [
          {
            "type": "section",
            "text": {
              "type": "mrkdwn",
              "text": `Last success at: ${
                dayjs(success_started_at).format("DD.MM.YYYY HH:mm (Z)")
              }\n\`\`\`\n${JSON.stringify(success_result)}\n\`\`\``,
            },
          },
        ],
      },
    ],
  });
}


`1`	`import { WebClient } from "@slack/web-api";`
`2`	`import dayjs from "dayjs";`
`3`
`4`	`type Slack = {`
`5`	`token: string;`
`6`	`};`
`7`
`8`	`function formatError(error: any) {`
`9`	`if (error.stack && error.name && error.message) {`
`10`	return `${error.name}: ${error.message}\`\`\`\n${error.stack}\n\`\`\``;
`11`	`} else {`
`12`	return `\`\`\`\n${JSON.stringify(error, null, 2)}\n\`\`\``;
`13`	`}`
`14`	`}`
`15`
`16`	`export async function main(`
`17`	`path: string, // The path of the script or flow that errored`
`18`	`is_flow: boolean, // Whether the runnable is a flow`
`19`	`schedule_path: string, // The path of the schedule`
`20`	`error: object, // The error details`
`21`	`error_started_at: string, // The start datetime of the latest job that failed`
`22`	`success_times: number, // The number of times the schedule succeeded before calling the recovery handler.`
`23`	`success_result: object, // The result of the latest successful job`
`24`	`success_started_at: string, // The start datetime of the latest successful job`
`25`	`slack: Slack,`
`26`	`channel: string,`
`27`	`) {`
`28`	`const baseUrl = process.env["WM_BASE_URL"];`
`29`	`const scheduleUrl = baseUrl + "/runs?schedule_path=" +`
`30`	`encodeURIComponent(schedule_path);`
`31`	`const runnableUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +`
`32`	`path;`
`33`	`const web = new WebClient(slack.token);`
`34`
`35`	`await web.chat.postMessage({`
`36`	`channel,`
`37`	text: `Schedule ${schedule_path} recovered ${
`38`	`success_times > 1 ? (success_times + " times in a row") : ""`
`39`	}`,
`40`	`blocks: [`
`41`	`{`
`42`	`"type": "section",`
`43`	`"text": {`
`44`	`"type": "mrkdwn",`
`45`	"text": `Schedule <${scheduleUrl}\|${schedule_path}> recovered${
`46`	`success_times > 1 ? (" " + success_times + " times in a row") : ""`
`47`	}:\n- ${is_flow ? "Flow" : "Script"}: <${runnableUrl}\|${path}>`,
`48`	`},`
`49`	`},`
`50`	`],`
`51`	`attachments: [`
`52`	`{`
`53`	`"blocks": [`
`54`	`{`
`55`	`"type": "section",`
`56`	`"text": {`
`57`	`"type": "mrkdwn",`
`58`	"text": `Last failure at: ${
`59`	`dayjs(error_started_at).format("DD.MM.YYYY HH:mm (Z)")`
`60`	}\n${formatError(error)}`,
`61`	`},`
`62`	`},`
`63`	`],`
`64`	`},`
`65`	`{`
`66`	`color: "#00ff00",`
`67`	`"blocks": [`
`68`	`{`
`69`	`"type": "section",`
`70`	`"text": {`
`71`	`"type": "mrkdwn",`
`72`	"text": `Last success at: ${
`73`	`dayjs(success_started_at).format("DD.MM.YYYY HH:mm (Z)")`
`74`	}\n\`\`\`\n${JSON.stringify(success_result)}\n\`\`\``,
`75`	`},`
`76`	`},`
`77`	`],`
`78`	`},`
`79`	`],`
`80`	`});`
`81`	`}`
`82`

`1`	`import { WebClient } from "@slack/web-api";`
`2`	`import dayjs from "dayjs";`
`3`
`4`	`type Slack = {`
`5`	`token: string;`
`6`	`};`
`7`
`8`	`function formatError(error: any) {`
`9`	`if (error.stack && error.name && error.message) {`
`10`	return `${error.name}: ${error.message}\`\`\`\n${error.stack}\n\`\`\``;
`11`	`} else {`
`12`	return `\`\`\`\n${JSON.stringify(error, null, 2)}\n\`\`\``;
`13`	`}`
`14`	`}`
`15`
`16`	`export async function main(`
`17`	`path: string, // The path of the script or flow that errored`
`18`	`is_flow: boolean, // Whether the runnable is a flow`
`19`	`schedule_path: string, // The path of the schedule`
`20`	`error: object, // The error details`
`21`	`error_started_at: string, // The start datetime of the latest job that failed`
`22`	`success_times: number, // The number of times the schedule succeeded before calling the recovery handler.`
`23`	`success_result: object, // The result of the latest successful job`
`24`	`success_started_at: string, // The start datetime of the latest successful job`
`25`	`slack: Slack,`
`26`	`channel: string,`
`27`	`) {`
`28`	`const baseUrl = process.env["WM_BASE_URL"];`
`29`	`const scheduleUrl = baseUrl + "/runs?schedule_path=" +`
`30`	`encodeURIComponent(schedule_path);`
`31`	`const runnableUrl = baseUrl + (is_flow ? "/flows/get/" : "/scripts/get/") +`
`32`	`path;`
`33`	`const web = new WebClient(slack.token);`
`34`
`35`	`await web.chat.postMessage({`
`36`	`channel,`
`37`	text: `Schedule ${schedule_path} recovered ${
`38`	`success_times > 1 ? (success_times + " times in a row") : ""`
`39`	}`,
`40`	`blocks: [`
`41`	`{`
`42`	`"type": "section",`
`43`	`"text": {`
`44`	`"type": "mrkdwn",`
`45`	"text": `Schedule <${scheduleUrl}\|${schedule_path}> recovered${
`46`	`success_times > 1 ? (" " + success_times + " times in a row") : ""`
`47`	}:\n- ${is_flow ? "Flow" : "Script"}: <${runnableUrl}\|${path}>`,
`48`	`},`
`49`	`},`
`50`	`],`
`51`	`attachments: [`
`52`	`{`
`53`	`"blocks": [`
`54`	`{`
`55`	`"type": "section",`
`56`	`"text": {`
`57`	`"type": "mrkdwn",`
`58`	"text": `Last failure at: ${
`59`	`dayjs(error_started_at).format("DD.MM.YYYY HH:mm (Z)")`
`60`	}\n${formatError(error)}`,
`61`	`},`
`62`	`},`
`63`	`],`
`64`	`},`
`65`	`{`
`66`	`color: "#00ff00",`
`67`	`"blocks": [`
`68`	`{`
`69`	`"type": "section",`
`70`	`"text": {`
`71`	`"type": "mrkdwn",`
`72`	"text": `Last success at: ${
`73`	`dayjs(success_started_at).format("DD.MM.YYYY HH:mm (Z)")`
`74`	}\n\`\`\`\n${JSON.stringify(success_result)}\n\`\`\``,
`75`	`},`
`76`	`},`
`77`	`],`
`78`	`},`
`79`	`],`
`80`	`});`
`81`	`}`
`82`