Spaces:
Paused
Paused
| import type { Conversation } from "$lib/types/Conversation"; | |
| import { sha256 } from "$lib/utils/sha256"; | |
| import { collections } from "$lib/server/database"; | |
| export async function uploadFile(file: Blob, conv: Conversation): Promise<string> { | |
| const sha = await sha256(await file.text()); | |
| const upload = collections.bucket.openUploadStream(`${conv._id}-${sha}`, { | |
| metadata: { conversation: conv._id.toString(), mime: "image/jpeg" }, | |
| }); | |
| upload.write((await file.arrayBuffer()) as unknown as Buffer); | |
| upload.end(); | |
| // only return the filename when upload throws a finish event or a 10s time out occurs | |
| return new Promise((resolve, reject) => { | |
| upload.once("finish", () => resolve(sha)); | |
| upload.once("error", reject); | |
| setTimeout(() => reject(new Error("Upload timed out")), 10000); | |
| }); | |
| } | |