cha0s/latus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: promises

Browse Source
This commit is contained in:
cha0s 2020-12-09 22:07:00 -06:00
parent d4b8af601d
commit a1ba60d9c6
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
packages/socket/src/client/socket.js
View File

@ -94,22 +94,22 @@ export default class SocketClient extends decorate(Class) {
return this.socket ? this.socket.id : undefined; return this.socket ? this.socket.id : undefined;
} }
static send(latus, socket, packetOrDehydrated) { static send(latus, socket, packetOrDehydrated, method) {
const packet = Array.isArray(packetOrDehydrated) const packet = Array.isArray(packetOrDehydrated)
? this.hydrate(latus, packetOrDehydrated) ? this.hydrate(latus, packetOrDehydrated)
: packetOrDehydrated; : packetOrDehydrated;
debug('sending packet %o', packet); debug('sending packet %o', packet);
const {id} = packet.constructor; const {id} = packet.constructor;
return socket.emitPromise(id, packet.data); return socket[method](id, packet.data);
} }
send(packet) { send(packet) {
return this.constructor.send(this.latus, this.socket, packet); return this.constructor.send(this.latus, this.socket, packet, 'emitPromise');
} }
to(room) { to(room) {
return { return {
send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet), send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet, 'emit'),
}; };
} }

8
packages/socket/src/socket.js
View File

@ -72,22 +72,22 @@ export default class ServerSocket extends decorate(Class) {
return this.socket.rooms; return this.socket.rooms;
} }
static send(latus, socket, packetOrDehydrated) { static send(latus, socket, packetOrDehydrated, method) {
const packet = Array.isArray(packetOrDehydrated) const packet = Array.isArray(packetOrDehydrated)
? this.hydrate(latus, packetOrDehydrated) ? this.hydrate(latus, packetOrDehydrated)
: packetOrDehydrated; : packetOrDehydrated;
debug('sending packet %s(%o)', packet.constructor.name, packet.data); debug('sending packet %s(%o)', packet.constructor.name, packet.data);
const {id} = packet.constructor; const {id} = packet.constructor;
return socket.emitPromise(id, packet.data); return socket[method](id, packet.data);
} }
send(packet) { send(packet) {
return this.constructor.send(this.latus, this.socket, packet); return this.constructor.send(this.latus, this.socket, packet, 'emitPromise');
} }
to(room) { to(room) {
return { return {
send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet), send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet, 'emit'),
}; };
} }