Fix TypeScript build errors for strict type checking

- Add explicit types to reduce/map/filter callback parameters across
  multiple files to resolve implicit 'any' type errors
- Export NotificationResult interface from notification-dispatcher.ts
- Add type cast for CorrelationState status field to match union type
- Replace 'any' types in field-correlation-engine.ts with proper
  Prisma-inferred types
- Add local interfaces (RecentLog, etc.) for component type safety

Files modified:
- src/lib/correlation-engine.ts
- src/lib/field-correlation-engine.ts
- src/lib/notification-dispatcher.ts
- src/app/(dashboard)/dashboard/page.tsx
- src/app/(dashboard)/dashboard/channels/page.tsx
- src/app/(dashboard)/dashboard/logs/page.tsx
- src/app/(dashboard)/dashboard/webhooks/[id]/page.tsx
- src/app/api/webhook/[uniqueUrl]/route.ts
- src/components/rules/unified-rule-builder.tsx
- src/components/rules/rule-builder.tsx

Author: Surgical17

src/app/(dashboard)/dashboard/channels/page.tsx

@@ -220,7 +220,7 @@ export default function ChannelsPage() {
 
       if (response.ok) {
         setChannels(
-          channels.map((c) => (c.id === id ? { ...c, enabled } : c))
+          channels.map((c: Channel) => (c.id === id ? { ...c, enabled } : c))
         );
         toast.success(`Channel ${enabled ? "enabled" : "disabled"}`);
       }
@@ -236,7 +236,7 @@ export default function ChannelsPage() {
       });
 
       if (response.ok) {
-        setChannels(channels.filter((c) => c.id !== id));
+        setChannels(channels.filter((c: Channel) => c.id !== id));
         toast.success("Channel deleted successfully");
       }
     } catch {

src/app/(dashboard)/dashboard/logs/page.tsx

@@ -234,7 +234,7 @@ export default function LogsPage() {
                   </TableRow>
                 </TableHeader>
                 <TableBody>
-                  {logs.map((log) => (
+                  {logs.map((log: WebhookLog) => (
                     <TableRow key={log.id}>
                       <TableCell className="font-mono text-sm">
                         {new Date(log.timestamp).toLocaleString()}

src/app/(dashboard)/dashboard/page.tsx

@@ -4,6 +4,16 @@ import { Card, CardContent, CardHeader, CardTitle } from "@/components/ui/card";
 import { Badge } from "@/components/ui/badge";
 import { Webhook, Bell, ScrollText, CheckCircle, XCircle, AlertCircle } from "lucide-react";
 
+interface RecentLog {
+  id: string;
+  timestamp: Date;
+  status: string;
+  notificationSent: boolean;
+  webhook: {
+    name: string;
+  };
+}
+
 async function getDashboardStats(userId: string) {
   const [webhooks, channels, logsToday, recentLogs] = await Promise.all([
     prisma.webhook.count({ where: { userId } }),
@@ -119,7 +129,7 @@ export default async function DashboardPage() {
             </p>
           ) : (
             <div className="space-y-4">
-              {stats.recentLogs.map((log) => (
+              {stats.recentLogs.map((log: RecentLog) => (
                 <div
                   key={log.id}
                   className="flex items-center justify-between border-b pb-4 last:border-0 last:pb-0"

src/app/(dashboard)/dashboard/webhooks/[id]/page.tsx

@@ -237,7 +237,7 @@ export default function WebhookDetailPage({
           prev
             ? {
                 ...prev,
-                rules: prev.rules.map((r) =>
+                rules: prev.rules.map((r: Rule) =>
                   r.id === ruleId ? { ...r, enabled } : r
                 ),
               }
@@ -259,7 +259,7 @@ export default function WebhookDetailPage({
       if (response.ok) {
         setWebhook((prev) =>
           prev
-            ? { ...prev, rules: prev.rules.filter((r) => r.id !== ruleId) }
+            ? { ...prev, rules: prev.rules.filter((r: Rule) => r.id !== ruleId) }
             : null
         );
         toast.success("Rule deleted successfully");
@@ -276,7 +276,7 @@ export default function WebhookDetailPage({
       });
 
       if (response.ok) {
-        setCorrelationRules((prev) => prev.filter((r) => r.id !== ruleId));
+        setCorrelationRules((prev) => prev.filter((r: CorrelationRule) => r.id !== ruleId));
         toast.success("Correlation rule deleted successfully");
       }
     } catch {

src/app/api/webhook/[uniqueUrl]/route.ts

@@ -1,7 +1,7 @@
 import { NextRequest, NextResponse } from "next/server";
 import { prisma } from "@/lib/prisma";
 import { evaluateRule, isRuleDebounced, updateRuleLastTriggered, updateServerState } from "@/lib/rule-engine";
-import { dispatchNotifications } from "@/lib/notification-dispatcher";
+import { dispatchNotifications, NotificationResult } from "@/lib/notification-dispatcher";
 import { processCorrelations } from "@/lib/correlation-engine";
 import { processFieldCorrelations } from "@/lib/field-correlation-engine";
 import { ConditionGroup, RuleAction } from "@/lib/validations/webhook";
@@ -119,7 +119,7 @@ export async function POST(request: NextRequest, { params }: RouteParams) {
           triggeredRules.push(rule.id);
 
           // Check results
-          const successfulNotifications = results.filter((r) => r.success);
+          const successfulNotifications = results.filter((r: NotificationResult) => r.success);
           const ruleNotificationSent = successfulNotifications.length > 0;
 
           if (ruleNotificationSent) {
@@ -129,7 +129,7 @@ export async function POST(request: NextRequest, { params }: RouteParams) {
             }
           } else {
             status = "failed";
-            const ruleErrors = results.map((r) => r.error).filter(Boolean).join("; ");
+            const ruleErrors = results.map((r: NotificationResult) => r.error).filter(Boolean).join("; ");
             errorMessage = errorMessage ? `${errorMessage}; ${ruleErrors}` : ruleErrors;
           }
 

src/components/rules/rule-builder.tsx

@@ -120,7 +120,7 @@ export function RuleBuilder({
         setLogic(parsedConditions.logic);
         setConditions(
           parsedConditions.conditions.filter(
-            (c): c is Condition => "field" in c
+            (c: Condition | ConditionGroup): c is Condition => "field" in c
           )
         );
 
@@ -170,7 +170,7 @@ export function RuleBuilder({
       return;
     }
 
-    const validConditions = conditions.filter((c) => c.field.trim());
+    const validConditions = conditions.filter((c: Condition) => c.field.trim());
     if (validConditions.length === 0) {
       toast.error("At least one condition is required");
       return;

src/components/rules/unified-rule-builder.tsx

@@ -166,7 +166,7 @@ export function UnifiedRuleBuilder({
         setLogic(parsedConditions.logic);
         setConditions(
           parsedConditions.conditions.filter(
-            (c): c is Condition => "field" in c
+            (c: Condition | ConditionGroup): c is Condition => "field" in c
           )
         );
 
@@ -187,7 +187,7 @@ export function UnifiedRuleBuilder({
         setLogic(parsedMatchConditions.logic);
         setConditions(
           parsedMatchConditions.conditions.filter(
-            (c): c is Condition => "field" in c
+            (c: Condition | ConditionGroup): c is Condition => "field" in c
           )
         );
 
@@ -270,7 +270,7 @@ export function UnifiedRuleBuilder({
       return;
     }
 
-    const validConditions = conditions.filter((c) => c.field.trim());
+    const validConditions = conditions.filter((c: Condition) => c.field.trim());
 
     if (selectedChannels.length === 0) {
       toast.error("At least one notification channel is required");
@@ -711,15 +711,15 @@ export function UnifiedRuleBuilder({
         <CardContent className="space-y-4">
           <div className="space-y-2">
             <Label>Notification Channels</Label>
-            {channels.filter((c) => c.enabled).length === 0 ? (
+            {channels.filter((c: Channel) => c.enabled).length === 0 ? (
               <p className="text-sm text-muted-foreground">
                 No channels configured. Add a channel first.
               </p>
             ) : (
               <div className="flex flex-wrap gap-2">
                 {channels
-                  .filter((c) => c.enabled)
-                  .map((channel) => (
+                  .filter((c: Channel) => c.enabled)
+                  .map((channel: Channel) => (
                     <Badge
                       key={channel.id}
                       variant={
@@ -812,8 +812,8 @@ export function UnifiedRuleBuilder({
                 <Label>Notification Channels</Label>
                 <div className="flex flex-wrap gap-2">
                   {channels
-                    .filter((c) => c.enabled)
-                    .map((channel) => (
+                    .filter((c: Channel) => c.enabled)
+                    .map((channel: Channel) => (
                       <Badge
                         key={channel.id}
                         variant={

src/lib/correlation-engine.ts

@@ -125,6 +125,14 @@ async function processAsTargetWebhook(
         ...rule,
         description: rule.description ?? undefined,
         timeoutActions: rule.timeoutActions ?? undefined,
+        correlationStates: rule.correlationStates.map((s: typeof rule.correlationStates[number]) => ({
+          ...s,
+          status: s.status as "waiting" | "completed" | "timeout",
+          targetWebhookId: s.targetWebhookId ?? undefined,
+          targetPayload: s.targetPayload ?? undefined,
+          targetReceivedAt: s.targetReceivedAt ?? undefined,
+          actionResult: s.actionResult ?? undefined,
+        })),
       };
       await completeCorrelation(state.id, webhookId, payload, ruleConfig);
     }
@@ -280,14 +288,14 @@ export async function getCorrelationStats(webhookId: string) {
 
   return {
     asSource: asSource.reduce(
-      (acc, item) => {
+      (acc: Record<string, number>, item: { status: string; _count: number }) => {
         acc[item.status] = item._count;
         return acc;
       },
       {} as Record<string, number>
     ),
     asTarget: asTarget.reduce(
-      (acc, item) => {
+      (acc: Record<string, number>, item: { status: string; _count: number }) => {
         acc[item.status] = item._count;
         return acc;
       },

src/lib/field-correlation-engine.ts

@@ -9,6 +9,9 @@ import { prisma } from "@/lib/prisma";
 import { evaluateConditionGroup } from "./rule-engine";
 import { dispatchNotifications } from "./notification-dispatcher";
 
+// Type inferred from Prisma model
+type FieldCorrelationRule = NonNullable<Awaited<ReturnType<typeof prisma.fieldCorrelationRule.findFirst>>>;
+
 /**
  * Process field correlations when a webhook receives data
  */
@@ -77,7 +80,7 @@ export async function processFieldCorrelations(
  * Process a received value for a correlation rule
  */
 async function processCorrelationValue(
-  rule: any,
+  rule: FieldCorrelationRule,
   fieldValue: string,
   payload: Record<string, unknown>,
   expectedValues: string[]
@@ -123,7 +126,7 @@ async function processCorrelationValue(
     }
   } else {
     // Create new correlation state
-    const receivedValues: Record<string, any> = {
+    const receivedValues: Record<string, Record<string, unknown>> = {
       [fieldValue]: payload,
     };
     const pendingValues = expectedValues.filter((v) => v !== fieldValue);
@@ -153,8 +156,8 @@ async function processCorrelationValue(
  */
 async function completeCorrelation(
   stateId: string,
-  rule: any,
-  receivedValues: Record<string, any>
+  rule: FieldCorrelationRule,
+  receivedValues: Record<string, Record<string, unknown>>
 ): Promise<void> {
   const state = await prisma.fieldCorrelationState.findUnique({
     where: { id: stateId },
@@ -287,15 +290,15 @@ async function cleanupExpiredStates(): Promise<void> {
 /**
  * Get nested value from object using dot notation
  */
-function getNestedValue(obj: any, path: string): any {
+function getNestedValue(obj: Record<string, unknown>, path: string): unknown {
   const keys = path.split(".");
-  let current = obj;
+  let current: unknown = obj;
 
   for (const key of keys) {
     if (current === null || current === undefined) {
       return undefined;
     }
-    current = current[key];
+    current = (current as Record<string, unknown>)[key];
   }
 
   return current;

src/lib/notification-dispatcher.ts

@@ -6,7 +6,7 @@ import { promisify } from "util";
 
 const execAsync = promisify(exec);
 
-interface NotificationResult {
+export interface NotificationResult {
   channelId: string;
   channelName: string;
   success: boolean;