yvachot/chatless
Archived
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Delete just for Khai

Browse source
This commit is contained in:
NyxiumYuuki 2021-05-30 23:26:05 +02:00
parent 0533dae04a
commit bc6aa6dd28
11 changed files with 0 additions and 2369 deletions
Download patch file Download diff file Expand all files Collapse all files

8
backend/service-privateroom/Dockerfile
View file

@ -1,8 +0,0 @@
# syntax=docker/dockerfile:1
FROM node:current-slim
ENV NODE_ENV=production
WORKDIR /app-privateroom
COPY ["package.json", "package-lock.json*", "./"]
RUN npm install --production
COPY . .
CMD [ "node", "server.js" ]

28
backend/service-privateroom/auth.js
View file

@ -1,28 +0,0 @@
const request = require('request');
function getSession (req, callback) {
if(typeof req.headers.cookie !== 'undefined'){
request.post({
headers: {'content-type' : 'application/x-www-form-urlencoded'},
url: 'http://127.0.0.1:3000/verify:token',
body: 'sessionid='+req.headers.cookie.replace('SESSIONID=','')
},function (error, response, body) {
const bodyJson = JSON.parse(body);
if (bodyJson && bodyJson.status && bodyJson.data) {
if (bodyJson.status === 'ok') {
return callback(bodyJson.data.token);
} else {
return callback(bodyJson.data.reason);
}
}
});
}
return callback(undefined);
}
module.exports.getSession = getSession;
function getUsername(session) {
if (typeof session === 'undefined' || typeof session.username === 'undefined') return -1;
return session.username;
}
module.exports.getUsername = getUsername;

15
backend/service-privateroom/config.js
View file

@ -1,15 +0,0 @@
const config = {
mongodbDatabase: 'chat',
mongodbHost: 'mongodb://127.0.0.1:27021/',
// mongodbHost: 'mongodb://127.0.0.1:27018/', //when commit
charset: 'utf8',
mongodbLogin: '',
mongodbPassword: '',
mongodbPrivatedMessages: 'privatedMessages',
mongodbConversations: 'conversations'
};
module.exports = config;

20
backend/service-privateroom/models/Conversation.js
View file

@ -1,20 +0,0 @@
const config = require('../config');
const mongoose = require( 'mongoose' );
const url = config.mongodbHost+config.mongodbDatabase;
mongoose.connect(url,({useNewUrlParser: true, useUnifiedTopology: true})).then( function(){
console.log('mongodb-privated-room connected '+mongoose.connection.readyState);
}).catch(function(err){
console.log('error : '+err);
});
const ConversationSchema = new mongoose.Schema(
{
members: {
type: Array
},
},
{ timestamps: true }
);
module.exports = mongoose.model("Conversation", ConversationSchema);

29
backend/service-privateroom/models/Message.js
View file

@ -1,29 +0,0 @@
const config = require('../config');
const mongoose = require( 'mongoose' );
const url = config.mongodbHost+config.mongodbDatabase;
mongoose.connect(url,({useNewUrlParser: true, useUnifiedTopology: true})).then( function(){
console.log('mongodb-privated-room connected '+mongoose.connection.readyState);
}).catch(function(err){
console.log('error : '+err);
});
const MessageSchema = new mongoose.Schema(
{
conversationId: {
type: String
},
sender: {
type: String
},
text: {
type: String
},
date:{
type: Date,
},
},
{ timestamps: true }
);
module.exports = mongoose.model(config.mongodbPrivatedMessages, MessageSchema);

37
backend/service-privateroom/mongodb-message.js
View file

@ -1,37 +0,0 @@
const config = require('./config');
const mongoose = require( 'mongoose' );
const url = config.mongodbHost+config.mongodbDatabase;
mongoose.connect(url,({useNewUrlParser: true, useUnifiedTopology: true})).then( function(){
console.log('mongodb-message connected '+mongoose.connection.readyState);
}).catch(function(err){
console.log('error : '+err);
});
const schemaMessage = mongoose.Schema({
username:{
type: String,
required: true
},
date:{
type: Date,
required: true
},
channel:{
type: String,
required: true
},
message:{
type: String,
required: true
}
},{ versionKey: false });
const messages = mongoose.model(config.mongodbMessages, schemaMessage);
// messages.find({},(err, messages) => {
// if(err) throw err;
// console.log(messages);
// });
module.exports = messages;

2056
backend/service-privateroom/package-lock.json generated
View file

