summaryrefslogtreecommitdiff
path: root/src/queue/processors/http
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue/processors/http')
-rw-r--r--src/queue/processors/http/process-inbox.ts6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/queue/processors/http/process-inbox.ts b/src/queue/processors/http/process-inbox.ts
index ce5b7d5a89..2c49a67b66 100644
--- a/src/queue/processors/http/process-inbox.ts
+++ b/src/queue/processors/http/process-inbox.ts
@@ -1,7 +1,7 @@
import * as kue from 'kue';
import * as debug from 'debug';
-import { verifySignature } from 'http-signature';
+const httpSignature = require('http-signature');
import parseAcct from '../../../acct/parse';
import User, { IRemoteUser } from '../../../models/user';
import perform from '../../../remote/activitypub/perform';
@@ -32,7 +32,7 @@ export default async (job: kue.Job, done): Promise<void> => {
return;
}
- user = await User.findOne({ usernameLower: username, hostLower: host }) as IRemoteUser;
+ user = await User.findOne({ usernameLower: username, host: host.toLowerCase() }) as IRemoteUser;
} else {
user = await User.findOne({
host: { $ne: null },
@@ -50,7 +50,7 @@ export default async (job: kue.Job, done): Promise<void> => {
return;
}
- if (!verifySignature(signature, user.publicKey.publicKeyPem)) {
+ if (!httpSignature.verifySignature(signature, user.publicKey.publicKeyPem)) {
console.warn('signature verification failed');
done();
return;