Merge pull request #47 from cognitedata/t/bugfix

Release 2.26.1

Author: timurgen

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@cognite/neo4j-graphql-js",
-  "version": "2.26.0",
+  "version": "2.26.1",
   "description": "A GraphQL to Cypher query execution layer for Neo4j. ",
   "main": "./dist/index.js",
   "types": "./index.d.ts",

src/index.js

@@ -319,22 +319,27 @@ export const assertSchema = ({
   schema,
   dropExisting = true,
   debug = false,
-  sessionParams = {}
+  sessionParams = {},
+  context = {}
 }) => {
   const statement = schemaAssert({ schema, dropExisting });
   const executeQuery = driver => {
     const session = driver.session(sessionParams);
     return session
-      .writeTransaction(tx =>
-        tx.run(statement).then(result => {
-          if (debug === true) {
-            const recordsJSON = result.records.map(record => record.toObject());
-            recordsJSON.sort((lhs, rhs) => lhs.label < rhs.label);
-            console.table(recordsJSON);
-          }
-          return result;
-        }),
-        context.transactionConfig)
+      .writeTransaction(
+        tx =>
+          tx.run(statement).then(result => {
+            if (debug === true) {
+              const recordsJSON = result.records.map(record =>
+                record.toObject()
+              );
+              recordsJSON.sort((lhs, rhs) => lhs.label < rhs.label);
+              console.table(recordsJSON);
+            }
+            return result;
+          }),
+        context.transactionConfig
+      )
       .finally(() => session.close());
   };
   return executeQuery(driver);
@@ -345,7 +350,8 @@ export const searchSchema = async ({
   schema,
   debug = false,
   sessionParams = {},
-  dropExisting = true
+  dropExisting = true,
+  context = {}
 }) => {
   const session = driver.session(sessionParams);
   // drop all search indexes, given they cannot be updated via a second CALL to createNodeIndex
@@ -355,15 +361,16 @@ export const searchSchema = async ({
   RETURN TRUE
   `;
   if (dropExisting) {
-    const dropResult = await session.writeTransaction(tx =>
-      tx.run(dropStatement).then(result => {
-        if (debug === true) {
-          console.log(
-            `\n[searchSchema] Search indexes dropped using Cypher:${dropStatement}`
-          );
-        }
-        return true;
-      }),
+    const dropResult = await session.writeTransaction(
+      tx =>
+        tx.run(dropStatement).then(result => {
+          if (debug === true) {
+            console.log(
+              `\n[searchSchema] Search indexes dropped using Cypher:${dropStatement}`
+            );
+          }
+          return true;
+        }),
       context.transactionConfig
     );
     if (!dropResult) {
@@ -375,15 +382,16 @@ export const searchSchema = async ({
   const createStatement = schemaSearch({ schema });
   if (createStatement) {
     return await session
-      .writeTransaction(tx =>
-        tx.run(createStatement).then(result => {
-          if (debug === true) {
-            console.log(
-              `[searchSchema] Search indexes created using Cypher:\n${createStatement}\n`
-            );
-          }
-          return true;
-        }),
+      .writeTransaction(
+        tx =>
+          tx.run(createStatement).then(result => {
+            if (debug === true) {
+              console.log(
+                `[searchSchema] Search indexes created using Cypher:\n${createStatement}\n`
+              );
+            }
+            return true;
+          }),
         context.transactionConfig
       )
       .finally(() => session.close());