diff options
| author | Akihiko Odaki <nekomanma@pixiv.co.jp> | 2018-04-04 19:51:41 +0900 |
|---|---|---|
| committer | Akihiko Odaki <nekomanma@pixiv.co.jp> | 2018-04-04 19:51:41 +0900 |
| commit | 783453897f04869c213dfa7aef7e8d33490ff47a (patch) | |
| tree | 43be0b4da4883d4223e05efad6599a8ae4641a65 /src/remote/activitypub/act/delete | |
| parent | Implement Delete activity (diff) | |
| download | misskey-783453897f04869c213dfa7aef7e8d33490ff47a.tar.gz misskey-783453897f04869c213dfa7aef7e8d33490ff47a.tar.bz2 misskey-783453897f04869c213dfa7aef7e8d33490ff47a.zip | |
Allow to undo Create activity
Diffstat (limited to 'src/remote/activitypub/act/delete')
| -rw-r--r-- | src/remote/activitypub/act/delete/index.ts | 24 | ||||
| -rw-r--r-- | src/remote/activitypub/act/delete/post.ts | 10 |
2 files changed, 0 insertions, 34 deletions
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())) -]); |