mirror of
https://github.com/socketio/socket.io.git
synced 2026-01-13 08:57:59 -05:00
ae8dd88995
Note: this issue has existed since Socket.IO v1.0 (see [1]), because
the `deconstructPacket()` method also mutates its input argument.
This also explains why some adapters (like [2]) need to use
`process.nextTick()` when extending the `broadcast()` method, because
`Adapter.broadcast()` calls `Encoder.encode()` ([3]).
Related:
- https://github.com/socketio/socket.io/issues/4374
- https://github.com/socketio/socket.io-mongo-adapter/issues/10
[1]: 299849b002
[2]: https://github.com/socketio/socket.io-postgres-adapter/blob/0.3.0/lib/index.ts#L587-L590
[3]: https://github.com/socketio/socket.io-adapter/blob/2.4.0/lib/index.ts#L148
36 lines
866 B
JavaScript
36 lines
866 B
JavaScript
const parser = require("..");
|
|
const expect = require("expect.js");
|
|
const encoder = new parser.Encoder();
|
|
|
|
// tests encoding and decoding a single packet
|
|
module.exports.test = (obj) => {
|
|
return new Promise((resolve) => {
|
|
const encodedPackets = encoder.encode(obj);
|
|
|
|
const decoder = new parser.Decoder();
|
|
decoder.on("decoded", (packet) => {
|
|
expect(packet).to.eql(obj);
|
|
resolve();
|
|
});
|
|
|
|
decoder.add(encodedPackets[0]);
|
|
});
|
|
};
|
|
|
|
// tests encoding of binary packets
|
|
module.exports.test_bin = (obj) => {
|
|
return new Promise((resolve) => {
|
|
const encodedPackets = encoder.encode(obj);
|
|
|
|
const decoder = new parser.Decoder();
|
|
decoder.on("decoded", (packet) => {
|
|
expect(obj).to.eql(packet);
|
|
resolve();
|
|
});
|
|
|
|
for (let i = 0; i < encodedPackets.length; i++) {
|
|
decoder.add(encodedPackets[i]);
|
|
}
|
|
});
|
|
};
|