fix(enrichments): preserve single-part names and output contracts

Author: waleedlatif1

apps/docs/content/docs/integrations/firecrawl.mdx

@@ -456,7 +456,7 @@ Retrieve the remaining and allocated Firecrawl credits for the team.
 
 ### Firecrawl Enrich
 
-Find work emails, mobile numbers, LinkedIn profiles, company domains, and company information through Firecrawl Alexandria. Uses FullEnrich for contact lookups and People Data Labs for company and name-based profile lookups. Provider terms must be enabled in Firecrawl. People Data Labs has a 50,000-record annual team limit.
+Find work emails, phone numbers, LinkedIn profiles, company domains, and company information through Firecrawl Alexandria. Uses FullEnrich for contact lookups and People Data Labs for company, name-based profile, and single-part-name contact lookups. Provider terms must be enabled in Firecrawl. People Data Labs has a 50,000-record annual team limit.
 
 <ReferenceDetails>
 
@@ -478,13 +478,13 @@ Find work emails, mobile numbers, LinkedIn profiles, company domains, and compan
 | --------- | ---- | ----------- |
 | `email` | string | Work email, when found |
 | `emailVerified` | boolean | True only when FullEnrich reports DELIVERABLE; catch-all and high-probability addresses remain unverified |
-| `phone` | string | Mobile number, when found |
+| `phone` | string | Phone number, preferring mobile when available |
 | `linkedinUrl` | string | LinkedIn profile URL, when found |
 | `domain` | string | Company website domain, when found |
 | `employeeCount` | string | Company headcount or size range |
 | `description` | string | Company description |
 | `creditsUsed` | number | Firecrawl credits charged for this lookup |
-| `status` | number | Provider or HTTP response status |
+| `statusCode` | number | Provider or HTTP response status code |
 
 </ReferenceDetails>
 

apps/sim/blocks/blocks/firecrawl.ts

