diff options
| -rw-r--r-- | test/streaming.ts | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/test/streaming.ts b/test/streaming.ts index 4e2337f33b..2095c94efc 100644 --- a/test/streaming.ts +++ b/test/streaming.ts @@ -93,6 +93,27 @@ describe('Streaming', () => { server.close(); }); + test('Connection#send', async () => { + const server = new WS('wss://misskey.test/streaming'); + const stream = new Stream('https://misskey.test', { token: 'TOKEN' }); + + const messaging = stream.useChannel('messaging', { otherparty: 'aaa' }); + messaging.send('read', { id: 'aaa' }); + + await server.connected; + const connectMsg = JSON.parse(await server.nextMessage as string); + const channelId = connectMsg.body.id; + const msg = JSON.parse(await server.nextMessage as string); + + expect(msg.type).toEqual('ch'); + expect(msg.body.id).toEqual(channelId); + expect(msg.body.type).toEqual('read'); + expect(msg.body.body).toEqual({ id: 'aaa' }); + + stream.close(); + server.close(); + }); + test('Connection#dispose', async () => { const server = new WS('wss://misskey.test/streaming'); const stream = new Stream('https://misskey.test', { token: 'TOKEN' }); |