]>
Commit | Line | Data |
---|---|---|
e4f97bab | 1 | import * as WebFinger from 'webfinger.js' |
892211e8 | 2 | import { WebFingerData } from '../../shared' |
50d6de9c | 3 | import { ActorModel } from '../models/activitypub/actor' |
e4f97bab | 4 | import { isTestInstance } from './core-utils' |
da854ddd | 5 | import { isActivityPubUrlValid } from './custom-validators/activitypub/misc' |
e4f97bab C |
6 | |
7 | const webfinger = new WebFinger({ | |
8 | webfist_fallback: false, | |
9 | tls_only: isTestInstance(), | |
10 | uri_fallback: false, | |
11 | request_timeout: 3000 | |
12 | }) | |
13 | ||
50d6de9c C |
14 | async function loadActorUrlOrGetFromWebfinger (name: string, host: string) { |
15 | const actor = await ActorModel.loadByNameAndHost(name, host) | |
16 | if (actor) return actor.url | |
e4f97bab | 17 | |
a5625b41 C |
18 | return getUrlFromWebfinger(name, host) |
19 | } | |
20 | ||
21 | async function getUrlFromWebfinger (name: string, host: string) { | |
50d6de9c C |
22 | const webfingerData: WebFingerData = await webfingerLookup(name + '@' + host) |
23 | return getLinkOrThrow(webfingerData) | |
e4f97bab C |
24 | } |
25 | ||
26 | // --------------------------------------------------------------------------- | |
27 | ||
28 | export { | |
a5625b41 | 29 | getUrlFromWebfinger, |
50d6de9c | 30 | loadActorUrlOrGetFromWebfinger |
e4f97bab C |
31 | } |
32 | ||
33 | // --------------------------------------------------------------------------- | |
34 | ||
50d6de9c C |
35 | function getLinkOrThrow (webfingerData: WebFingerData) { |
36 | if (Array.isArray(webfingerData.links) === false) throw new Error('WebFinger links is not an array.') | |
37 | ||
38 | const selfLink = webfingerData.links.find(l => l.rel === 'self') | |
39 | if (selfLink === undefined || isActivityPubUrlValid(selfLink.href) === false) { | |
40 | throw new Error('Cannot find self link or href is not a valid URL.') | |
41 | } | |
42 | ||
43 | return selfLink.href | |
44 | } | |
45 | ||
350e31d6 | 46 | function webfingerLookup (nameWithHost: string) { |
e4f97bab | 47 | return new Promise<WebFingerData>((res, rej) => { |
350e31d6 | 48 | webfinger.lookup(nameWithHost, (err, p) => { |
e4f97bab C |
49 | if (err) return rej(err) |
50 | ||
350e31d6 | 51 | return res(p.object) |
e4f97bab C |
52 | }) |
53 | }) | |
54 | } |