@@ -86,7 +86,7 @@ export const FirecrawlBlock: BlockConfig = {
       type: 'dropdown',
       options: [
         { label: 'Work Email', id: 'work_email' },
-        { label: 'Mobile Number', id: 'phone' },
+        { label: 'Phone Number', id: 'phone' },
         { label: 'LinkedIn Profile', id: 'linkedin' },
         { label: 'Company Information', id: 'company' },
         { label: 'Company Domain', id: 'company_domain' },
@@ -111,6 +111,11 @@ export const FirecrawlBlock: BlockConfig = {
       title: 'Company Domain',
       type: 'short-input',
       placeholder: 'example.com',
+      required: {
+        field: 'operation',
+        value: 'enrich',
+        and: { field: 'enrichmentType', value: 'company' },
+      },
       condition: {
         field: 'operation',
         value: 'enrich',
@@ -122,6 +127,11 @@ export const FirecrawlBlock: BlockConfig = {
       title: 'Company Name',
       type: 'short-input',
       placeholder: 'Company name',
+      required: {
+        field: 'operation',
+        value: 'enrich',
+        and: { field: 'enrichmentType', value: 'company_domain' },
+      },
       condition: {
         field: 'operation',
         value: 'enrich',
@@ -870,11 +880,12 @@ Example 2 - Product Data:
   outputs: {
     email: { type: 'string', description: 'Work email, when found' },
     emailVerified: { type: 'boolean', description: 'Whether the work email is mailbox-verified' },
-    phone: { type: 'string', description: 'Mobile number, when found' },
+    phone: { type: 'string', description: 'Phone number, preferring mobile when available' },
     linkedinUrl: { type: 'string', description: 'LinkedIn profile URL, when found' },
     domain: { type: 'string', description: 'Company website domain, when found' },
     employeeCount: { type: 'string', description: 'Company headcount or size range' },
     description: { type: 'string', description: 'Company description' },
+    statusCode: { type: 'number', description: 'Enrichment provider or HTTP response status code' },
     // Scrape output
     markdown: { type: 'string', description: 'Page content markdown' },
     html: { type: 'string', description: 'Raw HTML content' },

apps/sim/enrichments/phone-number/phone-number.ts

@@ -1,5 +1,5 @@
 import { Phone } from '@sim/emcn/icons'
-import { normalizeDomain, splitName, str, toolProvider } from '@/enrichments/providers'
+import { normalizeDomain, str, toolProvider } from '@/enrichments/providers'
 import type { EnrichmentConfig } from '@/enrichments/types'
 
 export const phoneNumberEnrichment: EnrichmentConfig = {
@@ -22,7 +22,7 @@ export const phoneNumberEnrichment: EnrichmentConfig = {
         const fullName = str(inputs.fullName)
         const companyDomain = normalizeDomain(inputs.companyDomain)
         const linkedinUrl = str(inputs.linkedinUrl)
-        if (!linkedinUrl && !(splitName(fullName) && companyDomain)) return null
+        if (!linkedinUrl && !(fullName && companyDomain)) return null
         return { enrichmentType: 'phone', fullName, companyDomain, linkedinUrl }
       },
       mapOutput: (output) => {

apps/sim/enrichments/providers.ts

@@ -52,7 +52,10 @@ export function splitName(fullName: unknown): { firstName: string; lastName: str
 export function projectEnrichmentProviderFailure(
   failure: EnrichmentProviderFailure
 ): EnrichmentProviderFailureProjection {
-  if (isRecordLike(failure.output) && failure.output.status === 404) {
+  if (
+    isRecordLike(failure.output) &&
+    (failure.output.statusCode ?? failure.output.status) === 404
+  ) {
     return { status: 'no_match' }
   }
   return { status: 'error', error: failure.error }

apps/sim/enrichments/run.test.ts

@@ -50,35 +50,36 @@ beforeEach(() => {
 })
 
 describe('runEnrichment cascade detail', () => {
-  it('records the first match and stops the cascade', async () => {
-    mockExecuteTool.mockImplementation((toolId: string) => {
-      if (toolId === 'tool_a') return { success: false, output: { status: 404 } }
-      if (toolId === 'tool_b')
-        return { success: true, output: { email: 'j@acme.com', cost: { total: 0.05 } } }
-      throw new Error('tool_c should never run after a match')
-    })
-
-    const outcome = await runEnrichment(config([prov('a'), prov('b'), prov('c')]), {}, ctx)
-
-    expect(outcome.result).toEqual({ email: 'j@acme.com' })
-    expect(outcome.cost).toBe(0.05)
-    expect(outcome.error).toBeNull()
-    expect(outcome.provider).toBe('B')
-
-    expect(outcome.detail.matchedProvider).toBe('b')
-    expect(outcome.detail.totalCost).toBe(0.05)
-    // The full cascade is recorded; the provider after the match is `not_run`.
-    expect(outcome.detail.providers.map((p) => p.id)).toEqual(['a', 'b', 'c'])
-    expect(outcome.detail.providers.map((p) => p.status)).toEqual([
-      'no_match',
-      'matched',
-      'not_run',
-    ])
-    expect(outcome.detail.providers[1]?.cost).toBe(0.05)
-    expect(outcome.detail.providers.every((p) => typeof p.durationMs === 'number')).toBe(true)
-    // The tool is never called for the matched-past provider.
-    expect(mockExecuteTool).toHaveBeenCalledTimes(2)
-  })
+  it.each(['status', 'statusCode'])(
+    'records a %s miss before the first match',
+    async (statusField) => {
+      mockExecuteTool.mockImplementation((toolId: string) => {
+        if (toolId === 'tool_a') return { success: false, output: { [statusField]: 404 } }
+        if (toolId === 'tool_b')
+          return { success: true, output: { email: 'j@acme.com', cost: { total: 0.05 } } }
+        throw new Error('tool_c should never run after a match')
+      })
+
+      const outcome = await runEnrichment(config([prov('a'), prov('b'), prov('c')]), {}, ctx)
+
+      expect(outcome.result).toEqual({ email: 'j@acme.com' })
+      expect(outcome.cost).toBe(0.05)
+      expect(outcome.error).toBeNull()
+      expect(outcome.provider).toBe('B')
+
+      expect(outcome.detail.matchedProvider).toBe('b')
+      expect(outcome.detail.totalCost).toBe(0.05)
+      expect(outcome.detail.providers.map((p) => p.id)).toEqual(['a', 'b', 'c'])
+      expect(outcome.detail.providers.map((p) => p.status)).toEqual([
+        'no_match',
+        'matched',
+        'not_run',
+      ])
+      expect(outcome.detail.providers[1]?.cost).toBe(0.05)
+      expect(outcome.detail.providers.every((p) => typeof p.durationMs === 'number')).toBe(true)
+      expect(mockExecuteTool).toHaveBeenCalledTimes(2)
+    }
+  )
 
   it('marks providers with insufficient inputs as skipped without calling the tool', async () => {
     mockExecuteTool.mockImplementation(() => ({

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

@@ -1,5 +1,5 @@
 import { Mail } from '@sim/emcn/icons'
-import { normalizeDomain, splitName, str, toolProvider } from '@/enrichments/providers'
+import { normalizeDomain, str, toolProvider } from '@/enrichments/providers'
 import type { EnrichmentConfig } from '@/enrichments/types'
 
 export const workEmailEnrichment: EnrichmentConfig = {
@@ -22,7 +22,7 @@ export const workEmailEnrichment: EnrichmentConfig = {
         const fullName = str(inputs.fullName)
         const companyDomain = normalizeDomain(inputs.companyDomain)
         const linkedinUrl = str(inputs.linkedinUrl)
-        if (!linkedinUrl && !(splitName(fullName) && companyDomain)) return null
+        if (!linkedinUrl && !(fullName && companyDomain)) return null
         return { enrichmentType: 'work_email', fullName, companyDomain, linkedinUrl }
       },
       mapOutput: (output) => {

apps/sim/scripts/test-firecrawl-enrichment-e2e.ts

@@ -28,15 +28,38 @@ const person = {
   linkedinUrl: requiredEnv('FIRECRAWL_TEST_LINKEDIN_URL'),
   email: requiredEnv('FIRECRAWL_TEST_EMAIL'),
 }
+const profileUrl = new URL(
+  /^https?:\/\//i.test(person.linkedinUrl)
+    ? person.linkedinUrl
+    : `https://${person.linkedinUrl.replace(/^\/+/, '')}`
+)
+const [profileKind, profileSlug] = profileUrl.pathname.split('/').filter(Boolean)
+assert.match(profileUrl.hostname, /(^|\.)linkedin\.com$/i)
+assert.equal(profileKind?.toLowerCase(), 'in')
+assert.ok(profileSlug)
+const expectedLinkedinUrl = `https://www.linkedin.com/in/${profileSlug}`
 
 interface LiveCheck {
   name: string
   config: EnrichmentConfig
   inputs: Record<string, string>
-  verify: (output: Record<string, unknown>) => void
+  verify?: (output: Record<string, unknown>) => void
+  expectNoMatch?: boolean
 }
 
 const checks: LiveCheck[] = [
+  {
+    name: 'single-part-name email lookup returns a clean miss',
+    config: workEmailEnrichment,
+    inputs: { fullName: 'AlexandriaNoMatchFixture', companyDomain: 'example.com' },
+    expectNoMatch: true,
+  },
+  {
+    name: 'single-part-name phone lookup returns a clean miss',
+    config: phoneNumberEnrichment,
+    inputs: { fullName: 'AlexandriaNoMatchFixture', companyDomain: 'example.com' },
+    expectNoMatch: true,
+  },
   {
     name: 'work email from name and company',
     config: workEmailEnrichment,
@@ -54,13 +77,13 @@ const checks: LiveCheck[] = [
     name: 'LinkedIn from email',
     config: linkedinProfileEnrichment,
     inputs: { fullName: person.fullName, email: person.email },
-    verify: (output) => assert.equal(output.linkedinUrl, person.linkedinUrl),
+    verify: (output) => assert.equal(output.linkedinUrl, expectedLinkedinUrl),
   },
   {
     name: 'LinkedIn from name and company',
     config: linkedinProfileEnrichment,
     inputs: { fullName: person.fullName, companyDomain: person.companyDomain },
-    verify: (output) => assert.equal(output.linkedinUrl, person.linkedinUrl),
+    verify: (output) => assert.equal(output.linkedinUrl, expectedLinkedinUrl),
   },
   {
     name: 'company information',
@@ -112,10 +135,21 @@ try {
         signal: AbortSignal.timeout(180_000),
       })
       const result = await transform(response, params)
-      assert.ok(result.success, result.error)
-      const mapped = provider.mapOutput(result.output)
-      assert.ok(mapped, 'Expected a matching record')
-      check.verify(mapped)
+      if (check.expectNoMatch) {
+        assert.equal(result.success, false)
+        const failure = provider.projectFailure({
+          error: result.error ?? 'Lookup failed',
+          output: result.output,
+        })
+        assert.equal(failure.status, 'no_match')
+        assert.equal(result.output.creditsUsed, 0)
+      } else {
+        assert.ok(result.success, result.error)
+        const mapped = provider.mapOutput(result.output)
+        assert.ok(mapped, 'Expected a matching record')
+        assert.ok(check.verify)
+        check.verify(mapped)
+      }
       assert.ok(Number.isFinite(result.output.creditsUsed))
       assert.equal(pricing?.type, 'custom')
       const cost = pricing?.type === 'custom' ? pricing.getCost(params, result.output) : undefined

apps/sim/tools/firecrawl/enrich.test.ts

@@ -26,7 +26,7 @@ describe('Alexandria enrichment wire contract', () => {
     })
     expect(result.success).toBe(false)
     expect(result.error).toContain('Accept provider terms')
-    expect(result.output.status).toBe(403)
+    expect(result.output.statusCode).toBe(403)
   })
 
   it('preserves a provider 404 for the enrichment runner to classify as no match', async () => {
@@ -35,7 +35,7 @@ describe('Alexandria enrichment wire contract', () => {
       data: { creditsCost: 0, alexandria: [{ error: { message: 'No match', status: 404 } }] },
     })
     expect(result.success).toBe(false)
-    expect(result.output.status).toBe(404)
+    expect(result.output.statusCode).toBe(404)
   })
 
   it('rejects malformed success envelopes instead of reporting a clean miss', async () => {
@@ -126,4 +126,27 @@ describe('Alexandria enrichment wire contract', () => {
     expect(result.output.email).toBeNull()
     expect(result.output.creditsUsed).toBe(0)
   })
+
+  it('maps PDL contact records without claiming mailbox verification', async () => {
+    const result = await transform({
+      success: true,
+      data: {
+        creditsCost: 60,
+        alexandria: [
+          {
+            provider: 'people-data-labs',
+            capability: 'person/enrich',
+            data: {
+              data: { work_email: 'person@example.com', mobile_phone: '+12025550123' },
+            },
+          },
+        ],
+      },
+    })
+    expect(result.output).toMatchObject({
+      email: 'person@example.com',
+      emailVerified: false,
+      phone: '+12025550123',
+    })
+  })
 })

apps/sim/tools/firecrawl/enrich.ts

@@ -16,9 +16,25 @@ function enrichmentCall(params: FirecrawlEnrichParams) {
     case 'work_email':
     case 'phone': {
       const name = splitName(fullName)
-      if (!linkedinUrl && !(name && (companyDomain || companyName))) {
+      const company = companyDomain || companyName
+      if (!linkedinUrl && !(fullName && company)) {
         throw new Error('Provide a LinkedIn URL or a full name and company for contact enrichment')
       }
+      if (!linkedinUrl && !name) {
+        const fields =
+          params.enrichmentType === 'phone' ? ['mobile_phone', 'phone_numbers'] : ['work_email']
+        return {
+          provider: 'people-data-labs',
+          capability: 'person/enrich',
+          options: {
+            name: fullName,
+            company,
+            min_likelihood: 6,
+            required: fields.join(' OR '),
+            data_include: fields.join(','),
+          },
+        }
+      }
       return {
         provider: 'fullenrich',
         capability: params.enrichmentType === 'phone' ? 'contacts/mobile' : 'contacts/work-email',
@@ -82,7 +98,7 @@ export const firecrawlEnrichTool: ToolConfig<FirecrawlEnrichParams, FirecrawlEnr
   id: 'firecrawl_enrich',
   name: 'Firecrawl Enrich',
   description:
-    'Find work emails, mobile numbers, LinkedIn profiles, company domains, and company information through Firecrawl Alexandria. Uses FullEnrich for contact lookups and People Data Labs for company and name-based profile lookups. Provider terms must be enabled in Firecrawl. People Data Labs has a 50,000-record annual team limit.',
+    'Find work emails, phone numbers, LinkedIn profiles, company domains, and company information through Firecrawl Alexandria. Uses FullEnrich for contact lookups and People Data Labs for company, name-based profile, and single-part-name contact lookups. Provider terms must be enabled in Firecrawl. People Data Labs has a 50,000-record annual team limit.',
   version: '1.0.0',
   hosting: firecrawlHosting<FirecrawlEnrichParams>(),
   params: {
@@ -153,15 +169,15 @@ export const firecrawlEnrichTool: ToolConfig<FirecrawlEnrichParams, FirecrawlEnr
       employeeCount: null,
       description: null,
       creditsUsed: 0,
-      status: typeof error.status === 'number' ? error.status : response.status,
+      statusCode: typeof error.status === 'number' ? error.status : response.status,
     }
     if (!response.ok || envelope.success !== true || result.error) {
       return {
         success: false,
         error:
           toStringOrNull(error.message) ??
           toStringOrNull(envelope.error) ??
-          `Firecrawl enrichment failed (${output.status})`,
+          `Firecrawl enrichment failed (${output.statusCode})`,
         output,
       }
     }
@@ -190,6 +206,13 @@ export const firecrawlEnrichTool: ToolConfig<FirecrawlEnrichParams, FirecrawlEnr
       output.linkedinUrl = toStringOrNull(social.url)
     } else if (result.provider === 'people-data-labs') {
       const person = toRecord(record.data)
+      output.email = toStringOrNull(person.work_email)
+      output.phone =
+        toStringOrNull(person.mobile_phone) ||
+        toArray(person.phone_numbers)
+          .map(toStringOrNull)
+          .find((phone) => phone?.trim()) ||
+        null
       output.linkedinUrl = toStringOrNull(person.linkedin_url)
       output.domain = toStringOrNull(record.website)
       output.employeeCount =
@@ -209,7 +232,11 @@ export const firecrawlEnrichTool: ToolConfig<FirecrawlEnrichParams, FirecrawlEnr
       description:
         'True only when FullEnrich reports DELIVERABLE; catch-all and high-probability addresses remain unverified',
     },
-    phone: { type: 'string', description: 'Mobile number, when found', optional: true },
+    phone: {
+      type: 'string',
+      description: 'Phone number, preferring mobile when available',
+      optional: true,
+    },
     linkedinUrl: {
       type: 'string',
       description: 'LinkedIn profile URL, when found',
@@ -223,6 +250,6 @@ export const firecrawlEnrichTool: ToolConfig<FirecrawlEnrichParams, FirecrawlEnr
     },
     description: { type: 'string', description: 'Company description', optional: true },
     creditsUsed: { type: 'number', description: 'Firecrawl credits charged for this lookup' },
-    status: { type: 'number', description: 'Provider or HTTP response status' },
+    statusCode: { type: 'number', description: 'Provider or HTTP response status code' },
   },
 }