Broaden Gmail query, clear caches on reset, improve scan logging

- Widen Interac email search to match multiple sender addresses and subject keywords
- Add clearScanCaches() to reset branch cache and active jobs on data reset
- Add structured logging to scan route for better debugging
- Clean up stale database files

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

packages/server/src/routes/emails.ts

@@ -3,7 +3,9 @@ import { z } from 'zod';
 import { resolveScanDates } from '@icc/shared';
 import { requireAuth, type AuthRequest } from '../middleware/auth.js';
 import { executeScan, getJobStatus, getScanHistory } from '../services/scanService.js';
+import pino from 'pino';
 
+const logger = pino({ level: 'info', transport: { target: 'pino-pretty', options: { colorize: true } } });
 const router = Router();
 
 const scanRequestSchema = z.object({
@@ -17,6 +19,7 @@ const scanRequestSchema = z.object({
 router.post('/start', requireAuth, async (req: AuthRequest, res) => {
   const parsed = scanRequestSchema.safeParse(req.body);
   if (!parsed.success) {
+    logger.warn({ issues: parsed.error.issues }, 'Invalid scan request');
     res.status(400).json({ error: true, message: 'Paramètres de scan invalides', details: parsed.error.issues });
     return;
   }
@@ -25,6 +28,7 @@ router.post('/start', requireAuth, async (req: AuthRequest, res) => {
 
   try {
     const dateRange = resolveScanDates(preset, startDate, endDate);
+    logger.info({ preset, dateRange, forceRescan, userId: req.userId }, 'Scan requested: %s (%s → %s)', preset, dateRange.startDate, dateRange.endDate);
 
     const jobId = await executeScan(
       { dateRange, forceRescan },
@@ -33,6 +37,7 @@ router.post('/start', requireAuth, async (req: AuthRequest, res) => {
 
     res.json({ jobId, dateRange, status: 'queued' });
   } catch (err: any) {
+    logger.error({ err: err.message, preset, userId: req.userId }, 'Scan start failed');
     res.status(500).json({ error: true, message: err.message });
   }
 });

packages/server/src/routes/settings.ts

@@ -6,6 +6,7 @@ import { eq, sql } from 'drizzle-orm';
 import { requireAuth, type AuthRequest } from '../middleware/auth.js';
 import { AIService } from '../services/aiService.js';
 import { config } from '../config/env.js';
+import { clearScanCaches } from '../services/scanService.js';
 
 const router = Router();
 
@@ -143,6 +144,9 @@ router.post('/reset', requireAuth, async (req: AuthRequest, res) => {
     db.delete(branchConfig).run();
     db.delete(aiSettings).run();
 
+    // Clear in-memory caches
+    clearScanCaches();
+
     res.json({ success: true, message: 'All data has been reset' });
   } catch (err: any) {
     res.status(500).json({ error: true, message: err.message || 'Reset failed' });

packages/server/src/services/gmailService.ts

@@ -19,6 +19,8 @@ export function buildGmailQuery(dateRange: ScanDateRange): string {
   const start = new Date(dateRange.startDate);
   const end = new Date(dateRange.endDate);
 
+  // Gmail after:/before: are exclusive date boundaries (midnight-based).
+  // Subtract 1 day from start and add 1 day to end for inclusivity.
   const afterDate = new Date(start);
   afterDate.setDate(afterDate.getDate() - 1);
 
@@ -27,8 +29,8 @@ export function buildGmailQuery(dateRange: ScanDateRange): string {
 
   const fmt = (d: Date) => `${d.getFullYear()}/${d.getMonth() + 1}/${d.getDate()}`;
 
-  // Only fetch actual Interac e-Transfer notification emails
-  return `from:notify@payments.interac.ca after:${fmt(afterDate)} before:${fmt(beforeDate)}`;
+  // Broader query: match Interac notification sender OR subject keywords
+  return `(from:notify@payments.interac.ca OR from:interac.ca OR subject:"virement Interac" OR subject:"Interac e-Transfer") after:${fmt(afterDate)} before:${fmt(beforeDate)}`;
 }
 
 function getOAuth2Client() {

packages/server/src/services/scanService.ts

@@ -68,6 +68,13 @@ export function getJobStatus(jobId: string): ScanJobState | undefined {
   return activeJobs.get(jobId);
 }
 
+/** Clear all in-memory caches (branch cache + active jobs) */
+export function clearScanCaches() {
+  _branchCache = null;
+  _branchCacheTime = 0;
+  activeJobs.clear();
+}
+
 // User-scoped scan history (newest first)
 export async function getScanHistory(userId: string) {
   return db.select().from(scanLogs).where(eq(scanLogs.userId, userId)).orderBy(desc(scanLogs.id)).limit(100);
@@ -133,7 +140,7 @@ async function runScan(jobId: string, scanRequest: ScanRequest, userId: string,
     // Phase 1: Email discovery
     jobState.status = 'scanning';
     const query = buildGmailQuery(dateRange);
-    logger.info({ jobId, query }, 'Starting email discovery');
+    logger.info({ jobId, query, dateRange }, 'Starting email discovery — query: %s', query);
 
     const messageIds = await fetchAllMessageIds(userId, query);
     jobState.progress.emailsFound = messageIds.length;