Function createVideoAndGetUploadUrl

apps/web/actions/video/upload.ts:112–264

({
	videoId,
	duration,
	resolution,
	videoCodec,
	audioCodec,
	isScreenshot = false,
	isUpload = false,
	folderId,
	orgId,
	screenshotContentType,
	supportsUploadProgress = false,
}: {
	videoId?: Video.VideoId;
	duration?: number;
	resolution?: string;
	videoCodec?: string;
	audioCodec?: string;
	isScreenshot?: boolean;
	isUpload?: boolean;
	folderId?: Folder.FolderId;
	orgId: Organisation.OrganisationId;
	screenshotContentType?: string;
	// TODO: Remove this once we are happy with it's stability
	supportsUploadProgress?: boolean;
})

}

export async function createVideoAndGetUploadUrl({
	videoId,
	duration,
	resolution,
	videoCodec,
	audioCodec,
	isScreenshot = false,
	isUpload = false,
	folderId,
	orgId,
	screenshotContentType,
	supportsUploadProgress = false,
}: {
	videoId?: Video.VideoId;
	duration?: number;
	resolution?: string;
	videoCodec?: string;
	audioCodec?: string;
	isScreenshot?: boolean;
	isUpload?: boolean;
	folderId?: Folder.FolderId;
	orgId: Organisation.OrganisationId;
	screenshotContentType?: string;
	// TODO: Remove this once we are happy with it's stability
	supportsUploadProgress?: boolean;
}) {
	const user = await getCurrentUser();

	if (!user) throw new Error("Unauthorized");

	try {
		if (!userIsPro(user) && duration && duration > 300)
			throw new Error("upgrade_required");

		await requireOrganizationAccess(user.id, orgId);

		const date = new Date();
		const formattedDate = `${date.getDate()} ${date.toLocaleString("default", {
			month: "long",
		})} ${date.getFullYear()}`;

		if (videoId) {
			const [existingVideo] = await db()
				.select()
				.from(videos)
				.where(eq(videos.id, videoId));

			if (existingVideo) {
				if (existingVideo.ownerId !== user.id) throw new Error("Forbidden");

				const existingVideoDomain = Video.Video.decodeSync({
					...existingVideo,
					bucketId: existingVideo.bucket,
					storageIntegrationId: existingVideo.storageIntegrationId,
					createdAt: existingVideo.createdAt.toISOString(),
					updatedAt: existingVideo.updatedAt.toISOString(),
					metadata: existingVideo.metadata,
				});