summaryrefslogtreecommitdiff
path: root/src/remote/activitypub/kernel/index.ts
diff options
context:
space:
mode:
authorMeiMei <30769358+mei23@users.noreply.github.com>2019-12-15 03:37:19 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2019-12-15 03:37:19 +0900
commit3e85aad80a882abc764c13a0fc40e3333bb61c4b (patch)
treec4ef1a407e5a714dda25cb907bc4d40acb89ec26 /src/remote/activitypub/kernel/index.ts
parentFix #5637 (#5638) (diff)
downloadsharkey-3e85aad80a882abc764c13a0fc40e3333bb61c4b.tar.gz
sharkey-3e85aad80a882abc764c13a0fc40e3333bb61c4b.tar.bz2
sharkey-3e85aad80a882abc764c13a0fc40e3333bb61c4b.zip
Implement Talk has read federation (#5636)
* Talk read * fix * 複数のRead ActivityはCollectionとして送るように * あ
Diffstat (limited to 'src/remote/activitypub/kernel/index.ts')
-rw-r--r--src/remote/activitypub/kernel/index.ts5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/remote/activitypub/kernel/index.ts b/src/remote/activitypub/kernel/index.ts
index c8298dc797..615edff88c 100644
--- a/src/remote/activitypub/kernel/index.ts
+++ b/src/remote/activitypub/kernel/index.ts
@@ -1,8 +1,9 @@
-import { IObject, isCreate, isDelete, isUpdate, isFollow, isAccept, isReject, isAdd, isRemove, isAnnounce, isLike, isUndo, isBlock, isCollectionOrOrderedCollection, isCollection } from '../type';
+import { IObject, isCreate, isDelete, isUpdate, isRead, isFollow, isAccept, isReject, isAdd, isRemove, isAnnounce, isLike, isUndo, isBlock, isCollectionOrOrderedCollection, isCollection } from '../type';
import { IRemoteUser } from '../../../models/entities/user';
import create from './create';
import performDeleteActivity from './delete';
import performUpdateActivity from './update';
+import { performReadActivity } from './read';
import follow from './follow';
import undo from './undo';
import like from './like';
@@ -41,6 +42,8 @@ async function performOneActivity(actor: IRemoteUser, activity: IObject): Promis
await performDeleteActivity(actor, activity);
} else if (isUpdate(activity)) {
await performUpdateActivity(actor, activity);
+ } else if (isRead(activity)) {
+ await performReadActivity(actor, activity);
} else if (isFollow(activity)) {
await follow(actor, activity);
} else if (isAccept(activity)) {