mirror of
https://github.com/socketio/socket.io.git
synced 2026-01-15 01:48:01 -05:00
Usage:
```js
interface SocketData {
name: string;
age: number;
}
const io = new Server<ClientToServerEvents, ServerToClientEvents, InterServerEvents, SocketData>();
io.on("connection", (socket) => {
socket.data.name = "john";
socket.data.age = 42;
});
```
68 lines
1.8 KiB
TypeScript
68 lines
1.8 KiB
TypeScript
import { Namespace } from "./namespace";
|
|
import type { Server } from "./index";
|
|
import type {
|
|
EventParams,
|
|
EventNames,
|
|
EventsMap,
|
|
DefaultEventsMap,
|
|
} from "./typed-events";
|
|
import type { BroadcastOptions } from "socket.io-adapter";
|
|
|
|
export class ParentNamespace<
|
|
ListenEvents extends EventsMap = DefaultEventsMap,
|
|
EmitEvents extends EventsMap = ListenEvents,
|
|
ServerSideEvents extends EventsMap = DefaultEventsMap,
|
|
SocketData = any
|
|
> extends Namespace<ListenEvents, EmitEvents, ServerSideEvents, SocketData> {
|
|
private static count: number = 0;
|
|
private children: Set<
|
|
Namespace<ListenEvents, EmitEvents, ServerSideEvents, SocketData>
|
|
> = new Set();
|
|
|
|
constructor(
|
|
server: Server<ListenEvents, EmitEvents, ServerSideEvents, SocketData>
|
|
) {
|
|
super(server, "/_" + ParentNamespace.count++);
|
|
}
|
|
|
|
/**
|
|
* @private
|
|
*/
|
|
_initAdapter(): void {
|
|
const broadcast = (packet: any, opts: BroadcastOptions) => {
|
|
this.children.forEach((nsp) => {
|
|
nsp.adapter.broadcast(packet, opts);
|
|
});
|
|
};
|
|
// @ts-ignore FIXME is there a way to declare an inner class in TypeScript?
|
|
this.adapter = { broadcast };
|
|
}
|
|
|
|
public emit<Ev extends EventNames<EmitEvents>>(
|
|
ev: Ev,
|
|
...args: EventParams<EmitEvents, Ev>
|
|
): boolean {
|
|
this.children.forEach((nsp) => {
|
|
nsp.emit(ev, ...args);
|
|
});
|
|
|
|
return true;
|
|
}
|
|
|
|
createChild(
|
|
name: string
|
|
): Namespace<ListenEvents, EmitEvents, ServerSideEvents, SocketData> {
|
|
const namespace = new Namespace(this.server, name);
|
|
namespace._fns = this._fns.slice(0);
|
|
this.listeners("connect").forEach((listener) =>
|
|
namespace.on("connect", listener)
|
|
);
|
|
this.listeners("connection").forEach((listener) =>
|
|
namespace.on("connection", listener)
|
|
);
|
|
this.children.add(namespace);
|
|
this.server._nsps.set(name, namespace);
|
|
return namespace;
|
|
}
|
|
}
|