send message to slack on cio api error

src/inngest/events/send-slack-message.ts

@@ -12,7 +12,7 @@ const Attachments: z.ZodType<MessageAttachment> = z.any()
 
 export const SlackMessage = z.object({
   instructorId: z.string().optional(),
-  messageType: z.enum(['instructor-comms', 'feedback']),
+  messageType: z.enum(['instructor-comms', 'feedback', 'error']),
   message: z.string(),
   attachments: z.array(Attachments),
 })

src/inngest/functions/send-slack-message.ts

@@ -59,6 +59,19 @@ export const sendSlackMessage = inngest.createFunction(
     } else if (messageType === 'feedback') {
       channel = process.env.SLACK_EGGHEAD_FEEDBACK_CHANNEL_WEBHOOK ?? ''
 
+      try {
+        await postFeedbackToSlack({
+          webhookUrl: channel,
+          username: 'Eggo',
+          text: message,
+          attachments,
+        })
+      } catch (error) {
+        console.error('Error sending slack message', error)
+      }
+    } else if (messageType === 'error') {
+      channel = process.env.SLACK_EGGHEAD_MONITORING_CHANNEL_WEBHOOK ?? ''
+
       try {
         await postFeedbackToSlack({
           webhookUrl: channel,

src/pages/api/cio-subscriber.ts

@@ -4,6 +4,8 @@ import getTracer from '@/utils/honeycomb-tracer'
 import {setupHttpTracing} from '@/utils/tracing-js/dist/src/index'
 import {CIO_IDENTIFIER_KEY} from '@/config'
 import {ENCODED_CUSTOMER_IO_TRACKING_API_CREDENTIALS} from '@/lib/customer-io'
+import {inngest} from '@/inngest/inngest.server'
+import {SEND_SLACK_MESSAGE_EVENT} from '@/inngest/events/send-slack-message'
 
 const serverCookie = require('cookie')
 const axios = require('axios')
@@ -113,8 +115,33 @@ const cioSubscriber = async (req: NextApiRequest, res: NextApiResponse) => {
         console.error('no subscriber was loaded')
         res.status(200).end()
       }
-    } catch (error) {
+    } catch (error: any) {
       console.error(error)
+      console.log('sending message', {res: error.response})
+      const cioId = error.response.config.url.split('/').pop()
+      await inngest.send({
+        name: SEND_SLACK_MESSAGE_EVENT,
+        data: {
+          messageType: 'error',
+          message: `CustomerIO responded with a ${error.response.status} / ${error.response.statusText} on ${error.response.request.path}for /api/cio-subscriber`,
+          channel: 'C04AUF65Y9G',
+          attachments: [
+            {
+              color: '#d42115',
+              blocks: [
+                {
+                  type: 'section',
+                  text: {
+                    type: 'mrkdwn',
+                    text: `${process.env.CUSTOMER_IO_WORKSPACE_URL}/${cioId}`,
+                  },
+                },
+              ],
+            },
+          ],
+        },
+      })
+
       res.status(200).end()
     }
   } else {

src/pages/api/cio/identify/[id].ts

@@ -3,6 +3,8 @@ import getTracer from '@/utils/honeycomb-tracer'
 import {setupHttpTracing} from '@/utils/tracing-js/dist/src'
 import {CIO_IDENTIFIER_KEY} from '@/config'
 import {ENCODED_CUSTOMER_IO_TRACKING_API_CREDENTIALS} from '@/lib/customer-io'
+import {inngest} from '@/inngest/inngest.server'
+import {SEND_SLACK_MESSAGE_EVENT} from '@/inngest/events/send-slack-message'
 
 const serverCookie = require('cookie')
 const axios = require('axios')
@@ -57,8 +59,31 @@ const cioIdentify = async (req: NextApiRequest, res: NextApiResponse) => {
 
       res.setHeader('Set-Cookie', cioCookie)
       res.status(200).json(customer)
-    } catch (error) {
-      console.error(error)
+    } catch (error: any) {
+      console.log('sending message', {res: error.response})
+      const cioId = error.response.config.url.split('/').pop()
+      await inngest.send({
+        name: SEND_SLACK_MESSAGE_EVENT,
+        data: {
+          messageType: 'error',
+          message: `CustomerIO responded with a ${error.response.status} / ${error.response.statusText} on ${error.response.request.path}`,
+          attachments: [
+            {
+              color: '#d42115',
+              blocks: [
+                {
+                  type: 'section',
+                  text: {
+                    type: 'mrkdwn',
+                    text: `${process.env.CUSTOMER_IO_WORKSPACE_URL}/${cioId}`,
+                  },
+                },
+              ],
+            },
+          ],
+        },
+      })
+
       res.status(200).end()
     }
   } else {