Log for testWebhookReceiver

app.ts

@@ -22,6 +22,7 @@ import {
   EmitterLoggerName,
   getInternalLoggers,
   ObserverLoggerName,
+  TestWebhookReceiverLoggerName,
   WebLoggerName,
 } from "./logUtils.ts";
 import { observer } from "./observer.ts";
@@ -101,6 +102,10 @@ async function main() {
         level: "DEBUG",
         handlers: ["console"],
       },
+      [TestWebhookReceiverLoggerName]: {
+        level: "INFO",
+        handlers: ["console"],
+      },
       lop: {
         level: "INFO",
         handlers: ["console"],

logUtils.ts

@@ -19,6 +19,7 @@ export const WebLoggerName = "web";
 // dev utility logger names
 export const DevLoggerName = "dev";
 export const DataproxyLoggerName = "dataproxy";
+export const TestWebhookReceiverLoggerName = "testWebhookReceiver";
 
 // internal logger names
 export const ControlLoggerName = "control";

testWebhookReceiver.ts

@@ -1,7 +1,19 @@
+import { ConsoleHandler } from "https://deno.land/[email protected]/log/handlers.ts";
+import {
+  getLogger,
+  setup as setupLog,
+} from "https://deno.land/[email protected]/log/mod.ts";
+
 import {
   Application as OakApplication,
 } from "https://deno.land/x/[email protected]/mod.ts";
+
 import { parse } from "npm:lossless-json";
+
+import {
+  defaultLogFormatter,
+  TestWebhookReceiverLoggerName,
+} from "./logUtils.ts";
 import { runAndCleanup } from "./runHelpers.ts";
 
 function numberParser(value: string) {
@@ -11,10 +23,11 @@ function numberParser(value: string) {
 }
 
 export async function testWebhookReceiver() {
+  const logger = getLogger(TestWebhookReceiverLoggerName);
   const abortController = new AbortController();
   const app = new OakApplication();
   app.use(async (ctx) => {
-    console.log(
+    logger.info(
       "Received Webhook:",
       parse(
         await ctx.request.body({ type: "text" }).value,
@@ -25,17 +38,36 @@ export async function testWebhookReceiver() {
     ctx.response.body = "";
   });
 
+  const port = 8888;
+  logger.info(`Test webhook receiver listening on port ${port}.`);
   const runningPromise = app.listen({
-    port: 8888,
+    port,
     signal: abortController.signal,
   });
 
   async function cleanup() {
+    logger.info(`Stopping test webhook receiver.`);
     abortController.abort();
     await runningPromise;
   }
 
   return await Promise.resolve({ runningPromise, cleanup });
 }
 
-if (import.meta.main) await runAndCleanup(testWebhookReceiver);
+if (import.meta.main) {
+  setupLog({
+    handlers: {
+      console: new ConsoleHandler("DEBUG", {
+        formatter: defaultLogFormatter,
+      }),
+    },
+
+    loggers: {
+      [TestWebhookReceiverLoggerName]: {
+        level: "DEBUG",
+        handlers: ["console"],
+      },
+    },
+  });
+  await runAndCleanup(testWebhookReceiver);
+}