Dekescordes/spacebar
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

subscribe clients to member events when they lazy request members

Browse Source
This commit is contained in:
Madeline 2023-01-30 20:19:24 +11:00
parent ac51849f28
commit d4d1ab181e
1 changed files with 23 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/gateway/opcodes/LazyRequest.ts
View File

@ -197,6 +197,17 @@ async function getMembers(guild_id: string, range: [number, number]) {
}; };
} }
async function subscribeToMemberEvents(this: WebSocket, user_id: string) {
if (this.events[user_id]) return false; // already subscribed as friend
if (this.member_events[user_id]) return false; // already subscribed in member list
this.member_events[user_id] = await listenEvent(
user_id,
handlePresenceUpdate.bind(this),
this.listen_options,
);
return true;
}
export async function onLazyRequest(this: WebSocket, { d }: Payload) { export async function onLazyRequest(this: WebSocket, { d }: Payload) {
// TODO: check data // TODO: check data
check.call(this, LazyRequestSchema, d); check.call(this, LazyRequestSchema, d);
@ -209,6 +220,16 @@ export async function onLazyRequest(this: WebSocket, { d }: Payload) {
await Promise.all([ await Promise.all([
members.map(async (x) => { members.map(async (x) => {
if (!x) return;
const didSubscribe = await subscribeToMemberEvents.call(
this,
x,
);
if (!didSubscribe) return;
// if we didn't subscribe just now, this is a new subscription
// and we should send a PRESENCE_UPDATE immediately
const sessions = await Session.find({ where: { user_id: x } }); const sessions = await Session.find({ where: { user_id: x } });
const session = getMostRelevantSession(sessions); const session = getMostRelevantSession(sessions);
// eslint-disable-next-line @typescript-eslint/ban-ts-comment // eslint-disable-next-line @typescript-eslint/ban-ts-comment
@ -251,14 +272,8 @@ export async function onLazyRequest(this: WebSocket, { d }: Payload) {
ops.forEach((op) => { ops.forEach((op) => {
op.members.forEach(async (member) => { op.members.forEach(async (member) => {
if (!member) return; if (!member?.user.id) return;
if (this.events[member.user.id]) return; // already subscribed as friend return subscribeToMemberEvents.call(this, member.user.id);
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,
);
}); });
}); });