Refactor as per adam-cowley#16

lib/neo4j.service.ts

@@ -1,5 +1,5 @@
 import { Injectable, Inject, OnApplicationShutdown } from '@nestjs/common';
-import neo4j, { Driver, Result, int, Transaction } from 'neo4j-driver';
+import neo4j, { Driver, int, Transaction, QueryResult } from 'neo4j-driver';
 import TransactionImpl from 'neo4j-driver-core/lib/transaction';
 import { Neo4jConfig } from './interfaces/neo4j-config.interface';
 import { NEO4J_OPTIONS, NEO4J_DRIVER } from './neo4j.constants';
@@ -50,40 +50,48 @@ export class Neo4jService implements OnApplicationShutdown {
     });
   }
 
-  transaction<Result>(
-    uow: (c: Transaction) => Promise<Result>,
+  transaction<QueryResult>(
+    uow: (c: Transaction) => Promise<QueryResult>,
     database?: string,
     onError?: (e: Error) => Promise<void>,
     throwOnError = true,
-  ): Promise<Result> {
+  ): Promise<QueryResult> {
     const session = this.getWriteSession(database);
     return transaction(session, uow, onError, throwOnError);
   }
 
-  read(
+  async read(
     cypher: string,
     params?: Record<string, any>,
     databaseOrTransaction?: string | Transaction,
-  ): Result {
+  ): Promise<QueryResult> {
     if (databaseOrTransaction instanceof TransactionImpl) {
       return (<Transaction>databaseOrTransaction).run(cypher, params);
     }
 
     const session = this.getReadSession(<string>databaseOrTransaction);
-    return session.run(cypher, params);
+    const res = await session.executeRead((tx) => tx.run(cypher, params));
+
+    await session.close();
+
+    return res;
   }
 
-  write(
+  async write(
     cypher: string,
     params?: Record<string, any>,
     databaseOrTransaction?: string | Transaction,
-  ): Result {
+  ): Promise<QueryResult> {
     if (databaseOrTransaction instanceof TransactionImpl) {
       return (<Transaction>databaseOrTransaction).run(cypher, params);
     }
 
     const session = this.getWriteSession(<string>databaseOrTransaction);
-    return session.run(cypher, params);
+    const res = await session.executeWrite((tx) => tx.run(cypher, params));
+
+    await session.close();
+
+    return res;
   }
 
   onApplicationShutdown() {

package.json

@@ -23,7 +23,7 @@
   "homepage": "https://github.com/adam-cowley/nest-neo4j#readme",
   "dependencies": {
     "class-transformer": "^0.5.1",
-    "neo4j-driver": "^4.4.7",
+    "neo4j-driver": "^5.0.1",
     "reflect-metadata": "^0.1.13"
   },
   "peerDependencies": {