6bf8bebf51
CI / Test and Build (push) Failing after 1s
CI / Migrate Dev DB (push) Has been skipped
CI / Migrate DB (push) Has been skipped
CodeQL / Analyze actions (push) Has been cancelled
CodeQL / Analyze javascript-typescript (push) Has been cancelled
CI / Detect Version (push) Has been cancelled
CI / Detect Desktop Changes (push) Has been cancelled
CI / Build AMD64 (blacksmith-2vcpu-ubuntu-2404, ./docker/cron.Dockerfile, ubuntu-latest, ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Build AMD64 (blacksmith-2vcpu-ubuntu-2404, ./docker/db.Dockerfile, ECR_MIGRATIONS, ubuntu-latest, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build AMD64 (blacksmith-4vcpu-ubuntu-2404, ./docker/pii.Dockerfile, ECR_PII, ubuntu-latest, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build AMD64 (blacksmith-4vcpu-ubuntu-2404, ./docker/realtime.Dockerfile, ECR_REALTIME, ubuntu-latest, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build AMD64 (blacksmith-8vcpu-ubuntu-2404, ./docker/app.Dockerfile, ECR_APP, linux-x64-8-core, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/cron.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/db.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/pii.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/realtime.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-8vcpu-ubuntu-2404-arm, ./docker/app.Dockerfile, linux-arm64-8-core, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Check Docs Changes (push) Has been cancelled
Publish CLI Package / publish-npm (push) Has been cancelled
Publish Python SDK / publish-pypi (push) Has been cancelled
CI / Deploy Trigger.dev (Dev) (push) Has been cancelled
Helm Chart / Lint, test, and validate chart (push) Has been cancelled
Helm Chart / Chart version bumped (push) Has been cancelled
Publish TypeScript SDK / publish-npm (push) Has been cancelled
CI / Build Dev ECR (blacksmith-8vcpu-ubuntu-2404, ./docker/app.Dockerfile, ECR_APP, linux-x64-8-core) (push) Has been cancelled
CI / Promote Images (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-2vcpu-ubuntu-2404, ./docker/db.Dockerfile, ECR_MIGRATIONS, ubuntu-latest) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-4vcpu-ubuntu-2404, ./docker/pii.Dockerfile, ECR_PII, ubuntu-latest) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-4vcpu-ubuntu-2404, ./docker/realtime.Dockerfile, ECR_REALTIME, ubuntu-latest) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Process Docs (push) Has been cancelled
CI / Create GitHub Release (push) Has been cancelled
CI / Check Desktop Signing Secrets (push) Has been cancelled
CI / Desktop Release (push) Has been cancelled
CI / Create Desktop Prerelease (push) Has been cancelled
CI / Desktop Prerelease Build (push) Has been cancelled
CI / Publish Desktop Prerelease (push) Has been cancelled
CI / Prune Desktop Prereleases (push) Has been cancelled
Helm Chart / Install on kind and run helm test (push) Has been cancelled
82 lines
3.0 KiB
TypeScript
82 lines
3.0 KiB
TypeScript
import { createHash } from 'node:crypto'
|
|
import { createLogger } from '@sim/logger'
|
|
import { getErrorMessage } from '@sim/utils/errors'
|
|
import { downloadFile, uploadFile } from '@/lib/uploads/core/storage-service'
|
|
import { isHevcHeifContainer, transcodeHeicToJpeg } from '@/lib/uploads/server/heic'
|
|
|
|
const logger = createLogger('ImageDerivative')
|
|
|
|
/**
|
|
* Keyed by the source's storage key rather than a hash of its bytes. Workspace keys
|
|
* are regenerated on every content replacement, so the key is already a content
|
|
* version — using it avoids streaming the whole original just to hash it.
|
|
*/
|
|
function derivativeKey(storageKey: string): string {
|
|
const hash = createHash('sha256').update(storageKey, 'utf-8').digest('hex')
|
|
return `image-derivative/${hash}.jpg`
|
|
}
|
|
|
|
async function loadDerivative(storageKey: string): Promise<Buffer | null> {
|
|
try {
|
|
return await downloadFile({ key: derivativeKey(storageKey), context: 'copilot' })
|
|
} catch {
|
|
return null
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Stores the derivative, swallowing failure.
|
|
*
|
|
* Unlike the compiled-doc store — which throws, because its serve path is load-only
|
|
* and cannot rebuild a missing artifact — a miss here is fully recoverable: the next
|
|
* read transcodes again. Failing the request would turn a cache problem into a broken
|
|
* image for bytes we have already rendered successfully.
|
|
*/
|
|
async function storeDerivative(storageKey: string, jpeg: Buffer): Promise<void> {
|
|
try {
|
|
await uploadFile({
|
|
file: jpeg,
|
|
fileName: 'derivative.jpg',
|
|
contentType: 'image/jpeg',
|
|
context: 'copilot',
|
|
customKey: derivativeKey(storageKey),
|
|
preserveKey: true,
|
|
})
|
|
} catch (error) {
|
|
logger.warn('Failed to store image derivative', {
|
|
storageKey,
|
|
error: getErrorMessage(error),
|
|
})
|
|
}
|
|
}
|
|
|
|
/**
|
|
* A browser-renderable form of stored image bytes, or `null` when the stored bytes
|
|
* are already renderable and should be served untouched.
|
|
*
|
|
* Only HEVC-coded HEIF needs this today: no browser outside Safari decodes it, and
|
|
* serving it under `X-Content-Type-Options: nosniff` guarantees a broken image.
|
|
* AV1-coded HEIF (`.avif`) renders natively everywhere and is left alone — probing
|
|
* it would cost a decode that can only fail. The transcoded JPEG is cached, because
|
|
* a preview is re-fetched on every view and the WebAssembly decode costs roughly a
|
|
* second for a phone photo.
|
|
*
|
|
* The original always remains the stored object — this runs only for `preview=1`
|
|
* requests, so it never rewrites what a download hands back.
|
|
*/
|
|
export async function resolveServableImageBytes(
|
|
buffer: Buffer,
|
|
storageKey: string
|
|
): Promise<{ buffer: Buffer; contentType: string } | null> {
|
|
if (!isHevcHeifContainer(buffer)) return null
|
|
|
|
const cached = await loadDerivative(storageKey)
|
|
if (cached) return { buffer: cached, contentType: 'image/jpeg' }
|
|
|
|
const jpeg = await transcodeHeicToJpeg(buffer)
|
|
if (!jpeg) return null
|
|
|
|
await storeDerivative(storageKey, jpeg)
|
|
return { buffer: jpeg, contentType: 'image/jpeg' }
|
|
}
|