API Reference

interface UploadOptions {
  /** Unique identifier for this content (used for key derivation) */
  contentId: string

  /** Key server URL including the /keys path (e.g., "https://your-worker.workers.dev/keys") */
  keyServerUrl: string

  /** URL of the presign endpoint */
  presignUrl: string

  /** Returns a Bearer token for auth (called for key fetch and presign requests) */
  auth?: () => Promise<string>

  /** Called after each segment is uploaded */
  onProgress?: (progress: { completed: number; total: number }) => void

  /** AbortSignal to cancel the upload */
  signal?: AbortSignal

  /** Number of parallel uploads (default: 4) */
  concurrency?: number

  /** S3 key prefix (default: "content/<contentId>/") */
  prefix?: string
}

interface SegmentInput {
  /** Segment number (used for IV derivation) */
  index: number

  /** Raw .ts segment bytes (plaintext — will be encrypted) */
  data: Uint8Array

  /** Object key/path in storage (e.g., "seg-0.ts") */
  key: string
}

interface UploadResult {
  /** URL of the uploaded (rewritten) manifest */
  manifestUrl: string

  /** URLs of uploaded encrypted segments, in order */
  segmentUrls: string[]

  /** Total number of segments uploaded */
  segmentCount: number
}

{ completed: number; total: number }

import { rewriteManifest } from "@blindcast/storage"

interface RewriteOpts {
  /** Key server base URL — /keys/:contentId is appended automatically */
  keyServerUrl: string

  /** Content identifier (used in the EXT-X-KEY URI) */
  contentId: string

  /** Map original segment filenames → uploaded URLs */
  segmentUrlMap: Record<string, string>

  /** If set, insert new EXT-X-KEY every N segments (key rotation) */
  segmentsPerEpoch?: number
}