server/helpers/webfinger.ts

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