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

refactor: nicer

Browse Source
This commit is contained in:
cha0s 2022-03-23 02:31:46 -05:00
parent 2511e90b70
commit c401951949
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -24,26 +24,16 @@ export default class Socket {
this.on('packet', acceptor(this)); this.on('packet', acceptor(this));
} }
static send(flecks, socket, packetOrDehydrated, method) { send(packetOrDehydrated) {
const packet = normalize(flecks, packetOrDehydrated); const packet = normalize(this.flecks, packetOrDehydrated);
const {constructor: Packet} = packet; const {constructor: Packet} = packet;
debug('sending packet %s(%j)', Packet.type, packet.data); debug('sending packet %s(%j)', Packet.type, packet.data);
try { try {
return socket[method](Packet.id, Packet.encode(packet.data)); return this.socket.emitPromise(Packet.id, Packet.encode(packet.data));
} }
catch (error) { catch (error) {
throw new Error(`${error.message}, data: ${JSON.stringify(packet.data, null, 2)}`); throw new Error(`${error.message}, data: ${JSON.stringify(packet.data, null, 2)}`);
} }
} }
send(packet) {
return this.constructor.send(this.flecks, this.socket, packet, 'emitPromise');
}
to(room) {
return {
send: (packet) => this.constructor.send(this.flecks, this.socket.to(room), packet, 'emit'),
};
}
} }