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 | 1x 1x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 4x 3x 3x 1x 1x 4x 4x 4x 4x 4x 1x 3x 2x 1x 1x 1x | // Admin Routes - Feedback Management
import { Hono } from "hono";
import { desc, eq } from "drizzle-orm";
import type { Dal } from "../../dal";
import type { getDb } from "../../db";
import type { Services } from "../../services";
import { feedback } from "../../db/schema";
import { success, error, handleError } from "../../lib/response";
import { getPagination, buildPaginationMeta } from "../../lib/utils";
type Env = {
Bindings: CloudflareBindings;
Variables: {
user: { id: string; name: string; email: string } | null;
session: unknown;
dal: Dal;
services: Services;
db: ReturnType<typeof getDb>;
};
};
const feedbackRoutes = new Hono<Env>();
// List all feedback with pagination
feedbackRoutes.get("/", async (c) => {
try {
const db = c.get("db");
const page = Number(c.req.query("page") || "1");
const limit = Number(c.req.query("limit") || "20");
const status = c.req.query("status");
const { offset, limit: safeLimit, page: safePage } = getPagination(page, limit);
const statusFilter =
status && ["new", "reviewed", "resolved"].includes(status)
? eq(feedback.status, status as "new" | "reviewed" | "resolved")
: undefined;
const baseQuery = db.select().from(feedback);
const itemsQuery = statusFilter
? baseQuery.where(statusFilter).orderBy(desc(feedback.createdAt)).limit(safeLimit).offset(offset)
: baseQuery.orderBy(desc(feedback.createdAt)).limit(safeLimit).offset(offset);
const countQuery = statusFilter
? db.$count(feedback, statusFilter)
: db.$count(feedback);
const [items, total] = await Promise.all([itemsQuery, countQuery]);
const meta = buildPaginationMeta(total, safePage, safeLimit);
return success(c, items, 200, meta);
} catch (err) {
return handleError(c, err);
}
});
// Update feedback status
feedbackRoutes.patch("/:id", async (c) => {
try {
const db = c.get("db");
const id = Number(c.req.param("id"));
const body = await c.req.json();
if (!body.status || !["new", "reviewed", "resolved"].includes(body.status)) {
return error(c, "VALIDATION_ERROR", "Invalid status. Must be one of: new, reviewed, resolved", 400);
}
const [updated] = await db
.update(feedback)
.set({ status: body.status })
.where(eq(feedback.id, id))
.returning();
if (!updated) {
return error(c, "NOT_FOUND", "Feedback not found", 404);
}
return success(c, updated);
} catch (err) {
return handleError(c, err);
}
});
export default feedbackRoutes;
|