Mass updates

This commit is contained in:
2026-01-05 11:33:32 +01:00
parent 32b6cf4af7
commit 04534b2530
36 changed files with 1886 additions and 12036 deletions

View File

@@ -1,5 +1,4 @@
import type { SocketMessage } from "#shared/websocket.util";
import type { User } from "~/types/auth";
export default defineWebSocketHandler({
message(peer, message) {
@@ -31,14 +30,11 @@ export default defineWebSocketHandler({
const topic = `campaigns/${id}`;
peer.subscribe(topic);
peer.publish(topic, { type: 'status', data: [{ user: (peer.context.user as User).id, status: true }] });
peer.send({ type: 'status', data: peer.peers.values().filter(e => e.topics.has(topic)).map(e => ({ user: (e.context.user as User).id, status: true })).toArray() })
},
close(peer, details) {
const id = new URL(peer.request.url).pathname.split('/').slice(-1)[0];
if(!id) return peer.close();
peer.publish(`campaigns/${id}`, { type: 'status', data: [{ user: (peer.context.user as User).id, status: false }] });
peer.unsubscribe(`campaigns/${id}`);
}
});