build out demo

Author: JEverhart383

webhook-notifications-knock/.env.example

@@ -1,3 +1,5 @@
 MUX_WEBHOOK_SECRET=
-KNOCK_API_KEY="sk_12345"
-KNOCK_SIGNING_KEY="S25vY2sga25vY2sh..."
+KNOCK_SECRET_KEY=
+NEXT_PUBLIC_KNOCK_API_KEY="sk_12345"
+NEXT_PUBLIC_KNOCK_USER_ID="adfasf"
+NEXT_PUBLIC_KNOCK_FEED_CHANNEL_ID="asdfsdfa"

webhook-notifications-knock/.gitignore

@@ -27,6 +27,7 @@ yarn-error.log*
 
 # local env files
 .env*.local
+.env.local
 
 # vercel
 .vercel

webhook-notifications-knock/app/api/knock/channels/route.ts

@@ -0,0 +1,43 @@
+import { revalidatePath } from 'next/cache';
+import { headers } from 'next/headers';
+
+import { Knock } from '@knocklabs/node';
+const knockClient = new Knock(process.env.KNOCK_SECRET_KEY);
+
+const channels = [
+  {
+    id: 'knock',
+    properties: {
+      name: 'Knock',
+      icon: '🔔',
+      YouTube: 'https://www.youtube.com/channel/UCDScOjujAI3-_9iJ0Me0Aug',
+      Twitter: 'https://twitter.com/knocklabs',
+    },
+  },
+  {
+    id: 'mux',
+    properties: {
+      name: 'Mux',
+      icon: '📹',
+      YouTube: 'https://www.youtube.com/@MuxHQ',
+      Twitter: 'https://twitter.com/MuxHQ',
+    },
+  },
+];
+
+export async function POST(request: Request) {
+  const body = await request.text();
+  const payload = JSON.parse(body);
+  if (payload.action === 'create') {
+    channels.forEach(async (channel) => {
+      await knockClient.objects.set('channels', channel.id, channel.properties);
+    });
+  }
+
+  if (payload.action === 'delete') {
+    channels.forEach(async (channel) => {
+      await knockClient.objects.delete('channels', channel.id);
+    });
+  }
+  return Response.json({ message: 'ok' });
+}

webhook-notifications-knock/app/api/knock/on-play/route.ts

@@ -0,0 +1,20 @@
+import { revalidatePath } from 'next/cache';
+import { headers } from 'next/headers';
+
+import { Knock } from '@knocklabs/node';
+const knockClient = new Knock(process.env.KNOCK_SECRET_KEY);
+
+export async function POST(request: Request) {
+  const body = await request.text();
+  const inlineUser = {
+    id: 'fde69556-a3a5-4812-a3e9-c9ded0cbc950',
+    name: 'John Hammond',
+    email: '[email protected]',
+  };
+  knockClient.workflows.trigger('new-view', {
+    recipients: [process.env.NEXT_PUBLIC_KNOCK_USER_ID as string],
+    data: JSON.parse(body),
+  });
+
+  return Response.json({ message: 'ok' });
+}

webhook-notifications-knock/app/api/knock/subscriptions/route.ts

@@ -0,0 +1,66 @@
+import { revalidatePath } from 'next/cache';
+import { headers } from 'next/headers';
+
+import { Knock } from '@knocklabs/node';
+const knockClient = new Knock(process.env.KNOCK_SECRET_KEY);
+
+const subscriptions = [
+  {
+    id: '9d17eb2d-1980-4614-bcfe-5696ca9be631',
+    properties: {
+      role: 'regular',
+    },
+  },
+  {
+    id: 'a12896b9-658b-43ff-8d5b-79c34215778a',
+    properties: {
+      role: 'allAccess',
+    },
+  },
+];
+
+export async function POST(request: Request) {
+  const body = await request.text();
+  const payload = JSON.parse(body);
+  if (payload.action === 'create') {
+    channels.forEach(async (channel) => {
+      subscriptions.forEach(async (subscription) => {
+        await knockClient.objects.addSubscriptions('channels', channel.id, {
+          recipients: [subscription.id],
+          properties: subscription.properties,
+        });
+      });
+    });
+  }
+
+  if (payload.action === 'delete') {
+    channels.forEach(async (channel) => {
+      subscriptions.forEach(async (subscription) => {
+        await knockClient.objects.deleteSubscriptions('channels', channel.id, {
+          recipients: [subscription.id],
+        });
+      });
+    });
+  }
+  return Response.json({ message: 'ok' });
+}
+const channels = [
+  {
+    id: 'knock',
+    properties: {
+      name: 'Knock',
+      icon: '🔔',
+      YouTube: 'https://www.youtube.com/channel/UCDScOjujAI3-_9iJ0Me0Aug',
+      Twitter: 'https://twitter.com/knocklabs',
+    },
+  },
+  {
+    id: 'mux',
+    properties: {
+      name: 'Mux',
+      icon: '📹',
+      YouTube: 'https://www.youtube.com/@MuxHQ',
+      Twitter: 'https://twitter.com/MuxHQ',
+    },
+  },
+];

webhook-notifications-knock/app/api/webhooks/mux/route.ts

@@ -3,36 +3,42 @@ import { headers } from 'next/headers';
 
 import Mux from '@mux/mux-node';
 
-const { Knock } = require("@knocklabs/node");
-const knockClient = new Knock(process.env.KNOCK_API_KEY);
+import { Knock } from '@knocklabs/node';
+const knockClient = new Knock(process.env.KNOCK_SECRET_KEY);
 
-const mux = new Mux({
-    webhookSecret: process.env.MUX_WEBHOOK_SECRET,
-});
+// const mux = new Mux({
+//   webhookSecret: process.env.MUX_WEBHOOK_SECRET,
+// });
 
 export async function POST(request: Request) {
-    const headersList = headers();
-    const body = await request.text();
-    const event = mux.webhooks.unwrap(body, headersList);
+  const headersList = headers();
+  const body = await request.text();
+  const event = JSON.parse(body);
+  console.log(event);
+  //   const event = mux.webhooks.unwrap(body, headersList);
 
-    switch (event.type) {
-        case 'video.live_stream.active':
-        case 'video.asset.ready':
-            // The key of the workflow (from Knock dashboard)
-            await knockClient.notify("dinosaurs-loose", {
-                // user id of who performed the action
-                actor: "dnedry",
-                // list of user ids for who should receive the notification
-                recipients: ["jhammond", "agrant", "imalcolm", "esattler"],
-                // data payload to send through
-                data: event.data,
-                // an optional identifier for the tenant that the notifications belong to
-                tenant: "jurassic-park",
-            });
-            break;
-        default:
-            break;
-    }
+  switch (event.type) {
+    case 'video.live_stream.active':
+      console.log('📺 live stream started.....');
+      const channel = await knockClient.objects.get('channels', 'knock');
+      const { workflow_run_id } = await knockClient.workflows.trigger(
+        'new-stream',
+        {
+          recipients: [{ collection: 'channels', id: 'knock' }],
+          data: {
+            channel,
+          },
+        }
+      );
+      break;
+    case 'video.asset.ready':
+      console.log('🎞️ new asset ready.....');
 
-    return Response.json({ message: 'ok' });
+      console.log(`📨 new workflow run started: ${workflow_run_id}`);
+      break;
+    default:
+      break;
+  }
+
+  return Response.json({ message: 'ok' });
 }