chore: init

redis.ts

@@ -0,0 +1,102 @@
+import { createClient } from "redis";
+
+type LogAction = "called" | "completed" | "no-show";
+type TicketStatus = "called" | "completed" | "no-show";
+
+interface LogEntry {
+	ticket: string;
+	time: string;
+	action: LogAction;
+	room: string | null;
+};
+
+interface Ticket {
+	status: TicketStatus;
+	created: string;
+	room: string | null;
+	calledDate: string | null;
+}
+
+const redis = await createClient({
+	url: process.env.DATABASE_URL || "redis://localhost:6379"
+}).connect();
+
+export function logAction(entry: LogEntry) {
+	redis.lPush("log", JSON.stringify(entry));
+}
+
+export async function getLogEntries(): Promise<LogEntry[]> {
+	const entries = await redis.lRange("log", 0, -1);
+	return entries.map(entry => JSON.parse(entry));
+}
+
+// export async function createTicket(ticket: string) {
+// 	// redisjson ticket:{ticket} = { status: "waiting", created: now, room: null, calledDate: null }
+// 	await redis.json.set(`ticket:${ticket}`, "$", {
+// 		status: "waiting" as TicketStatus,
+// 		created: new Date().toISOString(),
+// 		room: null,
+// 		calledDate: null
+// 	});
+// 	logAction({ ticket, time: new Date().toISOString(), action: "entered", room: null });
+// }
+
+export async function callTicket(ticket: string, room: string) {
+	// await redis.json.set(`ticket:${ticket}`, "$.status", "called");
+	// await redis.json.set(`ticket:${ticket}`, "$.room", room);
+	// await redis.json.set(`ticket:${ticket}`, "$.calledDate", new Date().toISOString());
+	await redis.json.set(`ticket:${ticket}`, "$", {
+		status: "called" as TicketStatus,
+		created: new Date().toISOString(),
+		room,
+		calledDate: new Date().toISOString()
+	});
+	logAction({ ticket, time: new Date().toISOString(), action: "called", room });
+}
+
+export async function completeTicket(ticket: string) {
+	await redis.json.set(`ticket:${ticket}`, "$.status", "completed");
+	const room = await redis.json.get(`ticket:${ticket}`, { path: "$.room" }) as string | null;
+	logAction({ ticket, time: new Date().toISOString(), action: "completed", room });
+}
+
+export async function noShowTicket(ticket: string) {
+	await redis.json.set(`ticket:${ticket}`, "$.status", "no-show");
+	const room = await redis.json.get(`ticket:${ticket}`, { path: "$.room" }) as string | null;
+	logAction({ ticket, time: new Date().toISOString(), action: "no-show", room });
+}
+
+export async function getCurrentTicket(room: string): Promise<{num: string, ticket: Ticket} | null> {
+	const tickets = await redis.keys("ticket:*");
+	for (const key of tickets) {
+		const ticket = key.split(":")[1]!;
+		const ticketData = await getTicket(ticket);
+		if (ticketData?.status === "called" && ticketData.room === room) {
+			return { num: ticket, ticket: ticketData };
+		}
+	}
+	return null;
+}
+
+export async function getDisplayTickets(): Promise<{num: string, ticket: Ticket}[]> {
+	const result: {num: string, ticket: Ticket}[] = [];
+	const tickets = await redis.keys("ticket:*");
+	for (const key of tickets) {
+		const ticket = key.split(":")[1]!;
+		const ticketData = await getTicket(ticket);
+		if (ticketData?.status === "called" || ticketData?.status === "no-show") {
+			result.push({ num: ticket, ticket: ticketData });
+		}
+	}
+	// Sort by calledDate
+	result.sort((a, b) => {
+		const dateA = new Date(a.ticket.calledDate || "1970-01-01T00:00:00.000Z");
+		const dateB = new Date(b.ticket.calledDate || "1970-01-01T00:00:00.000Z");
+		return dateA.getTime() - dateB.getTime();
+	});
+	return result;
+}
+
+export async function getTicket(ticket: string): Promise<Ticket | null> {
+	return await redis.json.get(`ticket:${ticket}`) as Ticket | null;
+}