Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/improsocial/impro
An extensible Bluesky client for web impro.social
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135import { wait } from "/js/utils.js";
export const VIDEO_MAX_BYTES = 100_000_000;export const VIDEO_MAX_DURATION_S = 180;export const VIDEO_MIME_TYPES = [ "video/mp4", "video/mpeg", "video/webm", "video/quicktime", "image/gif",];
export class VideoValidationError extends Error { constructor(message, code) { super(message); this.code = code; }}
export function isGifFile(file) { return file.type === "image/gif";}
export function validateVideoFile(file) { if (!VIDEO_MIME_TYPES.includes(file.type)) { throw new VideoValidationError( "Unsupported video format. Please use mp4, webm, mov, mpeg, or gif.", "UNSUPPORTED_TYPE", ); } if (file.size > VIDEO_MAX_BYTES) { throw new VideoValidationError( `Video is too large. Maximum size is ${Math.round(VIDEO_MAX_BYTES / 1_000_000)} MB.`, "TOO_LARGE", ); }}
function readGifMetadata(file) { return new Promise((resolve, reject) => { const image = new Image(); const url = URL.createObjectURL(file); image.onload = () => { const width = image.naturalWidth; const height = image.naturalHeight; URL.revokeObjectURL(url); const aspectRatio = width > 0 && height > 0 ? { width, height } : null; resolve({ duration: null, width, height, aspectRatio }); }; image.onerror = () => { URL.revokeObjectURL(url); reject( new VideoValidationError("Could not read GIF file.", "UNREADABLE"), ); }; image.src = url; });}
export function readVideoMetadata(file) { if (isGifFile(file)) { return readGifMetadata(file); } return new Promise((resolve, reject) => { const video = document.createElement("video"); video.preload = "metadata"; const url = URL.createObjectURL(file); video.src = url; video.onloadedmetadata = () => { const duration = video.duration; const width = video.videoWidth; const height = video.videoHeight; URL.revokeObjectURL(url); if (duration > VIDEO_MAX_DURATION_S) { reject( new VideoValidationError( `Video is too long. Maximum duration is ${VIDEO_MAX_DURATION_S} seconds.`, "TOO_LONG", ), ); return; } // Leave aspectRatio unset when dimensions are missing - matches // social-app, which prefers an absent field to a 0 value that would // fail lexicon validation. const aspectRatio = width > 0 && height > 0 ? { width, height } : null; resolve({ duration, width, height, aspectRatio }); }; video.onerror = () => { URL.revokeObjectURL(url); reject( new VideoValidationError("Could not read video file.", "UNREADABLE"), ); }; });}
export class VideoUploader { constructor(api) { this.api = api; }
async upload(file, { onJobStart, onProgress, signal, intervalMs } = {}) { const limits = await this.api.getVideoUploadLimits({ signal }); if (!limits.canUpload) { throw new Error(limits.message || "Video uploads are not allowed"); } const job = await this.api.uploadVideoBlob(file, { signal }); onJobStart?.(job); return await this.pollJob(job.jobId, { onProgress, signal, intervalMs }); }
async pollJob(jobId, { onProgress, signal, intervalMs = 1500 } = {}) { while (true) { if (signal) { signal.throwIfAborted(); } const status = await this.api.getVideoJobStatus(jobId, { signal }); onProgress?.(status.state, status.progress ?? 0); if (status.state === "JOB_STATE_COMPLETED") { if (!status.blob) { throw new Error("Video job completed but returned no blob"); } return status.blob; } if (status.state === "JOB_STATE_FAILED") { throw new Error( status.error || status.message || "Video processing failed", ); } await wait(intervalMs); } }}