summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-04-05 01:07:07 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-04-05 01:07:07 +0900
commitfba46b4c7f5751cd31463e922edb19f5652ca408 (patch)
treefb1b5849c90090389ac0777d5a994e9653b8f7c7 /src/queue
parentwip (diff)
downloadsharkey-fba46b4c7f5751cd31463e922edb19f5652ca408.tar.gz
sharkey-fba46b4c7f5751cd31463e922edb19f5652ca408.tar.bz2
sharkey-fba46b4c7f5751cd31463e922edb19f5652ca408.zip
wip
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/http/index.ts10
-rw-r--r--src/queue/processors/http/perform-activitypub.ts7
2 files changed, 2 insertions, 15 deletions
diff --git a/src/queue/processors/http/index.ts b/src/queue/processors/http/index.ts
index 8f9aa717c3..06c6b1d1aa 100644
--- a/src/queue/processors/http/index.ts
+++ b/src/queue/processors/http/index.ts
@@ -1,17 +1,11 @@
-import deliverPost from './deliver-post';
-import follow from './follow';
-import performActivityPub from './perform-activitypub';
+import deliver from './deliver';
import processInbox from './process-inbox';
import reportGitHubFailure from './report-github-failure';
-import unfollow from './unfollow';
const handlers = {
- deliverPost,
- follow,
- performActivityPub,
+ deliver,
processInbox,
reportGitHubFailure,
- unfollow
};
export default (job, done) => handlers[job.data.type](job).then(() => done(), done);
diff --git a/src/queue/processors/http/perform-activitypub.ts b/src/queue/processors/http/perform-activitypub.ts
deleted file mode 100644
index 963e532fe5..0000000000
--- a/src/queue/processors/http/perform-activitypub.ts
+++ /dev/null
@@ -1,7 +0,0 @@
-import User from '../../models/user';
-import act from '../../remote/activitypub/act';
-import Resolver from '../../remote/activitypub/resolver';
-
-export default ({ data }) => User.findOne({ _id: data.actor })
- .then(actor => act(new Resolver(), actor, data.outbox))
- .then(Promise.all);