From 783453897f04869c213dfa7aef7e8d33490ff47a Mon Sep 17 00:00:00 2001 From: Akihiko Odaki Date: Wed, 4 Apr 2018 19:51:41 +0900 Subject: Allow to undo Create activity --- src/remote/activitypub/act/delete/index.ts | 24 ------------------------ src/remote/activitypub/act/delete/post.ts | 10 ---------- 2 files changed, 34 deletions(-) delete mode 100644 src/remote/activitypub/act/delete/index.ts delete mode 100644 src/remote/activitypub/act/delete/post.ts (limited to 'src/remote/activitypub/act/delete') diff --git a/src/remote/activitypub/act/delete/index.ts b/src/remote/activitypub/act/delete/index.ts deleted file mode 100644 index eabf9a0436..0000000000 --- a/src/remote/activitypub/act/delete/index.ts +++ /dev/null @@ -1,24 +0,0 @@ -import create from '../../create'; -import deletePost from './post'; - -export default async (resolver, actor, activity) => { - if ('actor' in activity && actor.account.uri !== activity.actor) { - throw new Error(); - } - - const results = await create(resolver, actor, activity.object); - - await Promise.all(results.map(async promisedResult => { - const result = await promisedResult; - if (result === null) { - return; - } - - switch (result.object.$ref) { - case 'posts': - await deletePost(result.object); - } - })); - - return null; -}; diff --git a/src/remote/activitypub/act/delete/post.ts b/src/remote/activitypub/act/delete/post.ts deleted file mode 100644 index 1b748afe82..0000000000 --- a/src/remote/activitypub/act/delete/post.ts +++ /dev/null @@ -1,10 +0,0 @@ -import Post from '../../../../models/post'; -import queue from '../../../../queue'; - -export default ({ $id }) => Promise.all([ - Post.findOneAndDelete({ _id: $id }), - new Promise((resolve, reject) => queue.create('db', { - type: 'deletePostDependents', - id: $id - }).delay(65536).save(error => error ? reject(error) : resolve())) -]); -- cgit v1.2.3-freya