0

Tal como dice el titulo, tengo una api rest de prueba en node y express, y lo que quiero hacer es: configurar el socket y luego poder emitir eventos desde una funcion especifica de algun controlador. Este codigo no me arroja ningun error, pero el cliente no puede conectarse al socket. Este es mi Server.js en el cual tengo configurado mi servidor:

const express = require('express')

const { dbConnect } = require('../config/db')

const cors = require('cors')

const io = require('./socket')


class Server {
    constructor() {

        this.app = express()

        this.server = require("http").createServer(this.app); //añadi esto para poder ejecutar socket.io
        this.io = require("socket.io")(this.server, { //añadi esto para poder ejecutar socket.io
            cors: {
                origin: "*",
            },
        });

        this.port = process.env.SERVER_PORT || 3000

        // 1- middleware
        this.middlewares()

        // 2- connect DB
        this.connectDB()

        // 3- routes
        this.routes()

    }

    async connectDB() {
        await dbConnect()
    }

    middlewares() {
        this.app.use(cors())
        this.app.use((req, res, next) => { // añado _this.io_ al response para poder usarlo en cualquier controlador
            res.io = this.io
            next()
        });

        this.app.use(express.json())

        this.app.use(express.static('public'))
    }

    routes() {
        this.app.use('/api/example', require('./modules/example/example.router')) // router que me lleva al controlador que se indica mas abajo
    }

    listen() {

        // socket connection
        io.on("connection", (socket) => { //añadi esto para poder ejecutar socket.io
            console.log(socket.id);
        })

        this.app.listen(this.port, () => {
            console.log('Conectado...', this.port)
        })
    }
}

module.exports = Server;

Este es el controlador conde voy a usarlo:

const { request, response } = require('express');
const { getExamples } = require('./example.queries');

const all = async (req = request, res = response) => {

    const data = await getExamples()

    res.io.emit("mensaje", {
        message: "hello from controller"
    });
    return res.status(200).json({
        msg: 'Este es un mensaje de la funcion all del controller',
        data
    });
}

module.exports = {
    all,

}

y este es el cliente de ejemplo:

<!DOCTYPE html>
<html lang="en">

<head>
    <script src="https://cdn.socket.io/4.7.2/socket.io.min.js"></script>
    <title>Reciever</title>
</head>

<body>

    <script>
        const socket = io('http://localhost:3000')
        socket.on('mensaje', (data) => {
            console.log(data)
        })

    </script>
</body>

</html>

</html>

0

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Examina otras preguntas con la etiqueta o formula tu propia pregunta.