import { blob } from "https://esm.town/v/std/blob"; export { blob }; // this causes timeouts for uploadfromfileurl // import { fetch } from "https://esm.town/v/std/fetch"; export class Blobby { // by default we have no prefixes or scope, whicm neans these will need to be managed by // the setters / calling function. These are used as shortcuts, but they can cause a lot of confusion // if you forget they were set (oops) // use prefix to set major scope, like project name or file type prefix = ""; // "kv", "blob", "file:" etc. // use scope as a foldering system, like username or index/lookup scope = ""; // "user", "project", "folder/subfolder/file" constructor(prefix: string = "", scope: string = "") { this.scope = scope ? `${scope}:` : ""; } getKey(key: string = ""): string { // output: "prefix/scope/filename" // output: "audiogen/user3/somefile.mp3" return (this.prefix&&this.prefix+"/") + (this.scope&&this.scope+"/") + key; } // accessors / CRUDers // blob uses these for http, but we just use these to get/set values async get(key: string): Promise { // this could be a json most likely... but also a readable stream of some object // return await blob.getJSON(this.getKey(key)); let result try { result = await blob.getJSON(key); } catch(e) { // handling blobs; don't consume arraybuffers here tho? result = await blob.get(key); } return result } async set(key: string, value: any): Promise { await blob.setJSON(this.getKey(key), value); } async delete(key: string): Promise { await blob.delete(this.getKey(key)); } async copy(sourceKey: string, destinationKey: string): Promise { await blob.copy(sourceKey, destinationKey); } // renames the blob async move(sourceKey: string, destinationKey: string): Promise { await blob.move(sourceKey, destinationKey); } // strips prefix and scope from returned list of blobs // doing this can get SUPER CONFUSING lol strip(bloblist, prefix?, scope?) { prefix = prefix||this.prefix scope = scope||this.scope return bloblist.map((blob) => blob.slice(prefix.length + scope.length)); } // prefer using the static version to strip instead, on the calling function static strip(bloblist, prefix?, scope?) { return bloblist.map((blob) => blob.slice(prefix.length + scope.length)); } // strips prefix and scope from returned list of blobs // doing this can get SUPER CONFUSING lol // async list(strip?: boolean): Promise { // const bloblist = await blob.list(this.getKey(key)); // if(strip) return this.strip(bloblist) // return bloblist // } async list(key?: string): Promise { const bloblist = await blob.list(this.getKey(key)); // return this.strip(bloblist) return bloblist } // gets the list and the content // really slow!! But kind of useful. Use sparingly async listGet(key?: string): Promise { const bloblist = await blob.list(this.getKey(key)); let objects = {} await Promise.all(bloblist.map(async (item) => { try { // some of the values are stored as json strings, others are stored as json. // we make sure they're not json-strings let result = await blob.getJSON(item.key); try { result = JSON.parse(result); } catch(e) {} item["json"] = result; } catch(e) { // handling blobs; don't consume arraybuffers here tho? item["stream"] = await blob.get(item.key) } objects[item.key] = item })) return objects } // is this even used? // lists all values within blobby's prefix async listFull(key?: string): Promise { const bloblist = await blob.list(this.getKey(key)); return bloblist // return keys.map((item) => item.key?.slice(this.prefix.length + this.scope.length)); } // static async listByScope(scope: string): Promise { // const prefix = `kv:${scope}:`; // const keys = await blob.list(prefix); // console.log('[listByScope]', keys); // return keys.map((item) => item.key?.slice(prefix.length)); // } // file blob management async upload(key: string, data: string | ArrayBuffer | Blob): Promise { await blob.set(this.getKey(key), data); } async uploadFromUrl(key: string, url: string): Promise { // Ensure the URL starts with HTTPS if (!url.startsWith('https://')) { url = 'https://' + url.replace(/^(http:\/\/)?/, ''); } const response = await fetch(url); const arrayBuffer = await response.arrayBuffer(); await blob.set(this.getKey(key), arrayBuffer); } // serves to be displayed in browser instead of download (eg for images, PDFs) async serve(key: string, rangeHeader?: string): Promise { const stored = await blob.get(this.getKey(key)); const contentType = getContentType(key); // Get the actual file size const arrayBuffer = await stored.arrayBuffer(); const fileSize = arrayBuffer.byteLength; const headers = new Headers({ "Content-Type": contentType, "Accept-Ranges": "bytes", "Content-Length": fileSize.toString(), "Content-Disposition": "inline", // Ensure content is displayed inline }); if (rangeHeader) { const parts = rangeHeader.replace(/bytes=/, "").split("-"); const start = parseInt(parts[0], 10); const end = parts[1] ? parseInt(parts[1], 10) : fileSize - 1; const chunksize = end - start + 1; headers.set("Content-Range", `bytes ${start}-${end}/${fileSize}`); headers.set("Content-Length", chunksize.toString()); const slicedBuffer = arrayBuffer.slice(start, end + 1); return new Response(slicedBuffer, { headers, status: 206, }); } // Ensure the Content-Disposition is inline for PDFs if (contentType === 'application/pdf') { headers.set("Content-Disposition", "inline"); } return new Response(arrayBuffer, { headers, status: 200, }); } async download(key: string): Promise { const stored = await blob.get(this.getKey(key)); return new Response(stored.body, { headers: stored.headers, }); } // these are for reading/writing documents // this one's the same as download, but use this for docs ("upload" is the wrong word) async write(key: string, data: string | ArrayBuffer | Blob): Promise { await blob.set(this.getKey(key), data); } // consume / read a blob response — useful for reading stored text / documents async read(key: string): Promise { const stored = await blob.get(this.getKey(key)); return await stored.text() } // pass in content type manually; not really used async getContent(key: string, contentType: string): Promise { const stored = await blob.get(this.getKey(key)); return new Response(stored.body, { headers: { "Content-Type": contentType, }, }); } } function getContentType(key: string): string { const extension = key.split(".").pop()?.toLowerCase(); switch (extension) { case "jpg": case "jpeg": return "image/jpeg"; case "png": return "image/png"; case "mp3": return "audio/mpeg"; // Add more cases for other file types case "pdf": return "application/pdf"; default: return "application/octet-stream"; } } export const blobby = new Blobby();