feat: add HTTP-accessible emit | broadcast | whisper methods;

- Closes #7
- Closes #13

example/worker/room.ts

@@ -35,12 +35,50 @@ export class Room extends Replica<Bindings> {
 	async receive(req: Request) {
 		console.log('[ HELLO ][receive] req.url', req.url);
 
-		let { pathname } = new URL(req.url);
+		let { pathname, searchParams } = new URL(req.url);
 
 		if (pathname === '/ws') {
 			return this.connect(req);
 		}
 
+		if (pathname === '/broadcast') {
+			await this.broadcast({
+				type: 'user:msg',
+				from: 'HTTP',
+				text: 'SENT VIA "/broadcast" HTTP route',
+				time: Date.now(),
+			});
+
+			return new Response('DONE');
+		}
+
+		if (pathname === '/whisper') {
+			let target = searchParams.get('target') || 'aaa';
+
+			await this.whisper(target, {
+				type: 'user:msg',
+				from: 'HTTP',
+				text: 'SENT VIA "/whisper" HTTP route',
+				time: Date.now(),
+				meta: 'whisper',
+				to: target,
+			});
+
+			return new Response('DONE');
+		}
+
+		if (pathname === '/emit') {
+			this.emit({
+				type: 'user:msg',
+				from: 'HTTP',
+				text: 'SENT VIA "/emit" HTTP route',
+				time: Date.now(),
+				meta: 'group'
+			});
+
+			return new Response('DONE');
+		}
+
 		// NOTE: can employ whatever routing logic
 		return new Response(`PATH: "${pathname}"`);
 	}

index.d.ts

@@ -92,6 +92,24 @@ export abstract class Replica<T extends Bindings> {
 	 */
 	connect(req: Request): Promise<Response>;
 
+	/**
+	 * Send a message (via HTTP) to WebSockets owned by the Replica
+	 * @NOTE This is the HTTP-accessible version of `Socket.emit`
+	 */
+	emit(msg: Message): void;
+
+	/**
+	 * Send a message (via HTTP) to ALL WebSockets within the CLUSTER.
+	 * @NOTE This is the HTTP-accessible version of `Socket.broadcast`
+	 */
+	broadcast(msg: Message): Promise<void>;
+
+	/**
+	 * Send a message (via HTTP) to a specific WebSocket target.
+	 * @NOTE This is the HTTP-accessible version of `Socket.whisper`
+	 */
+	whisper(target: string, msg: Message): Promise<void>;
+
 	/**
 	 * Respond to another Replica's gossip.
 	 * @NOTE Must return a JSON-serializable value.

src/replica.ts

@@ -30,6 +30,8 @@ export abstract class Replica<T extends ModuleWorker.Bindings> implements DOG.Re
 	readonly #parent: DurableObjectNamespace;
 	readonly #self: DurableObjectNamespace;
 
+	#gid?: string;
+
 	constructor(state: DurableObjectState, env: T) {
 		this.uid = state.id.toString();
 		this.#neighbors = new Set;
@@ -168,7 +170,7 @@ export abstract class Replica<T extends ModuleWorker.Bindings> implements DOG.Re
 		if (this.#neighbors.size < 1) return [];
 
 		let list = await this.#dispatch({
-			group: 'Q', // ignored
+			group: this.#gid!,
 			sender: this.uid, // this replica
 			route: ROUTES.GOSSIP,
 			body: msg == null ? msg : JSON.stringify(msg)
@@ -192,6 +194,7 @@ export abstract class Replica<T extends ModuleWorker.Bindings> implements DOG.Re
 		}
 
 		if (pathname === ROUTES.NEIGHBOR) {
+			this.#gid = this.#gid || gid; // save
 			// rid === HEADERS.NEIGHBORID
 			this.#neighbors.add(rid);
 			return new Response;
@@ -248,6 +251,18 @@ export abstract class Replica<T extends ModuleWorker.Bindings> implements DOG.Re
 		}
 	}
 
+	emit(msg: DOG.Message): void {
+		this.#emit(this.#gid!, msg, true);
+	}
+
+	broadcast(msg: DOG.Message): Promise<void> {
+		return this.#broadcast(this.#gid!, this.uid, msg, true);
+	}
+
+	whisper(target: string, msg: DOG.Message): Promise<void> {
+		return this.#whisper(this.#gid!, this.uid, target, msg);
+	}
+
 	/**
 	 * Share a message ONLY with this REPLICA's connections
 	 */