Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 | 357x 357x 2x 2x 1x 1x 1x 1x 357x 6x 6x 6x 6x 4x 357x 10x 10x 10x 9x 10x 357x 4x 4x 4x 4x 4x 4x 4x 4x 40x 4x 4x 4x 3x 3x 3x 3x 2x 357x 2x 2x 2x 2x 1x 357x | import type Database from "better-sqlite3-multiple-ciphers";
import { Hono } from "hono";
import { parseIntParam } from "../validation.js";
interface DraftRow {
id: number;
identity_id: number;
to_addresses: string | null;
cc_addresses: string | null;
bcc_addresses: string | null;
subject: string | null;
text_body: string | null;
html_body: string | null;
in_reply_to: string | null;
references: string | null;
original_message_id: number | null;
compose_mode: string;
created_at: string;
updated_at: string;
}
export function draftRoutes(getDb: () => Database.Database): Hono {
const api = new Hono();
/** GET /drafts?identity_id=N — list drafts for an identity */
api.get("/", (c) => {
const rawIdentityId = c.req.query("identity_id");
if (!rawIdentityId) return c.json({ error: "identity_id query parameter is required" }, 400);
const identityId = Number(rawIdentityId);
Iif (!Number.isFinite(identityId) || identityId < 1) {
return c.json({ error: "Invalid identity_id: must be a positive integer" }, 400);
}
const drafts = getDb()
.prepare(
`SELECT id, identity_id, to_addresses, cc_addresses, bcc_addresses,
subject, SUBSTR(text_body, 1, 200) as preview,
compose_mode, original_message_id, created_at, updated_at
FROM drafts WHERE identity_id = ? ORDER BY updated_at DESC`,
)
.all(identityId);
return c.json(drafts);
});
/** GET /drafts/:id — get a single draft */
api.get("/:id", (c) => {
const id = parseIntParam(c, "id", c.req.param("id"));
Iif (id instanceof Response) return id;
const draft = getDb().prepare("SELECT * FROM drafts WHERE id = ?").get(id) as
| DraftRow
| undefined;
if (!draft) return c.json({ error: "Draft not found" }, 404);
return c.json(draft);
});
/** POST /drafts — create a new draft */
api.post("/", async (c) => {
const db = getDb();
const body = await c.req.json();
if (!body.identity_id) return c.json({ error: "identity_id is required" }, 400);
const result = db
.prepare(`
INSERT INTO drafts (identity_id, to_addresses, cc_addresses, bcc_addresses,
subject, text_body, html_body, in_reply_to, "references",
original_message_id, compose_mode)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
`)
.run(
body.identity_id,
body.to_addresses ?? null,
body.cc_addresses ?? null,
body.bcc_addresses ?? null,
body.subject ?? null,
body.text_body ?? null,
body.html_body ?? null,
body.in_reply_to ?? null,
body.references ?? null,
body.original_message_id ?? null,
body.compose_mode ?? "new",
);
return c.json({ id: Number(result.lastInsertRowid) }, 201);
});
/** PUT /drafts/:id — update an existing draft */
api.put("/:id", async (c) => {
const db = getDb();
const id = parseIntParam(c, "id", c.req.param("id"));
Iif (id instanceof Response) return id;
const body = await c.req.json();
const allowedFields = [
"to_addresses",
"cc_addresses",
"bcc_addresses",
"subject",
"text_body",
"html_body",
"in_reply_to",
"references",
"original_message_id",
"compose_mode",
];
const sets: string[] = [];
const values: (string | number | null)[] = [];
for (const field of allowedFields) {
if (field in body) {
sets.push(`${field === "references" ? '"references"' : field} = ?`);
values.push(body[field] as string | number | null);
}
}
if (sets.length === 0) return c.json({ error: "No fields to update" }, 400);
sets.push("updated_at = datetime('now')");
values.push(id);
const result = db
.prepare(`UPDATE drafts SET ${sets.join(", ")} WHERE id = ?`)
.run(...(values as [string | number | null, ...Array<string | number | null>]));
if (result.changes === 0) return c.json({ error: "Draft not found" }, 404);
return c.json({ ok: true });
});
/** DELETE /drafts/:id — delete a draft */
api.delete("/:id", (c) => {
const id = parseIntParam(c, "id", c.req.param("id"));
Iif (id instanceof Response) return id;
const result = getDb().prepare("DELETE FROM drafts WHERE id = ?").run(id);
if (result.changes === 0) return c.json({ error: "Draft not found" }, 404);
return c.json({ ok: true });
});
return api;
}
|