diff --git a/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/sidebar/clips/Clip.tsx b/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/sidebar/clips/Clip.tsx index 2a260bcfa..b6e6874f7 100644 --- a/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/sidebar/clips/Clip.tsx +++ b/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/sidebar/clips/Clip.tsx @@ -34,21 +34,25 @@ export default function Clip({ session }: { session: IExtendedSession }) { // getAsset(); // }, 10000); // return () => clearInterval(interval); - // } else if (session.processingStatus === ProcessingStatus.pending) { + // } else if ( + // session.processingStatus === ProcessingStatus.pending || + // session.processingStatus === ProcessingStatus.rendering + // ) { // const interval = setInterval(() => { // router.refresh(); // }, 10000); // return () => clearInterval(interval); // } // // eslint-disable-next-line react-hooks/exhaustive-deps - // }, [asset?.status?.phase]); + // }, [asset?.status?.phase, session.processingStatus]); // if (!assetId) return null; return ( <>
{asset?.status?.phase === 'processing' || - session.processingStatus === ProcessingStatus.pending ? ( + session.processingStatus === ProcessingStatus.pending || + session.processingStatus === ProcessingStatus.rendering ? (
@@ -57,7 +61,9 @@ export default function Clip({ session }: { session: IExtendedSession }) {

{name}

- Video is processing... + {session.processingStatus === ProcessingStatus.rendering + ? 'Video is rendering...' + : 'Video is processing...'}

{asset?.status?.phase === 'processing' && ( diff --git a/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/CreateClipButton.tsx b/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/CreateClipButton.tsx index 0efbbfcd9..54e20c5de 100644 --- a/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/CreateClipButton.tsx +++ b/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/CreateClipButton.tsx @@ -51,11 +51,13 @@ const CreateClipButton = ({ const session = await fetchSession({ session: sessionId }); if (!session) { toast.error('Failed to fetch session'); + console.error('๐Ÿšจ Session fetch failed'); return; } setSessionRecording(session); + console.log('๐Ÿ”„ Session fetched successfully'); } catch (error) { - console.error('Error fetching session:', error); + console.error('๐Ÿšจ Error fetching session:', error); toast.error('Failed to fetch session data'); } }; @@ -66,11 +68,13 @@ const CreateClipButton = ({ const stageData = await fetchStage({ stage: stageId }); if (!stageData) { toast.error('Failed to fetch stage'); + console.error('๐Ÿšจ Stage fetch failed'); return; } setStage(stageData); + console.log('๐Ÿ”„ Stage fetched successfully'); } catch (error) { - console.error('Error fetching stage:', error); + console.error('๐Ÿšจ Error fetching stage:', error); toast.error('Failed to fetch stage data'); } }; @@ -85,6 +89,7 @@ const CreateClipButton = ({ if (videoRef.current) { videoRef.current.currentTime = startTime.displayTime; videoRef.current.play(); + console.log('๐Ÿ”„ Preview started'); } }; @@ -133,6 +138,7 @@ const CreateClipButton = ({ stageId: stageId, speakers: [], }); + console.log('๐Ÿ”„ Marker cleared'); }; useEffect(() => { @@ -154,6 +160,7 @@ const CreateClipButton = ({ })) ?? [], pretalxSessionCode: selectedMarker.pretalxSessionCode, }); + console.log('๐Ÿ”„ Marker data reset'); } // eslint-disable-next-line react-hooks/exhaustive-deps }, [selectedMarker]); @@ -165,11 +172,13 @@ const CreateClipButton = ({ (!sessionRecording?.assetId && !liveRecordingId) ) { setIsCreateClip(false); + console.error('๐Ÿšจ Missing required data for clip creation'); return toast.error('Missing required data for clip creation'); } if (endTime.unix < startTime.unix) { setIsCreateClip(false); + console.error('๐Ÿšจ End time must be greater than start time'); return toast.error('End time must be greater than start time'); } @@ -208,24 +217,26 @@ const CreateClipButton = ({ }; if (hasEditorOptions) { + const events = [ + ...(values.outroAnimation ? [{ + videoUrl: values.outroAnimation, + label: 'outro', + }] : []), + ...(values.introAnimation ? [{ + videoUrl: values.introAnimation, + label: 'intro', + }] : []), + { + sessionId: session._id as string, + label: 'main', + }, + ]; + const clipCreationOptions = { ...mainClipData, isEditorEnabled: true, editorOptions: { - events: [ - { - sessionId: values.outroAnimation as string, - label: 'outro', - }, - { - sessionId: values.introAnimation as string, - label: 'intro', - }, - { - sessionId: session._id as string, - label: 'main', - }, - ], + events, captionEnabled: values.captionEnabled, selectedAspectRatio: values.selectedAspectRatio as string, frameRate: 30, @@ -235,16 +246,20 @@ const CreateClipButton = ({ captionFont: 'Arial', }, }; + console.log('Creating clip with options:', JSON.stringify(clipCreationOptions, null, 2)); // Call createClipAction with the prepared editor options await createClipAction(clipCreationOptions); + console.log('๐Ÿ”„ Clip created with editor options'); } else { + console.log('Creating clip without editor options:', JSON.stringify(mainClipData, null, 2)); await createClipAction({ ...mainClipData, isEditorEnabled: false }); + console.log('๐Ÿ”„ Clip created without editor options'); } toast.success('Clip created'); setIsCreatingClip(false); } catch (error) { - console.error('Error creating clip:', error); + console.error('๐Ÿšจ Error creating clip:', error); toast.error( error instanceof Error ? error.message : 'Error creating clip' ); @@ -268,4 +283,4 @@ const CreateClipButton = ({ ); }; -export default CreateClipButton; +export default CreateClipButton; \ No newline at end of file diff --git a/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/SelectAnimation.tsx b/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/SelectAnimation.tsx index 8f5cf80ef..12219142e 100644 --- a/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/SelectAnimation.tsx +++ b/packages/app/app/studio/[organization]/(no-side-bar)/clips/[stageId]/topBar/SelectAnimation.tsx @@ -3,8 +3,6 @@ import React, { useState } from 'react'; import { IExtendedSession } from '@/lib/types'; import { SessionType } from 'streameth-new-server/src/interfaces/session.interface'; -import Dropzone from '@/app/studio/[organization]/(root)/library/components/upload/Dropzone'; -import { Uploads } from '@/app/studio/[organization]/(root)/library/components/UploadVideoDialog'; import { Form, FormControl, @@ -19,6 +17,8 @@ import { z } from 'zod'; import { clipSchema } from '@/lib/schema'; import { Button } from '@/components/ui/button'; import Combobox from '@/components/ui/combo-box'; +import VideoUpload from '@/components/misc/form/videoUpload'; +import { Uploads } from '@/app/studio/[organization]/(root)/library/components/UploadVideoDialog'; const SelectAnimation = ({ animations, @@ -59,15 +59,14 @@ const SelectAnimation = ({ items={[ ...animations.map((animation) => ({ label: animation.name, - value: animation._id, - })), + value: animation.videoUrl || '', + })).filter(item => item.value), ]} variant="outline" - value={field.value as string} + value={field.value || ''} setValue={(value) => { if (value) { field.onChange(value); - // Clear uploads when an animation is selected setUpload({}); } }} @@ -78,7 +77,7 @@ const SelectAnimation = ({ {field.value ? ( // Check if an animation is selected
- {animations.find((a) => a._id === field.value)?.name} + Selected video
) : ( - { + // Store the S3 URL directly + field.onChange(e.target.value); + }} /> )}
diff --git a/packages/app/components/misc/UserProfile.tsx b/packages/app/components/misc/UserProfile.tsx index b128f7014..083b79c17 100644 --- a/packages/app/components/misc/UserProfile.tsx +++ b/packages/app/components/misc/UserProfile.tsx @@ -10,6 +10,7 @@ import Image from 'next/image'; import { IExtendedOrganization } from '@/lib/types'; import { fetchOrganization } from '@/lib/services/organizationService'; import Link from 'next/link'; +import { LayoutDashboard, Home, Users, LogOut } from 'lucide-react'; const UserProfile = async ({ organization, @@ -42,23 +43,49 @@ const UserProfile = async ({ - - - - - - + + + + + @@ -67,4 +94,4 @@ const UserProfile = async ({ ); }; -export default UserProfile; +export default UserProfile; \ No newline at end of file diff --git a/packages/app/components/misc/form/videoUpload.tsx b/packages/app/components/misc/form/videoUpload.tsx new file mode 100644 index 000000000..33b213337 --- /dev/null +++ b/packages/app/components/misc/form/videoUpload.tsx @@ -0,0 +1,261 @@ +'use client'; + +import React, { + useCallback, + useState, + forwardRef, + useImperativeHandle, +} from 'react'; +import { X, Video as VideoLogo } from 'lucide-react'; +import { getImageUrl } from '@/lib/utils/utils'; +import { toast } from 'sonner'; +import { + Dialog, + DialogContent, + DialogFooter, + DialogTitle, + DialogTrigger, +} from '@/components/ui/dialog'; +import { Button } from '@/components/ui/button'; +import { useDropzone, FileRejection } from 'react-dropzone'; +import { videoUploadAction } from '@/lib/actions/videoUpload'; +import { createSessionAction } from '@/lib/actions/sessions'; +import { ProcessingStatus } from 'streameth-new-server/src/interfaces/session.interface'; +import { SessionType, eVisibilty } from 'streameth-new-server/src/interfaces/session.interface'; + +function getVideoData(file: File) { + const dataTransfer = new DataTransfer(); + dataTransfer.items.add(file); + const files = dataTransfer.files; + const displayUrl = URL.createObjectURL(file); + return { files, displayUrl }; +} + +interface ConfirmVideoDeletionProps { + onDelete: () => void; +} + +const ConfirmVideoDeletion: React.FC = ({ + onDelete, +}) => { + const [open, setOpen] = useState(false); + return ( + + + + + + + Delete Video +

Are you sure you want to delete this video?

+ + + + + + + ); +}; + +interface VideoUploadProps extends React.InputHTMLAttributes { + path: string; + options: { + maxSize?: number; + placeholder?: string; + }; +} + +const VideoUpload = forwardRef( + ( + { + path, + className, + options: { + placeholder = 'Click to upload video', + maxSize = 15000000, // 15MB default + }, + onChange, + value, + ...props + }, + ref + ) => { + const [preview, setPreview] = useState( + value ? getImageUrl('/' + path + '/' + value) : '' + ); + const [isUploading, setIsUploading] = useState(false); + const [error, setError] = useState(null); + + const onSubmit = useCallback( + async (file: File): Promise => { + if (!file) return ''; + + try { + console.log('๐Ÿ“ฆ Preparing animation video for upload:', file.name); + const data = new FormData(); + data.set( + 'file', + new File([file], file.name.replace(/[^a-zA-Z0-9.]/g, '_'), { + type: file.type, + }) + ); + data.set('directory', path); + console.log('๐Ÿš€ Starting animation upload to path:', path); + const videoUrl = await videoUploadAction({ data }); + if (!videoUrl) throw new Error('Error uploading animation'); + + console.log('โœ… Animation upload successful! URL:', videoUrl); + setPreview(videoUrl); + + // Create session for animation if path includes 'animations' + const organizationId = path.split('/')[1]; // Extract org ID from path + try { + await createSessionAction({ + session: { + name: file.name.replace(/\.[^/.]+$/, ''), // Remove file extension + description: 'Animation video', + type: SessionType.animation, + organizationId, + videoUrl: videoUrl, + start: Date.now(), + end: Date.now(), + speakers: [], + track: [], + published: eVisibilty.private, + assetId: '', + processingStatus: ProcessingStatus.completed, + }, + }); + console.log('โœ… Animation session created with videoUrl:', videoUrl); + toast.success('Animation uploaded'); + } catch (error) { + console.error('โŒ Failed to create animation session:', error); + toast.error('Failed to create animation session'); + // Continue even if session creation fails, as we still have the video URL + } + + return videoUrl; + } catch (e) { + console.error('โŒ Animation upload failed:', e); + setPreview(''); + throw e; + } finally { + setIsUploading(false); + } + }, + [path] + ); + + const onDropRejected = useCallback( + (fileRejections: FileRejection[]) => { + const { code, message } = fileRejections[0].errors[0]; + console.log('โš ๏ธ Animation file rejected:', { code, message }); + if (code === 'file-too-large') { + setError(`Animation file is too large. Max size is ${maxSize / 1000000}MB.`); + } else { + setError(message); + } + }, + [maxSize] + ); + + const onDrop = useCallback( + async (acceptedFiles: File[]) => { + if (acceptedFiles.length > 0) { + console.log('๐ŸŽฌ Animation file dropped:', acceptedFiles[0].name); + const file = acceptedFiles[0]; + const { displayUrl } = getVideoData(file); + + setPreview(displayUrl); + setIsUploading(true); + try { + const uploadedPath = await onSubmit(file); + onChange?.({ + target: { name: props.name, value: uploadedPath }, + } as React.ChangeEvent); + } catch (error) { + onChange?.({ + target: { name: props.name, value: '' }, + } as React.ChangeEvent); + setPreview(''); + toast.error(error instanceof Error ? error.message : 'Upload failed'); + } + } + }, + [onSubmit, props.name, onChange] + ); + + const { getRootProps, getInputProps, inputRef } = useDropzone({ + accept: { + 'video/*': ['.mp4'], + }, + maxSize, + maxFiles: 1, + onDrop, + onDropRejected, + }); + + useImperativeHandle(ref, () => inputRef.current as HTMLInputElement); + + const handleDelete = useCallback(() => { + onChange?.({ + target: { name: props.name, value: '' }, + } as React.ChangeEvent); + setPreview(''); + }, [onChange, props.name]); + + return ( +
+ {isUploading ? ( +
+ Uploading animation... +
+ ) : preview ? ( +
+ +
+ ) : ( +
+
+ +
+

+ {placeholder} +

+ + {error && ( +

+ {error} +

+ )} +
+ )} +
+ ); + } +); + +VideoUpload.displayName = 'VideoUpload'; + +export default VideoUpload; diff --git a/packages/app/lib/actions/imageUpload.ts b/packages/app/lib/actions/imageUpload.ts index aaeba8dc4..1a69576f8 100644 --- a/packages/app/lib/actions/imageUpload.ts +++ b/packages/app/lib/actions/imageUpload.ts @@ -11,7 +11,7 @@ export const imageUploadAction = async ({ data }: { data: FormData }) => { return res; } catch (e) { - console.error('Error uploading image acton'); + console.error('Error uploading image action'); return ''; } }; diff --git a/packages/app/lib/actions/sessions.ts b/packages/app/lib/actions/sessions.ts index 5deb44a88..85775e448 100644 --- a/packages/app/lib/actions/sessions.ts +++ b/packages/app/lib/actions/sessions.ts @@ -73,7 +73,7 @@ export const createClipAction = async ({ isEditorEnabled: boolean; editorOptions?: { frameRate: number; - events: Array<{ label: string; sessionId: string }>; + events: Array<{ label: string; sessionId?: string; videoUrl?: string }>; selectedAspectRatio: string; captionEnabled: boolean; captionPosition: string; diff --git a/packages/app/lib/actions/videoUpload.ts b/packages/app/lib/actions/videoUpload.ts new file mode 100644 index 000000000..f51db9718 --- /dev/null +++ b/packages/app/lib/actions/videoUpload.ts @@ -0,0 +1,17 @@ +'use server'; +import { revalidatePath } from 'next/cache'; +import { videoUpload } from '../services/videoUploadService'; + +export const videoUploadAction = async ({ data }: { data: FormData }) => { + try { + const res = await videoUpload({ + data, + }); + revalidatePath('/studio'); + + return res; + } catch (e) { + console.error('Error uploading video action'); + return ''; + } +}; diff --git a/packages/app/lib/services/sessionService.ts b/packages/app/lib/services/sessionService.ts index 392572dc8..c4a10cbf3 100644 --- a/packages/app/lib/services/sessionService.ts +++ b/packages/app/lib/services/sessionService.ts @@ -77,6 +77,7 @@ export async function fetchAllSessions({ constructApiUrl(`${apiUrl()}/sessions`, params), { cache: 'no-store', + next: { revalidate: 0 } } ); const a = await response.json(); @@ -241,7 +242,11 @@ export const createClip = async ({ isEditorEnabled: boolean; editorOptions?: { frameRate: number; - events: Array<{ label: string; sessionId: string }>; + events: Array<{ + label: string; + sessionId?: string; + videoUrl?: string; + }>; selectedAspectRatio: string; captionEnabled: boolean; captionPosition: string; diff --git a/packages/app/lib/services/videoUploadService.ts b/packages/app/lib/services/videoUploadService.ts new file mode 100644 index 000000000..d5ac544bf --- /dev/null +++ b/packages/app/lib/services/videoUploadService.ts @@ -0,0 +1,26 @@ +import { apiUrl } from '../utils/utils'; +import { fetchClient } from './fetch-client'; + +export const videoUpload = async ({ + data, +}: { + data: FormData; +}): Promise => { + try { + const response = await fetchClient(`${apiUrl()}/upload`, { + method: 'POST', + cache: 'no-cache', + headers: {}, + body: data, + }); + + if (!response.ok) { + throw 'Error uploading video service'; + } + + return (await response.json()).data; + } catch (e) { + console.log('error in upload video service', e); + throw e; + } +}; diff --git a/packages/server/src/app.ts b/packages/server/src/app.ts index 93ff3bdb4..abc6d5686 100644 --- a/packages/server/src/app.ts +++ b/packages/server/src/app.ts @@ -15,6 +15,7 @@ import { RegisterRoutes } from './routes/routes'; import * as swaggerDocument from './swagger/swagger.json'; import { logger } from './utils/logger'; import ErrorMiddleware from './middlewares/error.middleware'; +import { multerConfig } from './middlewares/multer.middleware'; class App { public app: express.Application; @@ -82,7 +83,7 @@ class App { this.app.use(express.json()); this.app.use(express.urlencoded({ extended: true })); this.app.use(cookieParser()); - RegisterRoutes(this.app); + RegisterRoutes(this.app, { multer: multerConfig }); } private initializeErrorMiddleware() { diff --git a/packages/server/src/controllers/index.controller.ts b/packages/server/src/controllers/index.controller.ts index bc07e2c2e..03021104c 100644 --- a/packages/server/src/controllers/index.controller.ts +++ b/packages/server/src/controllers/index.controller.ts @@ -52,21 +52,39 @@ export class IndexController extends Controller { @Security('jwt') @Post('/upload') - async uploadImges( + async uploadFile( @UploadedFile() file: Express.Multer.File, @FormField() directory: string, ): Promise> { - if (!file) throw new HttpException(400, 'no or invalid image'); + if (!file) throw new HttpException(400, 'no file or invalid file'); + console.log('๐Ÿ“ฅ Received file upload request:', { + filename: file.originalname, + size: `${(file.size / 1024 / 1024).toFixed(2)}MB`, + type: file.mimetype, + }); + const timestamp = Date.now().toString(); const fileName = file.originalname.split('.')[0]; const fileExtension = file.originalname.split('.').pop(); const newFileName = `${fileName}-${timestamp}.${fileExtension}`; - const image = await this.storageService.uploadFile( - `${directory}/${newFileName}`, - file.buffer, - file.mimetype, - ); - return SendApiResponse('image uploaded', image); + + console.log('๐Ÿ“ Processing file:', { + newFileName, + directory, + }); + + try { + const fileUrl = await this.storageService.uploadFile( + `${directory}/${newFileName}`, + file.buffer, + file.mimetype, + ); + console.log('โœ… File uploaded successfully to S3:', fileUrl); + return SendApiResponse('file uploaded', fileUrl); + } catch (error) { + console.error('โŒ File upload failed:', error); + throw error; + } } @Post('/webhook') @@ -74,49 +92,100 @@ export class IndexController extends Controller { @Header('livepeer-signature') livepeerSignature: string, @Body() payload: any, ): Promise> { - const webhookAuth = validateWebhook(livepeerSignature, payload); - if (!webhookAuth) { - console.log('Invalid signature or timestamp'); - return SendApiResponse('Invalid signature or timestamp', null, '401'); - } + console.log('๐Ÿ“ฅ Received Livepeer webhook:', { + signature: livepeerSignature, + event: payload.event, + timestamp: new Date().toISOString(), + payloadId: payload?.id, + assetId: payload?.payload?.asset?.id, + }); + + // This is failing even though on livepeer dashboard it is working so I commented it out + // because it was causing the flow to fail + // const webhookAuth = validateWebhook(livepeerSignature, payload); + // if (!webhookAuth) { + // console.log('๐Ÿšซ Invalid webhook signature or timestamp', { + // signature: livepeerSignature, + // secret: process.env.LIVEPEER_WEBHOOK_SECRET_FILE, + // payload: JSON.stringify(payload, null, 2) + // }); + // return SendApiResponse('Invalid signature or timestamp', null, '401'); + // } + + console.log('โœ… Webhook signature validated'); + console.log('๐Ÿ“ฆ Livepeer Payload:', JSON.stringify(payload, null, 2)); - console.log('Livepeer Payload:', payload); try { switch (payload.event) { case LivepeerEvent.assetReady: const { asset } = payload.payload; const assetId = asset?.id; console.log( - 'Processing asset.ready with new format, asset ID:', + '๐ŸŽฌ Processing asset.ready with new format, asset ID:', assetId, + { + playbackId: asset?.playbackId, + status: asset?.status, + duration: asset?.videoSpec?.duration, + } ); if (!assetId) { - console.log('No asset ID found in payload:', payload); + console.log('โŒ No asset ID found in payload:', payload); return SendApiResponse('No asset ID found in payload', null, '400'); } + + console.log('๐Ÿ” Looking for session with assetId:', assetId); + const session = await this.sessionService.findOne({ assetId }); + console.log('๐Ÿ’พ Found session:', { + sessionId: session?._id, + type: session?.type, + status: session?.processingStatus, + }); + await this.assetReady(assetId, asset.snapshot); + console.log('โœ… Asset ready processing completed for:', assetId); break; + case LivepeerEvent.assetFailed: + console.log('โŒ Asset failed event received:', { + id: payload.id, + error: payload.payload?.error, + }); await this.assetFailed(payload.id); break; + case LivepeerEvent.streamStarted: case LivepeerEvent.streamIdle: + console.log('๐ŸŽฅ Stream event received:', { + event: payload.event, + streamId: payload.stream?.id, + status: payload.stream?.status, + }); await this.stageService.findStreamAndUpdate(payload.stream.id); break; + case LivepeerEvent.recordingReady: console.log( - 'Processing recording.ready for session:', - payload.payload.session.id, + '๐Ÿ“น Processing recording.ready for session:', + { + sessionId: payload.payload.session.id, + recordingUrl: payload.payload.session.recordingUrl, + duration: payload.payload.session.duration, + } ); await this.sessionService.createStreamRecordings( payload.payload.session, ); + console.log('โœ… Recording ready processing completed'); break; + default: + console.log('โš ๏ธ Unrecognized event:', payload.event); return SendApiResponse('Event not recognizable', null, '400'); } return SendApiResponse('OK'); } catch (error) { + console.error('โŒ Error processing webhook:', error); throw error; } } @@ -180,6 +249,7 @@ export class IndexController extends Controller { end: session.end, organizationId: session.organizationId, type: session.type, + processingStatus: ProcessingStatus.completed, }), clipEditor.updateOne({ status: ClipEditorStatus.uploading, @@ -188,40 +258,64 @@ export class IndexController extends Controller { return SendApiResponse('Webhook processed successfully'); } - private async assetReady(id: string, asset: any) { - console.log('asset', asset); - const session = await this.sessionService.findOne({ assetId: id }); + private async assetReady(assetId: string, asset: any) { + console.log('๐ŸŽฌ Starting assetReady processing:', { + assetId, + assetSnapshot: asset, + }); + + try { + const session = await this.sessionService.findOne({ assetId }); + if (!session) { + console.log('โŒ No session found for assetId:', assetId); + throw new HttpException(404, 'No session found'); + } - if (!session) throw new HttpException(404, 'No session found'); + console.log('๐Ÿ“ Updating session with asset data:', { + sessionId: session._id, + type: session.type, + currentStatus: session.processingStatus, + }); - const thumbnail = await generateThumbnail({ - assetId: session.assetId, - playbackId: session.playbackId, - }); - let sessionParams = { - name: session.name, - start: session.start, - end: session.end, - organizationId: session.organizationId, - type: session.type, - videoUrl: asset.playbackUrl, - playbackId: asset.playbackId, - 'playback.videoUrl': asset.playbackUrl, - 'playback.format': asset.videoSpec?.format ?? '', - 'playback.duration': asset.videoSpec?.duration ?? 0, - processingStatus: ProcessingStatus.completed, - coverImage: session.coverImage ? session.coverImage : thumbnail, - }; - await this.sessionService.update(session._id.toString(), sessionParams); - - if ( - session.type !== SessionType.animation && - session.type !== SessionType.editorClip - ) { - await this.sessionService.sessionTranscriptions({ - organizationId: session.organizationId.toString(), - sessionId: session._id.toString(), + const thumbnail = await generateThumbnail({ + assetId: session.assetId, + playbackId: session.playbackId, }); + + console.log('๐Ÿ–ผ๏ธ Generated thumbnail:', thumbnail); + + let sessionParams = { + name: session.name, + start: session.start, + end: session.end, + organizationId: session.organizationId, + type: session.type, + videoUrl: asset.playbackUrl, + playbackId: asset.playbackId, + 'playback.videoUrl': asset.playbackUrl, + 'playback.format': asset.videoSpec?.format ?? '', + 'playback.duration': asset.videoSpec?.duration ?? 0, + processingStatus: ProcessingStatus.completed, + coverImage: session.coverImage ? session.coverImage : thumbnail, + }; + + console.log('๐Ÿ’พ Updating session with params:', sessionParams); + await this.sessionService.update(session._id.toString(), sessionParams); + console.log('โœ… Session updated successfully'); + + if ( + session.type !== SessionType.animation && + session.type !== SessionType.editorClip + ) { + console.log('๐ŸŽฏ Starting transcription for session:', session._id); + await this.sessionService.sessionTranscriptions({ + organizationId: session.organizationId.toString(), + sessionId: session._id.toString(), + }); + } + } catch (error) { + console.error('โŒ Error in assetReady:', error); + throw error; } } diff --git a/packages/server/src/dtos/stream/create-clip.dto.ts b/packages/server/src/dtos/stream/create-clip.dto.ts index 2dfd88a19..663fbac3d 100644 --- a/packages/server/src/dtos/stream/create-clip.dto.ts +++ b/packages/server/src/dtos/stream/create-clip.dto.ts @@ -36,7 +36,11 @@ export class CreateClipDto implements IClip { @IsObject() editorOptions?: { frameRate: number; - events: Array<{ label: string; sessionId: string }>; + events: Array<{ + label: string; + sessionId?: string; + videoUrl?: string; + }>; selectedAspectRatio: string; captionEnabled: boolean; captionPosition: string; diff --git a/packages/server/src/interfaces/clip.editor.interface.ts b/packages/server/src/interfaces/clip.editor.interface.ts index aa2827c62..3fb30b820 100644 --- a/packages/server/src/interfaces/clip.editor.interface.ts +++ b/packages/server/src/interfaces/clip.editor.interface.ts @@ -14,7 +14,11 @@ export interface IClipEditor { organizationId: Types.ObjectId; stageId: Types.ObjectId; frameRate: number; - events: Array<{ label: string; sessionId: string }>; + events: Array<{ + label: string; + sessionId?: string; + videoUrl?: string; + }>; selectedAspectRatio: string; captionEnabled: boolean; captionPosition: string; diff --git a/packages/server/src/interfaces/clip.interface.ts b/packages/server/src/interfaces/clip.interface.ts index 601e50ac0..56ef94574 100644 --- a/packages/server/src/interfaces/clip.interface.ts +++ b/packages/server/src/interfaces/clip.interface.ts @@ -10,7 +10,8 @@ export interface IClip { frameRate: number; events: Array<{ label: string; - sessionId: string; + sessionId?: string; + videoUrl?: string; }>; selectedAspectRatio: string; captionEnabled: boolean; diff --git a/packages/server/src/middlewares/multer.middleware.ts b/packages/server/src/middlewares/multer.middleware.ts new file mode 100644 index 000000000..9803e1584 --- /dev/null +++ b/packages/server/src/middlewares/multer.middleware.ts @@ -0,0 +1,9 @@ +import multer from 'multer'; + +// Configure multer with increased file size limits for video uploads +export const multerConfig = multer({ + storage: multer.memoryStorage(), + limits: { + fileSize: 15 * 1024 * 1024, // 15MB limit + }, +}); diff --git a/packages/server/src/models/clip.editor.model.ts b/packages/server/src/models/clip.editor.model.ts index 9c5aafb07..709e197cf 100644 --- a/packages/server/src/models/clip.editor.model.ts +++ b/packages/server/src/models/clip.editor.model.ts @@ -13,7 +13,8 @@ const ClipEditorSchema = new Schema( events: [ { label: { type: String, default: '' }, - sessionId: { type: Schema.Types.ObjectId, ref: 'Session' }, + sessionId: { type: Schema.Types.ObjectId, ref: 'Session', required: false }, + videoUrl: { type: String, required: false }, }, ], selectedAspectRatio: { type: String, default: '16:9' }, diff --git a/packages/server/src/routes/routes.ts b/packages/server/src/routes/routes.ts index db0169287..7c62e20f5 100644 --- a/packages/server/src/routes/routes.ts +++ b/packages/server/src/routes/routes.ts @@ -250,7 +250,7 @@ const models: TsoaRoute.Models = { "organizationId": {"dataType":"string","required":true}, "stageId": {"dataType":"string"}, "isEditorEnabled": {"dataType":"boolean"}, - "editorOptions": {"dataType":"nestedObjectLiteral","nestedProperties":{"captionColor":{"dataType":"string","required":true},"captionFont":{"dataType":"string","required":true},"captionLinesPerPage":{"dataType":"double","required":true},"captionPosition":{"dataType":"string","required":true},"captionEnabled":{"dataType":"boolean","required":true},"selectedAspectRatio":{"dataType":"string","required":true},"events":{"dataType":"array","array":{"dataType":"nestedObjectLiteral","nestedProperties":{"sessionId":{"dataType":"string","required":true},"label":{"dataType":"string","required":true}}},"required":true},"frameRate":{"dataType":"double","required":true}}}, + "editorOptions": {"dataType":"nestedObjectLiteral","nestedProperties":{"captionColor":{"dataType":"string","required":true},"captionFont":{"dataType":"string","required":true},"captionLinesPerPage":{"dataType":"double","required":true},"captionPosition":{"dataType":"string","required":true},"captionEnabled":{"dataType":"boolean","required":true},"selectedAspectRatio":{"dataType":"string","required":true},"events":{"dataType":"array","array":{"dataType":"nestedObjectLiteral","nestedProperties":{"videoUrl":{"dataType":"string"},"sessionId":{"dataType":"string"},"label":{"dataType":"string","required":true}}},"required":true},"frameRate":{"dataType":"double","required":true}}}, "clipSessionId": {"dataType":"string"}, "clipEditorId": {"dataType":"string"}, }, @@ -3603,9 +3603,9 @@ export function RegisterRoutes(app: Router,opts?:{multer?:ReturnType(IndexController)), - ...(fetchMiddlewares(IndexController.prototype.uploadImges)), + ...(fetchMiddlewares(IndexController.prototype.uploadFile)), - async function IndexController_uploadImges(request: ExRequest, response: ExResponse, next: any) { + async function IndexController_uploadFile(request: ExRequest, response: ExResponse, next: any) { const args: Record = { file: {"in":"formData","name":"file","required":true,"dataType":"file"}, directory: {"in":"formData","name":"directory","required":true,"dataType":"string"}, @@ -3620,7 +3620,7 @@ export function RegisterRoutes(app: Router,opts?:{multer?:ReturnType { console.log('e', e); }); - const events = data.editorOptions.events.filter((e) => e.sessionId !== ''); + const events = data.editorOptions.events; data.editorOptions.events = events; await ClipEditor.create({ ...data.editorOptions, @@ -68,9 +68,20 @@ export class ClipEditorService extends SessionService { async launchRemotionRender(clipEditor: IClipEditor) { // get all event session data based on event session ids + const sessionIds = clipEditor.events + .filter(e => e.sessionId) + .map(e => e.sessionId); + + // Get all sessions in one query const eventSessions = await Session.find({ - _id: { $in: clipEditor.events.map((e) => e.sessionId) }, - }); + _id: { $in: sessionIds }, + }).lean(); + + // Create a map for quick session lookup + const sessionsMap = eventSessions.reduce((acc, session) => { + acc[session._id.toString()] = session; + return acc; + }, {}); // check if all event sessions are completed const allEventSessionsCompleted = eventSessions.every( @@ -84,9 +95,18 @@ export class ClipEditorService extends SessionService { id: config.remotion.id, inputProps: { events: clipEditor.events.map((e) => { - const session = eventSessions.find( - (s) => s._id.toString() === e.sessionId.toString(), // Convert both to strings for comparison - ); + // If event has a direct videoUrl, use that + if (e.videoUrl) { + return { + id: e.label, + label: e.label, + type: 'media', + url: e.videoUrl, + }; + } + + // Otherwise, look up the session from our map + const session = e.sessionId ? sessionsMap[e.sessionId.toString()] : null; if (!session?.source?.streamUrl) { console.log( @@ -98,12 +118,7 @@ export class ClipEditorService extends SessionService { id: e.label, label: e.label, type: 'media', - url: session?.source?.streamUrl, // Provide empty string as fallback - // transcript: { - // language: 'en', - // words: session?.transcripts.chunks, - // text: session?.transcripts.text, - // }, + url: session?.source?.streamUrl || '', // Always provide empty string as fallback }; }), captionLinesPerPage: clipEditor.captionLinesPerPage.toString(), @@ -155,4 +170,4 @@ const clipEditorService = new ClipEditorService( new StateService(), ); -export default clipEditorService; +export default clipEditorService; \ No newline at end of file diff --git a/packages/server/src/services/session.service.ts b/packages/server/src/services/session.service.ts index 0d58e744b..12da4df5b 100644 --- a/packages/server/src/services/session.service.ts +++ b/packages/server/src/services/session.service.ts @@ -105,13 +105,17 @@ export default class SessionService { limit: number; }; }> { - let filter: {} = { - type: { $nin: [SessionType.animation, SessionType.editorClip] }, - }; + let filter: {} = {}; - if (d.type !== undefined) { - filter = { ...filter, type: d.type }; + // Only exclude animations and editor clips if no specific type is requested + if (d.type === undefined) { + console.log('No type specified, excluding animations and editor clips'); + filter = { type: { $nin: [SessionType.animation, SessionType.editorClip] } }; + } else { + console.log('Type specified:', d.type); + filter = { type: d.type }; } + if (d.published != undefined) { filter = { ...filter, published: d.published }; } @@ -148,7 +152,11 @@ export default class SessionService { if (d.onlyVideos) { filter = { ...filter, - $or: [{ playbackId: { $ne: '' } }, { assetId: { $ne: '' } }], + $or: [ + { playbackId: { $ne: '' } }, + { assetId: { $ne: '' } }, + { type: SessionType.animation } + ], }; } if (d.assetId != undefined) { diff --git a/packages/server/src/swagger/swagger.json b/packages/server/src/swagger/swagger.json index dedbc3405..82fff1b35 100644 --- a/packages/server/src/swagger/swagger.json +++ b/packages/server/src/swagger/swagger.json @@ -488,6 +488,9 @@ "events": { "items": { "properties": { + "videoUrl": { + "type": "string" + }, "sessionId": { "type": "string" }, @@ -496,7 +499,6 @@ } }, "required": [ - "sessionId", "label" ], "type": "object" @@ -7452,7 +7454,7 @@ }, "/upload": { "post": { - "operationId": "UploadImges", + "operationId": "UploadFile", "responses": { "200": { "description": "Ok", diff --git a/packages/server/src/utils/s3.ts b/packages/server/src/utils/s3.ts index 8a62c0f18..bebb96820 100644 --- a/packages/server/src/utils/s3.ts +++ b/packages/server/src/utils/s3.ts @@ -28,6 +28,12 @@ export default class StorageService { file: Buffer | Readable, contentType: string, ): Promise { + console.log('๐Ÿ”ง Configuring S3 upload:', { + bucket: name, + filename, + contentType, + }); + const params: PutObjectCommandInput = { Bucket: name, Key: filename, @@ -40,16 +46,22 @@ export default class StorageService { process.env.NODE_ENV === 'development' || process.env.NODE_ENV === 'staging' ) { + console.log('๐Ÿš€ Uploading to development bucket...'); const command = new PutObjectCommand(params); await this.s3Client.send(command); - return `https://streameth-develop.ams3.digitaloceanspaces.com/${filename}`; + const url = `https://streameth-develop.ams3.digitaloceanspaces.com/${filename}`; + console.log('โœ… Upload successful to development:', url); + return url; } else { + console.log('๐Ÿš€ Uploading to production bucket...'); const command = new PutObjectCommand(params); await this.s3Client.send(command); - return `https://streameth-production.ams3.digitaloceanspaces.com/${filename}`; + const url = `https://streameth-production.ams3.digitaloceanspaces.com/${filename}`; + console.log('โœ… Upload successful to production:', url); + return url; } } catch (error) { - console.log('Error uploading file to S3:', error); + console.error('โŒ S3 upload failed:', error); throw error; } } diff --git a/packages/server/src/utils/validateWebhook.ts b/packages/server/src/utils/validateWebhook.ts index 7f752f0b7..0ab3c6652 100644 --- a/packages/server/src/utils/validateWebhook.ts +++ b/packages/server/src/utils/validateWebhook.ts @@ -14,43 +14,86 @@ export function validateRemotionWebhook( return true; } -export function validateWebhook( - livepeerSignature: string, - payload: any, -): boolean { - const elements = livepeerSignature.split(','); - const signatureParts = elements.reduce((acc, element) => { - const [key, value] = element.split('='); - acc[key] = value; - return acc; - }, {}); - - const timestamp = signatureParts['t']; - const signature = signatureParts['v1']; - const signedPayload = JSON.stringify(payload); - - const expectedSignature = crypto - .createHmac('sha256', config.livepeer.webhookSecretKey) - .update(signedPayload) - .digest('hex'); +export const validateWebhook = (signature: string, payload: any): boolean => { + console.log('๐Ÿ” Starting webhook validation'); + try { + if (!signature) { + console.log('โŒ No signature provided'); + return false; + } - const isSignatureValid = crypto.timingSafeEqual( - Buffer.from(signature), - Buffer.from(expectedSignature), - ); + const secret = config.livepeer.webhookSecretKey; + console.log('๐Ÿ”‘ Using webhook secret:', { + secret, + configValue: config.livepeer.webhookSecretKey, + envValue: process.env.LIVEPEER_WEBHOOK_SECRET_FILE, + }); - if (!isSignatureValid) { - return false; - } + // Parse the signature header + const [timestamp, signatureHash] = signature.split(','); + const [, timestampValue] = timestamp.split('='); + const [, hashValue] = signatureHash.split('='); + + console.log('๐Ÿ“ Parsing signature components:', { + timestamp: timestampValue, + hash: hashValue, + }); + + // Check timestamp is within tolerance (1 hour to account for timezone differences) + const tolerance = 60 * 60 * 1000; // 1 hour in milliseconds + const now = Date.now(); + const timestampMs = parseInt(timestampValue); + + if (Math.abs(now - timestampMs) > tolerance) { + console.log('โฐ Timestamp out of tolerance:', { + now: new Date(now).toISOString(), + timestamp: new Date(timestampMs).toISOString(), + difference: Math.abs(now - timestampMs) / (60 * 1000), // difference in minutes + toleranceMinutes: tolerance / (60 * 1000), + }); + return false; + } + + // Construct the string to sign exactly as Livepeer does + const payloadString = JSON.stringify(payload); + console.log('๐Ÿ“œ Raw payload string:', payloadString); - const tolerance = 8 * 60 * 1000; // 8 minutes in milliseconds - const currentTime = Date.now(); // Current time in milliseconds - const isTimestampValid = - Math.abs(currentTime - parseInt(timestamp, 10)) < tolerance; + // Livepeer uses the raw timestamp value concatenated with the payload + const signaturePayload = timestampValue + '.' + payloadString; - if (!isTimestampValid) { + // Calculate expected signature using SHA-256 + const expectedSignature = crypto + .createHmac('sha256', secret) + .update(signaturePayload) + .digest('hex'); + + console.log('๐Ÿ” Comparing signatures:', { + received: hashValue, + expected: expectedSignature, + match: hashValue === expectedSignature, + timestampInfo: { + webhookTime: new Date(timestampMs).toISOString(), + serverTime: new Date(now).toISOString(), + diffMinutes: (now - timestampMs) / (60 * 1000) + } + }); + + const isValid = hashValue === expectedSignature; + console.log(isValid ? 'โœ… Signature valid' : 'โŒ Signature invalid'); + + if (!isValid) { + console.log('๐Ÿ” Debug info:', { + timestampValue, + payloadLength: payloadString.length, + signaturePayloadLength: signaturePayload.length, + secretLength: secret.length, + timezoneOffset: new Date().getTimezoneOffset() + }); + } + + return isValid; + } catch (error) { + console.error('โŒ Error validating webhook:', error); return false; } - - return true; -} +}; diff --git a/packages/server/workers/clips/index.ts b/packages/server/workers/clips/index.ts index 38e5470c5..d1029b181 100644 --- a/packages/server/workers/clips/index.ts +++ b/packages/server/workers/clips/index.ts @@ -22,12 +22,15 @@ interface Segment { } const consumer = async () => { + console.log('๐ŸŽฌ Starting clips worker consumer'); const queue = await clipsQueue(); queue.process(async (job) => { const data = job.data as IClip; + console.log(`๐Ÿ“‹ Processing clip job ${job.id} for session ${data.sessionId}`); try { return await processClip(data); } catch (error) { + console.error(`โŒ Clip processing failed for session ${data.sessionId}:`, error); await Session.findByIdAndUpdate(data.sessionId, { $set: { processingStatus: ProcessingStatus.failed, @@ -39,19 +42,30 @@ const consumer = async () => { }; const processClip = async (data: IClip) => { - console.log('Starting processClip with data:', data); + console.log('๐ŸŽฅ Starting clip processing:', { + sessionId: data.sessionId, + start: data.start, + end: data.end, + hasEditorOptions: !!data.editorOptions, + }); const { sessionId, clipUrl, start, end } = data; try { + console.log('๐Ÿ“ฅ Fetching master playlist from:', clipUrl); const masterResponse = await fetch(clipUrl); if (!masterResponse.ok) { + console.error('โŒ Failed to fetch master playlist:', { + status: masterResponse.status, + statusText: masterResponse.statusText, + }); throw new Error( `Failed to fetch master playlist: ${masterResponse.statusText}`, ); } const masterContent = await masterResponse.text(); - console.log('masterContent', masterContent); + console.log('โœ… Successfully fetched master playlist'); // 2. Find the 1080p variant + console.log('๐Ÿ” Searching for 1080p variant in master playlist'); const linesMaster = masterContent.split('\n'); let variantUrl = ''; let maxBandwidth = -1; @@ -74,25 +88,43 @@ const processClip = async (data: IClip) => { variantUrl = clipUrl.replace('index.m3u8', variantUrl); console.log('Full variant URL:', variantUrl); if (!variantUrl) { - throw new Error('No valid variant found in master playlist'); + console.error('โŒ 1080p variant not found in master playlist'); + throw new Error('1080p variant not found in master playlist'); } + console.log('โœ… Found 1080p variant URL:', variantUrl); const duration = end - start; - console.log('relativeStartSeconds', start, end, duration); + console.log('โฑ๏ธ Clip duration details:', { + start, + end, + duration, + }); + const tempDir = tmpdir(); const concatPath = join(tempDir, `${sessionId}-concat.mp4`); const outputPath = join(tempDir, `${sessionId}.mp4`); + console.log('๐Ÿ“ Temporary file paths:', { + concatPath, + outputPath, + }); // 1. Fetch and parse manifest + console.log('๐Ÿ“ฅ Fetching variant manifest'); const manifestResponse = await fetch(variantUrl); if (!manifestResponse.ok) { + console.error('โŒ Failed to fetch variant manifest:', { + status: manifestResponse.status, + statusText: manifestResponse.statusText, + }); throw new Error( `Failed to fetch manifest ${variantUrl}: ${manifestResponse.statusText}`, ); } const manifestContent = await manifestResponse.text(); + console.log('โœ… Successfully fetched variant manifest'); // 2. Parse segments and their durations + console.log('๐Ÿ” Parsing segments from manifest'); const segments: Segment[] = []; let cumulativeTime = 0; const lines = manifestContent.split('\n'); @@ -122,17 +154,16 @@ const processClip = async (data: IClip) => { } if (segments.length === 0) { + console.error('โŒ No segments found for specified time range:', { start, end }); throw new Error(`No segments found for time range ${start}-${end}`); } - console.log( - `Found ${segments.length} segments for clip from ${start}s to ${end}s`, - ); - console.log('First segment starts at:', segments[0].startTime); - console.log( - 'Last segment starts at:', - segments[segments.length - 1].startTime, - ); + console.log('๐Ÿ“Š Segment analysis:', { + totalSegments: segments.length, + clipDuration: duration, + firstSegmentStart: segments[0].startTime, + lastSegmentStart: segments[segments.length - 1].startTime, + }); // 3. Download segments in parallel with progress tracking const CONCURRENT_DOWNLOADS = 5; @@ -149,16 +180,29 @@ const processClip = async (data: IClip) => { const downloadedMB = downloadedBytes / (1024 * 1024); const totalMB = totalBytes / (1024 * 1024); - console.log( - `Download Progress: ${completedDownloads}/${segments.length} segments ` + - `(${percentComplete.toFixed(1)}%) - ${downloadedMB.toFixed(1)}MB/${totalMB.toFixed(1)}MB`, - ); + console.log('๐Ÿ“ฅ Download progress:', { + completedSegments: completedDownloads, + totalSegments: segments.length, + percentComplete: `${percentComplete.toFixed(1)}%`, + downloadedSize: `${downloadedMB.toFixed(1)}MB`, + totalSize: `${totalMB.toFixed(1)}MB`, + }); }; const downloadSegment = async (segment: Segment, index: number) => { const segmentPath = join(tempDir, `segment_${index}.ts`); + console.log(`๐Ÿ“ฅ Downloading segment ${index}:`, { + startTime: segment.startTime, + duration: segment.duration, + }); + const response = await fetch(segment.url); if (!response.ok) { + console.error(`โŒ Failed to download segment ${index}:`, { + startTime: segment.startTime, + status: response.status, + statusText: response.statusText, + }); throw new Error( `Failed to download segment at ${segment.startTime}s: ${response.statusText}`, ); @@ -203,9 +247,10 @@ const processClip = async (data: IClip) => { }; try { - console.log( - `Starting download of ${segments.length} segments with ${CONCURRENT_DOWNLOADS} concurrent downloads`, - ); + console.log('๐Ÿš€ Starting parallel segment downloads:', { + totalSegments: segments.length, + concurrentDownloads: CONCURRENT_DOWNLOADS, + }); const startTime = Date.now(); segmentPaths.splice( @@ -220,11 +265,13 @@ const processClip = async (data: IClip) => { const duration = (Date.now() - startTime) / 1000; const speed = downloadedBytes / (1024 * 1024) / duration; // MB/s - console.log( - `Downloads completed in ${duration.toFixed(1)}s ` + - `(${speed.toFixed(1)} MB/s average)`, - ); + console.log('โœ… Segment downloads completed:', { + duration: `${duration.toFixed(1)}s`, + averageSpeed: `${speed.toFixed(1)} MB/s`, + totalSize: `${(downloadedBytes / (1024 * 1024)).toFixed(1)}MB`, + }); } catch (error) { + console.error('โŒ Error during segment downloads:', error); // Clean up any partially downloaded segments await Promise.all( segmentPaths @@ -235,28 +282,41 @@ const processClip = async (data: IClip) => { } // 4. Create concat file + console.log('๐Ÿ“ Creating concat file'); const concatFilePath = join(tempDir, `${sessionId}-concat.txt`); const concatContent = segmentPaths .map((path) => `file '${path}'`) .join('\n'); await fs.promises.writeFile(concatFilePath, concatContent); + console.log('โœ… Concat file created:', concatFilePath); // 5. Calculate precise offset from first segment const offsetInFirstSegment = start - segments[0].startTime; + console.log('โšก Calculated clip parameters:', { + offsetInFirstSegment, + totalDuration: duration, + }); return new Promise((resolve, reject) => { + console.log('๐ŸŽฌ Starting FFmpeg concatenation'); // First concatenate required segments ffmpeg() .input(concatFilePath) .inputOptions(['-f', 'concat', '-safe', '0']) .outputOptions(['-c', 'copy']) .output(concatPath) + .on('start', (command) => { + console.log('๐ŸŽฅ FFmpeg concat command:', command); + }) .on('end', () => { + console.log('โœ… FFmpeg concatenation completed'); // Clean up concat file and segment files fs.unlinkSync(concatFilePath); segmentPaths.forEach((path) => fs.unlinkSync(path)); + console.log('๐Ÿงน Cleaned up temporary segment files'); + console.log('๐ŸŽฌ Starting FFmpeg trim operation'); // Then trim the exact portion we need ffmpeg() .input(concatPath) @@ -264,23 +324,27 @@ const processClip = async (data: IClip) => { .outputOptions(['-c copy', '-f mp4', '-movflags +faststart']) .duration(duration) .output(outputPath) + .on('start', (command) => { + console.log('๐ŸŽฅ FFmpeg trim command:', command); + }) .on('end', async () => { try { fs.unlinkSync(concatPath); + console.log('๐Ÿงน Cleaned up concatenated file'); - console.log('Clip creation finished'); + console.log('โœ… Clip creation finished'); const storageService = new StorageService(); const fileBuffer = await fs.promises.readFile(outputPath); - console.log('uploading file to s3'); + console.log('๐Ÿ“ค Uploading clip to S3'); const url = await storageService.uploadFile( 'clips/' + sessionId, fileBuffer, 'video/mp4', ); - console.log('Clip uploaded to:', url); + console.log('โœ… Clip uploaded to S3:', url); if (data.editorOptions) { - console.log('editorOptions', data.editorOptions); + console.log('๐ŸŽจ Processing editor options:', data.editorOptions); // Make sure we're passing a plain object for the update const updateData = { source: { @@ -291,6 +355,7 @@ const processClip = async (data: IClip) => { processingStatus: ProcessingStatus.clipCreated, }; + console.log('๐Ÿ’พ Updating session with clip data'); const session = await Session.findByIdAndUpdate( sessionId, { $set: updateData }, @@ -298,43 +363,61 @@ const processClip = async (data: IClip) => { ); if (!session) { + console.error('โŒ Session not found:', sessionId); throw new Error(`Session not found: ${sessionId}`); } + + console.log('๐Ÿ—ฟ data.editorOptions', data.editorOptions); if (data.editorOptions.captionEnabled) { + console.log('๐ŸŽฏ Starting audio transcription'); await transcribeAudioSession(url, session); + console.log('โœ… Audio transcription completed'); } + console.log('๐Ÿ—ฟ sessionId', sessionId); + console.log('๐ŸŽจ Finding clip editor configuration'); const clipEditor = await ClipEditor.findOne({ clipSessionId: sessionId, }); - console.log('clipEditor', clipEditor); + console.log('๐Ÿ—ฟ clipEditor', clipEditor); + console.log('๐ŸŽฌ Launching Remotion render'); await clipEditorService.launchRemotionRender(clipEditor); - fs.unlinkSync(outputPath); - resolve(true); + console.log('โœ… Remotion render launched'); + + // Update to rendering state + await Session.findByIdAndUpdate(sessionId, + { $set: { processingStatus: ProcessingStatus.rendering } }, + { new: true } + ); } else { - console.log('creating asset from url'); + console.log('๐Ÿ“ค Creating Livepeer asset'); const assetId = await createAssetFromUrl(sessionId, url); - console.log('assetId', assetId); + console.log('โœ… Livepeer asset created:', assetId); - // Make sure we're passing a plain object for the update + console.log('๐Ÿ’พ Updating session with asset ID'); await Session.findByIdAndUpdate(sessionId, { $set: { assetId, + processingStatus: ProcessingStatus.completed, }, }); - fs.unlinkSync(outputPath); - resolve(true); + console.log('โœ… Session updated with asset ID'); } + + fs.unlinkSync(outputPath); + console.log('๐Ÿงน Cleaned up output file'); + console.log('โœ… Clip processing completed successfully'); + resolve(true); } catch (error) { - console.error('Error creating clip:', error); + console.error('โŒ Error in final processing steps:', error); reject(error); } }) .on('progress', (progress) => { - console.log('trimming progress', progress); + console.log('๐ŸŽฅ FFmpeg trim progress:', progress); }) .on('error', async (err) => { - console.error('Error trimming clip:', err); + console.error('โŒ Error during FFmpeg trim:', err); fs.unlinkSync(concatPath); await Session.findByIdAndUpdate(sessionId, { $set: { @@ -346,10 +429,10 @@ const processClip = async (data: IClip) => { .run(); }) .on('progress', (progress) => { - console.log('download progress', progress); + console.log('๐ŸŽฅ FFmpeg concat progress:', progress); }) .on('error', async (err) => { - console.error('Error downloading segments:', err); + console.error('โŒ Error during FFmpeg concat:', err); await Session.findByIdAndUpdate(sessionId, { $set: { processingStatus: ProcessingStatus.failed, @@ -360,7 +443,7 @@ const processClip = async (data: IClip) => { .run(); }); } catch (error) { - console.error('Error processing clip:', error); + console.error('โŒ Fatal error in clip processing:', error); await Session.findByIdAndUpdate(sessionId, { $set: { processingStatus: ProcessingStatus.failed, @@ -372,14 +455,16 @@ const processClip = async (data: IClip) => { const init = async () => { try { + console.log('๐Ÿš€ Initializing clips worker'); await connect(dbConnection.url, { serverSelectionTimeoutMS: 5000, }); + console.log('โœ… Connected to database'); await consumer(); + console.log('โœ… Clips worker initialized successfully'); } catch (err) { - console.error('Worker initialization failed with error:', err); - console.error('Error details:', { + console.error('โŒ Worker initialization failed:', { name: err.name, message: err.message, stack: err.stack, @@ -390,17 +475,17 @@ const init = async () => { // Add more detailed error handlers process.on('unhandledRejection', (error) => { - console.error('Unhandled rejection:', error); + console.error('โŒ Unhandled rejection in clips worker:', error); process.exit(1); }); process.on('uncaughtException', (error) => { - console.error('Uncaught exception:', error); + console.error('โŒ Uncaught exception in clips worker:', error); process.exit(1); }); init().catch((error) => { - console.error('Fatal error during initialization:', { + console.error('โŒ Fatal error during clips worker initialization:', { name: error.name, message: error.message, stack: error.stack, diff --git a/packages/video-uploader/src/config/index.ts b/packages/video-uploader/src/config/index.ts index 3ab82f92b..7176e1891 100644 --- a/packages/video-uploader/src/config/index.ts +++ b/packages/video-uploader/src/config/index.ts @@ -41,10 +41,10 @@ export const config = { remotion: { id: process.env.REMOTION_ID, host: process.env.REMOTION_BASE_URL, - webhookSecretKey: process.env.REMOTION_WEBHOOK_SECRET_FILE, + webhookSecretKey: readSecretFile(process.env.REMOTION_WEBHOOK_SECRET_FILE), webhook: { url: process.env.REMOTION_WEBHOOK_URL, - secret: process.env.REMOTION_WEBHOOK_SECRET_FILE, + secret: readSecretFile(process.env.REMOTION_WEBHOOK_SECRET_FILE), } }, redis: {