Skip to content

Commit

Permalink
Se agrega funcionalidad para que el servicio REST emita a los sockets…
Browse files Browse the repository at this point in the history
… los mensjaes ya sean privados o globales
  • Loading branch information
Yoe Cardenas committed Oct 7, 2020
1 parent d56afac commit fa834aa
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 2 deletions.
16 changes: 16 additions & 0 deletions routes/router.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,9 @@

import {Router, Request, Response} from 'express';
import Server from '../class/server';

const router = Router();
const server = Server.instance;

router.get('/mensajes', (req: Request, res: Response) => {

Expand All @@ -17,6 +19,13 @@ router.post('/mensajes', (req: Request, res: Response) => {
const cuerpo = req.body.cuerpo;
const de = req.body.de;

const payload = {
de,
cuerpo
}

server.io.emit('mensaje-nuevo', payload)

res.json({
ok: true,
cuerpo,
Expand All @@ -31,6 +40,13 @@ router.post('/mensajes/:id', (req: Request, res: Response) => {
const de = req.body.de;
const id = req.params.id;

const payload = {
de,
cuerpo
}

server.io.in( id ).emit('mensaje-privado', payload)

res.json({
ok: true,
cuerpo,
Expand Down
2 changes: 0 additions & 2 deletions sockets/sockets.ts
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,6 @@ export const MENSAJE = (cliente: Socket, io: socketIO.Server) => {

cliente.on('mensaje', (payload: {de: string, cuerpo: string}) => {

console.log(`Mensaje recibido`, payload);

io.emit('mensaje-nuevo', payload );

})
Expand Down

0 comments on commit fa834aa

Please sign in to comment.