diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2021-03-21 15:14:03 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2021-03-21 15:14:03 +0900 |
| commit | 8050352ad88798be222f735a3217367acaee277f (patch) | |
| tree | 812ca46b632f91a49d0f749e53221d93be0ab5dc /src/services/blocking | |
| parent | add note (diff) | |
| download | misskey-8050352ad88798be222f735a3217367acaee277f.tar.gz misskey-8050352ad88798be222f735a3217367acaee277f.tar.bz2 misskey-8050352ad88798be222f735a3217367acaee277f.zip | |
perf: 各ストリーミング接続ごとにポーリングしないように
Diffstat (limited to 'src/services/blocking')
| -rw-r--r-- | src/services/blocking/create.ts | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/src/services/blocking/create.ts b/src/services/blocking/create.ts index def4f33585..4f0238db91 100644 --- a/src/services/blocking/create.ts +++ b/src/services/blocking/create.ts @@ -1,4 +1,4 @@ -import { publishMainStream } from '../stream'; +import { publishMainStream, publishUserEvent } from '../stream'; import { renderActivity } from '../../remote/activitypub/renderer'; import renderFollow from '../../remote/activitypub/renderer/follow'; import renderUndo from '../../remote/activitypub/renderer/undo'; @@ -55,7 +55,10 @@ async function cancelRequest(follower: User, followee: User) { if (Users.isLocalUser(follower)) { Users.pack(followee, follower, { detail: true - }).then(packed => publishMainStream(follower.id, 'unfollow', packed)); + }).then(packed => { + publishUserEvent(follower.id, 'unfollow', packed); + publishMainStream(follower.id, 'unfollow', packed); + }); } // リモートにフォローリクエストをしていたらUndoFollow送信 @@ -97,7 +100,10 @@ async function unFollow(follower: User, followee: User) { if (Users.isLocalUser(follower)) { Users.pack(followee, follower, { detail: true - }).then(packed => publishMainStream(follower.id, 'unfollow', packed)); + }).then(packed => { + publishUserEvent(follower.id, 'unfollow', packed); + publishMainStream(follower.id, 'unfollow', packed); + }); } // リモートにフォローをしていたらUndoFollow送信 |