fix(icypeas): handle 200 validationErrors body as a BAD_INPUT verdict

Author: TheodoreSpeaks

apps/sim/tools/icypeas-hosting.test.ts

@@ -83,6 +83,72 @@ describe('Icypeas verify-email pricing', () => {
   })
 })
 
+describe('Icypeas transformResponse validation errors', () => {
+  it('verify-email maps a 200 validationErrors body to a BAD_INPUT verdict', async () => {
+    const response = new Response(
+      JSON.stringify({
+        success: false,
+        validationErrors: [
+          { expected: 'email', type: 'required', field: 'email', message: 'validation_required' },
+        ],
+      }),
+      { status: 200, headers: { 'Content-Type': 'application/json' } }
+    )
+
+    const result = await icypeasVerifyEmailTool.transformResponse!(response, {
+      apiKey: 'test-key',
+      email: 'support@stripe.com',
+    } as any)
+
+    expect(result.success).toBe(true)
+    expect((result.output as any).status).toBe('BAD_INPUT')
+    expect((result.output as any).valid).toBe(false)
+    expect((result.output as any).email).toBe('support@stripe.com')
+    expect((result.output as any).searchId).toBeNull()
+  })
+
+  it('find-email maps a 200 validationErrors body to a BAD_INPUT verdict', async () => {
+    const response = new Response(
+      JSON.stringify({
+        success: false,
+        validationErrors: [
+          {
+            expected: 'string',
+            type: 'required',
+            field: 'domainOrCompany',
+            message: 'validation_required',
+          },
+        ],
+      }),
+      { status: 200, headers: { 'Content-Type': 'application/json' } }
+    )
+
+    const result = await icypeasFindEmailTool.transformResponse!(response, {
+      apiKey: 'test-key',
+      domainOrCompany: 'stripe.com',
+    } as any)
+
+    expect(result.success).toBe(true)
+    expect((result.output as any).status).toBe('BAD_INPUT')
+    expect((result.output as any).email).toBeNull()
+    expect((result.output as any).searchId).toBeNull()
+  })
+
+  it('verify-email still throws when a success body has no item _id', async () => {
+    const response = new Response(JSON.stringify({ success: true, item: {} }), {
+      status: 200,
+      headers: { 'Content-Type': 'application/json' },
+    })
+
+    await expect(
+      icypeasVerifyEmailTool.transformResponse!(response, {
+        apiKey: 'test-key',
+        email: 'jane@example.com',
+      } as any)
+    ).rejects.toThrow(/item _id/)
+  })
+})
+
 describe('Icypeas find-email postProcess poll', () => {
   it('polls the results endpoint until terminal status and returns the email', async () => {
     vi.useFakeTimers()

apps/sim/tools/icypeas/find_email.ts

@@ -112,6 +112,24 @@ export const icypeasFindEmailTool: ToolConfig<IcypeasFindEmailParams, IcypeasFin
       throw new Error(`Icypeas API error: ${response.status} - ${errorText}`)
     }
     const json = (await response.json()) as Record<string, unknown>
+    // Icypeas returns HTTP 200 with { success: false, validationErrors: [...] } when
+    // it rejects the input up front (missing/invalid name or domain). There is no item
+    // to poll — this is a BAD_INPUT verdict, not a transport error. Surface it as a
+    // successful run with a null email so the enrichment cascade records the verdict
+    // instead of inflating the runner's error count.
+    if (json.success === false || Array.isArray(json.validationErrors)) {
+      return {
+        success: true,
+        output: {
+          searchId: null,
+          status: 'BAD_INPUT',
+          email: null,
+          firstname: null,
+          lastname: null,
+          item: json,
+        },
+      }
+    }
     // Submit response: { success: true, item: { _id: '...', status: 'NONE', ... } }
     const item = (json.item as Record<string, unknown> | undefined) ?? {}
     const searchId = (item._id as string | undefined) ?? null

apps/sim/tools/icypeas/verify_email.ts

@@ -99,12 +99,29 @@ export const icypeasVerifyEmailTool: ToolConfig<
     }),
   },
 
-  transformResponse: async (response: Response) => {
+  transformResponse: async (response: Response, params?: IcypeasVerifyEmailParams) => {
     if (!response.ok) {
       const errorText = await response.text()
       throw new Error(`Icypeas API error: ${response.status} - ${errorText}`)
     }
     const json = (await response.json()) as Record<string, unknown>
+    // Icypeas returns HTTP 200 with { success: false, validationErrors: [...] } when
+    // it rejects the input up front (bad format, role-based address, etc.). There is
+    // no item to poll — this is a BAD_INPUT verdict, not a transport error. Surface it
+    // as a successful run with valid=false so the enrichment cascade records the
+    // verdict instead of inflating the runner's error count.
+    if (json.success === false || Array.isArray(json.validationErrors)) {
+      return {
+        success: true,
+        output: {
+          searchId: null,
+          status: 'BAD_INPUT',
+          email: params?.email ?? null,
+          valid: false,
+          item: json,
+        },
+      }
+    }
     // Submit response: { success: true, item: { _id: '...', status: 'NONE', ... } }
     const item = (json.item as Record<string, unknown> | undefined) ?? {}
     const searchId = (item._id as string | undefined) ?? null