Other data source updates

Author: GTFalcao

components/notion/actions/create-page-from-database/create-page-from-database.mjs

@@ -17,28 +17,28 @@ export default {
         notion,
         "databaseId",
       ],
-      label: "Parent Database ID",
-      description: "Select a parent database or provide a database ID",
     },
-    dataSource: {
+    parentDataSource: {
       propDefinition: [
         notion,
         "dataSourceId",
         ({ parent }) => ({
           databaseId: parent,
         }),
       ],
+      label: "Parent Data Source ID",
+      description: "Select a parent data source or provide a data source ID",
     },
     Name: {
       type: "string",
       label: "Name",
-      description: "The name of the page. Use this only if the database has a `title` property named `Name`. Otherwise, use the `Properties` prop below to set the title property.",
+      description: "The name of the page. Use this only if the data source has a `title` property named `Name`. Otherwise, use the `Properties` prop below to set the title property.",
       optional: true,
     },
     properties: {
       type: "object",
       label: "Properties",
-      description: "The values of the page's properties. The schema must match the parent database's properties. [See the documentation](https://developers.notion.com/reference/property-object) for information on various property types. Example: `{ \"Tags\": [ \"tag1\" ], \"Link\": \"https://pipedream.com\" }`",
+      description: "The values of the page's properties. The schema must match the parent data source's properties. [See the documentation](https://developers.notion.com/reference/property-object) for information on various property types. Example: `{ \"Tags\": [ \"tag1\" ], \"Link\": \"https://pipedream.com\" }`",
       optional: true,
     },
     icon: {
@@ -87,7 +87,7 @@ export default {
   },
   async run({ $ }) {
     const MAX_BLOCKS = 100;
-    const parentPage = await this.notion.retrieveDataSource(this.dataSource);
+    const parentPage = await this.notion.retrieveDataSource(this.parentDataSource);
     const {
       children, ...page
     } = this.buildPage(parentPage);

components/notion/actions/retrieve-database-schema/retrieve-database-schema.mjs

@@ -2,9 +2,9 @@ import notion from "../../notion.app.mjs";
 
 export default {
   key: "notion-retrieve-database-schema",
-  name: "Retrieve Database Schema",
-  description: "Get the property schema of a database in Notion. [See the documentation](https://developers.notion.com/reference/retrieve-a-database)",
-  version: "0.0.11",
+  name: "Retrieve Data Source Schema",
+  description: "Get the property schema of a data source in Notion. [See the documentation](https://developers.notion.com/reference/retrieve-a-data-source)",
+  version: "1.0.0",
   type: "action",
   props: {
     notion,
@@ -14,10 +14,19 @@ export default {
         "databaseId",
       ],
     },
+    dataSourceId: {
+      propDefinition: [
+        notion,
+        "dataSourceId",
+        ({ databaseId }) => ({
+          databaseId,
+        }),
+      ],
+    },
   },
   async run({ $ }) {
-    const response = await this.notion.retrieveDatabase(this.databaseId);
-    $.export("$summary", "Successfully retrieved database schema");
+    const response = await this.notion.retrieveDataSource(this.dataSourceId);
+    $.export("$summary", "Successfully retrieved data source schema");
     return response;
   },
 };

components/notion/actions/update-database/update-database.mjs

@@ -5,9 +5,9 @@ import base from "../common/base-page-builder.mjs";
 export default {
   ...base,
   key: "notion-update-database",
-  name: "Update Database",
-  description: "Update a database. [See the documentation](https://developers.notion.com/reference/update-a-database)",
-  version: "0.0.2",
+  name: "Update Data Source",
+  description: "Update a data source. [See the documentation](https://developers.notion.com/reference/update-a-data-source)",
+  version: "1.0.0",
   type: "action",
   props: {
     notion,
@@ -16,34 +16,43 @@ export default {
         notion,
         "databaseId",
       ],
+    },
+    dataSourceId: {
+      propDefinition: [
+        notion,
+        "dataSourceId",
+        ({ databaseId }) => ({
+          databaseId,
+        }),
+      ],
       reloadProps: true,
     },
     title: {
       type: "string",
       label: "Title",
-      description: "Title of database as it appears in Notion. An array of [rich text objects](https://developers.notion.com/reference/rich-text).",
+      description: "Title of the data source as it appears in Notion. An array of [rich text objects](https://developers.notion.com/reference/rich-text).",
       optional: true,
     },
     description: {
       type: "string",
       label: "Description",
-      description: "An array of [rich text objects](https://developers.notion.com/reference/rich-text) that represents the description of the database that is displayed in the Notion UI. If omitted, then the database description remains unchanged.",
+      description: "An array of [rich text objects](https://developers.notion.com/reference/rich-text) that represents the description of the data source that is displayed in the Notion UI. If omitted, then the data source description remains unchanged.",
       optional: true,
     },
     properties: {
       type: "object",
       label: "Properties",
-      description: "The properties of a database to be changed in the request, in the form of a JSON object. If updating an existing property, then the keys are the names or IDs of the properties as they appear in Notion, and the values are [property schema objects](https://developers.notion.com/reference/rich-text). If adding a new property, then the key is the name of the new database property and the value is a [property schema object](https://developers.notion.com/reference/property-schema-object).",
+      description: "The properties of a data source to be changed in the request, in the form of a JSON object. If updating an existing property, then the keys are the names or IDs of the properties as they appear in Notion, and the values are [property schema objects](https://developers.notion.com/reference/rich-text). If adding a new property, then the key is the name of the new data source property and the value is a [property schema object](https://developers.notion.com/reference/property-schema-object).",
       optional: true,
     },
   },
   async additionalProps(props) {
-    if (this.databaseId) {
-      const database = await this.notion.retrieveDatabase(this.databaseId);
+    if (this.databaseId && this.dataSourceId) {
+      const dataSource = await this.notion.retrieveDataSource(this.dataSourceId);
 
-      props.title.default = database.title.map((text) => text.text.content).join(" ");
-      props.description.default = database.description.map((text) => text.plain_text).join(" ");
-      props.properties.default = Object.entries(database.properties).reduce((acc, [
+      props.title.default = dataSource.title.map((text) => text.text.content).join(" ");
+      props.description.default = dataSource.description.map((text) => text.plain_text).join(" ");
+      props.properties.default = Object.entries(dataSource.properties).reduce((acc, [
         key,
         value,
       ]) => {
@@ -54,8 +63,8 @@ export default {
     }
   },
   async run({ $ }) {
-    const response = await this.notion.updateDatabase({
-      database_id: this.databaseId,
+    const response = await this.notion.updateDataSource({
+      dataSource_id: this.dataSourceId,
       title: [
         {
           text: {
@@ -73,7 +82,7 @@ export default {
       properties: utils.parseObject(this.properties),
     });
 
-    $.export("$summary", `Successfully updated database with ID ${response.id}`);
+    $.export("$summary", `Successfully updated data source with ID ${response.id}`);
     return response;
   },
 };

components/notion/actions/update-page/update-page.mjs

@@ -7,7 +7,7 @@ export default {
   key: "notion-update-page",
   name: "Update Page",
   description: "Update a page's property values. To append page content, use the *Append Block* action instead. [See the documentation](https://developers.notion.com/reference/patch-page)",
-  version: "1.1.10",
+  version: "2.0.0",
   type: "action",
   props: {
     notion,
@@ -16,18 +16,18 @@ export default {
       alertType: "info",
       content: "Properties that are not set will remain unchanged.",
     },
-    databaseId: {
+    parent: {
       propDefinition: [
         notion,
         "databaseId",
       ],
     },
-    parent: {
+    parentDataSource: {
       propDefinition: [
         notion,
         "dataSourceId",
         (c) => ({
-          databaseId: c.databaseId,
+          databaseId: c.parent,
         }),
       ],
       label: "Parent Data Source ID",
@@ -39,7 +39,7 @@ export default {
         notion,
         "pageIdInDataSource",
         (c) => ({
-          dataSourceId: c.parent,
+          dataSourceId: c.parentDataSource,
         }),
       ],
     },
@@ -60,7 +60,7 @@ export default {
         notion,
         "propertyTypes",
         (c) => ({
-          parentId: c.parent,
+          parentId: c.parentDataSource,
           parentType: "dataSource",
         }),
       ],
@@ -69,7 +69,7 @@ export default {
   },
   async additionalProps() {
     try {
-      const { properties } = await this.notion.retrieveDataSource(this.parent);
+      const { properties } = await this.notion.retrieveDataSource(this.parentDataSource);
       const selectedProperties = pick(properties, this.propertyTypes);
 
       return this.buildAdditionalProps({

components/notion/common/notion-meta-properties.mjs

@@ -2,14 +2,15 @@ import utils from "./utils.mjs";
 
 /**
  * Implementation for Database Meta in Notion - https://developers.notion.com/reference/database
+ * See also Data Sources - https://developers.notion.com/reference/data-source
  *
  * convertToNotion: converts the prop values to send to the Notion API
  */
 export const NOTION_DATA_SOURCE_META = {
   parent: {
     convertToNotion: (property) => ({
       type: "data_source_id",
-      database_id: property.value,
+      data_source_id: property.value,
     }),
   },
   title: {

components/notion/notion.app.mjs

@@ -25,11 +25,8 @@ export default {
       description: "Select a data source from the database or provide a data source ID",
       async options({ databaseId }) {
         this._checkOptionsContext(databaseId, "Database ID");
-        const dataSources = await this.getDataSourcesForDatabase(databaseId);
-        return dataSources?.map((dataSource) => ({
-          label: dataSource.name,
-          value: dataSource.id,
-        })) || [];
+        const response = await this.getDataSourcesForDatabase(databaseId);
+        return this._extractDatabaseTitleOptions(response);
       },
     },
     pageId: {

components/notion/sources/common/base.mjs

@@ -34,7 +34,7 @@ export default {
       } = obj;
       const ts = Date.parse(lastTime);
 
-      if (type === constants.types.DATABASE) {
+      if (type === constants.types.DATABASE || type === constants.types.DATA_SOURCE) {
         title = this.notion.extractDatabaseTitle(obj);
       } else {
         title = this.notion.extractPageTitle(obj);

components/notion/sources/common/constants.mjs

@@ -1,10 +1,12 @@
 const types = {
   DATABASE: "database",
+  DATA_SOURCE: "data_source",
   PAGE: "page",
 };
 
 const summaries = {
   DATABASE_ADDED: "Database added",
+  DATA_SOURCE_ADDED: "Data source added",
   PAGE_ADDED: "Page added",
   PAGE_UPDATED: "Page updated",
 };

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

@@ -6,8 +6,8 @@ import sampleEmit from "./test-event.mjs";
 export default {
   ...base,
   key: "notion-new-page",
-  name: "New Page in Database",
-  description: "Emit new event when a page is created in the selected database. [See the documentation](https://developers.notion.com/reference/page)",
+  name: "New Page in Data Source",
+  description: "Emit new event when a page is created in the selected data source. [See the documentation](https://developers.notion.com/reference/page)",
   version: "0.0.16",
   type: "source",
   props: {
@@ -18,6 +18,15 @@ export default {
         "databaseId",
       ],
     },
+    dataSourceId: {
+      propDefinition: [
+        notion,
+        "dataSourceId",
+        ({ databaseId }) => ({
+          databaseId,
+        }),
+      ],
+    },
   },
   hooks: {
     ...base.hooks,
@@ -46,7 +55,7 @@ export default {
 
       // Get pages in created order descending until the first page edited after
       // lastCreatedTimestamp, then reverse list of pages and emit
-      const pagesStream = this.notion.getPages(this.databaseId, params);
+      const pagesStream = this.notion.getPages(this.dataSourceId, params);
 
       for await (const page of pagesStream) {
         if (!this.isResultNew(page.created_time, lastCreatedTimestamp)

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

@@ -6,7 +6,7 @@ export default {
   key: "notion-page-properties-updated-instant",
   name: "Page Properties Updated (Instant)",
   description: "Emit new event each time a page property is updated in a data source. For use with Page Properties Updated event type. Webhook must be set up in Notion. [See the documentation](https://developers.notion.com/reference/webhooks#step-1-creating-a-webhook-subscription)",
-  version: "0.0.2",
+  version: "1.0.0",
   type: "source",
   dedupe: "unique",
   props: {