Requested changes done

Author: lcaresia

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

@@ -61,9 +61,7 @@ export default {
       table: this.table,
       data: this.recordData,
     });
-
     $.export("$summary", `Successfully created Record with ID: '${response.id}'`);
-
     return response;
   },
 };

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

@@ -36,10 +36,7 @@ export default {
       endpoint: this.endpoint,
       database: this.database,
     });
-
     $.export("$summary", `Successfully retrieved '${response.branches.length}' branches`);
-
-
     return response;
   },
 };

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

@@ -49,6 +49,12 @@ export default {
       propDefinition: [
         app,
         "recordId",
+        (c) => ({
+          endpoint: c.endpoint,
+          database: c.database,
+          table: c.table,
+          branch: c.branch,
+        }),
       ],
     },
     recordData: {
@@ -68,9 +74,7 @@ export default {
       recordId: this.recordId,
       data: this.recordData,
     });
-
     $.export("$summary", `Successfully replaced Record with ID: '${response.id}'`);
-
     return response;
   },
 };

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

@@ -49,6 +49,12 @@ export default {
       propDefinition: [
         app,
         "recordId",
+        (c) => ({
+          endpoint: c.endpoint,
+          database: c.database,
+          table: c.table,
+          branch: c.branch,
+        }),
       ],
     },
     recordData: {
@@ -68,9 +74,7 @@ export default {
       recordId: this.recordId,
       data: this.recordData,
     });
-
     $.export("$summary", `Successfully updated/created Record with ID: '${response.id}'`);
-
     return response;
   },
 };

components/xata/package.json

@@ -11,5 +11,8 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.2"
   }
 }

components/xata/xata.app.mjs

@@ -8,6 +8,20 @@ export default {
       type: "string",
       label: "Record ID",
       description: "ID of the record to create or update",
+      async options({
+        endpoint, database, branch, table,
+      }) {
+        const response = await this.listRecords({
+          endpoint,
+          database,
+          branch,
+          table,
+        });
+        const recordIds = response.records;
+        return recordIds.map(({ id }) => ({
+          value: id,
+        }));
+      },
     },
     table: {
       type: "string",
@@ -122,6 +136,15 @@ export default {
         ...args,
       });
     },
+    async listRecords({
+      endpoint, database, branch, table, ...args
+    }) {
+      return this._makeRequest({
+        method: "post",
+        url: `${endpoint}/db/${database}:${branch}/tables/${table}/query`,
+        ...args,
+      });
+    },
     async listWorkspaces(args = {}) {
       return this._makeRequest({
         path: "/workspaces",