[Components] xata #13198

components/algodocs/algodocs.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/allocadence/allocadence.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/ical/ical.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/virifi/virifi.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/xata/actions/common/common.mjs

@@ -0,0 +1,108 @@
+import app from "../../xata.app.mjs";
+
+export default {
+  props: {
+    app,
+    endpoint: {
+      propDefinition: [
+        app,
+        "endpoint",
+      ],
+    },
+    workspace: {
+      propDefinition: [
+        app,
+        "workspace",
+      ],
+    },
+    database: {
+      propDefinition: [
+        app,
+        "database",
+        (c) => ({
+          workspace: c.workspace,
+        }),
+      ],
+    },
+    branch: {
+      propDefinition: [
+        app,
+        "branch",
+        (c) => ({
+          endpoint: c.endpoint,
+          database: c.database,
+        }),
+      ],
+    },
+    table: {
+      propDefinition: [
+        app,
+        "table",
+        (c) => ({
+          endpoint: c.endpoint,
+          database: c.database,
+          branch: c.branch,
+        }),
+      ],
+      reloadProps: true,
+    },
+  },
+  async additionalProps(props) {
+    const {
+      endpoint,
+      database,
+      branch,
+      table,
+    } = this;
+
+    const description = "The keys and values of the data that will be recorded in the database.";
+
+    if (endpoint && database && branch && table) {
+      const { columns } = await this.app.listColumns({
+        endpoint,
+        database,
+        branch,
+        table,
+      });
+      if (columns?.length) {
+        let descriptionWithColumns = `${description} Available Columns:`;
+        for (const column of columns) {
+          descriptionWithColumns += ` \`${column.name}\``;
+        }
+        props.recordData.description = descriptionWithColumns;
+        return {};
+      }
+    }
+    props.recordData.description = description;
+    return {};
+  },
+  methods: {
+    async formatRecordData() {
+      const recordData = this.recordData;
+      const { columns } = await this.app.listColumns({
+        endpoint: this.endpoint,
+        database: this.database,
+        branch: this.branch,
+        table: this.table,
+      });
+      if (!columns?.length) {
+        return this.recordData;
+      }
+      for (const column of columns) {
+        if (!recordData[column.name] || typeof recordData[column.name] !== "string") {
+          continue;
+        }
+        if ((column.type === "int" || column.type === "float")) {
+          recordData[column.name] = +recordData[column.name];
+        }
+        if (column.type === "bool") {
+          recordData[column.name] = !(recordData[column.name] === "false" || recordData[column.name === "0"]);
+        }
+        if (column.type === "multiple" || column.type === "vector") {
+          recordData[column.name] = JSON.parse(recordData[column.name]);
+        }
+      }
+      return recordData;
+    },
+  },
+};

components/xata/actions/create-record/create-record.mjs

@@ -0,0 +1,31 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "xata-create-record",
+  name: "Create Record",
+  description: "Create a new Record in the specified database. [See the documentation](https://xata.io/docs/api-reference/db/db_branch_name/tables/table_name/data#insert-record)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    ...common.props,
+    recordData: {
+      propDefinition: [
+        common.props.app,
+        "recordData",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.app.createRecord({
+      $,
+      endpoint: this.endpoint,
+      database: this.database,
+      branch: this.branch,
+      table: this.table,
+      data: await this.formatRecordData(),
+    });
+    $.export("$summary", `Successfully created Record with ID: '${response.id}'`);
+    return response;
+  },
+};

components/xata/actions/list-branches/list-branches.mjs

@@ -0,0 +1,42 @@
+import app from "../../xata.app.mjs";
+
+export default {
+  key: "xata-list-branches",
+  name: "List Branches",
+  description: "List branches of the specified database. [See the documentation](https://xata.io/docs/api-reference/dbs/db_name#list-branches)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    endpoint: {
+      propDefinition: [
+        app,
+        "endpoint",
+      ],
+    },
+    workspace: {
+      propDefinition: [
+        app,
+        "workspace",
+      ],
+    },
+    database: {
+      propDefinition: [
+        app,
+        "database",
+        (c) => ({
+          workspace: c.workspace,
+        }),
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.app.listBranches({
+      $,
+      endpoint: this.endpoint,
+      database: this.database,
+    });
+    $.export("$summary", `Successfully retrieved '${response.branches.length}' branches`);
+    return response;
+  },
+};

components/xata/actions/replace-record/replace-record.mjs

@@ -0,0 +1,44 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "xata-replace-record",
+  name: "Replace Record",
+  description: "Replace a record with the specified ID. [See the documentation](https://xata.io/docs/api-reference/db/db_branch_name/tables/table_name/data/record_id#insert-record-with-id)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    ...common.props,
+    recordId: {
+      propDefinition: [
+        common.props.app,
+        "recordId",
+        (c) => ({
+          endpoint: c.endpoint,
+          database: c.database,
+          table: c.table,
+          branch: c.branch,
+        }),
+      ],
+    },
+    recordData: {
+      propDefinition: [
+        common.props.app,
+        "recordData",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.app.replaceRecord({
+      $,
+      endpoint: this.endpoint,
+      database: this.database,
+      branch: this.branch,
+      table: this.table,
+      recordId: this.recordId,
+      data: await this.formatRecordData(),
+    });
+    $.export("$summary", `Successfully replaced Record with ID: '${response.id}'`);
+    return response;
+  },
+};

components/xata/actions/update-record/update-record.mjs

@@ -0,0 +1,44 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "xata-update-record",
+  name: "Update Record",
+  description: "Update or create a record with the specified ID. [See the documentation](https://xata.io/docs/api-reference/db/db_branch_name/tables/table_name/data/record_id#upsert-record-with-id)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    ...common.props,
+    recordId: {
+      propDefinition: [
+        common.props.app,
+        "recordId",
+        (c) => ({
+          endpoint: c.endpoint,
+          database: c.database,
+          table: c.table,
+          branch: c.branch,
+        }),
+      ],
+    },
+    recordData: {
+      propDefinition: [
+        common.props.app,
+        "recordData",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.app.updateRecord({
+      $,
+      endpoint: this.endpoint,
+      database: this.database,
+      branch: this.branch,
+      table: this.table,
+      recordId: this.recordId,
+      data: await this.formatRecordData(),
+    });
+    $.export("$summary", `Successfully updated/created Record with ID: '${response.id}'`);
+    return response;
+  },
+};

components/xata/package.json

@@ -1,16 +1,18 @@
 {
   "name": "@pipedream/xata",
-  "version": "0.0.2",
-  "description": "Pipedream Xata Components",
-  "main": "dist/app/xata.app.mjs",
+  "version": "0.1.0",
+  "description": "Pipedream xata Components",
+  "main": "xata.app.mjs",
   "keywords": [
     "pipedream",
     "xata"
   ],
-  "files": ["dist"],
   "homepage": "https://pipedream.com/apps/xata",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.2"
   }
 }