cleanup uptime deps

Author: izadoesdev

apps/uptime/src/actions.ts

@@ -331,7 +331,7 @@ export function checkUptime(
 	siteId: string,
 	url: string,
 	attempt = 1,
-	maxRetries: number = CONFIG.maxRetries
+	_maxRetries: number = CONFIG.maxRetries
 ): Promise<ActionResult<UptimeData>> {
 	return record("uptime.check_uptime", async () => {
 		try {

apps/uptime/src/index.ts

@@ -1,6 +1,5 @@
 import { Receiver } from "@upstash/qstash";
-import Elysia from "elysia";
-import { z } from "zod";
+import { Elysia, t } from "elysia";
 import { checkUptime, lookupSchedule } from "./actions";
 import { sendUptimeEvent } from "./lib/producer";
 import {
@@ -85,13 +84,13 @@ const app = new Elysia()
 	.get("/health", () => ({ status: "ok" }))
 	.post("/", async ({ headers, body }) => {
 		try {
-			const headerSchema = z.object({
-				"upstash-signature": z.string(),
-				"x-schedule-id": z.string(),
-				"x-max-retries": z.string().optional(),
+			const headerSchema = t.Object({
+				"upstash-signature": t.String(),
+				"x-schedule-id": t.String(),
+				"x-max-retries": t.String().optional(),
 			});
 
-			const parsed = headerSchema.safeParse(headers);
+			const parsed = headerSchema.parse(headers);
 			if (!parsed.success) {
 				return new Response("Missing required headers", { status: 400 });
 			}

apps/uptime/src/lib/producer.ts

@@ -16,7 +16,7 @@ type ProducerConfig = {
 class UptimeProducer {
     private producer: Producer | null = null;
     private connected = false;
-    private config: ProducerConfig;
+    private readonly config: ProducerConfig;
 
     constructor(config: ProducerConfig) {
         this.config = config;
@@ -49,7 +49,7 @@ class UptimeProducer {
             this.producer = kafka.producer({
                 maxInFlightRequests: 1,
                 idempotent: true,
-                transactionTimeout: 30000,
+                transactionTimeout: 30_000,
             });
 
             await this.producer.connect();
@@ -64,7 +64,7 @@ class UptimeProducer {
 
     async send(topic: string, event: unknown, key?: string): Promise<void> {
         try {
-            if (!(await this.connect()) || !this.producer) {
+            if (!((await this.connect()) && this.producer)) {
                 console.error("Failed to connect to Redpanda, event not sent");
                 return;
             }
@@ -113,12 +113,8 @@ function getDefaultProducer(): UptimeProducer {
     return defaultProducer;
 }
 
-export const sendUptimeEvent = (
-    event: unknown,
-    key?: string
-): Promise<void> => {
-    return getDefaultProducer().send("analytics-uptime-checks", event, key);
-};
+export const sendUptimeEvent = (event: unknown, key?: string): Promise<void> =>
+    getDefaultProducer().send("analytics-uptime-checks", event, key);
 
 // Graceful shutdown
 process.on("SIGTERM", async () => {
@@ -132,4 +128,3 @@ process.on("SIGINT", async () => {
         await defaultProducer.disconnect();
     }
 });
-