Merge branch 'master' into 13965-bug-linkedin-components-api-version-update

Author: luancazarine

components/botcake/botcake.app.mjs

@@ -0,0 +1,11 @@
+export default {
+  type: "app",
+  app: "botcake",
+  propDefinitions: {},
+  methods: {
+    // this.$auth contains connected account data
+    authKeys() {
+      console.log(Object.keys(this.$auth));
+    },
+  },
+};

components/botcake/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "@pipedream/botcake",
+  "version": "0.0.1",
+  "description": "Pipedream Botcake Components",
+  "main": "botcake.app.mjs",
+  "keywords": [
+    "pipedream",
+    "botcake"
+  ],
+  "homepage": "https://pipedream.com/apps/botcake",
+  "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  }
+}

components/clarify/clarify.app.mjs

@@ -0,0 +1,11 @@
+export default {
+  type: "app",
+  app: "clarify",
+  propDefinitions: {},
+  methods: {
+    // this.$auth contains connected account data
+    authKeys() {
+      console.log(Object.keys(this.$auth));
+    },
+  },
+};

components/clarify/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "@pipedream/clarify",
+  "version": "0.0.1",
+  "description": "Pipedream Clarify Components",
+  "main": "clarify.app.mjs",
+  "keywords": [
+    "pipedream",
+    "clarify"
+  ],
+  "homepage": "https://pipedream.com/apps/clarify",
+  "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  }
+}

components/notion/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/notion",
-  "version": "0.1.20",
+  "version": "0.1.21",
   "description": "Pipedream Notion Components",
   "main": "notion.app.mjs",
   "keywords": [

components/notion/sources/updated-page/updated-page.mjs

@@ -8,7 +8,7 @@ export default {
   key: "notion-updated-page",
   name: "Updated Page in Database", /* eslint-disable-line pipedream/source-name */
   description: "Emit new event when a page in a database is updated. To select a specific page, use `Updated Page ID` instead",
-  version: "0.0.15",
+  version: "0.0.16",
   type: "source",
   dedupe: "unique",
   props: {
@@ -40,14 +40,12 @@ export default {
   },
   hooks: {
     async deploy() {
-      if (!this.properties?.length) {
-        return;
-      }
+      const properties = await this.getProperties();
       const propertyValues = {};
       const pagesStream = this.notion.getPages(this.databaseId);
       for await (const page of pagesStream) {
         propertyValues[page.id] = {};
-        for (const property of this.properties) {
+        for (const property of properties) {
           propertyValues[page.id][property] = JSON.stringify(page.properties[property]);
         }
       }
@@ -62,70 +60,61 @@ export default {
     _setPropertyValues(propertyValues) {
       this.db.set("propertyValues", propertyValues);
     },
+    async getProperties() {
+      if (this.properties?.length) {
+        return this.properties;
+      }
+      const { properties } = await this.notion.retrieveDatabase(this.databaseId);
+      return Object.keys(properties);
+    },
+    generateMeta(obj, summary) {
+      const { id } = obj;
+      const title = this.notion.extractPageTitle(obj);
+      const ts = Date.now();
+      return {
+        id: `${id}-${ts}`,
+        summary: `${summary}: ${title} - ${id}`,
+        ts,
+      };
+    },
   },
   async run() {
     const lastCheckedTimestamp = this.getLastUpdatedTimestamp();
-    const lastCheckedTimestampDate = new Date(lastCheckedTimestamp);
-    const lastCheckedTimestampISO = lastCheckedTimestampDate.toISOString();
     const propertyValues = this._getPropertyValues();
 
-    // Add a filter so that we only receive pages that have been updated since the last call.
     const params = {
       ...this.lastUpdatedSortParam(),
-      filter: {
-        timestamp: "last_edited_time",
-        last_edited_time: {
-          after: lastCheckedTimestampISO,
-        },
-      },
     };
     let newLastUpdatedTimestamp = lastCheckedTimestamp;
-
+    const properties = await this.getProperties();
     const pagesStream = this.notion.getPages(this.databaseId, params);
 
     for await (const page of pagesStream) {
-      if (!this.isResultNew(page.last_edited_time, lastCheckedTimestamp)) {
-        // The call to getPages() includes a descending sort by last_edited_time.
-        // As soon as one page !isResultNew(), all of the following ones will also.
-        // NOTE: the last_edited_filter means this will never be called,
-        // but it's worth keeping as future-proofing.
-        break;
-      }
-
       newLastUpdatedTimestamp = Math.max(
         newLastUpdatedTimestamp,
         Date.parse(page?.last_edited_time),
       );
 
-      if (this.properties?.length) {
-        let propertyChangeFound = false;
-        for (const property of this.properties) {
-          const currentProperty = JSON.stringify(page.properties[property]);
-          if (!propertyValues[page.id] || currentProperty !== propertyValues[page.id][property]) {
-            propertyChangeFound = true;
-            propertyValues[page.id] = {
-              ...propertyValues[page.id],
-              [property]: currentProperty,
-            };
-          }
-        }
-        if (!propertyChangeFound) {
-          continue;
+      let propertyChangeFound = false;
+      for (const property of properties) {
+        const currentProperty = JSON.stringify(page.properties[property]);
+        if (!propertyValues[page.id] || currentProperty !== propertyValues[page.id][property]) {
+          propertyChangeFound = true;
+          propertyValues[page.id] = {
+            ...propertyValues[page.id],
+            [property]: currentProperty,
+          };
         }
       }
+      if (!propertyChangeFound && Date.parse(page?.last_edited_time) <= lastCheckedTimestamp) {
+        continue;
+      }
 
       if (!this.includeNewPages && page?.last_edited_time === page?.created_time) {
         continue;
       }
 
-      const meta = this.generateMeta(
-        page,
-        constants.types.PAGE,
-        constants.timestamps.LAST_EDITED_TIME,
-        constants.summaries.PAGE_UPDATED,
-        true,
-      );
-
+      const meta = this.generateMeta(page, constants.summaries.PAGE_UPDATED);
       this.$emit(page, meta);
     }
 

docs-v2/vercel.json

@@ -1,15 +1,13 @@
 {
-  "rewrites": [
+  "redirects": [
     {
       "source": "/docs/v3",
       "destination": "/docs"
     },
     {
       "source": "/docs/v3/(.*)",
       "destination": "/docs/$1"
-    }
-  ],
-  "redirects": [
+    },
     {
       "source": "/docs/notebook/actions/",
       "destination": "/workflows/steps/actions/"
@@ -222,14 +220,6 @@
       "source": "/docs/components/quickstart/nodejs/actions",
       "destination": "/docs/components/actions-quickstart"
     },
-    {
-      "source": "/docs/components/quickstart/nodejs/sources",
-      "destination": "/docs/components/sources-quickstart"
-    },
-    {
-      "source": "/docs/v3/components/quickstart/nodejs/sources",
-      "destination": "/docs/components/sources-quickstart"
-    },
     {
       "source": "/docs/github-sync",
       "destination": "/docs/quickstart/github-sync"
@@ -285,14 +275,6 @@
     {
       "source": "/docs/workflows/networking",
       "destination": "/docs/databases#connecting-to-restricted-databases"
-    },
-    {
-      "source": "/docs/errors/",
-      "destination": "/docs/workflows/errors"
-    },
-    {
-      "source": "/docs/v3/api/sse",
-      "destination": "/docs/destinations/sse"
     }
   ]
 }