BLOBBYFACE

import { Hono } from "npm:hono"; import { blobby } from "https://esm.town/v/yawnxyz/blobby"; import { fileTypeFromBuffer } from 'npm:file-type'; import { modifyFetchHandler } from "https://esm.town/v/andreterron/codeOnValTown?v=50"; import { passwordAuth } from "https://esm.town/v/pomdtr/password_auth?v=74"; // import { MagikaNode as Magika } from "npm:magika"; // doesn't yet work :( const app = new Hono(); const DOWNLOAD_URL = "https://yawnxyz-serve.web.val.run"; // https://yawnxyz-serve.web.val.run/myImage.jpg // Define an array of JSON objects let blobbyList = await blobby.list(); // blobbyList = blobbyList.slice(0, 40); // prototyping console.log('blobbyList:', blobbyList.length); async function streamToBuffer(stream) { const chunks = []; const reader = stream.getReader(); while (true) { const { done, value } = await reader.read(); if (done) { break; } chunks.push(value); } return new Uint8Array(chunks.reduce((acc, chunk) => acc.concat(Array.from(chunk)), [])); } async function detectFileType(buffer) { const type = await fileTypeFromBuffer(buffer); // return type ? type.mime : 'unknown'; return type ? type.mime : 'text/plain'; } export async function get(key, c) { let result = await blobby.get(key); // console.log('raw result for key:', result, typeof result); if (typeof result == 'string') { try { result = JSON.parse(result); } catch (e) { /* not a json */ } } else if (result instanceof Response) { if (result.body instanceof ReadableStream) { // let resultBlob = await result.blob(); const buffer = await streamToBuffer(result.body); const fileType = await detectFileType(buffer); // Set the appropriate content type header c.header('Content-Type', fileType); return c.body(buffer); } } return c.json(result); } // Endpoint to fetch blob by key app.get("/blob/:key", async (c) => { const key = c.req.param('key'); console.log('blobbing for key:', key); return await get(key, c); }); // Endpoint to delete blob by key // use /get instead of /delete — yes this is super hacky/leaky but this is for prototoyping app.get("/delete/:key", async (c) => { const key = c.req.param('key'); console.log('deleting key:', key); let result = await blobby.delete(key); return c.json(result); }); // Endpoint to create blob by key app.get("/create/:key", async (c) => { const key = c.req.param('key'); const value = c.req.query('val'); let jsonValue; try { jsonValue = JSON.parse(value); } catch (e) { // If parsing fails, use the original value jsonValue = value; } await blobby.set(key, jsonValue); return await get(key, c); }); app.get("/rename", async (c) => { const key = c.req.query('key'); const newKey = c.req.query('newKey'); if (!key || !newKey) { return c.text('Missing key or newKey', 400); } try { await blobby.move(key, newKey); return c.text('Renamed successfully'); } catch (error) { console.error('Error renaming blob:', error); return c.text('Failed to rename blob', 500); } }); app.get("/uploadUrl", async (c) => { const key = c.req.query('key'); const url = c.req.query('url'); await blobby.uploadFromUrl(key, url) return await get(key, c); }); // Endpoint to create blob by key app.post("/create/:key", async (c) => { let key = c.req.param('key'); const value = await c.req.json(); key = value.key || key ; await blobby.set(key, value) console.log('update/created key:', key, value, await blobby.get(key)); return c.text('ok'); }); app.post("/upload/:key", async (c) => { let key = c.req.param('key'); const contentType = c.req.raw.headers.get("content-type") || ""; // Handle file uploads from form data if (contentType.startsWith("multipart/form-data")) { const formData = await c.req.parseBody(); console.log('formData:', typeof formData, formData); key = formData.get('key') || key; if (formData.file instanceof File) { console.log("Uploading file:", formData.file.name); await blobby.upload(key, await formData.file.arrayBuffer()); console.log("File uploaded successfully"); return c.text('File uploaded successfully'); } else { console.log("No file found in the form data"); return c.text('No file found in the form data', 400); } } else { console.log("Invalid content type. Expected multipart/form-data"); return c.text('Invalid content type. Expected multipart/form-data', 400); } }); // Serve the HTML page with Alpine.js app.get("/", (c) => { const initialFilter = c.req.query('filter') || ''; const html = ` BLOBBYFACE

BlobbyFace:

All your blobs in one place

`; return c.html(html); }); app.get("/id/:key", async (c) => { const key = c.req.param('key'); const blob = await blobby.get(key); if (!blob) { return c.notFound(); } const html = ` Blob: ${key}

Blob:

Back to All Blobs

`; return c.html(html); }); // export default app.fetch; export default passwordAuth(app.fetch, { // password: "123", // Deno.env.get("AUTH_TEST"), });

blobbyFace