creating new webhook for the options-automator

src/blocks/slackBlocks.ts

@@ -1,4 +1,12 @@
-import { KnownBlock, MrkdwnElement } from '@slack/types';
+import { HeaderBlock, KnownBlock, MrkdwnElement, PlainTextElement } from '@slack/types';
+
+
+export function header(text: PlainTextElement): HeaderBlock {
+  return {
+    type: 'header',
+    text,
+  };
+}
 
 export function divider(): KnownBlock {
   return {
@@ -13,9 +21,23 @@ export function markdown(text: string): MrkdwnElement {
   };
 }
 
+export function plaintext(text: string): PlainTextElement {
+  return {
+    type: 'plain_text',
+    text,
+  };
+}
+
 export function section(block: MrkdwnElement): KnownBlock {
   return {
     type: 'section',
     text: block,
   };
 }
+
+export function SectionBlock(fields: MrkdwnElement[]): KnownBlock {
+  return {
+    type: 'section',
+    fields: fields,
+  };
+}

src/config/index.ts

@@ -24,6 +24,8 @@ export const GOCD_ORIGIN =
   process.env.GOCD_ORIGIN || 'https://deploy.getsentry.net';
 export const FEED_DEPLOY_CHANNEL_ID =
   process.env.FEED_DEPLOY_CHANNEL_ID || 'C051ED5GLN4';
+export const FEED_OPTIONS_AUTOMATOR_CHANNEL_ID =
+  process.env.FEED_OPTIONS_AUTOMATOR_CHANNEL_ID || 'C05JJ5JNZAB';
 export const FEED_DEV_INFRA_CHANNEL_ID =
   process.env.FEED_DEV_INFRA_CHANNEL_ID || 'C05816N2A2K';
 export const FEED_ENGINEERING_CHANNEL_ID =

src/types/index.ts

@@ -65,7 +65,7 @@ export type CheckRun = EmitterWebhookEvent<'check_run'>['payload']['check_run'];
 //
 // Need to do this as we can't convert a string literal union to an array of literals
 export const CHECK_RUN_PROPERTIES = ['id', 'head_sha', 'html_url'] as const;
-export type CheckRunProperty = typeof CHECK_RUN_PROPERTIES[number];
+export type CheckRunProperty = (typeof CHECK_RUN_PROPERTIES)[number];
 export type CheckRunForRequiredChecksText = Pick<CheckRun, CheckRunProperty>;
 
 export type GoCDResponse = GoCDStageResponse | GoCDAgentResponse;
@@ -170,3 +170,12 @@ type GoCDApprovalType = 'success' | 'manual';
 type GoCDResultType = 'Passed' | 'Failed' | 'Cancelled' | 'Unknown';
 
 type GoCDStateType = 'Passed' | 'Failed' | 'Cancelled' | 'Building';
+
+export interface OptionsAutomatorResponse {
+  drifted_options: { option_name: string; option_value: string }[];
+  channel_updated_options: string[];
+  updated_options: { option_name: string; db_value: string; value: string }[];
+  set_options: { option_name: string; option_value: string }[];
+  unset_options: string[];
+  error_options: { option_name: string; error_msg: string }[];
+}

src/webhooks/options-automator/index.ts

@@ -0,0 +1 @@
+export { handler } from './options-automator';

src/webhooks/options-automator/options-automator.ts

@@ -0,0 +1,102 @@
+import { KnownBlock, SectionBlock } from '@slack/types';
+import { FastifyRequest } from 'fastify';
+
+import { OptionsAutomatorResponse } from '@types';
+
+import { bolt } from '@/api/slack';
+import * as slackblocks from '@/blocks/slackBlocks';
+import { FEED_OPTIONS_AUTOMATOR_CHANNEL_ID } from '@/config';
+
+export async function handler(
+  request: FastifyRequest<{ Body: OptionsAutomatorResponse }>
+) {
+  const { body }: { body: OptionsAutomatorResponse } = request;
+  await messageSlack(body);
+  return {};
+}
+
+export async function messageSlack(message: OptionsAutomatorResponse) {
+  const successBlock: KnownBlock[] = [
+    slackblocks.header(
+      slackblocks.plaintext('✅ Successfully Updated Options: ✅')
+    ),
+    slackblocks.divider(),
+    slackblocks.section(slackblocks.markdown('*Channel updated options:* ')),
+    slackblocks.SectionBlock(
+      message.channel_updated_options.map((option) =>
+        slackblocks.markdown(`channel updated \`${option}\``)
+      )
+    ),
+    slackblocks.divider(),
+    slackblocks.section(slackblocks.markdown('*Updated options:* ')),
+    slackblocks.SectionBlock(
+      message.updated_options.map((option) =>
+        slackblocks.markdown(
+          `updated \`${option.option_name}\` with db value \`${option.db_value}\` and value \`${option.value}\``
+        )
+      )
+    ),
+    slackblocks.divider(),
+    slackblocks.section(slackblocks.markdown('*Set Options:* ')),
+    slackblocks.SectionBlock(
+      message.set_options.map((option) =>
+        slackblocks.markdown(
+          `Set \`${option.option_name}\` with value \`${option.option_value}\``
+        )
+      )
+    ),
+    slackblocks.divider(),
+    slackblocks.section(slackblocks.markdown('*Unset Options:* ')),
+    slackblocks.SectionBlock(
+      message.unset_options.map((option) =>
+        slackblocks.markdown(`Unset \`${option}\``)
+      )
+    ),
+  ];
+
+  const failedBlock: KnownBlock[] = [
+    slackblocks.header(slackblocks.plaintext('❌ FAILED TO UPDATE: ❌')),
+    slackblocks.divider(),
+    slackblocks.section(slackblocks.markdown('*DRIFTED OPTIONS:* ')),
+    slackblocks.SectionBlock(
+      message.drifted_options.map((option) =>
+        slackblocks.markdown(`\`${option}\` drifted.`)
+      )
+    ),
+    slackblocks.divider(),
+    slackblocks.section(slackblocks.markdown('*FAILED:* ')),
+    slackblocks.SectionBlock(
+      message.error_options.map((option) =>
+        slackblocks.markdown(
+          `FAILED TO UPDATE \`${option.option_name}\` \nREASON: \`${option.error_msg}\``
+        )
+      )
+    ),
+    slackblocks.divider(),
+    slackblocks.section(slackblocks.markdown('*Set Options:* ')),
+    slackblocks.SectionBlock(
+      message.set_options.map((option) =>
+        slackblocks.markdown(
+          `Set \`${option.option_name}\` with value \`${option.option_value}\``
+        )
+      )
+    ),
+  ];
+
+  try {
+    // @ts-ignore
+    await bolt.client.chat.postMessage({
+      blocks: successBlock,
+      channel: FEED_OPTIONS_AUTOMATOR_CHANNEL_ID,
+      unfurl_links: false,
+    });
+    return await bolt.client.chat.postMessage({
+      blocks: failedBlock,
+      channel: FEED_OPTIONS_AUTOMATOR_CHANNEL_ID,
+      unfurl_links: false,
+    });
+  } catch (err) {
+    console.log(err);
+    return;
+  }
+}