forked from FoundKeyGang/FoundKey
3ecb0ab161
* add .github/workflows/nodejs.yml * fix * GitHub Actions: Node.js 8.xはサポートしない * add .github/workflows/docker.yml * Dockerビルドをキャッシュするように * Run test in github actions * 同リポジトリ内からのプルリクだと無駄に二回走るのを抑制 * 6925c00のdocker.ymlへの適応忘れ * fix .circleci/misskey/test.yml * test実行時にDBとかredisとか動かすように * fix * fix tests (#5544) * fix test * fix compile errors * PATH引き継ぎでchild_process.spawn時のENOENTを修正 * サーバー起動処理を共通化 * fix coding style * fd=4をipcに使うように * fix port * fix * fix ws port * #4033 にテストケースを追従 * fix? * fix?? * fix * fix * fix * maybe fix * fix * node 10.xサポートしてなかった * 11.10じゃないとだめだった * fix * remove chart test * fix * chart test復活 * fix * 一回一回コネクションを閉じる * Revert "一回一回コネクションを閉じる" This reverts commit 56e35cf4f83070744c8dd852f1a7075011d88828. * 一回一回sync→dropしてるのをやめてみる * fix * fix * … * キャッシュを切ってみる * add ts to require target * omg fix * Revert "キャッシュを切ってみる" This reverts commit 88161c59d2ea769ddf87143ba4fd4660a06afdf2. * done呼び忘れ * 実際の文字数リミットと違ってたので対応 * テストケースがバグってたので修正 * Revert "一回一回sync→dropしてるのをやめてみる" This reverts commit a9e543ba2eef790ac7a14ae8799b898765748e35. * fix * fix * fix * fix? * fix * chartのconnectionを分離する * fix * fix * fix tsconfig? * Revert "fix tsconfig?" This reverts commit ba9269eaf65507ff97ec1dd2e27260fb2cf0510b. * fix * TS_NODE_FILES を scripts の方で指定 * Windowsェ * Circle CIの実行条件をmasterへのpushのみに Co-authored-by: syuilo <Syuilotan@yahoo.co.jp>
913 lines
21 KiB
TypeScript
913 lines
21 KiB
TypeScript
/*
|
|
* Tests of streaming API
|
|
*
|
|
* How to run the tests:
|
|
* > npx mocha test/streaming.ts --require ts-node/register
|
|
*
|
|
* To specify test:
|
|
* > npx mocha test/streaming.ts --require ts-node/register -g 'test name'
|
|
*
|
|
* If the tests not start, try set following enviroment variables:
|
|
* TS_NODE_FILES=true and TS_NODE_TRANSPILE_ONLY=true
|
|
* for more details, please see: https://github.com/TypeStrong/ts-node/issues/754
|
|
*/
|
|
|
|
process.env.NODE_ENV = 'test';
|
|
|
|
import * as assert from 'assert';
|
|
import * as childProcess from 'child_process';
|
|
import { connectStream, signup, request, post, launchServer } from './utils';
|
|
import { Following } from '../src/models/entities/following';
|
|
import { initDb } from '../src/db/postgre';
|
|
|
|
describe('Streaming', () => {
|
|
let p: childProcess.ChildProcess;
|
|
let Followings: any;
|
|
|
|
beforeEach(launchServer(g => p = g, async () => {
|
|
const connection = await initDb(true);
|
|
Followings = connection.getRepository(Following);
|
|
}));
|
|
|
|
afterEach(() => {
|
|
p.kill();
|
|
});
|
|
|
|
const follow = async (follower: any, followee: any) => {
|
|
await Followings.save({
|
|
id: 'a',
|
|
createdAt: new Date(),
|
|
followerId: follower.id,
|
|
followeeId: followee.id,
|
|
followerHost: follower.host,
|
|
followerInbox: null,
|
|
followerSharedInbox: null,
|
|
followeeHost: followee.host,
|
|
followeeInbox: null,
|
|
followeeSharedInbox: null
|
|
});
|
|
};
|
|
|
|
it('mention event', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
const ws = await connectStream(bob, 'main', ({ type, body }) => {
|
|
if (type == 'mention') {
|
|
assert.deepStrictEqual(body.userId, alice.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(alice, {
|
|
text: 'foo @bob bar'
|
|
});
|
|
}));
|
|
|
|
it('renote event', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
const bobNote = await post(bob, {
|
|
text: 'foo'
|
|
});
|
|
|
|
const ws = await connectStream(bob, 'main', ({ type, body }) => {
|
|
if (type == 'renote') {
|
|
assert.deepStrictEqual(body.renoteId, bobNote.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(alice, {
|
|
renoteId: bobNote.id
|
|
});
|
|
}));
|
|
|
|
describe('Home Timeline', () => {
|
|
it('自分の投稿が流れる', () => new Promise(async done => {
|
|
const post = {
|
|
text: 'foo'
|
|
};
|
|
|
|
const me = await signup();
|
|
|
|
const ws = await connectStream(me, 'homeTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.text, post.text);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
request('/notes/create', post, me);
|
|
}));
|
|
|
|
it('フォローしているユーザーの投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await request('/following/create', {
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
const ws = await connectStream(alice, 'homeTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('フォローしていないユーザーの投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'homeTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('フォローしているユーザーのダイレクト投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await request('/following/create', {
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
const ws = await connectStream(alice, 'homeTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
assert.deepStrictEqual(body.text, 'foo');
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
// Bob が Alice 宛てのダイレクト投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'specified',
|
|
visibleUserIds: [alice.id]
|
|
});
|
|
}));
|
|
|
|
it('フォローしているユーザーでも自分が指定されていないダイレクト投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
const carol = await signup({ username: 'carol' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await request('/following/create', {
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'homeTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
// Bob が Carol 宛てのダイレクト投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'specified',
|
|
visibleUserIds: [carol.id]
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
});
|
|
|
|
describe('Local Timeline', () => {
|
|
it('自分の投稿が流れる', () => new Promise(async done => {
|
|
const me = await signup();
|
|
|
|
const ws = await connectStream(me, 'localTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, me.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(me, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('フォローしていないローカルユーザーの投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
const ws = await connectStream(alice, 'localTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('リモートユーザーの投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob', host: 'example.com' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'localTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('フォローしてたとしてもリモートユーザーの投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob', host: 'example.com' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await request('/following/create', {
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'localTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('ホーム指定の投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'localTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
// ホーム指定
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'home'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('フォローしているローカルユーザーのダイレクト投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await request('/following/create', {
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
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();
|
|
}
|
|
});
|
|
|
|
// Bob が Alice 宛てのダイレクト投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'specified',
|
|
visibleUserIds: [alice.id]
|
|
});
|
|
}));
|
|
|
|
it('フォローしていないローカルユーザーのフォロワー宛て投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'localTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
// フォロワー宛て投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'followers'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
});
|
|
|
|
describe('Hybrid Timeline', () => {
|
|
it('自分の投稿が流れる', () => new Promise(async done => {
|
|
const me = await signup();
|
|
|
|
const ws = await connectStream(me, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, me.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(me, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('フォローしていないローカルユーザーの投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
const ws = await connectStream(alice, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('フォローしているリモートユーザーの投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob', host: 'example.com' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await follow(alice, bob);
|
|
|
|
const ws = await connectStream(alice, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('フォローしていないリモートユーザーの投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob', host: 'example.com' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('フォローしているユーザーのダイレクト投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await request('/following/create', {
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
const ws = await connectStream(alice, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
assert.deepStrictEqual(body.text, 'foo');
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
// Bob が Alice 宛てのダイレクト投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'specified',
|
|
visibleUserIds: [alice.id]
|
|
});
|
|
}));
|
|
|
|
it('フォローしているユーザーのホーム投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// Alice が Bob をフォロー
|
|
await request('/following/create', {
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
const ws = await connectStream(alice, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
assert.deepStrictEqual(body.text, 'foo');
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
// ホーム投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'home'
|
|
});
|
|
}));
|
|
|
|
it('フォローしていないローカルユーザーのホーム投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
// ホーム投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'home'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('フォローしていないローカルユーザーのフォロワー宛て投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'hybridTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
// フォロワー宛て投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'followers'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
});
|
|
|
|
describe('Global Timeline', () => {
|
|
it('フォローしていないローカルユーザーの投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
const ws = await connectStream(alice, 'globalTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('フォローしていないリモートユーザーの投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob', host: 'example.com' });
|
|
|
|
const ws = await connectStream(alice, 'globalTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('ホーム投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'globalTimeline', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
});
|
|
|
|
// ホーム投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'home'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
});
|
|
|
|
describe('UserList Timeline', () => {
|
|
it('リストに入れているユーザーの投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// リスト作成
|
|
const list = await request('/users/lists/create', {
|
|
name: 'my list'
|
|
}, alice).then(x => x.body);
|
|
|
|
// Alice が Bob をリスイン
|
|
await request('/users/lists/push', {
|
|
listId: list.id,
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
const ws = await connectStream(alice, 'userList', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
ws.close();
|
|
done();
|
|
}
|
|
}, {
|
|
listId: list.id
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
}));
|
|
|
|
it('リストに入れていないユーザーの投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// リスト作成
|
|
const list = await request('/users/lists/create', {
|
|
name: 'my list'
|
|
}, alice).then(x => x.body);
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'userList', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
}, {
|
|
listId: list.id
|
|
});
|
|
|
|
post(bob, {
|
|
text: 'foo'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
// #4471
|
|
it('リストに入れているユーザーのダイレクト投稿が流れる', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// リスト作成
|
|
const list = await request('/users/lists/create', {
|
|
name: 'my list'
|
|
}, alice).then(x => x.body);
|
|
|
|
// Alice が Bob をリスイン
|
|
await request('/users/lists/push', {
|
|
listId: list.id,
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
const ws = await connectStream(alice, 'userList', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.userId, bob.id);
|
|
assert.deepStrictEqual(body.text, 'foo');
|
|
ws.close();
|
|
done();
|
|
}
|
|
}, {
|
|
listId: list.id
|
|
});
|
|
|
|
// Bob が Alice 宛てのダイレクト投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'specified',
|
|
visibleUserIds: [alice.id]
|
|
});
|
|
}));
|
|
|
|
// #4335
|
|
it('リストに入れているがフォローはしてないユーザーのフォロワー宛て投稿は流れない', () => new Promise(async done => {
|
|
const alice = await signup({ username: 'alice' });
|
|
const bob = await signup({ username: 'bob' });
|
|
|
|
// リスト作成
|
|
const list = await request('/users/lists/create', {
|
|
name: 'my list'
|
|
}, alice).then(x => x.body);
|
|
|
|
// Alice が Bob をリスイン
|
|
await request('/users/lists/push', {
|
|
listId: list.id,
|
|
userId: bob.id
|
|
}, alice);
|
|
|
|
let fired = false;
|
|
|
|
const ws = await connectStream(alice, 'userList', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
fired = true;
|
|
}
|
|
}, {
|
|
listId: list.id
|
|
});
|
|
|
|
// フォロワー宛て投稿
|
|
post(bob, {
|
|
text: 'foo',
|
|
visibility: 'followers'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fired, false);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
});
|
|
|
|
describe('Hashtag Timeline', () => {
|
|
it('指定したハッシュタグの投稿が流れる', () => new Promise(async done => {
|
|
const me = await signup();
|
|
|
|
const ws = await connectStream(me, 'hashtag', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
assert.deepStrictEqual(body.text, '#foo');
|
|
ws.close();
|
|
done();
|
|
}
|
|
}, {
|
|
q: [
|
|
['foo']
|
|
]
|
|
});
|
|
|
|
post(me, {
|
|
text: '#foo'
|
|
});
|
|
}));
|
|
|
|
it('指定したハッシュタグの投稿が流れる (AND)', () => new Promise(async done => {
|
|
const me = await signup();
|
|
|
|
let fooCount = 0;
|
|
let barCount = 0;
|
|
let fooBarCount = 0;
|
|
|
|
const ws = await connectStream(me, 'hashtag', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
if (body.text === '#foo') fooCount++;
|
|
if (body.text === '#bar') barCount++;
|
|
if (body.text === '#foo #bar') fooBarCount++;
|
|
}
|
|
}, {
|
|
q: [
|
|
['foo', 'bar']
|
|
]
|
|
});
|
|
|
|
post(me, {
|
|
text: '#foo'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#bar'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#foo #bar'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fooCount, 0);
|
|
assert.strictEqual(barCount, 0);
|
|
assert.strictEqual(fooBarCount, 1);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('指定したハッシュタグの投稿が流れる (OR)', () => new Promise(async done => {
|
|
const me = await signup();
|
|
|
|
let fooCount = 0;
|
|
let barCount = 0;
|
|
let fooBarCount = 0;
|
|
let piyoCount = 0;
|
|
|
|
const ws = await connectStream(me, 'hashtag', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
if (body.text === '#foo') fooCount++;
|
|
if (body.text === '#bar') barCount++;
|
|
if (body.text === '#foo #bar') fooBarCount++;
|
|
if (body.text === '#piyo') piyoCount++;
|
|
}
|
|
}, {
|
|
q: [
|
|
['foo'],
|
|
['bar']
|
|
]
|
|
});
|
|
|
|
post(me, {
|
|
text: '#foo'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#bar'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#foo #bar'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#piyo'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fooCount, 1);
|
|
assert.strictEqual(barCount, 1);
|
|
assert.strictEqual(fooBarCount, 1);
|
|
assert.strictEqual(piyoCount, 0);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
|
|
it('指定したハッシュタグの投稿が流れる (AND + OR)', () => new Promise(async done => {
|
|
const me = await signup();
|
|
|
|
let fooCount = 0;
|
|
let barCount = 0;
|
|
let fooBarCount = 0;
|
|
let piyoCount = 0;
|
|
let waaaCount = 0;
|
|
|
|
const ws = await connectStream(me, 'hashtag', ({ type, body }) => {
|
|
if (type == 'note') {
|
|
if (body.text === '#foo') fooCount++;
|
|
if (body.text === '#bar') barCount++;
|
|
if (body.text === '#foo #bar') fooBarCount++;
|
|
if (body.text === '#piyo') piyoCount++;
|
|
if (body.text === '#waaa') waaaCount++;
|
|
}
|
|
}, {
|
|
q: [
|
|
['foo', 'bar'],
|
|
['piyo']
|
|
]
|
|
});
|
|
|
|
post(me, {
|
|
text: '#foo'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#bar'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#foo #bar'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#piyo'
|
|
});
|
|
|
|
post(me, {
|
|
text: '#waaa'
|
|
});
|
|
|
|
setTimeout(() => {
|
|
assert.strictEqual(fooCount, 0);
|
|
assert.strictEqual(barCount, 0);
|
|
assert.strictEqual(fooBarCount, 1);
|
|
assert.strictEqual(piyoCount, 1);
|
|
assert.strictEqual(waaaCount, 0);
|
|
ws.close();
|
|
done();
|
|
}, 3000);
|
|
}));
|
|
});
|
|
});
|