1
0
mirror of https://github.com/spacebarchat/server.git synced 2024-11-10 12:42:44 +01:00

Fix gateway not listening for new channels events

This commit is contained in:
AlTech98 2021-09-18 10:44:25 +02:00
parent 2580f6b891
commit 296375c67e
3 changed files with 9 additions and 18 deletions

View File

@ -116,7 +116,7 @@ async function consume(this: WebSocket, opts: EventOpts) {
.has("VIEW_CHANNEL")
)
return;
break;
//No break needed here, we need to call the listenEvent function below
case "GUILD_CREATE":
this.events[id] = await listenEvent(id, consumer, listenOpts);
break;
@ -193,16 +193,11 @@ async function consume(this: WebSocket, opts: EventOpts) {
break;
}
let aa = {
Send(this, {
op: OPCODES.Dispatch,
t: event,
d: data,
s: this.sequence++,
}
//TODO remove before PR merge
console.log(aa)
Send(this, aa);
});
opts.acknowledge?.();
}

View File

@ -84,27 +84,24 @@ export class ChannelService {
return
}
let channel_dto = null;
await emitEvent({
event: "CHANNEL_DELETE",
data: await DmChannelDTO.from(channel, [user_id]),
user_id: user_id
});
//If the owner leave we make the first recipient in the list the new owner
if (channel.owner_id === user_id) {
channel.owner_id = channel.recipients!.find(r => r.user_id !== user_id)!.user_id //Is there a criteria to choose the new owner?
channel_dto = await DmChannelDTO.from(channel, [user_id])
await emitEvent({
event: "CHANNEL_UPDATE",
data: channel_dto,
data: await DmChannelDTO.from(channel, [user_id]),
channel_id: channel.id
});
}
await channel.save()
await emitEvent({
event: "CHANNEL_DELETE",
data: channel_dto !== null ? channel_dto : await DmChannelDTO.from(channel, [user_id]),
user_id: user_id
});
await emitEvent({
event: "CHANNEL_RECIPIENT_REMOVE", data: {
channel_id: channel.id,

View File

@ -5,7 +5,6 @@ import { EVENT, Event } from "../interfaces";
const events = new EventEmitter();
export async function emitEvent(payload: Omit<Event, "created_at">) {
console.log(payload) //TODO remove before merge
const id = (payload.channel_id || payload.user_id || payload.guild_id) as string;
if (!id) return console.error("event doesn't contain any id", payload);