feat(enrichments): add Findymail, Prospeo, Wiza to work-email waterfall

Author: TheodoreSpeaks

apps/sim/enrichments/work-email/work-email.test.ts

@@ -0,0 +1,70 @@
+/**
+ * @vitest-environment node
+ */
+import { describe, expect, it } from 'vitest'
+import type { EnrichmentProvider } from '@/enrichments/types'
+import { workEmailEnrichment } from '@/enrichments/work-email/work-email'
+
+function provider(id: string): EnrichmentProvider {
+  const p = workEmailEnrichment.providers.find((x) => x.id === id)
+  if (!p) throw new Error(`Provider ${id} not found in work-email cascade`)
+  return p
+}
+
+const inputs = { fullName: 'John Doe', companyDomain: 'https://www.acme.com/careers' }
+
+describe('work-email enrichment cascade', () => {
+  it('chains the five hosted providers in waterfall order', () => {
+    expect(workEmailEnrichment.providers.map((p) => p.id)).toEqual([
+      'hunter',
+      'findymail',
+      'prospeo',
+      'wiza',
+      'pdl',
+    ])
+  })
+
+  describe('findymail', () => {
+    const p = provider('findymail')
+    it('maps name + normalized domain and extracts contact.email', () => {
+      expect(p.toolId).toBe('findymail_find_email_from_name')
+      expect(p.buildParams(inputs)).toEqual({ name: 'John Doe', domain: 'acme.com' })
+      expect(p.mapOutput({ contact: { email: 'j@acme.com' } })).toEqual({ email: 'j@acme.com' })
+      expect(p.mapOutput({ contact: null })).toBeNull()
+    })
+    it('skips when name or domain is missing', () => {
+      expect(p.buildParams({ fullName: '', companyDomain: 'acme.com' })).toBeNull()
+      expect(p.buildParams({ fullName: 'John Doe', companyDomain: '' })).toBeNull()
+    })
+  })
+
+  describe('prospeo', () => {
+    const p = provider('prospeo')
+    it('maps full_name + company_website and extracts person.email.email', () => {
+      expect(p.toolId).toBe('prospeo_enrich_person')
+      expect(p.buildParams(inputs)).toEqual({ full_name: 'John Doe', company_website: 'acme.com' })
+      expect(
+        p.mapOutput({ person: { email: { email: 'j@acme.com', status: 'VERIFIED' } } })
+      ).toEqual({
+        email: 'j@acme.com',
+      })
+      expect(p.mapOutput({ free_enrichment: true, person: null })).toBeNull()
+    })
+  })
+
+  describe('wiza', () => {
+    const p = provider('wiza')
+    it('reveals email-only (partial) and maps output.email', () => {
+      expect(p.toolId).toBe('wiza_individual_reveal')
+      expect(p.buildParams(inputs)).toEqual({
+        full_name: 'John Doe',
+        domain: 'acme.com',
+        enrichment_level: 'partial',
+      })
+      expect(p.mapOutput({ email: 'j@acme.com', email_status: 'valid' })).toEqual({
+        email: 'j@acme.com',
+      })
+      expect(p.mapOutput({ email: null })).toBeNull()
+    })
+  })
+})

apps/sim/enrichments/work-email/work-email.ts

@@ -5,8 +5,10 @@ import type { EnrichmentConfig } from '@/enrichments/types'
 
 /**
  * Work Email enrichment. Finds a person's work email from their full name and
- * company domain, trying Hunter first (deterministic finder) then People Data
- * Labs (record match) as a fallback.
+ * company domain via a provider waterfall: deterministic finders first (Hunter,
+ * Findymail), then enrichment/reveal providers (Prospeo, Wiza), then People Data
+ * Labs as a broad record-match fallback. The first provider to return an email
+ * wins; each provider supports hosted keys so the cascade runs without BYOK.
  */
 export const workEmailEnrichment: EnrichmentConfig = {
   id: 'work-email',
@@ -34,6 +36,55 @@ export const workEmailEnrichment: EnrichmentConfig = {
         return email ? { email } : null
       },
     }),
+    toolProvider({
+      id: 'findymail',
+      label: 'Findymail',
+      toolId: 'findymail_find_email_from_name',
+      buildParams: (inputs) => {
+        const name = str(inputs.fullName)
+        const domain = normalizeDomain(inputs.companyDomain)
+        if (!name || !domain) return null
+        return { name, domain }
+      },
+      mapOutput: (output) => {
+        const contact = output.contact as Record<string, unknown> | null
+        const email = str(contact?.email)
+        return email ? { email } : null
+      },
+    }),
+    toolProvider({
+      id: 'prospeo',
+      label: 'Prospeo',
+      toolId: 'prospeo_enrich_person',
+      buildParams: (inputs) => {
+        const fullName = str(inputs.fullName)
+        const companyWebsite = normalizeDomain(inputs.companyDomain)
+        if (!fullName || !companyWebsite) return null
+        return { full_name: fullName, company_website: companyWebsite }
+      },
+      mapOutput: (output) => {
+        const person = output.person as Record<string, unknown> | undefined
+        const emailObj = person?.email as Record<string, unknown> | undefined
+        const email = str(emailObj?.email)
+        return email ? { email } : null
+      },
+    }),
+    toolProvider({
+      id: 'wiza',
+      label: 'Wiza',
+      toolId: 'wiza_individual_reveal',
+      buildParams: (inputs) => {
+        const fullName = str(inputs.fullName)
+        const domain = normalizeDomain(inputs.companyDomain)
+        if (!fullName || !domain) return null
+        // 'partial' reveals the email only (2 credits); avoids phone charges.
+        return { full_name: fullName, domain, enrichment_level: 'partial' }
+      },
+      mapOutput: (output) => {
+        const email = str(output.email)
+        return email ? { email } : null
+      },
+    }),
     toolProvider({
       id: 'pdl',
       label: 'People Data Labs',