API

import { createBetterMedia } from "@better-media/framework";
import { FileSystemStorageAdapter } from "@better-media/adapter-storage-filesystem";
import { memoryDatabase } from "@better-media/adapter-db-memory";
import { validationPlugin } from "@better-media/plugin-validation";

export const media = createBetterMedia({
  storage: new FileSystemStorageAdapter({ baseDir: "./uploads" }),
  database: memoryDatabase(),
  plugins: [validationPlugin({ maxSize: "10mb" })],
});

await media.upload.ingest({
  file: { path: req.file.path },           // or: { buffer }, { stream }, { url }
  metadata: {
    filename: req.file.originalname,
    mimeType: req.file.mimetype,
    size: req.file.size,
    context: { userId: req.user.id },      // arbitrary — passed into plugins
  },
  key: "avatars/photo.jpg",               // optional; derived from filename if omitted
});

import type { Request, Response } from "express";
import { media } from "../lib/media";

export async function postUpload(req: Request, res: Response) {
  if (!req.file) {
    res.status(400).json({ error: "No file" });
    return;
  }

  const result = await media.upload.ingest({
    file: { path: req.file.path },
    metadata: {
      filename: req.file.originalname,
      mimeType: req.file.mimetype,
      size: req.file.size,
    },
  });

  res.json({ id: result.id, key: result.key, status: result.status });
}

// 1. Issue token
const presign = await media.upload.requestPresignedUpload("user/123/avatar.png", {
  contentType: "image/png",
});

// 2. Browser uploads to presign.url (adapter-specific)

// 3. Run pipeline after bytes land in storage
const result = await media.upload.complete("user/123/avatar.png", {
  filename: "avatar.png",
  mimeType: "image/png",
  context: { userId: "123" },
});

import { ValidationError, AdapterError } from "@better-media/framework";

try {
  const result = await media.upload.ingest({ ... });
} catch (e) {
  if (e instanceof ValidationError) return res.status(400).json({ error: e.message });
  if (e instanceof AdapterError) return res.status(502).json({ error: "Storage error" });
  throw e;
}