Something went wrong. Try again.
zero-knowledge file sharing
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384import { Database } from "bun:sqlite";import { mkdirSync, unlinkSync } from "fs";
import { config } from "./config.ts";
const DATA_DIR = config.dataDir;const FILES_DIR = `${DATA_DIR}/files`;mkdirSync(FILES_DIR, { recursive: true });
const db = new Database(`${DATA_DIR}/drop.db`, { create: true });db.run("PRAGMA journal_mode = WAL;");
db.run(` CREATE TABLE IF NOT EXISTS files ( id TEXT PRIMARY KEY, expires_at INTEGER NOT NULL, burn_after_read INTEGER NOT NULL DEFAULT 0 );`);
const insertStmt = db.prepare<void, [string, number, number]>( "INSERT INTO files (id, expires_at, burn_after_read) VALUES (?, ?, ?)",);
type FileRow = { id: string; expires_at: number; burn_after_read: number;};
const selectStmt = db.prepare<FileRow, [string]>("SELECT * FROM files WHERE id = ?");
const deleteStmt = db.prepare<void, [string]>("DELETE FROM files WHERE id = ?");
const burnStmt = db.prepare<FileRow, [string]>( "DELETE FROM files WHERE id = ? AND burn_after_read = 1 RETURNING *",);
const cleanStmt = db.prepare<{ id: string }, [number]>( "DELETE FROM files WHERE expires_at <= ? RETURNING id",);
export function createFile(id: string, expiresAt: number, burnAfterRead: boolean): void { insertStmt.run(id, expiresAt, burnAfterRead ? 1 : 0);}
// Read-only lookup — does not trigger burn-after-read or delete expired rowsexport function peekFile(id: string) { const row = selectStmt.get(id); if (!row) return null; if (row.expires_at <= Math.floor(Date.now() / 1000)) return null; return row;}
export function getFile(id: string) { // Try atomic burn-after-read first — if the row has burn_after_read=1, // this deletes and returns it in one step, preventing double-reads const burned = burnStmt.get(id); if (burned) { if (burned.expires_at <= Math.floor(Date.now() / 1000)) return null; return burned; } const row = selectStmt.get(id); if (!row) return null; if (row.expires_at <= Math.floor(Date.now() / 1000)) { deleteStmt.run(id); return null; } return row;}
export function unlinkFile(id: string): void { try { unlinkSync(`${FILES_DIR}/${id}`); } catch {}}
export function cleanExpired(): void { const now = Math.floor(Date.now() / 1000); for (const { id } of cleanStmt.all(now)) { unlinkFile(id); }}