diff --git a/test/streaming.ts b/test/streaming.ts index cb962cfb3d..23d01757d0 100644 --- a/test/streaming.ts +++ b/test/streaming.ts @@ -318,7 +318,7 @@ describe('Streaming', () => { }, 3000); })); - it('フォローしているローカルユーザーのダイレクト投稿が流れる', () => new Promise(async done => { + it('フォローしているローカルユーザーのダイレクト投稿は流れない', () => new Promise(async done => { const alice = await signup({ username: 'alice' }); const bob = await signup({ username: 'bob' }); @@ -327,12 +327,11 @@ describe('Streaming', () => { userId: bob.id }, alice); + let fired = false; + const ws = await connectStream(alice, 'localTimeline', ({ type, body }) => { if (type == 'note') { - assert.deepStrictEqual(body.userId, bob.id); - assert.deepStrictEqual(body.text, 'foo'); - ws.close(); - done(); + fired = true; } }); @@ -342,6 +341,12 @@ describe('Streaming', () => { visibility: 'specified', visibleUserIds: [alice.id] }); + + setTimeout(() => { + assert.strictEqual(fired, false); + ws.close(); + done(); + }, 3000); })); it('フォローしていないローカルユーザーのフォロワー宛て投稿は流れない', () => new Promise(async done => {