diff --git a/gateway/src/listener/listener.ts b/gateway/src/listener/listener.ts
index e5630a43..7152c74b 100644
--- a/gateway/src/listener/listener.ts
+++ b/gateway/src/listener/listener.ts
@@ -26,16 +26,16 @@ import { Recipient } from "@fosscord/util";
// TODO: use already queried guilds/channels of Identify and don't fetch them again
export async function setupListener(this: WebSocket) {
- const members = await Member.find({ id: this.user_id });
- const guild_ids = members.map((x) => x.guild_id);
- const user = await User.findOneOrFail({ id: this.user_id });
+ const members = await Member.find({
+ where: { id: this.user_id },
+ relations: ["guild", "guild.channels"],
+ });
+ const guilds = members.map((x) => x.guild);
const recipients = await Recipient.find({
where: { user_id: this.user_id },
relations: ["channel"],
});
- const channels = await Channel.find({ guild_id: In(guild_ids) });
const dm_channels = recipients.map((x) => x.channel);
- const guild_channels = channels.filter((x) => x.guild_id);
const opts: { acknowledge: boolean; channel?: AMQChannel } = {
acknowledge: true,
@@ -54,18 +54,20 @@ export async function setupListener(this: WebSocket) {
this.events[channel.id] = await listenEvent(channel.id, consumer, opts);
}
- for (const guild of guild_ids) {
+ for (const guild of guilds) {
// contains guild and dm channels
- getPermission(this.user_id, guild)
+ getPermission(this.user_id, guild.id)
.then(async (x) => {
- this.permissions[guild] = x;
+ this.permissions[guild.id] = x;
this.listeners;
- this.events[guild] = await listenEvent(guild, consumer, opts);
+ this.events[guild.id] = await listenEvent(
+ guild.id,
+ consumer,
+ opts
+ );
- for (const channel of guild_channels.filter(
- (c) => c.guild_id === guild
- )) {
+ for (const channel of guild.channels) {
if (
x
.overwriteChannel(channel.permission_overwrites)
|
