diff --git a/server/worker.ts b/server/worker.ts
index b63481a..e454cee 100755
--- a/server/worker.ts
+++ b/server/worker.ts
@@ -21,6 +21,47 @@ export default {
       if (!ok) console.warn('[cron:discovery] heartbeat failed');
     }));
   },
+
+  async email(message: ForwardableEmailMessage, env: Env, ctx: ExecutionContext) {
+    const from = message.from;
+    const to = message.to;
+    const subject = message.headers.get('subject') || '(no subject)';
+    const messageId = message.headers.get('message-id') || `${Date.now()}`;
+    const size = message.rawSize;
+
+    console.log(`[email:inbound] from=${from} to=${to} subject="${subject}" size=${size}`);
+
+    // Store raw email in R2 for document ingestion pipeline
+    const ts = new Date().toISOString().replace(/[:.]/g, '-');
+    const sanitizedId = messageId.replace(/[<>]/g, '').replace(/[^a-zA-Z0-9@._-]/g, '_');
+    const key = `inbound-email/${ts}_${sanitizedId}.eml`;
+
+    const rawBytes = await new Response(message.raw).arrayBuffer();
+    await env.FINANCE_R2.put(key, rawBytes, {
+      customMetadata: {
+        from,
+        to,
+        subject,
+        messageId,
+        receivedAt: new Date().toISOString(),
+        sizeBytes: String(size),
+      },
+    });
+
+    console.log(`[email:inbound] stored in R2: ${key} (${rawBytes.byteLength} bytes)`);
+
+    // Index in KV for quick lookup
+    const kv = env.FINANCE_KV;
+    const indexEntry = JSON.stringify({
+      key,
+      from,
+      to,
+      subject,
+      receivedAt: new Date().toISOString(),
+      sizeBytes: rawBytes.byteLength,
+    });
+    await kv.put(`email:inbound:${ts}`, indexEntry, { expirationTtl: 86400 * 90 }); // 90 days
+  },
 } satisfies ExportedHandler<Env>;
 
 // Re-export the Agent DO class so Wrangler can bind it