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