Apollo、Output.ai、Zapier SDKでHubSpotのCompaniesをOAuthなしで強化する

zapier_hubspot_company_enrichment/
├── workflow.ts          # オーケストレーション — 並列取得、次にマップ、最後にアップサート
├── steps.ts             # 4ステップ: エンリッチ, fetchIndustries, mapIndustry, upsert
├── types.ts             # ZodスキーマとTypeScript型
├── prompts/
│   └── map_hubspot_industry@v1.prompt  # Haiku — セマンティックな業種マッピング
└── scenarios/
    └── stripe.json      # テスト入力: Stripe

import { workflow } from '@outputai/core';
import {
  enrichCompanyWithApollo,
  fetchHubspotIndustries,
  mapHubspotIndustry,
  upsertHubspotCompany,
} from './steps.js';
import { workflowInputSchema, workflowOutputSchema } from './types.js';

export default workflow({
  name: 'zapier_company_enrichment',
  description:
    'Enriches a company profile using Apollo via REST API and upserts the result into HubSpot via Zapier SDK',
  inputSchema: workflowInputSchema,
  outputSchema: workflowOutputSchema,
  fn: async (input) => {
    // ステップ1 + 2 — Apolloでエンリッチしつつ、HubSpotの業種選択肢を並列に取得
    const [apolloData, { industries }] = await Promise.all([
      enrichCompanyWithApollo({ website: input.website }),
      fetchHubspotIndustries(),
    ]);

    // ステップ3 — Apolloの生の業種文字列を、有効なHubSpotのenumにマップ（何かしら返ってきた場合）
    const hubspotIndustry = apolloData.industry
      ? (
          await mapHubspotIndustry({
            industry: apolloData.industry,
            hubspotIndustries: industries,
          })
        ).hubspotIndustry
      : undefined;

import { step } from '@outputai/core';
import { generateText, Output } from '@outputai/llm';
import { enrichOrganization } from '../../shared/clients/apollo.js';
import { createZapierClient } from '../../shared/clients/zapier.js';
import {
  enrichCompanyInputSchema,
  apolloCompanySchema,
  fetchHubspotIndustriesOutputSchema,
  mapHubspotIndustryInputSchema,
  mapHubspotIndustryOutputSchema,
  hubspotUpsertInputSchema,
  hubspotUpsertOutputSchema,
  zapierHubspotResponseSchema,
} from './types.js';

const HUBSPOT_CONNECTION_ID = 'your-hubspot-connection-id';

function extractDomain(website: string): string {
  const url = new URL(website);
  return url.hostname.replace(/^www\./, '');
}

// --- ステップ 1: Apollo REST API 経由で会社情報を強化する ---

export const enrichCompanyWithApollo = step({
  name: 'enrich_company_with_apollo',
  description: 'Enriches company data using Apollo REST API directly',
  inputSchema: enrichCompanyInputSchema,
  outputSchema: apolloCompanySchema,
  fn: async ({ website }) => {
    const domain = extractDomain(website);
    const org = await enrichOrganization(domain);

    if (!org?.name) {
      throw new Error(`Apollo returned no data for domain: ${domain}`);
    }

返却形式: {"translated": "翻訳されたHTML"}return {
      name: org.name,
      website: org.website_url ?? website,
      domain: org.primary_domain ?? domain,
      industry: org.industry ?? undefined,
      employeeCount: org.estimated_num_employees ?? undefined,
      estimatedRevenue: org.annual_revenue_printed ?? undefined,
      description: org.short_description ?? undefined,
      linkedinUrl: org.linkedin_url ?? undefined,
      city: org.city ?? undefined,
      country: org.country ?? undefined,
      keywords: Array.isArray(org.keywords) ? org.keywords : undefined,
      totalFunding: org.total_funding ?? undefined,
      latestFundingRound: org.latest_funding_round_date ?? undefined,
      fundingStage: org.latest_funding_stage ?? undefined,
    };
  },
});

// --- Step 2: Zapier SDK を介して HubSpot の業種エヌム選択肢を取得する ---

export const fetchHubspotIndustries = step({
  name: 'fetch_hubspot_industries',
  description: 'Zapier SDK を介して利用可能な HubSpot の業種フィールドの選択肢を取得します',
  outputSchema: fetchHubspotIndustriesOutputSchema,
  fn: async () => {
    const zapier = createZapierClient();

    const industries: string[] = [];
    for await (const item of zapier
      .listInputFieldChoices({
        appKey: 'hubspot',
        actionType: 'search_or_write',
        actionKey: 'company_crmSearch',
        inputFieldKey: 'industry',
        connectionId: HUBSPOT_CONNECTION_ID,
      })
      .items()) {
      const value = item.value ?? item.key ?? item.label;
      if (value) industries.push(value);
    }

    return { industries };
  },
});

// --- Step 3: LLM を介して Apollo の業種文字列を HubSpot のエヌムにマッピングする ---

返却形式: {"translated": "翻訳されたHTML"}export const mapHubspotIndustry = step({
  name: 'map_hubspot_industry',
  description: 'LLMを使って、生の業種文字列を有効なHubSpot業種enum値にマッピングします',
  inputSchema: mapHubspotIndustryInputSchema,
  outputSchema: mapHubspotIndustryOutputSchema,
  fn: async ({ industry, hubspotIndustries }) => {
    const { output } = await generateText({
      prompt: 'map_hubspot_industry@v1',
      variables: {
        industry,
        hubspotIndustries: hubspotIndustries.join(', '),
      },
      output: Output.object({ schema: mapHubspotIndustryOutputSchema }),
    });

    return output;
  },
});

// --- Step 4: Zapier SDK経由でHubSpotへアップサート ---

export const upsertHubspotCompany = step({
  name: 'upsert_hubspot_company',
  description:
    'Zapier SDKを介して、豊富化したApolloデータを使ってHubSpotの会社レコードを作成または更新します',
  inputSchema: hubspotUpsertInputSchema,
  outputSchema: hubspotUpsertOutputSchema,
  fn: async (input) => {
    const zapier = createZapierClient();

    const domain = input.domain ?? extractDomain(input.website ?? '');

    const inputs = {
      first_search_property_name: 'name',
      first_search_property_value: input.name,
      name: input.name,
      domain: domain ?? '',
      website: input.website ?? '',
      city: input.city ?? '',
      country: input.country ?? '',
      industry: input.hubspotIndustry ?? '',
      numberofemployees: input.employeeCount ? String(input.employeeCount) : '',
      description: input.description ?? '',
      linkedin_company_page: input.linkedinUrl ?? '',
      total_money_raised: input.totalFunding ? String(input.totalFunding) : '',
    };const { data: result } = await zapier.apps.hubspot.search_or_write.company_crmSearch({
      inputs,
      connectionId: HUBSPOT_CONNECTION_ID,
    });

    const [record] = zapierHubspotResponseSchema.parse(result);

    return {
      hubspotCompanyId: record.id,
      action: record.isNew ? 'created' : 'updated',
    };
  },
});

import { z } from '@outputai/core';

export const workflowInputSchema = z.object({
  companyName: z.string().describe('The name of the company to enrich'),
  website: z.string().url().describe('The company website URL (e.g. https://acme.com)'),
});

export const apolloCompanySchema = z.object({
  name: z.string(),
  website: z.string().optional(),
  domain: z.string().optional(),
  industry: z.string().optional(),
  employeeCount: z.number().optional(),
  estimatedRevenue: z.string().optional(),
  description: z.string().optional(),
  linkedinUrl: z.string().optional(),
  city: z.string().optional(),
  country: z.string().optional(),
  keywords: z.array(z.string()).optional(),
  totalFunding: z.number().optional().describe('Total funding raised in USD'),
  latestFundingRound: z.string().optional(),
  fundingStage: z.string().optional(),
});

返却形式: {"translated": "翻訳されたHTML"}export const workflowOutputSchema = z.object({
  companyName: z.string(),
  website: z.string(),
  hubspotCompanyId: z.string(),
  apolloData: apolloCompanySchema,
  action: z.enum(['created', 'updated']),
});

export const hubspotUpsertInputSchema = apolloCompanySchema.extend({
  hubspotIndustry: z.string().optional(),
});

---
provider: anthropic
model: claude-haiku-4-5
temperature: 0
maxTokens: 256
---

<system>
あなたは、企業の業種文字列を HubSpot の事前定義済みの業種 ENUM 値へ対応付けることに精通した専門家です。

業種カテゴリが与えられたら、最も適切に一致する 1 つの HubSpot 業種値を返してください。

有効な HubSpot 業種値:
{{ hubspotIndustries }}

ルール:
- 上のリストから、ちょうど 1 つの値だけを返す
- 完全に一致する文字列でなくても、最も近い意味的な一致を選ぶ
- 妥当な一致が存在しない場合は、最も近いカテゴリを返す
</system>

<user>
この業種を HubSpot の業種値に対応付けてください:

業種: {{ industry }}
</user>

import { createZapierSdk } from '@zapier/zapier-sdk';

const zapier = createZapierSdk({
  credentials: { clientId: '...', clientSecret: '...'},
});

const { data: result } = await zapier.apps.hubspot.search_or_write.company_crmSearch({
  inputs: {
    first_search_property_name: 'name',
    first_search_property_value: 'Stripe',
    name: 'Stripe',
    domain: 'stripe.com',
    industry: 'COMPUTER_SOFTWARE',
  },
  connectionId: HUBSPOT_CONNECTION_ID,
});