feat(proxy): add logging (#7)

Author: CorentinTh

package.json

@@ -32,6 +32,7 @@
     "release": "bumpp --commit --tag --push"
   },
   "dependencies": {
+    "@crowlog/logger": "^2.2.1",
     "@owlrelay/webhook": "^0.0.2",
     "postal-mime": "^2.4.1"
   },

pnpm-lock.yaml

@@ -1,5 +1,6 @@
 import type { Address, Email } from 'postal-mime';
 import type { Env } from './types';
+import { createLogger } from '@crowlog/logger';
 import { triggerWebhook } from '@owlrelay/webhook';
 import PostalMime from 'postal-mime';
 
@@ -51,15 +52,33 @@ function parseConfig({ env }: { env: Env }) {
   };
 }
 
+const logger = createLogger({ namespace: 'email-proxy' });
+const createRequestId = ({ now = new Date() }: { now?: Date } = {}) => `req_${now.getTime()}${Math.random().toString(36).substring(2, 15)}`;
+
 export default {
   async email(message: ForwardableEmailMessage, env: Env): Promise<void> {
+    const requestId = createRequestId();
     const { webhookUrl, webhookSecret } = parseConfig({ env });
     const { email } = await parseEmail({
       rawMessage: message.raw,
       realTo: message.to,
       realFrom: message.from,
     });
 
-    await triggerWebhook({ email, webhookUrl, webhookSecret });
+    logger.info({
+      from: email.from,
+      originalFrom: email.originalFrom,
+      to: email.to,
+      originalTo: email.originalTo,
+      requestId,
+    }, 'Received email');
+
+    try {
+      await triggerWebhook({ email, webhookUrl, webhookSecret });
+      logger.info({ requestId }, 'Webhook triggered successfully');
+    } catch (error) {
+      logger.error({ error, requestId }, 'Failed to trigger webhook');
+      throw error;
+    }
   },
 };

src/index.ts

@@ -1,3 +1,11 @@
 name = "papra-email-proxy"
 main = "src/index.ts"
 compatibility_date = "2025-01-22"
+
+[observability]
+
+[observability.logs]
+enabled = true
+head_sampling_rate = 1
+invocation_logs = true
+persist = true