[appview] implement logging using winston

backend/src/db/database.ts

···
 
 import { drizzle } from "drizzle-orm/libsql";
 import { Config } from "../config.ts";
+import Logger from "../logger.js";
 
 const config = Config.getInstance();
 const dbname = config.get("database.name");
···
 			try {
 				Database.instance = new Database();
 			} catch (e) {
-				console.error(e);
+				Logger.error(e);
 				process.exit(1);
 			}
 		}

backend/src/logger.ts

···
+/*
+ * clippr: a social bookmarking service for the AT Protocol
+ * Copyright (c) 2025 clippr contributors.
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+
+import { createLogger, format, transports } from "winston";
+
+// TODO: I can't seem to actually get the config setting for the log level yet.
+const loglevel: string = "debug";
+
+const Logger = createLogger({
+	level: loglevel,
+	transports: [
+		new transports.Console({
+			format: format.combine(
+				format.colorize(),
+				format.timestamp(),
+				format.printf(({ level, message, timestamp }) => {
+					return `[${timestamp}] ${level}: ${message}`;
+				}),
+			),
+		}),
+		new transports.File({
+			dirname: "logs",
+			filename: "clippr-error.log",
+			level: "error",
+		}),
+		new transports.File({
+			dirname: "logs",
+			filename: "clippr-combined.log",
+		}),
+	],
+	format: format.combine(format.timestamp(), format.json()),
+	defaultMeta: { service: "clippr-backend" },
+});
+
+export default Logger;

backend/src/main.ts

···
 import { readFromFirehose, startFirehose, stopFirehose } from "./network/jetstream.ts";
 import app from "./server.ts";
 import { Database } from "./db/database.js";
+import Logger from "./logger.js";
 
-function main() {
-	console.log("clippr-BE starting...");
+async function main() {
+	let logger = Logger;
+	logger.info("clippr-BE starting...");
 
-	console.log("initializing config");
-	const config: Config = Config.getInstance(); // Get config from config.toml
+	logger.info("initializing config");
+	const config = Config.getInstance();
 
-	console.log("initializing database");
+	logger.info("initializing database");
 	Database.getInstance();
 
-	console.log("initializing firehose connection");
+	logger.info("initializing firehose connection");
 	startFirehose();
 	readFromFirehose();
 
···
 		fetch: app.fetch,
 	});
 
-	console.log(
+	logger.info(
 		`server started at http://${config.get("hostname")}:${config.get("port")}`,
 	);
 
···
 	process.once("SIGTERM", () => gracefulShutdown("SIGTERM"));
 
 	function gracefulShutdown(signal: string) {
-		console.log(`\nreceived ${signal}, shutting down...`);
+		logger.info(`\nreceived ${signal}, shutting down...`);
 		stopFirehose();
 		server.close();
-		console.log("server shut down, bye!");
+		logger.info("server shut down, bye!");
 		process.exit(0);
 	}
 }

backend/src/network/commit.ts

···
 import { is } from "@atcute/lexicons";
 import { SocialClipprFeedClip, SocialClipprFeedTag } from "@clipprjs/lexicons";
 import type { At } from "@atcute/client/lexicons";
+import Logger from "../logger.js";
 
 const db = Database.getInstance().getDb();
 
···
 	if (event.commit.operation !== "create") return; // We currently do not handle these.
 
 	if (!is(SocialClipprFeedClip.mainSchema, event.commit.record)) {
-		console.log("invalid clip", event.commit.record);
+		Logger.verbose("Invalid clip", event.commit.record);
 		return;
 	}
 
···
 		languages: record.languages,
 	});
 
-	console.log("inserted new clip");
+	Logger.verbose("Indexed new clip:", event.did, event.commit.rkey);
 }
 
 export async function handleTag(event: CommitEvent<`social.clippr.${string}`>) {
 	if (event.commit.operation !== "create") return; // We currently do not handle these.
 
 	if (!is(SocialClipprFeedTag.mainSchema, event.commit.record)) {
-		console.log("invalid tag", event.commit.record);
+		Logger.verbose("Invalid tag", event.commit.record);
 		return;
 	}
 
···
 		color: record.color,
 	});
 
-	console.log("inserted new tag");
+	Logger.verbose("Indexed new tag:", event.did, event.commit.rkey);
 }

backend/src/network/jetstream.ts

···
 import { Jetstream } from "@skyware/jetstream";
 import { Config } from "../config.ts";
 import { handleClip, handleTag } from "./commit.js";
+import Logger from "../logger.js";
 
 const config = Config.getInstance();
 const hostname = config.get("network.firehose");
···
 				handleTag(e);
 				break;
 			default:
-				console.log(
+				Logger.debug(
 					`commit for ${e.commit.collection} is not relevant, dropping`,
 				);
 				break;
···
 	});
 
 	jetstream.on("account", (e) => {
-		console.log("account update", e.account.did);
+		Logger.debug(`Received account update for ${e.account.did}`);
 	});
 
 	jetstream.on("identity", (e) => {
-		console.log("identity update", e.identity.did);
+		Logger.debug(`Received identity update for ${e.identity.did}`);
 	});
 
 	jetstream.on("error", (e) => {
-		console.log(e);
+		Logger.warn(e);
 	});
 }

backend/src/server.ts

···
 
 import { Hono } from "hono";
 import misc from "./routes/misc.ts";
+import Logger from "./logger.js";
+import { logger } from "hono/logger";
+
+export function winstonLogger(message: string, ...rest: unknown[]) {
+	Logger.http(message, ...rest);
+}
 
 const app = new Hono();
+app.use(logger(winstonLogger));
 
 // Link all routes up
 app.route("/", misc);