summaryrefslogtreecommitdiff
path: root/src/remote/activitypub/request.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/remote/activitypub/request.ts')
-rw-r--r--src/remote/activitypub/request.ts44
1 files changed, 44 insertions, 0 deletions
diff --git a/src/remote/activitypub/request.ts b/src/remote/activitypub/request.ts
new file mode 100644
index 0000000000..85f43eb91d
--- /dev/null
+++ b/src/remote/activitypub/request.ts
@@ -0,0 +1,44 @@
+import { request } from 'https';
+import { sign } from 'http-signature';
+import { URL } from 'url';
+import * as debug from 'debug';
+
+import config from '../../config';
+import { ILocalUser } from '../../models/user';
+
+const log = debug('misskey:activitypub:deliver');
+
+export default (user: ILocalUser, url: string, object) => new Promise((resolve, reject) => {
+ log(`--> ${url}`);
+
+ const { protocol, hostname, port, pathname, search } = new URL(url);
+
+ const req = request({
+ protocol,
+ hostname,
+ port,
+ method: 'POST',
+ path: pathname + search,
+ }, res => {
+ res.on('end', () => {
+ log(`${url} --> ${res.statusCode}`);
+
+ if (res.statusCode >= 200 && res.statusCode < 300) {
+ resolve();
+ } else {
+ reject(res);
+ }
+ });
+
+ res.on('data', () => {});
+ res.on('error', reject);
+ });
+
+ sign(req, {
+ authorizationHeaderName: 'Signature',
+ key: user.keypair,
+ keyId: `acct:${user.username}@${config.host}`
+ });
+
+ req.end(JSON.stringify(object));
+});