diff --git a/packages/api/src/jobs/process-youtube-video.ts b/packages/api/src/jobs/process-youtube-video.ts index 75e3b7dbb..2802e89a6 100644 --- a/packages/api/src/jobs/process-youtube-video.ts +++ b/packages/api/src/jobs/process-youtube-video.ts @@ -360,7 +360,7 @@ export const processYouTubeVideo = async ( const videoId = videoURL.searchParams.get('v') if (!videoId) { - logger.warn('no video id for supplied youtube url', { + logger.warning('no video id for supplied youtube url', { url: libraryItem.originalUrl, }) return @@ -370,7 +370,7 @@ export const processYouTubeVideo = async ( const youtube = new YouTubeClient() const video = await youtube.getVideo(videoId) if (!video) { - logger.warn('no video found for youtube url', { + logger.warning('no video found for youtube url', { url: libraryItem.originalUrl, }) return @@ -427,11 +427,15 @@ export const processYouTubeVideo = async ( jobData.userId ) if (!updated) { - logger.warn('could not updated library item') + logger.warning('could not updated library item') } } } catch (err) { - logger.warn('error getting youtube metadata: ', { err, jobData, videoURL }) + logger.warning('error getting youtube metadata: ', { + err, + jobData, + videoURL, + }) } } @@ -517,10 +521,10 @@ export const processYouTubeTranscript = async ( jobData.userId ) if (!updated) { - logger.warn('could not updated library item') + logger.warning('could not updated library item') } } } catch (err) { - logger.warn('error getting youtube transcript: ', { err, jobData }) + logger.warning('error getting youtube transcript: ', { err, jobData }) } } diff --git a/packages/api/src/pubsub.ts b/packages/api/src/pubsub.ts index c64b45900..237a5801f 100644 --- a/packages/api/src/pubsub.ts +++ b/packages/api/src/pubsub.ts @@ -86,22 +86,24 @@ export const createPubSubClient = (): PubsubClient => { data, }) - if (await findFeatureByName(FeatureName.AISummaries, userId)) { - // await enqueueAISummarizeJob({ - // userId, - // libraryItemId, - // }) - } + if (type === EntityType.PAGE) { + if (await findFeatureByName(FeatureName.AISummaries, userId)) { + // await enqueueAISummarizeJob({ + // userId, + // libraryItemId, + // }) + } - const isYoutubeVideo = (data: any): data is { originalUrl: string } => { - return 'originalUrl' in data - } + const isYoutubeVideo = (data: any): data is { originalUrl: string } => { + return 'originalUrl' in data + } - if (isYoutubeVideo(data) && isYouTubeVideoURL(data['originalUrl'])) { - await enqueueProcessYouTubeVideo({ - userId, - libraryItemId, - }) + if (isYoutubeVideo(data) && isYouTubeVideoURL(data['originalUrl'])) { + await enqueueProcessYouTubeVideo({ + userId, + libraryItemId, + }) + } } }, entityUpdated: async >(