import { Storage, createInMemory } from "@anabranch/storage";

const connector = createInMemory({ prefix: "files/" });
const storage = await Storage.connect(connector).run();

await storage.put("hello.txt", "Hello, World!").run();
const object = await storage.get("hello.txt").run();
console.log(await new Response(object.body).text());

const connector = createInMemory();
const storage = await Storage.connect(connector).run();

await storage.put("users/1.json", '{"name": "Alice"}');
await storage.put("users/2.json", '{"name": "Bob"}');

const { successes, errors } = await storage.list("users/")
  .withConcurrency(5)
  .map(async (entry) => await processEntry(entry))
  .tapErr((err) => console.error("Failed:", err))
  .partition();

import { Storage, createInMemory } from "@anabranch/storage";

const connector = createInMemory();
const storage = await Storage.connect(connector).run();

await storage.put("image.png", imageBytes, { contentType: "image/png" }).run();
const metadata = await storage.head("image.png").run();
console.log(metadata.contentType, metadata.size);

await storage.put("important.txt", data)
  .retry({ attempts: 3, delay: (attempt) => 100 * Math.pow(2, attempt) })
  .timeout(30_000)
  .run();