File diff suppressed because it is too large Load diff

28
backend/service-privateroom/package.json
View file

@ -1,28 +0,0 @@
{
"name": "service-privateroom",
"version": "1.0.0",
"description": "",
"main": "server.js",
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1",
"start": "node server.js"
},
"author": "Van Khai PHAN",
"license": "ISC",
"dependencies": {
"body-parser": "^1.19.0",
"cookie-parser": "^1.4.5",
"cors": "^2.8.5",
"express": "^4.17.1",
"fs": "^0.0.1-security",
"http": "^0.0.1-security",
"jsonwebtoken": "^8.5.1",
"mongodb": "^3.6.9",
"mongoose": "^5.12.12",
"nodemon": "^2.0.7",
"socket.io": "^4.1.2"
},
"devDependencies": {
"request": "^2.88.2"
}
}

32
backend/service-privateroom/routes/conversations.js
View file

@ -1,32 +0,0 @@
const router = require("express").Router();
const Conversation = require("../models/Conversation");
// new conv
router.post("/", async (req, res) => {
const newConversation = new Conversation({
members: [req.body.senderId, req.body.receiverId]
});
try{
const savedConversation = await newConversation.save();
res.status(200).json(savedConversation);
}catch (err){
res.status(500).json(err)
}
});
// get conv
router.get("/:userId", async (req, res) => {
try {
const conversation = await Conversation.find({
members: { $in: [req.params.userId] },
// members: { $eq: [req.params.userId, "yuki"]},
});
res.status(200).json(conversation[0]["_id"]);
}catch (err){
res.status(500).json(err)
}
})
module.exports = router;

29
backend/service-privateroom/routes/messages.js
View file

@ -1,29 +0,0 @@
const router = require("express").Router();
const Messages = require("../models/Message");
// add
router.post("/", async (req, res) => {
let newMessage = new Messages(req.body);
const date = Date.now();
newMessage["date"] = date;
// res.status(200).json(newMessage);
try{
const savedMessage = await newMessage.save();
res.status(200).json(savedMessage);
}catch (err){
res.status(500).json(err)
}
})
// get
router.get("/:conversationId", async (req, res) => {
try{
const messages = await Messages.find({
conversationId: req.params.conversationId
})
res.status(200).json(messages);
}catch (err){
res.status(500).json(err)
}
})
module.exports = router;

87
backend/service-privateroom/server.js
View file

@ -1,87 +0,0 @@
const express = require('express');
const app = express();
const port = process.env.PORT || 3002;
const http = require('http');
const { Server } = require("socket.io");
const server = http.createServer(app);
const io = new Server(server, {
cors: {
origin: "http://127.0.0.1:4200",
methods: ["GET", "POST"],
credentials: true
}
});
const cookieParser = require('cookie-parser');
app.use(cookieParser());
const bodyParser = require('body-parser');
app.use(bodyParser.urlencoded({extended:true}));
app.use(bodyParser.json());
const cors = require('cors');
app.use(cors({origin: 'http://127.0.0.1:4200', credentials: true}));
const conversationRoute = require("./routes/conversations");
const messageRoute = require("./routes/messages");
const Conversations = require("../service-privateroom/models/Conversation");
const Messages = require("../service-privateroom/models/Message");
const auth = require("./auth");
app.use("/conversations", conversationRoute);
app.use("/messages", messageRoute);
io.on('connection',socket => {
let users = {};
auth.getSession(socket.request, function(res){
const getUsername = auth.getUsername(res);
if (getUsername === -1) {
socket.send('error','not authenticated');
}
else{
console.log(`${getUsername} joined the chat.`);
//TODO apply conversations and messages
socket.on('privateroom',function(data){
const sender = data.sender;
const receiver = data.receiver;
const date = data.date;
const message = data.message;
// get conversationid
const conversation = async () => {
const result = await Conversations.find({
members: {$eq: [sender, receiver]},
});
return result;
}
const conversationId = conversation[0]["_id"];
Messages.insertMany([{
conversationId: conversationId,
sender: sender,
text: message,
date: date
}
]).then(function(){
console.log(data, "inserted");
socket.broadcast.emit(conversationId,[data]);
socket.emit(conversationId,[data]);
}).catch(function(error){
console.log("error",error);
});
});
socket.on("disconnect", function() {
console.log(`${getUsername} left the chat.`);
});
}
});
});
server.listen(port, () => {
console.log(`listening on *:${port}/`);
});