-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.js
More file actions
84 lines (78 loc) · 2.96 KB
/
server.js
File metadata and controls
84 lines (78 loc) · 2.96 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
const express = require('express')
const app = express()
const https = require('https')
const http = require('http')
const cors = require('cors')
const fs = require('fs')
const funcoes = require('./src/funcoes')
const server = http.createServer({
//key: fs.readFileSync('./src/cert/certprivate.key'),
// cert: fs.readFileSync('./src/cert/publica.crt')
}, app)
const io = require('socket.io')(server)
const router = require('./router')
require('dotenv').config()
const jwt = require('jsonwebtoken');
/* const corsOptions = {
origin: process.env.ORIGIN.split(';'),
credentials: true,
methods: 'GET, POST, PUT, OPTIONS, DEELETE'
} */
app.set('view engine', 'ejs')
app.use(express.static('public'))
app.use(cors())
//app.use(cors(corsOptions))
app.use(router)
let mensagens = []
let users = []
let idContacts = []
io.on('connection', socket => {
//console.log('Conectado ao ID: ', socket.id)
console.log('Qt Clientes: ', socket.server.eio.clientsCount)
//console.log('Clientes: ', socket.server.eio)
//console.log(socket.handshake.query)
//const nomeUsuario = socket.handshake.query;
//console.log(`Usuário conectado: ${nomeUsuario}`)
//console.log(socket.handshake.query)
const nomeUsuario = socket.handshake.query.nomeUsuario
const idContact = socket.handshake.query.t
if(!idContacts.some(contact => contact.id === socket.handshake.query.t)){
idContacts.push({
id: socket.handshake.query.t,
nomeUsuario: socket.handshake.query.nomeUsuario})
}
if(!users.includes(nomeUsuario)){
users.push(nomeUsuario)
// console.log('Usuário desconectado:', nomeUsuario);
// console.log('Lista de usuários conectados:', users);
}
// Evento para lidar com desconexões e apagar da lista
socket.on('disconnect', () => {
const index = users.indexOf(nomeUsuario)
const idIndex = idContacts.findIndex(contact => contact.id === idContact)
if (index !== -1) {
users.splice(index, 1)
//console.log('Usuário desconectado:', nomeUsuario)
//console.log('Lista de usuários conectados:', users)
//console.log('Lista de IDContacts conectados:', idContacts)
}
if (idIndex !== -1) {
idContacts.splice(idIndex, 1); // Remove o objeto com o ID do array
}
})
setInterval(() =>{
socket.emit('online', {qt: socket.server.eio.clientsCount, 'users': users, 'idContacts': idContacts})
}, 2000)
socket.emit('previusMensagens', mensagens)
socket.on('message', dados => {
mensagens.push(dados)
//envia mensagem para todos conectados
socket.broadcast.emit('mensagemRecebida', dados);
})
socket.on('digi', data => {
socket.broadcast.emit('digitando', data);
})
})
server.listen(process.env.PORT, () => {
console.log(`server rodando na porta: ${process.env.PORT}\nRodar Aplicação em : http://${funcoes.getLocalIP()}:${process.env.PORT}/page`);
})