server/lib/activitypub/playlists/refresh.ts

   1 import { logger, loggerTagsFactory } from '@server/helpers/logger'
   2 import { PeerTubeRequestError } from '@server/helpers/requests'
   3 import { JobQueue } from '@server/lib/job-queue'
   4 import { MVideoPlaylist, MVideoPlaylistOwner } from '@server/types/models'
   5 import { HttpStatusCode } from '@shared/core-utils'
   6 import { createOrUpdateVideoPlaylist } from './create-update'
   7 import { fetchRemoteVideoPlaylist } from './shared'
   8
   9 function scheduleRefreshIfNeeded (playlist: MVideoPlaylist) {
  10   if (!playlist.isOutdated()) return
  11
  12   JobQueue.Instance.createJob({ type: 'activitypub-refresher', payload: { type: 'video-playlist', url: playlist.url } })
  13 }
  14
  15 async function refreshVideoPlaylistIfNeeded (videoPlaylist: MVideoPlaylistOwner): Promise<MVideoPlaylistOwner> {
  16   if (!videoPlaylist.isOutdated()) return videoPlaylist
  17
  18   const lTags = loggerTagsFactory('ap', 'video-playlist', 'refresh', videoPlaylist.uuid, videoPlaylist.url)
  19
  20   logger.info('Refreshing playlist %s.', videoPlaylist.url, lTags())
  21
  22   try {
  23     const { playlistObject } = await fetchRemoteVideoPlaylist(videoPlaylist.url)
  24
  25     if (playlistObject === undefined) {
  26       logger.warn('Cannot refresh remote playlist %s: invalid body.', videoPlaylist.url, lTags())
  27
  28       await videoPlaylist.setAsRefreshed()
  29       return videoPlaylist
  30     }
  31
  32     await createOrUpdateVideoPlaylist(playlistObject)
  33
  34     return videoPlaylist
  35   } catch (err) {
  36     if ((err as PeerTubeRequestError).statusCode === HttpStatusCode.NOT_FOUND_404) {
  37       logger.info('Cannot refresh not existing playlist %s. Deleting it.', videoPlaylist.url, lTags())
  38
  39       await videoPlaylist.destroy()
  40       return undefined
  41     }
  42
  43     logger.warn('Cannot refresh video playlist %s.', videoPlaylist.url, { err, ...lTags() })
  44
  45     await videoPlaylist.setAsRefreshed()
  46     return videoPlaylist
  47   }
  48 }
  49
  50 export {
  51   scheduleRefreshIfNeeded,
  52   refreshVideoPlaylistIfNeeded
  53 }