iOS with Swift

/// Asks the backend to create the job from the upload: "transcode" (one MP4) or "jobs" (several outputs).
func createJob(inputURL: String, kind: String) async throws -> Job {
    try await send("POST", "api/jobs", body: ["kind": kind, "input_url": inputURL])
}

/// Reads the job every 2 seconds until it ends. A push from your backend (after its webhook) can replace the polling.
func waitForJob(_ job: Job) async throws -> Job {
    var current = job
    while current.isActive {
        try await Task.sleep(nanoseconds: 2_000_000_000)
        current = try await send("GET", "api/jobs/\(current.id)")
    }
    return current
}

Copy failed. The text is selected; copy it with your keyboard.

private func send<T: Decodable>(_ method: String, _ path: String, body: [String: Any]? = nil) async throws -> T {
    var request = URLRequest(url: baseURL.appendingPathComponent(path))
    request.httpMethod = method
    if let body {
        request.setValue("application/json", forHTTPHeaderField: "Content-Type")
        request.httpBody = try JSONSerialization.data(withJSONObject: body)
    }
    let (data, response) = try await session.data(for: request)
    try check(data, response)
    return try JSONDecoder().decode(T.self, from: data)
}

/// An answer outside 2xx becomes its problem details, so the app can show the detail.
private func check(_ data: Data, _ response: URLResponse) throws {
    guard let http = response as? HTTPURLResponse, !(200..<300).contains(http.statusCode) else { return }
    throw (try? JSONDecoder().decode(Problem.self, from: data))
        ?? Problem(title: "The server answered with an error.", detail: "HTTP \(http.statusCode)", code: nil)
}

Copy failed. The text is selected; copy it with your keyboard.

/// Asks the backend for a one-time upload URL, then sends the file straight to Videxo with it.
/// The upload URL holds no API key and takes one PUT, so the app never retries the PUT: when
/// it fails this throws, and the next call creates a new upload.
func upload(file: URL, contentType: String) async throws -> String {
    let size = try FileManager.default.attributesOfItem(atPath: file.path)[.size] as? Int ?? 0
    struct Created: Decodable {
        let input_url: String
        let upload_url: URL
    }
    let created: Created = try await send(
        "POST", "api/uploads",
        body: ["filename": plainName(file.lastPathComponent), "size_bytes": size, "content_type": contentType])
    var put = URLRequest(url: created.upload_url)
    put.httpMethod = "PUT"
    put.setValue(contentType, forHTTPHeaderField: "Content-Type")
    let (data, response) = try await session.upload(for: put, fromFile: file)
    try check(data, response)
    return created.input_url
}

Copy failed. The text is selected; copy it with your keyboard.

private func process(_ file: URL) async {
    running = true
    defer { running = false }
    problem = nil
    job = nil
    // A file from the picker is outside the app's sandbox until it asks for access.
    let access = file.startAccessingSecurityScopedResource()
    defer { if access { file.stopAccessingSecurityScopedResource() } }
    let contentType = UTType(filenameExtension: file.pathExtension)?.preferredMIMEType ?? "application/octet-stream"
    do {
        status = "Uploading"
        let inputURL = try await backend.upload(file: file, contentType: contentType)
        let created = try await backend.createJob(inputURL: inputURL, kind: kind)
        status = "Job \(created.id): \(created.state)"
        let ended = try await backend.waitForJob(created)
        status = "Job \(ended.id): \(ended.state)"
        job = ended
    } catch {
        status = ""
        problem = error.localizedDescription
    }
}

Copy failed. The text is selected; copy it with your keyboard.

/// The backend's download route: it redirects to a fresh signed link. Opened with a `Link`, the
/// browser follows it; with `session.download(from:)` the app saves the file itself.
func downloadURL(job: Job, output: Output) -> URL {
    baseURL.appendingPathComponent("api/jobs/\(job.id)/outputs/\(output.alias)")
}

Copy failed. The text is selected; copy it with your keyboard.