defined database connector interface

Author: gambitier

Projects/BooksLibrary/src/app.ts

@@ -37,6 +37,13 @@ export default class Application {
             //Load the modules
             await Loader.init();
 
+            if (process.env.NODE_ENV === 'test') {
+                await Loader.databaseConnector.dropDatabase();
+            }
+
+            //Connect with database
+            await Loader.databaseConnector.init();
+
             //Set-up middlewares
             await this.setupMiddlewares();
 

Projects/BooksLibrary/src/database/database.connector.interface.ts

@@ -0,0 +1,13 @@
+export interface IDatabaseConnector {
+    connect(): Promise<boolean>;
+
+    sync(): Promise<boolean>;
+
+    createDatabase(): Promise<boolean>;
+
+    dropDatabase(): Promise<boolean>;
+
+    executeQuery(query: string): Promise<boolean>;
+
+    migrate(): Promise<boolean>;
+}

Projects/BooksLibrary/src/database/database.connector.ts

@@ -0,0 +1,28 @@
+import { Logger } from 'common/logger';
+import { inject, injectable } from 'tsyringe';
+import { IDatabaseConnector } from './database.connector.interface';
+
+@injectable()
+export class DatabaseConnector {
+    constructor(@inject('IDatabaseConnector') private _db: IDatabaseConnector) {}
+
+    public init = async (): Promise<boolean> => {
+        try {
+            await this._db.connect();
+            return true;
+        } catch (error) {
+            Logger.instance().log('Create database error: ' + error.message);
+            return false;
+        }
+    };
+
+    public dropDatabase = async (): Promise<boolean> => {
+        try {
+            await this._db.dropDatabase();
+            return true;
+        } catch (error) {
+            Logger.instance().log('Drop database error: ' + error.message);
+            return false;
+        }
+    };
+}

Projects/BooksLibrary/src/startup/loader.ts

@@ -2,6 +2,7 @@ import { container, DependencyContainer } from 'tsyringe';
 import { Authenticator } from 'auth/authenticator';
 import { Logger } from '../common/logger';
 import { Authorizer } from 'auth/authorizer';
+import { DatabaseConnector } from 'database/database.connector';
 
 export class Loader {
     private static _container: DependencyContainer = container;
@@ -22,9 +23,16 @@ export class Loader {
         return Loader._authenticator;
     }
 
+    private static _databaseConnector: DatabaseConnector = null;
+
+    public static get databaseConnector() {
+        return Loader._databaseConnector;
+    }
+
     public static init = async (): Promise<boolean> => {
         try {
             //Register injections here...
+            Loader._databaseConnector = container.resolve(DatabaseConnector);
 
             return true;
         } catch (error) {