Merge pull request #115 from Lemoncode/#114--Refactor-to-pods-structure-and-core

Refactored to pods and core structure

Author: nasdan

back/.babelrc

@@ -22,8 +22,6 @@
                       "core": "./src/core",
                       "dals": "./src/dals",
                       "pods": "./src/pods",
-                      "messages": "./src/messages",
-                      "business": "./src/business"
                     }
                   }
               ]

back/.env

@@ -1,7 +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
+STATIC_FILES_PATH="../../front/dist"

back/.vscode/launch.json

@@ -10,7 +10,8 @@
       "runtimeExecutable": null,
       "runtimeArgs": ["--nolazy"],
       "env": {
-        "NODE_ENV": "development"
+        "NODE_ENV": "development",
+        "MOCK_REPOSITORY": "true"
       },
       "console": "internalConsole",
       "sourceMaps": true,

back/src/app.ts

@@ -1,98 +1,24 @@
-import cors from 'cors';
-import SocketIOClient, { Socket } from 'socket.io';
+import express from 'express';
+import path from 'path';
 
-import { createApp } from './express.server';
-import { envConstants, connectToDB } from 'core';
-import { api } from './api';
-import { processInputMessage, InputMessageTypes, processOutputMessageCollection, Action, SocketInfo } from './messages';
+import { createApp, createSocketServer } from 'core/servers';
+import { connectToDB } from 'core/db';
+import { envConstants } from 'core/constants';
+import { api } from 'pods/room';
 
 const app = createApp();
-
-let http = require('http').Server(app);
-// set up socket.io and bind it to our
-// http server.
-let io: SocketIOClient.Socket = require('socket.io')(http);
-
-//options for cors midddleware
-const options: cors.CorsOptions = {
-  allowedHeaders: [
-    'Origin',
-    'X-Requested-With',
-    'Content-Type',
-    'Accept',
-    'X-Access-Token',
-  ],
-  credentials: true,
-  methods: 'GET,HEAD,OPTIONS,PUT,PATCH,POST,DELETE',
-  // IMPORTANT LIMIT HERE YOUR CLIENT APPS DOMAINS
-  origin: '*',
-  preflightContinue: false,
-};
-
-app.use(cors(options));
 app.use(envConstants.API_URL, api);
 
-app.listen(envConstants.PORT, async () => {
+const staticFilesPath = path.resolve(__dirname, envConstants.STATIC_FILES_PATH);
+app.use('/', express.static(staticFilesPath));
+
+const appServer = 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
-// a websocket, log that a user has connected
-io.on('connection', async function (socket: Socket) {
-  // WATCH OUT !! Reconnect is not implemented
-  // In the connection input processing, we should
-  // check if connectionId matches with userId and RoomId
-  // if not reject, if it's accepted send connection
-  // reestablished
-  const { room, trainertoken } = socket.handshake.query;
-  console.log(`room request: ${room}`);
-  console.log(`trainer token: ${trainertoken}`);
-  console.log('*** Session ID:', socket.conn.id);
-
-  let outputMessageCollection: Action[] = [];
-  const socketInfo: SocketInfo = {
-    socket: socket,
-    io,
-    connectionId: socket.conn.id,
-  };
-
-  // TODO encapuslate this to processInputMessage
-  if (trainertoken) {
-    outputMessageCollection = await processInputMessage(socketInfo, {
-      type: InputMessageTypes.ESTABLISH_CONNECTION_TRAINER,
-      payload: {
-        room,
-        trainertoken,
-      },
-    });
-  } else {
-    outputMessageCollection = await processInputMessage(socketInfo, {
-      type: InputMessageTypes.ESTABLISH_CONNECTION_STUDENT,
-      payload: {
-        room,
-      },
-    });
-  }
-
-  processOutputMessageCollection(socketInfo, outputMessageCollection);
-
-  socket.on('message', async function (message: any) {
-    console.log(message);
-    if (message && message.type) {
-      const outputMessageCollection: Action[] = await processInputMessage(
-        socketInfo,
-        message
-      );
+createSocketServer(appServer);
 
-      await processOutputMessageCollection(socketInfo, outputMessageCollection);
-    }
-  });
-});
-
-const server = http.listen(3001, function () {
-  console.log('listening on *:3001');
-});

back/src/business/index.ts

@@ -1,10 +1,12 @@
 export const envConstants = {
     NODE_ENV: process.env.NODE_ENV,
     PORT: process.env.PORT,
-    SOCKET_PORT: process.env.SOCKET_PORT,
     isMockRepository: process.env.MOCK_REPOSITORY === 'true',
     MONGODB_URI: process.env.MONGODB_URI,
     API_URL: process.env.API_URL,
     CORS_ORIGIN: process.env.CORS_ORIGIN,
+    isProduction: process.env.NODE_ENV === 'production',
+    STATIC_FILES_PATH: process.env.STATIC_FILES_PATH
   };
+  
 

back/src/core/constants/env.constants.ts

@@ -0,0 +1,5 @@
+export const headerConstants = {
+    protocol: 'x-forwarded-proto',
+    httpsProtocol: 'https',
+    host: 'host',
+  };

back/src/core/constants/header.constants.ts

@@ -1 +1,2 @@
-export * from './env.constants';
+export * from './env.constants';
+export * from './header.constants';

back/src/core/constants/index.ts

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

back/src/core/servers/cors.ts

@@ -1,12 +1,19 @@
 import express from 'express';
 import bodyParser from 'body-parser';
 import { corsOptions } from './cors'
+import { envConstants } from 'core/constants';
+import { redirectHttpsMiddleware } from './middlewares';
 
 export const createApp = () => {
   const app = express();
 
   app.use(bodyParser.urlencoded({ extended: false }));
   app.use(bodyParser.json());
   app.use(corsOptions);
+
+  if (envConstants.isProduction) {
+    app.use(redirectHttpsMiddleware);
+  }
+
   return app;
 };