Add Webinar Filter to Zoom Admin Webinar Ended Source

components/zoom_admin/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/zoom_admin",
-  "version": "0.11.0",
+  "version": "0.12.0",
   "description": "Pipedream Zoom_admin Components",
   "main": "zoom_admin.app.mjs",
   "keywords": [

components/zoom_admin/sources/account-created/account-created.mjs

@@ -3,13 +3,13 @@
 export default {
   key: "zoom_admin-account-created",
   type: "source",
   name: "Account Created",
   description: "Emits an event each time a sub-account is created in your master account",
-  version: "0.1.6",
+  version: "0.1.8",
   dedupe: "unique", // Dedupe based on account ID
   props: {
     zoomAdmin,
     zoomApphook: {
       type: "$.interface.apphook",
       appProp: "zoomAdmin",
       eventNames: [

components/zoom_admin/sources/account-settings-updated/account-settings-updated.mjs

@@ -3,12 +3,12 @@
 export default {
   key: "zoom_admin-account-settings-updated",
   type: "source",
   name: "Account Settings Updated",
   description: "Emits an event each time your master account or sub-account settings are updated",
-  version: "0.1.6",
+  version: "0.1.7",
   props: {
     zoomAdmin,
     zoomApphook: {
       type: "$.interface.apphook",
       appProp: "zoomAdmin",
       eventNames: [

components/zoom_admin/sources/account-updated/account-updated.mjs

@@ -3,9 +3,9 @@
 export default {
   key: "zoom_admin-account-updated",
   type: "source",
   name: "Account Updated",
   description: "Emits an event each time your master account or sub-account profile is updated",
-  version: "0.1.6",
+  version: "0.1.7",
   props: {
     zoomAdmin,
     zoomApphook: {

components/zoom_admin/sources/custom-events/custom-events.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "Custom Events",
   description: "Listen for any events tied to your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   props: {
     zoomAdmin,
     eventNameOptions: {

components/zoom_admin/sources/meeting-created/meeting-created.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "Meeting Created",
   description: "Emits an event each time a meeting is created in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on meeting ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/meeting-deleted/meeting-deleted.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "Meeting Deleted",
   description: "Emits an event each time a meeting is deleted in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on meeting ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/meeting-ended/meeting-ended.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "Meeting Ended",
   description: "Emits an event each time a meeting ends in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on meeting ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/meeting-started/meeting-started.mjs

@@ -6,7 +6,7 @@ export default {
   type: "source",
   name: "Meeting Started",
   description: "Emits an event each time a meeting starts in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on meeting ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/meeting-updated/meeting-updated.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "Meeting Updated",
   description: "Emits an event each time a meeting is updated in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // dedupe on the meeting ID + timestamp
   props: {
     zoomAdmin,

components/zoom_admin/sources/new-recording-transcript-completed/new-recording-transcript-completed.mjs

@@ -4,7 +4,7 @@ export default {
   key: "zoom_admin-new-recording-transcript-completed",
   name: "New Recording Transcript Completed (Instant)",
   description: "Emit new event each time a recording transcript is completed",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   props: {

components/zoom_admin/sources/recording-completed/recording-completed.mjs

@@ -6,7 +6,7 @@ export default {
   type: "source",
   name: "Recording Completed",
   description: "Emits an event each time a recording is ready for viewing in your Zoom account",
-  version: "0.1.7",
+  version: "0.1.8",
   dedupe: "unique", // Dedupe events based on the ID of the recording file
   props: {
     zoomAdmin,

components/zoom_admin/sources/user-activated/user-activated.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "New User Activated",
   description: "Emit new event each time a user is activated in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on user ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/user-created/user-created.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "User Created",
   description: "Emits an event each time a user is created in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on user ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/user-deactivated/user-deactivated.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "User Deactivated",
   description: "Emits an event each time a user is deactivated in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on user ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/user-deleted/user-deleted.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "User Deleted",
   description: "Emits an event each time a user is deleted in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on user ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/user-invitation-accepted/user-invitation-accepted.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "User Invitation Accepted",
   description: "Emits an event each time a user accepts an invite to your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on user ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/user-updated/user-updated.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "User Updated",
   description: "Emits an event each time a user's settings are updated in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on user ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/webinar-changes-to-panelists/webinar-changes-to-panelists.mjs

@@ -8,7 +8,7 @@ export default {
   type: "source",
   name: "Changes to Webinar Panelists",
   key: "zoom_admin-webinar-changes-to-panelists",
-  version: "0.1.6",
+  version: "0.1.7",
   description: "Emit new event every time a panelist is added or removed from a webinar, or any time their details change",
   dedupe: "unique",
   props: {

components/zoom_admin/sources/webinar-created/webinar-created.mjs

@@ -6,7 +6,7 @@ export default {
   name: "Webinar Created",
   description:
     "Emits an event each time a webinar is created in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on webinar ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/webinar-deleted/webinar-deleted.mjs

@@ -5,7 +5,7 @@ export default {
   name: "Webinar Deleted",
   description:
     "Emits an event each time a webinar is deleted in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   type: "source",
   dedupe: "unique", // Dedupe based on webinar ID
   props: {

components/zoom_admin/sources/webinar-ended/webinar-ended.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "Webinar Ended",
   description: "Emits an event each time a webinar ends in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on webinar ID
   props: {
     zoomAdmin,
@@ -15,21 +15,79 @@ export default {
       eventNames: [
         "webinar.ended",
       ],
+      label: "Zoom Webhook",
+      description: "The webhook to receive webinar ended events from Zoom",
+    },
+    webinar: {
+      type: "string",
+      label: "Webinar",
+      description:
+        "Select a specific webinar to monitor. For recurring webinars, all occurrences will trigger events. Leave empty to monitor all webinars.",
+      optional: true,
+      async options({
+        page,
+        prevContext,
+      }) {
+        if (!prevContext.nextPageToken && page > 0) {
+          return [];
+        }
+        const {
+          webinars,
+          next_page_token: nextPageToken,
+        } =
+          await this.zoomAdmin.listWebinars(30, prevContext.nextPageToken);
+
+        if (!webinars?.length) {
+          return [];
+        }
+
+        return {
+          options: webinars.map((w) => ({
+            label: w.topic,
+            value: w.id,
+          })),
+          context: {
+            nextPageToken,
+          },
+        };
+      },
+    },
+  },
+  methods: {
+    isRelevant(object) {
+      if (!this.webinar) {
+        return true;
+      }
+
+      if (object.id !== this.webinar) {
+        console.log(`Webinar ID ${object.id} does not match filter. Skipping.`);
+        return false;
+      }
+
+      return true;
+    },
+    emitEvent(payload, object) {
+      this.$emit(
+        {
+          event: "webinar.ended",
+          payload,
+        },
+        {
+          summary: `Webinar ${object.topic} ended`,
+          id: object.uuid,
+          ts: +new Date(object.start_time),
+        },
+      );
     },
   },
   async run(event) {
     const { payload } = event;
     const { object } = payload;
-    this.$emit(
-      {
-        event: "webinar.ended",
-        payload,
-      },
-      {
-        summary: `Webinar ${object.topic} ended`,
-        id: object.uuid,
-        ts: +new Date(object.start_time),
-      },
-    );
+
+    if (!this.isRelevant(object)) {
+      return;
+    }
+
+    this.emitEvent(payload, object);
   },
 };

components/zoom_admin/sources/webinar-started/webinar-started.mjs

@@ -5,7 +5,7 @@ export default {
   type: "source",
   name: "Webinar Started",
   description: "Emits an event each time a webinar starts in your Zoom account",
-  version: "0.1.8",
+  version: "0.1.9",
   dedupe: "unique", // Dedupe based on webinar ID
   props: {
     zoomAdmin,

components/zoom_admin/sources/webinar-updated/webinar-updated.mjs

@@ -6,7 +6,7 @@ export default {
   name: "Webinar Updated",
   description:
     "Emits an event each time a webinar is updated in your Zoom account",
-  version: "0.1.6",
+  version: "0.1.7",
   dedupe: "unique", // Dedupe based on webinar ID
   props: {
     zoomAdmin,