[Components] neo4j_auradb #15828

Sources
 - New Node
 - New Relationship
 - New Query Result

Actions
 - Create Node
 - Create Relationship
 - Run Query

Author: luancazarine

components/neo4j_auradb/actions/create-node/create-node.mjs

@@ -1,36 +1,35 @@
-import neo4jAuradb from "../../neo4j_auradb.app.mjs";
-import { axios } from "@pipedream/platform";
+import { parseObject } from "../../common/utils.mjs";
+import app from "../../neo4j_auradb.app.mjs";
 
 export default {
   key: "neo4j_auradb-create-node",
   name: "Create Node",
-  description: "Creates a new node in the Neo4j AuraDB instance. [See the documentation]()",
-  version: "0.0.{{ts}}",
+  description: "Creates a new node in the Neo4j AuraDB instance. [See the documentation](https://neo4j.com/docs/query-api/current/query/)",
+  version: "0.0.1",
   type: "action",
   props: {
-    neo4jAuradb,
-    createNodeLabel: {
-      propDefinition: [
-        neo4jAuradb,
-        "createNodeLabel",
-      ],
+    app,
+    nodeLabel: {
+      type: "string",
+      label: "Node Label",
+      description: "The label of the node to filter events for new node creation.",
     },
-    createNodeProperties: {
-      propDefinition: [
-        neo4jAuradb,
-        "createNodeProperties",
-      ],
+    nodeProperties: {
+      type: "object",
+      label: "Create Node Properties",
+      description: "Anobject representing the properties of the node to create.",
     },
   },
   async run({ $ }) {
-    const response = await this.neo4jAuradb.createNode({
-      createNodeLabel: this.createNodeLabel,
-      createNodeProperties: this.createNodeProperties,
+    const response = await this.app.createNode({
+      $,
+      label: this.nodeLabel,
+      properties: parseObject(this.nodeProperties),
     });
 
-    const node = response.results?.[0]?.data?.[0]?.row?.[0];
-    $.export("$summary", node
-      ? `Created node with id ${node.id}`
+    const elementId = response.data?.values?.[0]?.[0]?.elementId;
+    $.export("$summary", elementId
+      ? `Created node with id ${elementId}`
       : "Node created successfully");
     return response;
   },

components/neo4j_auradb/actions/create-relationship/create-relationship.mjs

@@ -1,52 +1,47 @@
-import neo4jAuradb from "../../neo4j_auradb.app.mjs";
-import { axios } from "@pipedream/platform";
+import { parseObject } from "../../common/utils.mjs";
+import app from "../../neo4j_auradb.app.mjs";
 
 export default {
   key: "neo4j_auradb-create-relationship",
   name: "Create Relationship",
-  description: "Creates a relationship between two existing nodes. [See the documentation]()",
-  version: "0.0.{{ts}}",
+  description: "Creates a relationship between two existing nodes. [See the documentation](https://neo4j.com/docs/query-api/current/query/)",
+  version: "0.0.1",
   type: "action",
   props: {
-    neo4jAuradb: {
-      type: "app",
-      app: "neo4j_auradb",
+    app,
+    relationshipType: {
+      type: "string",
+      label: "Create Relationship Type",
+      description: "The name of the relationship to create.",
     },
-    createRelationshipType: {
-      propDefinition: [
-        "neo4j_auradb",
-        "createRelationshipType",
-      ],
+    startNode: {
+      type: "object",
+      label: "Start Node Identifier",
+      description: "An object containing any fields used to identify the start node.",
     },
-    createStartNode: {
-      propDefinition: [
-        "neo4j_auradb",
-        "createStartNode",
-      ],
+    endNode: {
+      type: "object",
+      label: "End Node Identifier",
+      description: "An object containing any fields used to identify the end node.",
     },
-    createEndNode: {
-      propDefinition: [
-        "neo4j_auradb",
-        "createEndNode",
-      ],
-    },
-    createRelationshipProperties: {
-      propDefinition: [
-        "neo4j_auradb",
-        "createRelationshipProperties",
-      ],
+    relationshipProperties: {
+      type: "object",
+      label: "Create Relationship Properties",
+      description: "An object representing the properties of the relationship to create.",
+      optional: true,
     },
   },
   async run({ $ }) {
-    const response = await this.neo4jAuradb.createRelationship({
-      createRelationshipType: this.createRelationshipType,
-      createStartNode: this.createStartNode,
-      createEndNode: this.createEndNode,
-      createRelationshipProperties: this.createRelationshipProperties,
+    const response = await this.app.createRelationship({
+      $,
+      relationshipType: this.relationshipType,
+      startNode: parseObject(this.startNode),
+      endNode: parseObject(this.endNode),
+      relationshipProperties: parseObject(this.relationshipProperties),
     });
     $.export(
       "$summary",
-      `Created relationship '${this.createRelationshipType}' between nodes '${this.createStartNode}' and '${this.createEndNode}'`,
+      `Created relationship '${this.relationshipType}' between nodes`,
     );
     return response;
   },

components/neo4j_auradb/actions/run-query/run-query.mjs

@@ -1,24 +1,23 @@
-import neo4jAuradb from "../../neo4j_auradb.app.mjs";
-import { axios } from "@pipedream/platform";
+import app from "../../neo4j_auradb.app.mjs";
 
 export default {
   key: "neo4j_auradb-run-query",
   name: "Run Cypher Query",
-  description: "Executes a Cypher query against the Neo4j AuraDB instance. [See the documentation]()",
-  version: "0.0.{{ts}}",
+  description: "Executes a Cypher query against the Neo4j AuraDB instance. [See the documentation](https://neo4j.com/docs/query-api/current/query/)",
+  version: "0.0.1",
   type: "action",
   props: {
-    neo4jAuradb,
-    executeCypherQuery: {
-      propDefinition: [
-        neo4jAuradb,
-        "executeCypherQuery",
-      ],
+    app,
+    cypherQuery: {
+      type: "string",
+      label: "Execute Cypher Query",
+      description: "A valid Cypher query to execute against the Neo4j AuraDB instance.",
     },
   },
   async run({ $ }) {
-    const response = await this.neo4jAuradb.executeCypherQuery({
-      executeCypherQuery: this.executeCypherQuery,
+    const response = await this.app.executeCypherQuery({
+      $,
+      cypherQuery: this.cypherQuery,
     });
     $.export("$summary", "Executed Cypher query successfully");
     return response;

components/neo4j_auradb/common/constants.mjs

@@ -0,0 +1,16 @@
+export const LIMIT = 100;
+
+export const ORDER_TYPE_OPTIONS = [
+  {
+    label: "DateTime",
+    value: "datetime",
+  },
+  {
+    label: "Sequencial (integer)",
+    value: "sequencial",
+  },
+  {
+    label: "Other",
+    value: "other",
+  },
+];

components/neo4j_auradb/common/utils.mjs

@@ -0,0 +1,24 @@
+export const parseObject = (obj) => {
+  if (!obj) return undefined;
+
+  if (Array.isArray(obj)) {
+    return obj.map((item) => {
+      if (typeof item === "string") {
+        try {
+          return JSON.parse(item);
+        } catch (e) {
+          return item;
+        }
+      }
+      return item;
+    });
+  }
+  if (typeof obj === "string") {
+    try {
+      return JSON.parse(obj);
+    } catch (e) {
+      return obj;
+    }
+  }
+  return obj;
+};