Merge pull request #112 from Lemoncode/#23--Mongo-DB-persistence

Mongo DB persistence added

Author: brauliodiez

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

@@ -4,11 +4,11 @@
   "description": "",
   "main": "index.js",
   "scripts": {
-    "start": "run-p -l type-check:watch start:dev",
+    "start": "run-p -l type-check:watch start:dev start:local-db",
+    "start:mock": "cross-env MOCK_REPOSITORY=true run-p -l type-check:watch start:dev",
     "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\"",
     "build": "run-p -l type-check build:prod",

back/src/app.ts

@@ -1,15 +1,10 @@
-import { createApp } from './express.server';
-import { envConstants } from './env.constants';
-import { api } from './api';
 import cors from 'cors';
 import SocketIOClient, { Socket } from 'socket.io';
-import {
-  processInputMessage,
-  InputMessageTypes,
-  processOutputMessageCollection,
-  Action,
-  SocketInfo,
-} from './messages';
+
+import { createApp } from './express.server';
+import { envConstants, connectToDB } from 'core';
+import { api } from './api';
+import { processInputMessage, InputMessageTypes, processOutputMessageCollection, Action, SocketInfo } from './messages';
 
 const app = createApp();
 
@@ -35,10 +30,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/core/servers/cors.ts

@@ -1,4 +1,4 @@
-import { envConstants } from '../constants';
+import { envConstants } from 'core';
 import cors from 'cors';
 
 const options: cors.CorsOptions = {

back/src/dals/room/index.ts

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

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

@@ -0,0 +1,8 @@
+import { envConstants } from 'core';
+import * as mockRepository from './room.mock';
+import * as repository from './room.repository';
+import { RoomRepositoryContract } from './room.contract';
+
+export const roomRepository: RoomRepositoryContract = envConstants.isMockRepository
+  ? mockRepository
+  : repository;

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

@@ -0,0 +1,8 @@
+import { RoomInfo } from 'dals';
+
+export interface RoomRepositoryContract {
+  saveRoomInfo: (newRoomInfo: RoomInfo, action: string)  => Promise<void>;
+  isRoomAvailable: (room: string) => Promise<boolean>;
+  getRoomContent:(room: string) => Promise<string>;
+}
+

back/src/dals/room/repository/room.mock.ts

@@ -0,0 +1,51 @@
+import produce from 'immer';
+import { InputMessageTypes } from 'messages';
+import { RoomInfo, UserSession } from 'dals'
+
+let userCollectionSession: UserSession[] = [];
+let roomCollectionSession: RoomInfo[] = [];
+
+export const isRoomAvailable = async (room: string): Promise<boolean> =>
+  !userCollectionSession.find((session) => session.room === room);
+
+export const saveRoomInfo = async (newRoomInfo: RoomInfo, action: string): Promise<void> => {
+  const roomIndex: number = await getRoomIndexByName(newRoomInfo);
+  const content: string = newRoomInfo.content;
+  roomCollectionSession =
+    roomIndex === -1
+      ? await insertRoom(newRoomInfo)
+      : await updateRoomContent(roomIndex, content, action);
+};
+
+export const getRoomContent = async (room: string): Promise<string> => {
+  const roomInfo = roomCollectionSession.find(
+    (roomInfo: RoomInfo) => roomInfo.room === room
+  );
+
+  return roomInfo ? roomInfo.content : '';
+};
+
+const getRoomIndexByName = async (newRoomInfo: RoomInfo): Promise<number> => {
+  return roomCollectionSession.findIndex(
+    (roomInfo: RoomInfo) => roomInfo.room === newRoomInfo.room
+  );
+};
+
+const updateRoomContent = async (index: number, content: string, action:string): Promise<RoomInfo[]> => {
+  return produce(roomCollectionSession, (draftState: RoomInfo[]) => {
+    switch (action) {
+      case InputMessageTypes.TRAINER_APPEND_TEXT:
+        draftState[index].content += '\n' + content;
+        break;
+      case InputMessageTypes.TRAINER_SET_FULL_TEXT:
+        draftState[index].content = content;
+        break;
+    };
+  });
+};
+
+const insertRoom = async (newRoomInfo: RoomInfo): Promise<RoomInfo[]> => {
+  return produce(roomCollectionSession, (draftState: RoomInfo[]) => {
+    draftState.push(newRoomInfo);
+  });
+};