refactor: add logger

AmirSa12 · AmirSa12 · commit 488afdcf6c61 · 2025-12-06T12:45:19.000+03:30
diff --git a/eslint.config.js b/eslint.config.js
@@ -13,6 +13,8 @@ export default [
       "packages/*/dist/**",
       "packages/app/.nuxt/**",
       "packages/cli/dist/**",
+      "playgrounds/**",
+      "templates/**",
     ],
   },
   // JavaScript and TypeScript files
@@ -37,7 +39,7 @@ export default [
     },
     rules: {
       // Basic rules
-      "no-console": "off",
+      "no-console": "warn",
       "no-debugger": "warn",
       "no-unused-vars": [
         "warn",
@@ -110,7 +112,7 @@ export default [
       "vue/no-v-html": "off",
 
       // Basic rules
-      "no-console": "off",
+      "no-console": "warn",
       "no-debugger": "warn",
       "prefer-const": "error",
 
diff --git a/packages/app/app/components/RepoSearch.vue b/packages/app/app/components/RepoSearch.vue
@@ -1,5 +1,8 @@
 <script lang="ts" setup>
+import { createLogger } from "@pkg-pr-new/utils";
 import type { RepoNode } from "../../server/utils/types";
+
+const logger = createLogger();
 const search = useSessionStorage("search", "");
 const searchResults = ref<RepoNode[]>([]);
 const isLoading = ref(false);
@@ -32,7 +35,7 @@ watch(
       }
     } catch (err: any) {
       if (err.name !== "AbortError") {
-        console.error(err);
+        logger.error(err);
       }
     } finally {
       if (activeController === controller) {
diff --git a/packages/app/e2e.test.ts b/packages/app/e2e.test.ts
@@ -4,6 +4,7 @@ import ezSpawn from "@jsdevtools/ez-spawn";
 import { simulation } from "@simulacrum/github-api-simulator";
 import { afterAll, beforeAll, describe, expect, it } from "vitest";
 import { unstable_dev } from "wrangler";
+import { createLogger } from "@pkg-pr-new/utils";
 import prPullRequestSynchronizeFixture from "./fixtures/pr.pull_request.json";
 import prWorkflowRunRequestedFixture from "./fixtures/pr.workflow_run.requested.json";
 import pushWorkflowRunInProgressFixture from "./fixtures/workflow_run.in_progress.json";
@@ -12,6 +13,7 @@ let server: Awaited<ReturnType<ReturnType<typeof simulation>["listen"]>>;
 let workerUrl: string;
 
 let worker: UnstableDevWorker;
+const logger = createLogger();
 beforeAll(async () => {
   const app = simulation({
     initialState: {
@@ -122,9 +124,9 @@ describe.sequential.each([
           shell: true,
         },
       );
-      console.log(process.stdout);
+      logger.info(process.stdout);
     } catch (error) {
-      console.log(error);
+      logger.error(error);
     }
   }, 10_000);
 
diff --git a/packages/app/script/generate-dev-vars.ts b/packages/app/script/generate-dev-vars.ts
@@ -1,6 +1,9 @@
 import crypto from "node:crypto";
 import fs from "node:fs/promises";
 import path from "node:path";
+import { createLogger } from "@pkg-pr-new/utils";
+
+const logger = createLogger();
 
 async function generateDevVars() {
   const filePath = path.join(
@@ -63,7 +66,7 @@ async function generateDevVars() {
   // Write to .dev.vars file
   await fs.writeFile(filePath, envContent, "utf8");
 
-  console.log("Updated .dev.vars file successfully!");
+  logger.info("Updated .dev.vars file successfully!");
 }
 
-generateDevVars().catch(console.error);
+generateDevVars().catch(logger.error);
diff --git a/packages/app/script/update-webhook-url.ts b/packages/app/script/update-webhook-url.ts
@@ -1,8 +1,11 @@
 import process from "node:process";
 import { config } from "dotenv";
+import { createLogger } from "@pkg-pr-new/utils";
 import { createSigner } from "fast-jwt";
 import { Octokit } from "octokit";
 
+const logger = createLogger();
+
 config({ path: ".dev.vars" });
 
 const nitroSigner = createSigner({
@@ -31,7 +34,7 @@ const {
   data: { url },
 } = await octokit.request("GET /app/hook/config");
 
-console.log(`current webhook url: ${url}`);
+logger.info(`current webhook url: ${url}`);
 
 const newUrl = new URL(
   "/webhook",
@@ -44,4 +47,4 @@ const result = await octokit.request({
   data: { url: newUrl.href },
 });
 
-console.log(`webhook url is ${result.data.url} now!`);
+logger.info(`webhook url is ${result.data.url} now!`);
diff --git a/packages/app/server/api/repo/commits.get.ts b/packages/app/server/api/repo/commits.get.ts
@@ -1,5 +1,8 @@
+import { createLogger } from "@pkg-pr-new/utils";
 import { z } from "zod";
 
+const logger = createLogger();
+
 const querySchema = z.object({
   owner: z.string(),
   repo: z.string(),
@@ -95,7 +98,7 @@ export default defineEventHandler(async (event) => {
                 : null,
           };
         } catch (error) {
-          console.warn(
+          logger.warn(
             `Could not fetch check runs for commit ${commit.sha}:`,
             error,
           );
@@ -132,7 +135,7 @@ export default defineEventHandler(async (event) => {
       },
     };
   } catch (error) {
-    console.error("Error fetching repository commits:", error);
+    logger.error("Error fetching repository commits:", error);
 
     return {
       id: "error",
diff --git a/packages/app/server/api/repo/index.get.ts b/packages/app/server/api/repo/index.get.ts
@@ -1,6 +1,9 @@
 import type { H3Event } from "h3";
+import { createLogger } from "@pkg-pr-new/utils";
 import { z } from "zod";
 
+const logger = createLogger();
+
 const querySchema = z.object({
   owner: z.string(),
   repo: z.string(),
@@ -32,7 +35,7 @@ const getRepoInfo = defineCachedFunction(
         releaseCount,
       };
     } catch (error) {
-      console.error(
+      logger.error(
         `Error fetching repository info for ${owner}/${repo}:`,
         error,
       );
@@ -53,7 +56,7 @@ export default defineEventHandler(async (event) => {
     );
     return getRepoInfo(query.owner, query.repo, event);
   } catch (error) {
-    console.error("Error in repo info endpoint:", error);
+    logger.error("Error in repo info endpoint:", error);
     return {
       error: true,
       message: (error as Error).message,
diff --git a/packages/app/server/plugins/config.ts b/packages/app/server/plugins/config.ts
@@ -1,15 +1,19 @@
+import { createLogger } from "@pkg-pr-new/utils";
+
+const logger = createLogger();
+
 // This plugin ensures runtime config is properly initialized early in the request lifecycle
 export default defineNitroPlugin((nitro) => {
   nitro.hooks.hook("request", async (event) => {
     try {
       // Pre-load the configuration to ensure it's initialized
       const config = useRuntimeConfig(event);
-      console.log(
+      logger.info(
         "Runtime config initialized successfully:",
         Object.keys(config),
       );
     } catch (error) {
-      console.error("Failed to initialize runtime config:", error);
+      logger.error("Failed to initialize runtime config:", error);
     }
   });
 });
diff --git a/packages/app/server/plugins/error.ts b/packages/app/server/plugins/error.ts
@@ -1,5 +1,9 @@
+import { createLogger } from "@pkg-pr-new/utils";
+
+const logger = createLogger();
+
 export default defineNitroPlugin((nitro) => {
   nitro.hooks.hook("error", async (error, { event }) => {
-    console.error(`${event?.path} Application error:`, error);
+    logger.error(`${event?.path} Application error:`, error);
   });
 });
diff --git a/packages/app/server/routes/check.post.ts b/packages/app/server/routes/check.post.ts
@@ -1,3 +1,7 @@
+import { createLogger } from "@pkg-pr-new/utils";
+
+const logger = createLogger();
+
 export default eventHandler(async (event) => {
   try {
     const data = await readRawBody(event);
@@ -43,7 +47,7 @@ export default eventHandler(async (event) => {
     }
     return { sha: workflowData.sha };
   } catch (error: unknown) {
-    console.error("Check route error:", error);
+    logger.error("Check route error:", error);
 
     if (error && typeof error === "object" && "statusCode" in error) {
       throw error;
diff --git a/packages/app/server/routes/publish.post.ts b/packages/app/server/routes/publish.post.ts
@@ -2,12 +2,14 @@ import type { H3Event } from "h3";
 import type { components as OctokitComponents } from "@octokit/openapi-types";
 import type { Comment, PackageManager } from "@pkg-pr-new/utils";
 import type { WorkflowData } from "../types";
-import { isPullRequest, isWhitelisted } from "@pkg-pr-new/utils";
+import { createLogger, isPullRequest, isWhitelisted } from "@pkg-pr-new/utils";
 import { randomUUID } from "uncrypto";
+import { joinKeys } from "unstorage";
 import { setItemStream, useTemplatesBucket } from "../utils/bucket";
 import { useOctokitInstallation } from "../utils/octokit";
 import { generateTemplateHtml } from "../utils/template";
-import { joinKeys } from "unstorage";
+
+const logger = createLogger();
 
 export default eventHandler(async (event) => {
   try {
@@ -320,7 +322,7 @@ export default eventHandler(async (event) => {
             );
           }
         } catch (error) {
-          console.error("failed to create/update comment", error, permissions);
+          logger.error("failed to create/update comment", error, permissions);
         }
       }
     }
@@ -343,7 +345,7 @@ export default eventHandler(async (event) => {
       },
     };
   } catch (error: unknown) {
-    console.error("Publish route error:", error);
+    logger.error("Publish route error:", error);
 
     if (error && typeof error === "object" && "statusCode" in error) {
       throw error;
diff --git a/packages/app/server/utils/bucket.ts b/packages/app/server/utils/bucket.ts
@@ -1,10 +1,13 @@
 import type { H3EventContext } from "h3";
 import type { Cursor, WorkflowData, WebhookDebugData } from "../types";
+import { createLogger } from "@pkg-pr-new/utils";
 import type { Storage } from "unstorage";
 import { createStorage, joinKeys, prefixStorage } from "unstorage";
 import cloudflareR2BindingDriver from "unstorage/drivers/cloudflare-r2-binding";
 import { getR2Binding } from "unstorage/drivers/utils/cloudflare";
 
+const logger = createLogger();
+
 interface Event {
   context: { cloudflare: H3EventContext["cloudflare"] };
 }
@@ -174,7 +177,7 @@ export async function getRepoReleaseCount(
 
     return uniqueCommitShas.size;
   } catch (error) {
-    console.error(`Error counting releases for ${owner}/${repo}:`, error);
+    logger.error(`Error counting releases for ${owner}/${repo}:`, error);
     return 0;
   }
 }
diff --git a/packages/app/server/utils/octokit.ts b/packages/app/server/utils/octokit.ts
@@ -1,15 +1,18 @@
 import type { H3Event } from "h3";
+import { createLogger } from "@pkg-pr-new/utils";
 import type { App as AppType } from "octokit";
 import { paginateRest } from "@octokit/plugin-paginate-rest";
 import { App, Octokit } from "octokit";
 
+const logger = createLogger();
+
 export function useOctokitApp(event: H3Event): AppType {
   try {
     const config = useRuntimeConfig(event);
     const { appId, privateKey, webhookSecret, ghBaseUrl } = config;
 
     if (!appId || !privateKey || !webhookSecret) {
-      console.warn("Missing required GitHub App credentials in runtime config");
+      logger.warn("Missing required GitHub App credentials in runtime config");
       return {
         octokit: { request: async () => ({ data: { id: 0 } }) },
         getInstallationOctokit: async () => ({}),
@@ -26,7 +29,7 @@ export function useOctokitApp(event: H3Event): AppType {
       }),
     }) as unknown as AppType;
   } catch (error) {
-    console.error("Error initializing GitHub App:", error);
+    logger.error("Error initializing GitHub App:", error);
     return {
       octokit: { request: async () => ({ data: { id: 0 } }) },
       getInstallationOctokit: async () => ({}),
diff --git a/packages/cli/index.ts b/packages/cli/index.ts
diff --git a/packages/utils/index.ts b/packages/utils/index.ts
diff --git a/packages/utils/logger.ts b/packages/utils/logger.ts
