Nile Database - updates per their team (#14342)

* updates

* versions

Author: michelle0927

components/nile_database/actions/create-user/create-user.mjs

@@ -4,7 +4,7 @@ export default {
   key: "nile_database-create-user",
   name: "Create User",
   description: "Create a new database user by providing an email address and password. [See the documentation](https://www.thenile.dev/docs/reference/api-reference/users/create-user)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     nile,
@@ -18,6 +18,9 @@ export default {
       propDefinition: [
         nile,
         "database",
+        (c) => ({
+          workspace: c.workspace,
+        }),
       ],
     },
     email: {

components/nile_database/actions/execute-query/execute-query.mjs

@@ -4,7 +4,7 @@ export default {
   name: "Execute Query",
   key: "nile_database-execute-query",
   description: "Execute a custom PostgreSQL query.",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     nile,
@@ -18,6 +18,9 @@ export default {
       propDefinition: [
         nile,
         "database",
+        (c) => ({
+          workspace: c.workspace,
+        }),
       ],
     },
     user: {

components/nile_database/nile_database.app.mjs

@@ -18,8 +18,13 @@ export default {
       type: "string",
       label: "Database",
       description: "The database name",
-      async options() {
-        const { databases } = await this.getAuthenticatedUser();
+      async options({ workspace }) {
+        if (!workspace) {
+          return [];
+        }
+        const databases = await this.listDatabases({
+          workspace,
+        });
         return databases?.map(({ name }) => name) || [];
       },
     },
@@ -68,6 +73,14 @@ export default {
         ...opts,
       });
     },
+    listDatabases({
+      workspace, ...opts
+    }) {
+      return this._makeRequest({
+        url: `${this._globalBaseUrl()}/workspaces/${workspace}/databases`,
+        ...opts,
+      });
+    },
     getAuthenticatedUser(opts = {}) {
       return this._makeRequest({
         url: `${this._globalBaseUrl()}/developers/me/full`,

components/nile_database/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/nile_database",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Pipedream Nile Database Components",
   "main": "nile_database.app.mjs",
   "keywords": [

components/nile_database/sources/common/base.mjs

@@ -1,5 +1,7 @@
 import nile from "../../nile_database.app.mjs";
-import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+import {
+  DEFAULT_POLLING_SOURCE_TIMER_INTERVAL, ConfigurationError,
+} from "@pipedream/platform";
 
 export default {
   props: {
@@ -21,9 +23,24 @@ export default {
       propDefinition: [
         nile,
         "database",
+        (c) => ({
+          workspace: c.workspace,
+        }),
       ],
     },
   },
+  hooks: {
+    async deploy() {
+      try {
+        await this.nile.getDatabase({
+          workspace: this.workspace,
+          database: this.database,
+        });
+      } catch {
+        throw new ConfigurationError(`Database "${this.database}" with workspace "${this.workspace}" not found`);
+      }
+    },
+  },
   methods: {
     getResourceFn() {
       throw new Error("getResourceFn is not implemented");

components/nile_database/sources/new-tenant-created/new-tenant-created.mjs

@@ -5,7 +5,7 @@ export default {
   key: "nile_database-new-tenant-created",
   name: "New Tenant Created",
   description: "Emit new event when a new tenant is added to a Nile Database",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   methods: {

components/nile_database/sources/new-user-created/new-user-created.mjs

@@ -5,7 +5,7 @@ export default {
   key: "nile_database-new-user-created",
   name: "New User Created",
   description: "Emit new event when a new user is added in a Nile Database",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   methods: {