Skip to content

Commit 80ddef5

Browse files
committed
Some minors changes
1 parent 4c7752c commit 80ddef5

6 files changed

Lines changed: 15 additions & 24 deletions

File tree

‎back/package.json‎

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4,14 +4,13 @@
44
"description": "",
55
"main": "index.js",
66
"scripts": {
7-
"start": "run-p -l type-check:watch start:dev",
7+
"start": "run-p -l type-check:watch start:dev start:local-db",
8+
"start:mock": "cross-env MOCK_REPOSITORY=true run-p -l type-check:watch start:dev",
89
"start:dev": "nodemon --exec babel-node --extensions \".ts\" src/index.ts",
910
"start:debug": "run-p -l type-check:watch \"start:dev -- --inspect-brk\"",
1011
"start:prod": "node ./dist/index.js",
11-
"start:mock": "cross-env MOCK_REPOSITORY=true npm run start",
12-
"start:localdb": "cross-env run-p -l start start:docker-db",
13-
"start:docker-db": "docker-compose up || echo \"Run docker-compose up manually\"",
14-
"stop:docker-db": "docker-compose down || echo \"Run docker-compose down manually\"",
12+
"start:local-db": "docker-compose up || echo \"Run docker-compose up manually\"",
13+
"stop:local-db": "docker-compose down || echo \"Run docker-compose down manually\"",
1514
"build": "run-p -l type-check build:prod",
1615
"build:prod": "npm run clean && babel src -d dist --ignore=\"./src/test-runners\" --extensions \".ts\"",
1716
"build:dev": "npm run clean && babel src -d dist --ignore=\"./src/test-runners\" --extensions \".ts\" --source-maps",

‎back/src/app.ts‎

Lines changed: 5 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,10 @@
1-
import { createApp } from './express.server';
2-
import { envConstants } from 'core';
3-
import { api } from './api';
41
import cors from 'cors';
52
import SocketIOClient, { Socket } from 'socket.io';
6-
import {
7-
processInputMessage,
8-
InputMessageTypes,
9-
processOutputMessageCollection,
10-
Action,
11-
SocketInfo,
12-
} from './messages';
13-
import { connectToDB } from 'core';
3+
4+
import { createApp } from './express.server';
5+
import { envConstants, connectToDB } from 'core';
6+
import { api } from './api';
7+
import { processInputMessage, InputMessageTypes, processOutputMessageCollection, Action, SocketInfo } from './messages';
148

159
const app = createApp();
1610

‎back/src/core/servers/cors.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { envConstants } from '../constants';
1+
import { envConstants } from 'core';
22
import cors from 'cors';
33

44
const options: cors.CorsOptions = {

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
import { envConstants } from 'core/constants';
22
import * as mockRepository from './session.mock';
3-
//TODO: change to session.db
43
import * as repository from './session.repository';
54
import { SessionRepository } from './session.contract';
65

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

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import { InputMessageTypes } from 'messages';
2-
import {ConnectSessionInfo, RoomInfo, UserSession, UserSessionContext, RoomContext} from 'dals'
2+
import {RoomInfo, UserSession, UserSessionContext, RoomContext} from 'dals'
33

44
export const isRoomAvailable = async (room: string): Promise<boolean> => {
55
const roomAvailable = !(await RoomContext.exists({ room }));
@@ -65,10 +65,9 @@ export const isTrainerUser = async (connectionId: string): Promise<boolean> => {
6565

6666
export const isExistingConnection = async (connectionId: string): Promise<boolean> => {
6767
const session: UserSession = await getSessionFromConnectionId(connectionId);
68-
return session ? true : false;
68+
return Boolean(session);
6969
}
7070

7171
const getSessionFromConnectionId = async (connectionId: string): Promise<UserSession> => {
72-
return (await UserSessionContext.findOne({connectionId: connectionId}));
73-
};
74-
72+
return (await UserSessionContext.findOne({connectionId: connectionId}).lean());
73+
};

‎back/src/messages/input-processor.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ const handleEstablishConnectionTrainer = async (socketInfo: SocketInfo, room: st
100100
saveRoomInfo({room, content:""}, "");
101101
}
102102

103-
if (await isRoomAvailable(room) || !(await isExistingConnection(socketInfo.connectionId))) {
103+
if (roomAvailable || !(await isExistingConnection(socketInfo.connectionId))) {
104104
await addNewUser({ connectionId: socketInfo.connectionId, room, trainerToken, isTrainer: !!trainerToken });
105105
socketInfo.socket.join(room);
106106
}

0 commit comments

Comments
 (0)