Bunny Storage

bun add @ooneex/storage @bunny.net/storage-sdk

STORAGE_BUNNY_ACCESS_KEY=your_access_key
STORAGE_BUNNY_STORAGE_ZONE=your-zone
STORAGE_BUNNY_REGION=de

import { container } from "@ooneex/container";
import { BunnyStorage } from "@ooneex/storage";

const storage = container.get(BunnyStorage).setBucket("uploads");

// Write content — returns the number of bytes written
await storage.put("avatars/123.png", file); // file: Blob | BunFile | ArrayBuffer | ...
await storage.put("config.json", JSON.stringify({ theme: "dark" }));

// Read it back
const config = await storage.getAsJson<{ theme: string }>("config.json");
const buffer = await storage.getAsArrayBuffer("avatars/123.png");

// Existence, listing, and removal
await storage.exists("avatars/123.png"); // true
const keys = await storage.list();
await storage.delete("avatars/123.png");

// Upload one local file, or a directory recursively (images only)
await storage.putFile("avatars/123.png", "/tmp/avatar.png");
await storage.putDir("avatars", {
  path: "/tmp/avatars",
  filter: /\.(png|jpe?g)$/,
});

// Stream a large object straight to the response
const stream = storage.getAsStream("videos/intro.mp4");
return new Response(stream);

bun add @ooneex/app @ooneex/storage @bunny.net/storage-sdk

import { inject } from "@ooneex/container";
import { BunnyStorage } from "@ooneex/storage";

export class MediaService {
  constructor(@inject(BunnyStorage) private readonly storage: BunnyStorage) {}

  public async uploadAvatar(userId: string, file: Blob): Promise<void> {
    await this.storage.setBucket("uploads").put(`avatars/${userId}.png`, file);
  }
}

import { decorator } from "@ooneex/storage";
import { BunnyStorage } from "@ooneex/storage";

@decorator.storage()
export class AvatarStorage extends BunnyStorage {}

import { StorageException } from "@ooneex/storage";

try {
  await storage.put("avatars/123.png", file);
} catch (error) {
  if (error instanceof StorageException) {
    logger.error(`Storage error [${error.key}]: ${error.message}`, error.data);
  }
  throw error;
}