Merge pull request #64 from Findeton/master

Add optional isolation level configuration to sql transactions

Author: AJCStriker

src/cryptography/abstract/HMAC.ts

@@ -1,6 +1,6 @@
 import { Digest } from "./Digest"
 /**
- * A HMAC ( commonly referred to as a Hash ) (hash-based message authentication
+ * A HMAC (hash-based message authentication
  * code) is a type of message authentication code (MAC) that uses a
  * cryptographic hash function and a secret key. It may be used to verify data
  * integrity and authentication of a message.

src/cryptography/drivers/node/SHA1HMAC.ts

@@ -2,7 +2,7 @@ import { HMAC } from "../../abstract/HMAC"
 import { createHmac } from "crypto"
 
 /**
- * The SHA1HMAC provides a HMAC implementation using SHA1 based on Node's
+ * The SHA1HMAC class provides a HMAC implementation using SHA1 based on Node's
  * OpenSSL.
  *
  * This implementation relies on the node crypto implementation and may vary based

src/datastore/abstract/PGIsolationLevel.ts

@@ -0,0 +1,9 @@
+/**
+ * PostgreSQL transaction isolation levels
+ */
+export enum PGIsolationLevel {
+    SERIALIZABLE = "SERIALIZABLE",
+    REPEATABLE_READ = "REPEATABLE_READ",
+    READ_COMMITED = "READ_COMMITED",
+    READ_UNCOMMITTED = "READ_UNCOMMITTED",
+}

src/datastore/drivers/pg/PGStore.ts

@@ -1,3 +1,4 @@
+import { PGIsolationLevel } from "../../abstract/PGIsolationLevel"
 import { PGTransaction } from "./PGTransaction"
 import { SQLStore } from "../../abstract/SQLStore"
 import { Container } from "inversify"
@@ -34,15 +35,36 @@ export class PGStore implements Process, SQLStore {
         }
     }
 
-    public async createTransaction(): Promise<PGTransaction> {
+    public async createTransaction(
+        isolationLevel?: PGIsolationLevel
+    ): Promise<PGTransaction> {
         if (this.connection === undefined) {
             throw new Error(
                 "PGStore cannot open a transaction on a closed Pool. This usually happens from forgetting to call startup."
             )
         }
 
         let connection = await this.connection.connect()
-        await connection.query("BEGIN")
+
+        // By default, use PostgreSQL default isolation level (READ COMMITTED)
+        let query = "BEGIN"
+        if (isolationLevel !== undefined) {
+            switch (isolationLevel) {
+                case PGIsolationLevel.SERIALIZABLE:
+                    query = "BEGIN TRANSACTION ISOLATION LEVEL SERIALIZABLE"
+                    break
+                case PGIsolationLevel.REPEATABLE_READ:
+                    query = "BEGIN TRANSACTION ISOLATION LEVEL REPEATABLE READ"
+                    break
+                case PGIsolationLevel.READ_COMMITED:
+                    query = "BEGIN TRANSACTION ISOLATION LEVEL READ COMMITTED"
+                    break
+                case PGIsolationLevel.READ_UNCOMMITTED:
+                    query = "BEGIN TRANSACTION ISOLATION LEVEL READ UNCOMMITTED"
+                    break
+            }
+        }
+        await connection.query(query)
 
         return new PGTransaction(connection, this.logger)
     }

src/datastore/index.ts

@@ -1,4 +1,5 @@
 export * from "./abstract/SQLStore"
+export * from "./abstract/PGIsolationLevel"
 
 export * from "./drivers/mysql/MySQLStore"
 export * from "./drivers/mysql/MySQLTransaction"

src/logging/abstract/LogLevel.ts

@@ -1,5 +1,5 @@
 /**
- * The standarzied levels used across all Logger integrations
+ * The standardize levels used across all Logger integrations
  */
 export enum LogLevel {
     /**