From c7604fa785f89af09a6df457f046c51e8e915637 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?R=C4=B1dvan=20Akca?= <akca.ridvann@gmail.com>
Date: Tue, 11 Jun 2024 14:19:54 +0200
Subject: [PATCH] feat(eventbrite): add updated attendee trigger

---
 .../src/apps/eventbrite/triggers/index.js     |   8 +-
 .../triggers/updated-attendee/index.js        | 120 ++++++++++++++++++
 .../docs/pages/apps/eventbrite/triggers.md    |   2 +
 3 files changed, 129 insertions(+), 1 deletion(-)
 create mode 100644 packages/backend/src/apps/eventbrite/triggers/updated-attendee/index.js

diff --git a/packages/backend/src/apps/eventbrite/triggers/index.js b/packages/backend/src/apps/eventbrite/triggers/index.js
index c6992fbc..519887f4 100644
--- a/packages/backend/src/apps/eventbrite/triggers/index.js
+++ b/packages/backend/src/apps/eventbrite/triggers/index.js
@@ -1,5 +1,11 @@
 import newAttendeeCheckIn from './new-attendee-check-in/index.js';
 import newAttendeeRegistered from './new-attendee-registered/index.js';
 import newEvents from './new-events/index.js';
+import updatedAttendee from './updated-attendee/index.js';
 
-export default [newAttendeeCheckIn, newAttendeeRegistered, newEvents];
+export default [
+  updatedAttendee,
+  newAttendeeCheckIn,
+  newAttendeeRegistered,
+  newEvents,
+];
diff --git a/packages/backend/src/apps/eventbrite/triggers/updated-attendee/index.js b/packages/backend/src/apps/eventbrite/triggers/updated-attendee/index.js
new file mode 100644
index 00000000..e94d60f0
--- /dev/null
+++ b/packages/backend/src/apps/eventbrite/triggers/updated-attendee/index.js
@@ -0,0 +1,120 @@
+import Crypto from 'crypto';
+import defineTrigger from '../../../../helpers/define-trigger.js';
+
+export default defineTrigger({
+  name: 'Updated Attendee',
+  key: 'updatedAttendee',
+  type: 'webhook',
+  description: 'Triggers when attendee data is updated.',
+  arguments: [
+    {
+      label: 'Organization',
+      key: 'organizationId',
+      type: 'dropdown',
+      required: true,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listOrganizations',
+          },
+        ],
+      },
+    },
+    {
+      label: 'Event',
+      key: 'eventId',
+      type: 'dropdown',
+      required: false,
+      description: '',
+      variables: true,
+      source: {
+        type: 'query',
+        name: 'getDynamicData',
+        arguments: [
+          {
+            name: 'key',
+            value: 'listEvents',
+          },
+          {
+            name: 'parameters.organizationId',
+            value: '{parameters.organizationId}',
+          },
+        ],
+      },
+    },
+  ],
+
+  async run($) {
+    const dataItem = {
+      raw: $.request.body,
+      meta: {
+        internalId: Crypto.randomUUID(),
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async testRun($) {
+    const eventId = $.step.parameters.eventId;
+    const organizationId = $.step.parameters.organizationId;
+
+    const params = {
+      event_id: eventId,
+    };
+
+    const {
+      data: { attendees },
+    } = await $.http.get(`/v3/events/${eventId}/attendees/`, params);
+
+    if (attendees.length === 0) {
+      return;
+    }
+
+    const computedWebhookEvent = {
+      config: {
+        action: 'attendee.updated',
+        user_id: organizationId,
+        webhook_id: '11111111',
+        endpoint_url: $.webhookUrl,
+      },
+      api_url: attendees[0].resource_uri,
+    };
+
+    const dataItem = {
+      raw: computedWebhookEvent,
+      meta: {
+        internalId: computedWebhookEvent.user_id,
+      },
+    };
+
+    $.pushTriggerItem(dataItem);
+  },
+
+  async registerHook($) {
+    const organizationId = $.step.parameters.organizationId;
+    const eventId = $.step.parameters.eventId;
+
+    const payload = {
+      endpoint_url: $.webhookUrl,
+      actions: 'attendee.updated',
+      event_id: eventId,
+    };
+
+    const { data } = await $.http.post(
+      `/v3/organizations/${organizationId}/webhooks/`,
+      payload
+    );
+
+    await $.flow.setRemoteWebhookId(data.id);
+  },
+
+  async unregisterHook($) {
+    await $.http.delete(`/v3/webhooks/${$.flow.remoteWebhookId}/`);
+  },
+});
diff --git a/packages/docs/pages/apps/eventbrite/triggers.md b/packages/docs/pages/apps/eventbrite/triggers.md
index afab3406..6836df88 100644
--- a/packages/docs/pages/apps/eventbrite/triggers.md
+++ b/packages/docs/pages/apps/eventbrite/triggers.md
@@ -7,6 +7,8 @@ items:
     desc: Triggers when an attendee orders a ticket for an event.
   - name: New events
     desc: Triggers when a new event is published and live within an organization.
+  - name: Updated Attendee
+    desc: Triggers when attendee data is updated.
 ---
 
 <script setup>