]>
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' |
6dd9de95 | 6 | import { WEBSERVER } from '../initializers/constants' |
e4f97bab C |
7 | |
8 | const webfinger = new WebFinger({ | |
9 | webfist_fallback: false, | |
10 | tls_only: isTestInstance(), | |
11 | uri_fallback: false, | |
12 | request_timeout: 3000 | |
13 | }) | |
14 | ||
2ff83ae2 C |
15 | async function loadActorUrlOrGetFromWebfinger (uriArg: string) { |
16 | // Handle strings like @toto@example.com | |
17 | const uri = uriArg.startsWith('@') ? uriArg.slice(1) : uriArg | |
18 | ||
06a05d5f | 19 | const [ name, host ] = uri.split('@') |
f5b0af50 C |
20 | let actor: ActorModel |
21 | ||
cce1b3df | 22 | if (!host || host === WEBSERVER.HOST) { |
f5b0af50 C |
23 | actor = await ActorModel.loadLocalByName(name) |
24 | } else { | |
25 | actor = await ActorModel.loadByNameAndHost(name, host) | |
26 | } | |
06a05d5f | 27 | |
50d6de9c | 28 | if (actor) return actor.url |
e4f97bab | 29 | |
06a05d5f | 30 | return getUrlFromWebfinger(uri) |
a5625b41 C |
31 | } |
32 | ||
06a05d5f C |
33 | async function getUrlFromWebfinger (uri: string) { |
34 | const webfingerData: WebFingerData = await webfingerLookup(uri) | |
50d6de9c | 35 | return getLinkOrThrow(webfingerData) |
e4f97bab C |
36 | } |
37 | ||
38 | // --------------------------------------------------------------------------- | |
39 | ||
40 | export { | |
a5625b41 | 41 | getUrlFromWebfinger, |
50d6de9c | 42 | loadActorUrlOrGetFromWebfinger |
e4f97bab C |
43 | } |
44 | ||
45 | // --------------------------------------------------------------------------- | |
46 | ||
50d6de9c C |
47 | function getLinkOrThrow (webfingerData: WebFingerData) { |
48 | if (Array.isArray(webfingerData.links) === false) throw new Error('WebFinger links is not an array.') | |
49 | ||
50 | const selfLink = webfingerData.links.find(l => l.rel === 'self') | |
51 | if (selfLink === undefined || isActivityPubUrlValid(selfLink.href) === false) { | |
52 | throw new Error('Cannot find self link or href is not a valid URL.') | |
53 | } | |
54 | ||
55 | return selfLink.href | |
56 | } | |
57 | ||
350e31d6 | 58 | function webfingerLookup (nameWithHost: string) { |
e4f97bab | 59 | return new Promise<WebFingerData>((res, rej) => { |
350e31d6 | 60 | webfinger.lookup(nameWithHost, (err, p) => { |
e4f97bab C |
61 | if (err) return rej(err) |
62 | ||
350e31d6 | 63 | return res(p.object) |
e4f97bab C |
64 | }) |
65 | }) | |
66 | } |