Use EdgeSpark storage

import type { BucketDef } from "@sdk/server-types";

export const uploads: BucketDef<"uploads"> = {
  bucket_name: "uploads",
  description: "User-uploaded files",
};

export const avatars: BucketDef<"avatars"> = {
  bucket_name: "avatars",
  description: "Profile photos",
};

import { storage } from "edgespark";
import { Hono } from "hono";
import { buckets } from "@defs";

const app = new Hono().post("/api/reports/export", async (c) => {
  const csv = [
    "id,title",
    "1,Quarterly report",
    "2,Annual report",
  ].join("\\n");

  const path = `reports/export-${Date.now()}.csv`;
  await storage.from(buckets.uploads).put(path, new TextEncoder().encode(csv), {
    contentType: "text/csv",
  });

  return c.json({ path }, 201);
});

export default app;

import { storage } from "edgespark";
import { Hono } from "hono";
import { buckets } from "@defs";

const app = new Hono().get("/api/documents/:filename", async (c) => {
  const filename = c.req.param("filename");
  const { downloadUrl } = await storage
    .from(buckets.uploads)
    .createPresignedGetUrl(`documents/${filename}`, 3600);

  return c.json({ downloadUrl });
});

export default app;

import { storage } from "edgespark";
import { Hono } from "hono";
import { buckets } from "@defs";

const app = new Hono().get("/api/reports/:filename/raw", async (c) => {
  const object = await storage
    .from(buckets.uploads)
    .get(`reports/${c.req.param("filename")}`);

  if (!object) return c.json({ error: "Not found" }, 404);

  return new Response(object.body, {
    headers: {
      "Content-Type": object.metadata.contentType ?? "application/octet-stream",
    },
  });
});

export default app;

import { storage } from "edgespark";
import { Hono } from "hono";
import { buckets } from "@defs";

const app = new Hono()
  .get("/api/documents", async (c) => {
    const files = await storage.from(buckets.uploads).list({ prefix: "documents/" });
    return c.json(files);
  })
  .delete("/api/documents/:filename", async (c) => {
    await storage.from(buckets.uploads).delete(`documents/${c.req.param("filename")}`);
    return c.body(null, 204);
  });

export default app;

import { storage } from "edgespark";
import { auth } from "edgespark/http";
import { Hono } from "hono";
import { buckets } from "@defs";

const app = new Hono().post("/api/upload-url", async (c) => {
  const { filename, contentType } = await c.req.json<{
    filename: string;
    contentType?: string;
  }>();

  const path = `uploads/${auth.user.id}/${Date.now()}-${filename}`;
  const { uploadUrl, requiredHeaders } = await storage
    .from(buckets.uploads)
    .createPresignedPutUrl(path, 3600, {
      contentType,
    });

  return c.json({ uploadUrl, requiredHeaders, path });
});

export default app;