cha0s/reddichat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: leave

Browse Source
This commit is contained in:
cha0s 2020-12-11 23:36:54 -06:00
parent 6687884604
commit d10508fa05
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/chat/src/index.js
View File

@ -1,5 +1,6 @@
import { import {
channelIsAnonymous, channelIsAnonymous,
parseChannel,
parseChatChannel, parseChatChannel,
renderChannel, renderChannel,
validateChannel, validateChannel,
@ -16,6 +17,7 @@ import Message from './packets/message.server';
import ensureCanonical from './ensure-canonical'; import ensureCanonical from './ensure-canonical';
import defaultState, {channelsToHydrate} from './state'; import defaultState, {channelsToHydrate} from './state';
import joinChannel from './join-channel'; import joinChannel from './join-channel';
import leaveChannel from './leave-channel';
export * from './state'; export * from './state';
@ -66,6 +68,14 @@ export default {
.filter(({type}) => 'r' === type) .filter(({type}) => 'r' === type)
.filter((channel) => req.userId || channelIsAnonymous(channel)) .filter((channel) => req.userId || channelIsAnonymous(channel))
.map((channel) => joinChannel(latus, channel, socket)); .map((channel) => joinChannel(latus, channel, socket));
socket.on('disconnecting', async () => {
Object.keys(socket.rooms).forEach((room) => {
const parsed = parseChannel(room);
if (parsed && 'r' === parsed.type) {
leaveChannel(parsed, socket);
}
});
});
return Promise.all(joins); return Promise.all(joins);
}, },
'@reddichat/state/defaultState': async (req, latus) => ({ '@reddichat/state/defaultState': async (req, latus) => ({