Mongo DB persistence added

Author: MiguelAngelRL

back/.env

@@ -1,2 +1,7 @@
 NODE_ENV=development
 PORT=8081
+SOCKET_PORT=3000
+MOCK_REPOSITORY=false
+API_URL=/api
+CORS_ORIGIN=http://localhost:8080
+MONGODB_URI=mongodb://localhost:27017/code-paster

back/package.json

@@ -8,9 +8,10 @@
     "start:dev": "nodemon --exec babel-node --extensions \".ts\" src/index.ts",
     "start:debug": "run-p -l type-check:watch \"start:dev -- --inspect-brk\"",
     "start:prod": "node ./dist/index.js",
-    "start:mock-repository": "cross-env MOCK_REPOSITORY=true npm run start",
-    "start:local-db": "docker-compose up || echo \"Run docker-compose up manually\"",
-    "stop:local-db": "docker-compose down || echo \"Run docker-compose down manually\"",
+    "start:mock": "cross-env MOCK_REPOSITORY=true npm run start",
+    "start:localdb": "cross-env run-p -l start start:docker-db",
+    "start:docker-db": "docker-compose up || echo \"Run docker-compose up manually\"",
+    "stop:docker-db": "docker-compose down || echo \"Run docker-compose down manually\"",
     "build": "run-p -l type-check build:prod",
     "build:prod": "npm run clean && babel src -d dist --ignore=\"./src/test-runners\" --extensions \".ts\"",
     "build:dev": "npm run clean && babel src -d dist --ignore=\"./src/test-runners\" --extensions \".ts\" --source-maps",

back/src/app.ts

@@ -1,5 +1,5 @@
 import { createApp } from './express.server';
-import { envConstants } from './env.constants';
+import { envConstants } from 'core';
 import { api } from './api';
 import cors from 'cors';
 import SocketIOClient, { Socket } from 'socket.io';
@@ -10,6 +10,7 @@ import {
   Action,
   SocketInfo,
 } from './messages';
+import { connectToDB } from 'core';
 
 const app = createApp();
 
@@ -35,10 +36,14 @@ const options: cors.CorsOptions = {
 };
 
 app.use(cors(options));
-app.use('/api', api);
+app.use(envConstants.API_URL, api);
 
-app.listen(envConstants.PORT, () => {
-  console.log(`Server ready at http://localhost:${envConstants.PORT}/api`);
+app.listen(envConstants.PORT, async () => {
+  if(!envConstants.isMockRepository && envConstants.MONGODB_URI) {
+    await connectToDB(envConstants.MONGODB_URI);
+  }
+  console.log(`Using ${envConstants.isMockRepository ? 'Mock' : 'DataBase'} for session storage`)
+  console.log(`Server ready at http://localhost:${envConstants.PORT}${envConstants.API_URL}`);
 });
 
 // whenever a user connects on port 3000 via

back/src/core/db/index.ts

@@ -0,0 +1 @@
+export * from './database.connection';

back/src/core/index.ts

@@ -0,0 +1,3 @@
+export * from './constants'
+export * from './db'
+export * from './servers'

back/src/dals/room/index.ts

@@ -1 +1,2 @@
-export * from './room.model';
+export * from './room.model';
+export * from './room.context';

back/src/dals/room/room.context.ts

@@ -0,0 +1,12 @@
+import { Document, model, Schema } from 'mongoose';
+import { RoomInfo } from 'dals';
+
+const roomSchema = new Schema({
+  room: Schema.Types.String,
+  content: Schema.Types.String
+});
+
+export const RoomContext = model<RoomInfo & Document>(
+  'RoomInfo',
+  roomSchema
+);

back/src/dals/session/index.ts

@@ -1,2 +1,3 @@
 export * from './repository';
 export * from './session.model';
+export * from './session.context';

back/src/dals/session/repository/index.ts

@@ -1,7 +1,7 @@
 import { envConstants } from 'core/constants';
 import * as mockRepository from './session.mock';
 //TODO: change to session.db
-import * as repository from './session.mock';
+import * as repository from './session.repository';
 import { SessionRepository } from './session.contract';
 
 export const sessionRepository: SessionRepository = envConstants.isMockRepository

back/src/dals/session/repository/session.contract.ts

@@ -1,12 +1,13 @@
 import { RoomInfo } from 'dals/room';
 import { ConnectSessionInfo } from 'dals/session';
+import { UserSession } from '../session.model';
 
 export interface SessionRepository {
   isTrainerUser: (connectionId: string) => Promise<boolean>;
   saveRoomInfo: (newRoomInfo: RoomInfo, action: string)  => Promise<void>;
   isExistingConnection: (connectionId: string) => Promise<boolean>;
   isRoomAvailable: (room: string) => Promise<boolean>;
-  addNewUser: (connectionId: string, connectSession: ConnectSessionInfo) => Promise<void>;
+  addNewUser: (userSession: UserSession) => Promise<void>;
   getRoomFromConnectionId: (connectionId: string) => Promise<string>;
   getRoomContent:(room: string) => Promise<string>;
 }