Express + Soket.io передать IO в роутер?

Question

[IDONTSUDO]

Насколько я знаю Express строится на промежуточных обработчиках. Но почему то я не могу получить доступ к io в своём обработчике.
Структура моего приложения


main.js

const express = require('express')
const http = require('http')
const socketIO = require('socket.io')
const morgan = require('morgan')
const bodyParser = require('body-parser')

const port = 4001

const app = express()

const server = http.createServer(app)

const io = socketIO(server)
const Routes = require('./router/test.js')
// console.log(io) здесь я могу получить доступ к io переменной
app.use(function(req,res,next){
// console.log(io) а в промежуточном обработчике не могу
    req.io = io;
    next();
});


app.use(morgan("dev"))
app.use(bodyParser.json())
app.use("/", Routes)



server.listen(port, () => console.log(`Listening on port ${port}`))

test.router.js

const express = require("express")
const { test } = require("../controllers/test")

const router = express.Router({mergeParams: true});

router.get('/',test)

module.exports = router

test.controller.js

exports.test = async (req,res) =>{
    console.log(200)
}

Как мне сделать так что бы io соединение было доступно на уровне всего приложения?

Answer 1

[hzzzzl]

должно работать, а как ты знаешь, что
// console.log(io) а в промежуточном обработчике не могу
?

в test.controller.js тоже req.io === undefined?

буквально вчера так и писал

const express = require('express')
const app = express()
const server = require('http').createServer(app)
const io = require('socket.io')(server)

app.use('/', function(request, response, next) {
  request.io = io
  next()
})

............

router.post('/', async (req, res) => {
    const { socketId } = req.body
    req.io.to(socketId).emit('fetchstart')   // всё ок
.....

Comments

[IDONTSUDO]

роутер должен залогировать цифру 200, но не логирует. Это мега странно.

[hzzzzl]

IDONTSUDO, попробуй

// test.router.js
const test = require("../controllers/test.controller")  // у тебя здесь просто test.js?
..
router.get('/', test)


// test.controller.js
module.exports = async (req,res) =>{
    console.log(io)  // должен быть объект сокета в консоли ноды, но не в браузере?
    res.send(200)   // http статус, который браузер ожидает
}

[IDONTSUDO]

Оно работает, но только если я в браузере HTTP отсылаю.

[IDONTSUDO]

hzzzzl, не особо помогло

[hzzzzl]

IDONTSUDO, ну до роута test.controller.js вообще доходит дело?
в общем-то должно именно так всё и работать, и там должен быть заполненный req.io, который экспресс будет перекидывать из одной функции в другую

[IDONTSUDO]

hzzzzl, для статики я использую REACT. И все дело в этом, насколько я понимаю.

И когда я из реакт, пытаюсь туда постучать ничерта не работает.
Но вот когда вот так, все отлично работает. Я ни черта не понимаю.

// This creates our socket using the instance of the server
const io = socketIO(server)

// This is what the socket.io syntax is like, we will work this later
io.on('connection', socket => {
  console.log('User connected')
  
  socket.on('disconnect', () => {
    console.log('user disconnected')
  })
})


var chat = io
  .of('/chat')
  .on('connection', function (socket) {
    console.log("200")

    socket.emit('a message', {
        that: 'only'
      , '/chat': 'will get'
    });
    chat.emit('a message', {
        everyone: 'in'
      , '/chat': 'will get'
    });
  });

var news = io
  .of('/news')
  .on('connection', function (socket) {
    socket.emit('item', { news: 'item' });
  });


server.listen(port, () => console.log(`Listening on port ${port}`))

[IDONTSUDO]

и при таком варианте оно 3 раза дублирует одно подключение.