dandri/server
1
0
Fork 0
mirror of https://github.com/spacebarchat/server.git synced 2026-08-28 00:54:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

LazyRequest: support offload

Browse Source
This commit is contained in:
Rory&
2026-06-21 20:45:03 +02:00
parent 39bfd5050e
commit 1013bfd5b2
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/gateway/opcodes/LazyRequest.ts
+6 -2
View File
@@ -19,9 +19,9 @@
import murmur from "murmurhash-js/murmurhash3_gc";
import { getDatabase, Member, Role, Session, User, Channel } from "@spacebar/database";
import { arrayPartition, Stopwatch } from "@spacebar/extensions";
import { WebSocket, Payload, handlePresenceUpdate, OPCODES, Send } from "@spacebar/gateway";
import { WebSocket, Payload, handlePresenceUpdate, OPCODES, Send, handleOffloadedGatewayRequest } from "@spacebar/gateway";
import { LazyRequestSchema } from "@spacebar/schemas";
import { getPermission, listenEvent, Presence, Permissions, getMostRelevantSession } from "@spacebar/util";
import { getPermission, listenEvent, Presence, Permissions, getMostRelevantSession, Config } from "@spacebar/util";
import { check } from "./instanceOf";
import { start } from "node:repl";
@@ -158,6 +158,10 @@ export async function onLazyRequest(this: WebSocket, { d }: Payload) {
// noinspection JSUnusedLocalSymbols - TODO: implement typing/activities subscriptions
const { guild_id, typing, channels, activities, members } = d as LazyRequestSchema;
if (Config.get().offload.gateway.lazyRequestUrl !== null) {
return await handleOffloadedGatewayRequest(this, Config.get().offload.gateway.lazyRequestUrl!, d);
}
if (members) {
// Client has requested a PRESENCE_UPDATE for specific member