diff --git a/gateway/src/opcodes/LazyRequest.ts b/gateway/src/opcodes/LazyRequest.ts
deleted file mode 100644
index 7503ee61..00000000
--- a/gateway/src/opcodes/LazyRequest.ts
+++ /dev/null
@@ -1,175 +0,0 @@
-import { getPermission, listenEvent, Member, Role } from "@fosscord/util";
-import { LazyRequest } from "../schema/LazyRequest";
-import { Send } from "../util/Send";
-import { OPCODES } from "../util/Constants";
-import { WebSocket, Payload, handlePresenceUpdate } from "@fosscord/gateway";
-import { check } from "./instanceOf";
-import "missing-native-js-functions";
-import { getRepository } from "typeorm";
-import "missing-native-js-functions";
-
-// TODO: only show roles/members that have access to this channel
-// TODO: config: to list all members (even those who are offline) sorted by role, or just those who are online
-// TODO: rewrite typeorm
-
-async function getMembers(guild_id: string, range: [number, number]) {
- if (!Array.isArray(range) || range.length !== 2) {
- throw new Error("range is not a valid array");
- }
- // TODO: wait for typeorm to implement ordering for .find queries https://github.com/typeorm/typeorm/issues/2620
-
- let members = await getRepository(Member)
- .createQueryBuilder("member")
- .where("member.guild_id = :guild_id", { guild_id })
- .leftJoinAndSelect("member.roles", "role")
- .leftJoinAndSelect("member.user", "user")
- .leftJoinAndSelect("user.sessions", "session")
- .addSelect(
- "CASE WHEN session.status = 'offline' THEN 0 ELSE 1 END",
- "_status"
- )
- .orderBy("role.position", "DESC")
- .addOrderBy("_status", "DESC")
- .addOrderBy("user.username", "ASC")
- .offset(Number(range[0]) || 0)
- .limit(Number(range[1]) || 100)
- .getMany();
-
- const groups = [] as any[];
- const items = [];
- const member_roles = members
- .map((m) => m.roles)
- .flat()
- .unique((r: Role) => r.id);
-
- const offlineItems = [];
-
- for (const role of member_roles) {
- // @ts-ignore
- const [role_members, other_members] = partition(members, (m: Member) =>
- m.roles.find((r) => r.id === role.id)
- );
- const group = {
- count: role_members.length,
- id: role.id === guild_id ? "online" : role.id,
- };
-
- items.push({ group });
- groups.push(group);
-
- for (const member of role_members) {
- const roles = member.roles
- .filter((x: Role) => x.id !== guild_id)
- .map((x: Role) => x.id);
-
- const session = member.user.sessions.first();
-
- // TODO: properly mock/hide offline/invisible status
- const item = {
- member: {
- ...member,
- roles,
- user: { ...member.user, sessions: undefined },
- presence: {
- ...session,
- activities: session?.activities || [],
- user: { id: member.user.id },
- },
- },
- }
-
- if (!member?.user?.sessions || !member.user.sessions.length) {
- offlineItems.push(item);
- group.count--;
- continue;
- }
-
- items.push(item);
- }
- members = other_members;
- }
-
- if (offlineItems.length) {
- const group = {
- count: offlineItems.length,
- id: "offline",
- };
- items.push({ group });
- groups.push(group);
-
- items.push(...offlineItems);
- }
-
- return {
- items,
- groups,
- range,
- members: items.map((x) => 'member' in x ? x.member : undefined).filter(x => !!x),
- };
-}
-
-export async function onLazyRequest(this: WebSocket, { d }: Payload) {
- // TODO: check data
- check.call(this, LazyRequest, d);
- const { guild_id, typing, channels, activities } = d as LazyRequest;
-
- const channel_id = Object.keys(channels || {}).first();
- if (!channel_id) return;
-
- const permissions = await getPermission(this.user_id, guild_id, channel_id);
- permissions.hasThrow("VIEW_CHANNEL");
-
- const ranges = channels![channel_id];
- if (!Array.isArray(ranges)) throw new Error("Not a valid Array");
-
- const member_count = await Member.count({ guild_id });
- const ops = await Promise.all(ranges.map((x) => getMembers(guild_id, x)));
-
- // TODO: unsubscribe member_events that are not in op.members
-
- ops.forEach((op) => {
- op.members.forEach(async (member) => {
- if (this.events[member.user.id]) return; // already subscribed as friend
- if (this.member_events[member.user.id]) return; // already subscribed in member list
- this.member_events[member.user.id] = await listenEvent(
- member.user.id,
- handlePresenceUpdate.bind(this),
- this.listen_options
- );
- });
- });
-
- return Send(this, {
- op: OPCODES.Dispatch,
- s: this.sequence++,
- t: "GUILD_MEMBER_LIST_UPDATE",
- d: {
- ops: ops.map((x) => ({
- items: x.items,
- op: "SYNC",
- range: x.range,
- })),
- online_count: member_count,
- member_count,
- id: "everyone",
- guild_id,
- groups: ops
- .map((x) => x.groups)
- .flat()
- .unique(),
- },
- });
-}
-
-function partition<T>(array: T[], isValid: Function) {
- // @ts-ignore
- return array.reduce(
- // @ts-ignore
- ([pass, fail], elem) => {
- return isValid(elem)
- ? [[...pass, elem], fail]
- : [pass, [...fail, elem]];
- },
- [[], []]
- );
-}
|
