From 565c2ffe264c80737302315c95a7821a331bdeb8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?V=C3=ADtor=20Vieira?= <vitor.vieira@protonmail.com>
Date: Fri, 28 Nov 2025 20:33:15 +0000
Subject: [PATCH] Last update

---
 index.js          | 7 ++-----
 src/api.js        | 3 +--
 src/db.js         | 6 +++---
 tests/bot.test.js | 1 -
 4 files changed, 6 insertions(+), 11 deletions(-)

diff --git a/index.js b/index.js
index 3d01bfa..7e856a4 100644
--- a/index.js
+++ b/index.js
@@ -1,4 +1,3 @@
-import fs from "node:fs";
 import { parseArgs } from "node:util";
 import { prefetchRates } from "./src/api.js";
 import { Bot } from "./src/bot.js";
@@ -46,7 +45,7 @@ const interval = parseInt(values.interval, 10);
 const threshold = parseFloat(values.threshold);
 
 if (isNaN(interval) || interval < 100) {
-  logger.error("Interval must be a number larger than 100ms");
+  logger.error("Interval must be a number larger than 100");
   process.exit(1);
 }
 if (pairs.length === 0 || pairs.some((p) => !p.match(/^[A-Z]+-?[A-Z]+$/))) {
@@ -70,12 +69,10 @@ async function main() {
   try {
     await prefetchRates(pairs);
   } catch (err) {
-    logger.error(err, "Critical failure during cache warming");
+    logger.error(err, "Critical failure during cache population");
     process.exit(1);
   }
 
-  fs.promises.writeFile("/tmp/healthy", "ok");
-
   const handleAlert = async (alertData) => {
     await insertIntoDB(alertData);
   };
diff --git a/src/api.js b/src/api.js
index 089a8f0..b300e71 100644
--- a/src/api.js
+++ b/src/api.js
@@ -50,11 +50,10 @@ export async function fetchRate(pair) {
 }
 
 export async function prefetchRates(pairs) {
-  logger.info({ pairs }, "Verifying pairs...");
   const results = await Promise.allSettled(pairs.map((p) => fetchRate(p)));
 
   const failed = results.filter((r) => r.status === "rejected");
   if (failed.length > 0) {
-    logger.warn(`[API] ${failed.length} pairs failed initial check.`);
+    logger.warn(`[API] ${failed.length} pairs failed initial check`);
   }
 }
diff --git a/src/db.js b/src/db.js
index e1382d1..9e6dccc 100644
--- a/src/db.js
+++ b/src/db.js
@@ -24,7 +24,7 @@ export function getPool() {
   });
 
   pool.on("error", (err) => {
-    logger.error(err, "[DB] Unexpected error on idle client", err);
+    logger.error(err, "[DB] Unexpected error on client", err);
   });
 
   return pool;
@@ -59,7 +59,7 @@ export async function initDB() {
     try {
       client = await currentPool.connect();
       await client.query(CREATE_TABLE_QUERY);
-      logger.info("[DB] Database initialized and connected.");
+      logger.info("[DB] Database initialized and connected");
       return;
     } catch (err) {
       if (i === maxRetries - 1) {
@@ -106,7 +106,7 @@ export async function insertIntoDB(data) {
     await getPool().query(query, values);
     logger.info(`[DB] Event saved for ${data.pair}`);
   } catch (err) {
-    logger.error(`[DB] Failed to save alert: ${err.message}`);
+    logger.error(`[DB] Failed to save alert ${err.message}`);
     throw err;
   }
 }
diff --git a/tests/bot.test.js b/tests/bot.test.js
index a4443a1..1bb50df 100644
--- a/tests/bot.test.js
+++ b/tests/bot.test.js
@@ -128,7 +128,6 @@ describe("API", () => {
     vi.resetModules();
     nock.cleanAll();
 
-    // Import the actual module for these tests
     vi.doMock("../src/api.js", async () => {
       return await vi.importActual("../src/api.js");
     });