SDK Quickstart

import { createPipelynClient } from '@pipelyn/sdk'

const client = createPipelynClient({
  baseUrl: 'http://localhost:7990/api',
  defaultPreset: 'web',
})

const file = new File([bytes], 'sample.jpg', { type: 'image/jpeg' })

const result = await client.optimizeImage({
  media: file,
  preset: 'mobile',
})

console.log(result.savedPercent)
console.log(result.strategy)

const video = new File([videoBytes], 'clip.mp4', { type: 'video/mp4' })

const result = await client.optimizeVideo({
  media: video,
  preset: 'low-bandwidth',
})

console.log(result.outputBytes)

import { PipelynError } from '@pipelyn/sdk'

try {
  await client.optimizeMedia({ media: file })
} catch (error) {
  if (error instanceof PipelynError) {
    console.log(error.code, error.status, error.retriable)
  }
}

const presets = await client.getPresets()
console.log(presets.defaultPreset)

const client = createPipelynClient({
  baseUrl: 'https://your-instance.example.com/api',
  apiKey: process.env.PIPELYN_API_KEY,
})

// Submit and get a job ID immediately
const job = await client.submitJob({
  media: videoFile,
  preset: 'low-bandwidth',
})
console.log(job.jobId, job.status) // "pending"

// Poll until done (default: 5-minute timeout, 1 s poll interval)
const result = await client.waitForJob(job.jobId)

if (result.downloadUrl) {
  // Fetch the optimized file from the returned URL
  const res = await fetch(result.downloadUrl)
  const blob = await res.blob()
}

const status = await client.getJobStatus(job.jobId)
if (status.status === 'done') {
  console.log(status.result?.savedPercent)
}

const usage = await client.getUsage()
console.log(`${usage.totalJobs} jobs, ${(usage.totalSavedBytes / 1e6).toFixed(1)} MB saved`)