Merge pull request #4 from StrontiumJS/master

sync fork

Author: Findeton

package.json

@@ -1,6 +1,6 @@
 {
   "name": "strontium",
-  "version": "2.7.0",
+  "version": "2.7.4",
   "description": "Strontium is a TypeScript toolkit for High Performance API servers built for Production not Projects.",
   "main": "lib/src/index.js",
   "types": "lib/src/index.d.ts",

src/bootstrap/drivers/Environment.ts

@@ -0,0 +1,50 @@
+import { Container } from "inversify"
+import { Logger } from "../../logging"
+import { Process } from "../../runtime"
+import { ObjectValidator, ValidatedObject, isObject } from "../../validation"
+
+export class Environment<O extends ObjectValidator> implements Process {
+    private validatedEnvironment?: ValidatedObject<O>
+
+    constructor(private validator: O) {}
+
+    public getKey<K extends keyof ValidatedObject<O>>(
+        key: K
+    ): ValidatedObject<O>[K] {
+        if (this.validatedEnvironment !== undefined) {
+            return this.validatedEnvironment[key]
+        } else {
+            throw new Error(
+                "An environment value was accessed before the Environment container completed initialization."
+            )
+        }
+    }
+
+    public isHealthy(): boolean {
+        return this.validatedEnvironment !== undefined
+    }
+
+    public async startup(container: Container): Promise<void> {
+        container.bind(Environment).toConstantValue(this)
+
+        try {
+            this.validatedEnvironment = await isObject(this.validator)(
+                process.env
+            )
+        } catch (e) {
+            if (container.isBound(Logger)) {
+                container.get(Logger).error("Environment validation failed!", e)
+            } else {
+                console.error(e)
+            }
+
+            throw e
+        }
+    }
+
+    public async shutdown(container: Container): Promise<void> {
+        container.unbind(Environment)
+
+        this.validatedEnvironment = undefined
+    }
+}

src/bootstrap/index.ts

@@ -0,0 +1 @@
+export * from "./drivers/Environment"

src/datastore/drivers/pg/PGStore.ts

@@ -46,24 +46,26 @@ export class PGStore implements Process, SQLStore {
 
         let connection = await this.connection.connect()
 
-        // 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
-            }
+        // By default, use PostgreSQL default isolation level (READ COMMITTED out of the box)
+        let query: string
+        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
+            default:
+                query = "BEGIN"
+                break
         }
+
         await connection.query(query)
 
         return new PGTransaction(connection, this.logger)

src/index.ts

@@ -1,3 +1,4 @@
+export * from "./bootstrap"
 export * from "./cryptography"
 export * from "./datastore"
 export * from "./errors"