Mi intención es buscar una manera de poder manejar los eventos on
, emit
, etc. de socket, dentro de un endpoint.
Mi archivo index tiene esto:
Index.ts
import express, { Application } from 'express'
import morgan from 'morgan'
import HTTP from 'http'
import { Server } from 'socket.io'
import cors from 'cors'
import helmet from 'helmet'
import compression from 'compression'
import passport from 'passport'
import { config } from 'dotenv'
import './database/connect'
import passportAuth from './auth/passport'
//routers
import Authentication from './routers/authentication.routes'
class Backend {
private app: Application
private HTTP: HTTP.Server
private io: Server
constructor(){
this.app = express()
this.HTTP = HTTP.createServer(this.app)
this.io = new Server(this.http)
this._Config()
this._Routers()
config()
}
private _Config(): void {
// Settings
this.app.set('port', process.env.PORT || 8080);
// middlewares
this.app.use(morgan('dev'));
this.app.use(cors());
this.app.use(express.json());
this.app.use(express.urlencoded({ extended: true }));
this.app.use(passport.initialize());
this.app.use(helmet());
this.app.use(compression());
}
private _Routers(): void {
//ruta estatica
this.app.use("/uploads", express.static('./uploads'))
//end-points y controladores
this.app.use("/api", Authentication)
}
public _Start(): void {
this.http.listen(this.app.get('port'), () => {
console.log('Servidor escuchando en el puerto', this.app.get('port'))
})
this.io.on('connection', (socket)=>{
console.log(socket.id)
})
}
}
const server = new Backend()
server._Start()
Como pueden ver, estoy escuchando la conexión al socket
en el método _Start()
. Lo que yo quiero hacer es poder manipular el parámetro que recibo (socket
) de la función del on
que es donde escucho la conexión al servidor.
Dentro de una carpeta routers
manejo las rutas de la siguiente manera:
routers/authentication.routes.ts
import { Router } from 'express'
const route = Router()
//controllers
import { Iniciar_Sesion, Registrar } from './../controllers/authentication.controllers'
route.post('/iniciar', Iniciar_Sesion)
route.post('/registrar', Registrar)
export default route
Y como es obvio, dentro de otra carpeta contengo los controladores para tener mas ordenado mi código. Simplificando la pregunta, necesito poder emitir y escuchar eventos de los sockets
dentro de cada endpoint.
PD: Necesito que la conexión del socket no se reinicie cada vez que el usuario realice una petición, ya que guardo el id del socket dentro de la bbdd cada vez que el usuario inicia sesión y no es buena idea estar ingresando un nuevo id a la bbdd cuando el usuario haga una consulta al servidor, es por eso que hago la escucha
connection
dentro del_Start()
socket
(creado previamente en_Start()
) dentro de la funciónIniciar_Sesion
de tu archivorouters/authentication.routes.ts
?req
de los controladores para poder utilizar desde alli el objetosocket
, algo comoreq.socket.emit()
oreq.socket.on()
, me explico?