summaryrefslogtreecommitdiff
path: root/src/remote/activitypub/act/delete
diff options
context:
space:
mode:
authorAkihiko Odaki <nekomanma@pixiv.co.jp>2018-04-04 19:51:41 +0900
committerAkihiko Odaki <nekomanma@pixiv.co.jp>2018-04-04 19:51:41 +0900
commit783453897f04869c213dfa7aef7e8d33490ff47a (patch)
tree43be0b4da4883d4223e05efad6599a8ae4641a65 /src/remote/activitypub/act/delete
parentImplement Delete activity (diff)
downloadmisskey-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.ts24
-rw-r--r--src/remote/activitypub/act/delete/post.ts10
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()))
-]);