Estoy diseñando una aplicación que tiene muchos temas y para cada tema hay algunos usuarios en línea y por lo mismo estoy usando express/socket.io/mongoose como back-end y flutter como front-end.
Estoy atascado en una parte en la que puedo mostrar a los usuarios cuántos usuarios están actualmente en línea para un tema en tiempo real (se muestra como una vista de lista en la interfaz).
Los temas se almacenan en la base de datos.
Así que se me ocurrió este poco de lógica, pero creo que esta no es la forma correcta de hacerlo.
const roomChangeStream = roomModel.watch(); roomChangeStream.on('change', async (change) => { topicModel.find().then((topics) => { topics.forEach(topic => { roomModel.find().where('isSearching').equals(true) .where('preferredTopic').equals(topic.slug).count( (err,count)=>{ if (err) console.error(err); console.log("the count for" +topic.slug+" is ",count) // socket.emit }) }); }).catch((err)=>console.log(err)) })En el código anterior, estoy buscando un cambio en la base de datos de la sala (donde se almacenan los usuarios en línea) y cada vez que hay un cambio, reviso todos los temas (más de 100), luego busco el conteo de usuarios en línea y los emito.
Sé que esta es una mala pieza de código. asi que busco ayuda
De todos modos, después de que un usuario se conecta a su servidor, guarda ese socket de cliente en algún lugar, ¿verdad? Principalmente dentro de Redis o MemCached. Para ser más precisos, la identificación de ese socket. Por lo tanto, también puede guardar datos adicionales con él (topicId, userId). Luego, puede contar todos los sockets filtrándolos con topicId (como entendí, necesita usuarios activos por tema).