Add implementation file

Author: dat-devuap

implementation.js

@@ -0,0 +1,98 @@
+/**
+ * Perform a query operation on a Notion database.
+ * @param {Object} params - The parameters for the operation.
+ * @param {string} [params.databaseId] - The ID of the Notion database for create and read operations.
+ * @param {Array} [params.databaseStructure] - A list of properties in the Notion database structure, used to generate filter or sort criteria..
+ * @param {Object} [params.filter] - Optional filter for querying pages in the read operation.
+ * @param {Array} [params.sorts] - Optional sorting criteria for page results in the read operation.
+ * @param {number} [params.pageSize] - The number of results per page for the read operation.
+ * @param {string} [params.startCursor] - The start cursor for pagination in the read operation.
+ * @returns {Promise<Object>} - The response data from the Notion API.
+ */
+async function perform_notion_database_query(params, userSettings) {
+  const { databaseId, databaseStructure = [] } = params;
+  const { pluginServer, notionApiKey } = userSettings;
+
+  if (!pluginServer) {
+    throw new Error(
+      "Missing the Plugin Server URL. Please set it in the plugin settings."
+    );
+  }
+
+  if (!notionApiKey) {
+    throw new Error(
+      "Missing the Notion API Key. Please set it in the plugin settings."
+    );
+  }
+
+  if (!databaseId) {
+    throw new Error(
+      "Missing the Database Id. Please provide specific Database ID or Database URL"
+    );
+  }
+
+  if (!databaseStructure.length) {
+    throw new Error(
+      "Missing the Database Structure Properties. Please provide valid structure of your provided database."
+    );
+  }
+
+  try {
+    const result = await queryPages({
+      pluginServerUrl: pluginServer,
+      notionApiKey: notionApiKey,
+      databaseId: databaseId,
+      databaseStructure: databaseStructure,
+      filter: params.filter ?? {},
+      sorts: params.sorts ?? [],
+      pageSize: params.pageSize ?? 100,
+      startCursor: params.startCursor,
+    });
+    return result;
+  } catch (error) {
+    return { error: error.message };
+  }
+}
+
+async function queryPages({
+  notionApiKey,
+  pluginServerUrl,
+  databaseId,
+  databaseStructure,
+  filter,
+  sorts,
+  pageSize = 100,
+  startCursor = null,
+}) {
+  const requestBody = {
+    notionApiKey: notionApiKey,
+    databaseId: databaseId,
+    pageSize: pageSize,
+    databaseStructure: databaseStructure,
+  };
+  if (filter) requestBody.filter = filter;
+  if (sorts) requestBody.sorts = sorts;
+  if (startCursor) requestBody.startCursor = startCursor;
+
+  try {
+    const response = await fetch(
+      `${pluginServerUrl}/notion-database/query-pages`,
+      {
+        method: "POST",
+        headers: {
+          "Content-Type": "application/json",
+        },
+        body: JSON.stringify(requestBody),
+      }
+    );
+
+    if (!response.ok) {
+      throw new Error(`Error query pages: ${response.statusText}`);
+    }
+
+    const data = await response.json();
+    return data;
+  } catch (error) {
+    throw new Error(`Failed to query pages: ${error.message}`);
+  }
+}

plugin.json

@@ -528,7 +528,6 @@
             "required": true
         }
     ],
-    "code": "/**\n * Perform a query operation on a Notion database.\n * @param {Object} params - The parameters for the operation.\n * @param {string} [params.databaseId] - The ID of the Notion database for create and read operations.\n * @param {Array} [params.databaseStructure] - A list of properties in the Notion database structure, used to generate filter or sort criteria..\n * @param {Object} [params.filter] - Optional filter for querying pages in the read operation.\n * @param {Array} [params.sorts] - Optional sorting criteria for page results in the read operation.\n * @param {number} [params.pageSize] - The number of results per page for the read operation.\n * @param {string} [params.startCursor] - The start cursor for pagination in the read operation.\n * @returns {Promise<Object>} - The response data from the Notion API.\n */\nasync function perform_notion_database_query(params, userSettings) {\n  const { databaseId, databaseStructure = [] } = params;\n  const { pluginServer, notionApiKey } = userSettings;\n\n  if (!pluginServer) {\n    throw new Error(\n      \"Missing the Plugin Server URL. Please set it in the plugin settings.\"\n    );\n  }\n\n  if (!notionApiKey) {\n    throw new Error(\n      \"Missing the Notion API Key. Please set it in the plugin settings.\"\n    );\n  }\n\n  if (!databaseId) {\n    throw new Error(\n      \"Missing the Database Id. Please provide specific Database ID or Database URL\"\n    );\n  }\n\n  if (!databaseStructure.length) {\n    throw new Error(\n      \"Missing the Database Structure Properties. Please provide valid structure of your provided database.\"\n    );\n  }\n\n  try {\n    const result = await queryPages({\n      pluginServerUrl: pluginServer,\n      notionApiKey: notionApiKey,\n      databaseId: databaseId,\n      databaseStructure: databaseStructure,\n      filter: params.filter ?? {},\n      sorts: params.sorts ?? [],\n      pageSize: params.pageSize ?? 100,\n      startCursor: params.startCursor,\n    });\n    return result;\n  } catch (error) {\n    return { error: error.message };\n  }\n}\n\nasync function queryPages({\n  notionApiKey,\n  pluginServerUrl,\n  databaseId,\n  databaseStructure,\n  filter,\n  sorts,\n  pageSize = 100,\n  startCursor = null,\n}) {\n  const requestBody = {\n    notionApiKey: notionApiKey,\n    databaseId: databaseId,\n    pageSize: pageSize,\n    databaseStructure: databaseStructure,\n  };\n  if (filter) requestBody.filter = filter;\n  if (sorts) requestBody.sorts = sorts;\n  if (startCursor) requestBody.startCursor = startCursor;\n\n  try {\n    const response = await fetch(\n      `${pluginServerUrl}/notion-database/query-pages`,\n      {\n        method: \"POST\",\n        headers: {\n          \"Content-Type\": \"application/json\",\n        },\n        body: JSON.stringify(requestBody),\n      }\n    );\n\n    if (!response.ok) {\n      throw new Error(`Error query pages: ${response.statusText}`);\n    }\n\n    const data = await response.json();\n    console.log(JSON.stringify(data));\n    return data;\n  } catch (error) {\n    throw new Error(`Failed to query pages: ${error.message}`);\n  }\n}",
     "iconURL": "https://registry.npmmirror.com/@lobehub/icons-static-png/latest/files/light/notion.png",
     "authenticationType": "AUTH_TYPE_NONE",
     "implementationType": "javascript",