Collection item sources

Author: GTFalcao

components/webflow_v2/sources/changed-collection-item/changed-collection-item.mjs

@@ -3,7 +3,7 @@ import common from "../common/collection-common.mjs";
 export default {
   type: "source",
   key: "webflow_v2-changed-collection-item",
-  name: "New Changed Collection Item",
+  name: "Collection Item Updated",
   description: "Emit new event when a collection item is changed. [See the docs here](https://developers.webflow.com/#model16)",
   version: "0.0.{{ts}}",
   ...common,
@@ -13,11 +13,12 @@ export default {
       return "collection_item_changed";
     },
     generateMeta(data) {
-      const ts = Date.parse(data["updated-on"]);
+      const { id, fieldData, lastUpdated } = data;
+      const ts = Date.parse(lastUpdated);
 
       return {
-        id: `${data._id}-${ts}`,
-        summary: `Collection ${data.slug} item changed`,
+        id: `${id}-${ts}`,
+        summary: `Item updated: ${fieldData?.slug ?? fieldData?.name ?? id}`,
         ts,
       };
     },

components/webflow_v2/sources/new-collection-item/new-collection-item.mjs

@@ -1,56 +1,23 @@
-import constants from "../../common/constants.mjs";
 import common from "../common/common.mjs";
 
 export default {
   type: "source",
   key: "webflow_v2-new-collection-item",
-  name: "New Collection Item",
+  name: "New Collection Item Created",
   description: "Emit new event when a collection item is created. [See the docs here](https://developers.webflow.com/#item-model)",
   version: "0.0.{{ts}}",
   ...common,
-  hooks: {
-    ...common.hooks,
-    async deploy() {
-      if (this.collectionIds?.length !== 1) {
-        console.log("Skipping retrieval of historical events for multiple or no Collection ID");
-        return;
-      }
-
-      const path = `/collections/${this.collectionIds[0]}/items`;
-      console.log("Retrieving historical events...");
-
-      let {
-        total,
-        items: events,
-      } = await this._makeRequest(path);
-
-      if (total > constants.LIMIT) {
-        const offset = Math.floor(total / constants.LIMIT);
-
-        events = (await this._makeRequest(path, {
-          offset,
-        })).items.reverse();
-
-        events.push(...(await this._makeRequest(path, {
-          offset: offset - 1,
-        })).items.reverse());
-      } else {
-        events.reverse();
-      }
-
-      this.emitHistoricalEvents(events);
-    },
-  },
   methods: {
     ...common.methods,
     getWebhookTriggerType() {
       return "collection_item_created";
     },
     generateMeta(data) {
+      const { id, fieldData } = data;
       return {
-        id: data._id,
-        summary: `New collection item ${data.slug} created`,
-        ts: Date.parse(data["created-on"]),
+        id,
+        summary: `New item: ${fieldData?.slug ?? fieldData?.name ?? id}`,
+        ts: Date.parse(data["createdOn"]),
       };
     },
   },

components/webflow_v2/sources/new-deleted-collection-item/new-deleted-collection-item.mjs

@@ -13,10 +13,11 @@ export default {
       return "collection_item_deleted";
     },
     generateMeta(data) {
+      const { id } = data;
       return {
-        id: data.itemId,
-        summary: `Item ${data.itemId} deleted`,
-        ts: Date.parse(data["created-on"]),
+        id,
+        summary: `Item deleted: ${id}`,
+        ts: Date.now(),
       };
     },
   },