server/lib/activitypub/actors/refresh.ts

   1 import { logger, loggerTagsFactory } from '@server/helpers/logger'
   2 import { PeerTubeRequestError } from '@server/helpers/requests'
   3 import { ActorLoadByUrlType } from '@server/lib/model-loaders'
   4 import { ActorModel } from '@server/models/actor/actor'
   5 import { MActorAccountChannelId, MActorFull } from '@server/types/models'
   6 import { HttpStatusCode } from '@shared/core-utils'
   7 import { fetchRemoteActor } from './shared'
   8 import { APActorUpdater } from './updater'
   9 import { getUrlFromWebfinger } from './webfinger'
  10
  11 async function refreshActorIfNeeded <T extends MActorFull | MActorAccountChannelId> (
  12   actorArg: T,
  13   fetchedType: ActorLoadByUrlType
  14 ): Promise<{ actor: T | MActorFull, refreshed: boolean }> {
  15   if (!actorArg.isOutdated()) return { actor: actorArg, refreshed: false }
  16
  17   // We need more attributes
  18   const actor = fetchedType === 'all'
  19     ? actorArg as MActorFull
  20     : await ActorModel.loadByUrlAndPopulateAccountAndChannel(actorArg.url)
  21
  22   const lTags = loggerTagsFactory('ap', 'actor', 'refresh', actor.url)
  23
  24   logger.info('Refreshing actor %s.', actor.url, lTags())
  25
  26   try {
  27     const actorUrl = await getActorUrl(actor)
  28     const { actorObject } = await fetchRemoteActor(actorUrl)
  29
  30     if (actorObject === undefined) {
  31       logger.warn('Cannot fetch remote actor in refresh actor.')
  32       return { actor, refreshed: false }
  33     }
  34
  35     const updater = new APActorUpdater(actorObject, actor)
  36     await updater.update()
  37
  38     return { refreshed: true, actor }
  39   } catch (err) {
  40     if ((err as PeerTubeRequestError).statusCode === HttpStatusCode.NOT_FOUND_404) {
  41       logger.info('Deleting actor %s because there is a 404 in refresh actor.', actor.url, lTags())
  42
  43       actor.Account
  44         ? await actor.Account.destroy()
  45         : await actor.VideoChannel.destroy()
  46
  47       return { actor: undefined, refreshed: false }
  48     }
  49
  50     logger.warn('Cannot refresh actor %s.', actor.url, { err, ...lTags() })
  51     return { actor, refreshed: false }
  52   }
  53 }
  54
  55 export {
  56   refreshActorIfNeeded
  57 }
  58
  59 // ---------------------------------------------------------------------------
  60
  61 function getActorUrl (actor: MActorFull) {
  62   return getUrlFromWebfinger(actor.preferredUsername + '@' + actor.getHost())
  63     .catch(err => {
  64       logger.warn('Cannot get actor URL from webfinger, keeping the old one.', err)
  65       return actor.url
  66     })
  67 }