feat(oracle-fusion-sales): add Oracle Fusion Sales integration

Author: Bill Leoutsakos

apps/docs/components/ui/icon-mapping.ts

@@ -480,6 +480,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   onedrive: MicrosoftOneDriveIcon,
   onepassword: OnePasswordIcon,
   openai: OpenAIIcon,
+  oracle_fusion_sales: NetSuiteIcon,
   outlook: OutlookIcon,
   pagerduty: PagerDutyIcon,
   parallel_ai: ParallelIcon,

apps/docs/content/docs/integrations/meta.json

@@ -187,6 +187,7 @@
     "onedrive",
     "onepassword",
     "openai",
+    "oracle_fusion_sales",
     "outlook",
     "pagerduty",
     "parallel_ai",

apps/docs/content/docs/integrations/oracle_fusion_sales.mdx

@@ -251,6 +251,7 @@ import { OktaBlock, OktaBlockMeta } from '@/blocks/blocks/okta'
 import { OneDriveBlock, OneDriveBlockMeta } from '@/blocks/blocks/onedrive'
 import { OnePasswordBlock, OnePasswordBlockMeta } from '@/blocks/blocks/onepassword'
 import { OpenAIBlock, OpenAIBlockMeta } from '@/blocks/blocks/openai'
+import { OracleFusionSalesBlock, OracleFusionSalesBlockMeta } from '@/blocks/blocks/oracle_fusion_sales'
 import { OutlookBlock, OutlookBlockMeta } from '@/blocks/blocks/outlook'
 import { PagerDutyBlock, PagerDutyBlockMeta } from '@/blocks/blocks/pagerduty'
 import { ParallelBlock, ParallelBlockMeta } from '@/blocks/blocks/parallel'
@@ -584,6 +585,7 @@ export const BLOCK_REGISTRY: Record<string, BlockConfig> = {
   mysql: MySQLBlock,
   neo4j: Neo4jBlock,
   netsuite: NetSuiteBlock,
+  oracle_fusion_sales: OracleFusionSalesBlock,
   new_relic: NewRelicBlock,
   note: NoteBlock,
   notion: NotionBlock,
@@ -905,6 +907,7 @@ export const BLOCK_META_REGISTRY: Record<string, BlockMeta> = {
   mysql: MySQLBlockMeta,
   neo4j: Neo4jBlockMeta,
   netsuite: NetSuiteBlockMeta,
+  oracle_fusion_sales: OracleFusionSalesBlockMeta,
   neverbounce: NeverBounceBlockMeta,
   new_relic: NewRelicBlockMeta,
   notion: NotionBlockMeta,

apps/sim/blocks/blocks/oracle_fusion_sales.ts

@@ -243,6 +243,7 @@ export const DOCS_MANIFEST: readonly string[] = [
   'integrations/onedrive.mdx',
   'integrations/onepassword.mdx',
   'integrations/openai.mdx',
+  'integrations/oracle_fusion_sales.mdx',
   'integrations/outlook.mdx',
   'integrations/pagerduty.mdx',
   'integrations/parallel_ai.mdx',

apps/sim/blocks/registry-maps.ts

@@ -68,6 +68,7 @@ const EXPECTED_COVERAGE: Record<string, string[]> = {
   // NetSuite remains an API-key catalog integration, like Snowflake, while its
   // block uses the shared reusable-credential selector.
   'netsuite-service-account': [],
+  'oracle-fusion-service-account': [],
   'pipedrive-service-account': ['pipedrive'],
   'salesforce-service-account': ['salesforce'],
   'shopify-service-account': ['shopify'],
@@ -100,6 +101,20 @@ const serviceAccount = (providerId: string) => ({
 })
 
 describe('service-account coverage', () => {
+  it('offers Fusion Sales reusable credentials with API-key catalog classification', () => {
+    const integration = INTEGRATIONS.find((entry) => entry.type === 'oracle_fusion_sales')
+    expect(integration?.authType).toBe('api-key')
+    expect(OAUTH_PROVIDERS.oracle_fusion_sales.services.oracle_fusion_sales).toMatchObject({
+      providerId: 'oracle_fusion_sales',
+      serviceAccountProviderId: 'oracle-fusion-service-account',
+      authType: 'service_account',
+    })
+    expect(credentialProviderMatchesService(
+      'oracle-fusion-service-account',
+      OAUTH_PROVIDERS.oracle_fusion_sales.services.oracle_fusion_sales
+    )).toBe(true)
+  })
+
   it('exposes NetSuite reusable credentials without changing its API-key catalog class', () => {
     const netSuiteIntegration = INTEGRATIONS.find((integration) => integration.type === 'netsuite')
     expect(netSuiteIntegration?.authType).toBe('api-key')

apps/sim/lib/copilot/generated/docs-manifest.ts

@@ -462,6 +462,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   okta: OktaIcon,
   onedrive: MicrosoftOneDriveIcon,
   onepassword: OnePasswordIcon,
+  oracle_fusion_sales: NetSuiteIcon,
   outlook: OutlookIcon,
   pagerduty: PagerDutyIcon,
   parallel_ai: ParallelIcon,

apps/sim/lib/integrations/credential-display.test.ts

@@ -0,0 +1,104 @@
+/**
+ * @vitest-environment node
+ */
+import { beforeEach, describe, expect, it, vi } from 'vitest'
+
+const mocks = vi.hoisted(() => ({ json: vi.fn(), empty: vi.fn() }))
+vi.mock('@/lib/internal/oracle-fusion/client', () => ({
+  requestOracleFusionJson: mocks.json,
+  requestOracleFusionEmpty: mocks.empty,
+}))
+
+import { OracleFusionProviderError } from '@/lib/internal/oracle-fusion/errors'
+import { executeOracleFusionSalesTool } from '@/lib/internal/oracle-fusion-sales/execute-tool'
+
+const AUTH = {
+  oauthCredential: 'credential-1',
+  accessToken: 'dXNlcjpwYXNzd29yZA==',
+  instanceUrl: 'https://vision.fa.us2.oraclecloud.com',
+}
+
+function call(toolId: string, params: Record<string, unknown> = {}, signal?: AbortSignal) {
+  return executeOracleFusionSalesTool({
+    toolId,
+    input: { ...AUTH, ...params },
+    headers: new Headers(),
+    context: { workflowId: 'workflow-1', workspaceId: 'workspace-1', userId: 'user-1' },
+    requestId: 'request-1',
+    signal,
+  })
+}
+
+describe('Oracle Fusion Sales internal handler', () => {
+  beforeEach(() => vi.clearAllMocks())
+
+  it('rejects invalid required inputs before provider requests', async () => {
+    const response = await call('oracle_fusion_sales_create_account')
+    expect(response.status).toBe(400)
+    expect(await response.json()).toMatchObject({ success: false, retryable: false })
+    expect(mocks.json).not.toHaveBeenCalled()
+    expect(mocks.empty).not.toHaveBeenCalled()
+  })
+
+  it('returns documented action results without asserting business success', async () => {
+    mocks.json.mockResolvedValue({ result: 'Failure' })
+    const response = await call('oracle_fusion_sales_accept_lead', { leadId: '123' })
+    expect(response.status).toBe(200)
+    expect(await response.json()).toEqual({ success: true, output: { result: 'Failure' } })
+  })
+
+  it('uses the empty-body contract for deletes', async () => {
+    mocks.empty.mockResolvedValue(undefined)
+    const response = await call('oracle_fusion_sales_delete_account', { accountNumber: 'A001' })
+    expect(await response.json()).toEqual({ success: true, output: { deleted: true } })
+    expect(mocks.json).not.toHaveBeenCalled()
+  })
+
+  it.each([401, 403, 404, 429, 503])('preserves safe provider status %s', async (status) => {
+    mocks.json.mockRejectedValue(new OracleFusionProviderError('Oracle Fusion denied this request', status))
+    const response = await call('oracle_fusion_sales_accept_lead', { leadId: '123' })
+    expect(response.status).toBe(status)
+    expect(await response.json()).toEqual({
+      success: false, error: 'Oracle Fusion denied this request', retryable: false,
+    })
+  })
+
+  it('does not disclose unexpected provider or credential errors', async () => {
+    mocks.json.mockRejectedValue(new Error('private-provider-canary'))
+    const response = await call('oracle_fusion_sales_accept_lead', { leadId: '123' })
+    expect(response.status).toBe(500)
+    expect(await response.text()).not.toContain('private-provider-canary')
+  })
+
+  it('rejects malformed action output', async () => {
+    mocks.json.mockResolvedValue({ result: { OptyId: 123 } })
+    const response = await call('oracle_fusion_sales_convert_lead', { leadId: '123' })
+    expect(response.status).toBe(502)
+    expect(await response.json()).toMatchObject({ success: false })
+  })
+
+  it('preserves cancellation before and during provider execution', async () => {
+    const controller = new AbortController()
+    const reason = new DOMException('Cancelled', 'AbortError')
+    controller.abort(reason)
+    await expect(call('oracle_fusion_sales_list_accounts', {}, controller.signal)).rejects.toBe(reason)
+    expect(mocks.json).not.toHaveBeenCalled()
+
+    const pending = new AbortController()
+    mocks.json.mockImplementation(async () => {
+      pending.abort(reason)
+      return { result: 'Successful' }
+    })
+    await expect(call('oracle_fusion_sales_accept_lead', { leadId: '123' }, pending.signal))
+      .rejects.toBe(reason)
+    expect(mocks.json.mock.calls[0][2]).toBe(pending.signal)
+  })
+
+  it('does not dispatch unrelated or inherited object property names', async () => {
+    for (const toolId of ['oracle_fusion_service_list_accounts', 'oracle_fusion_sales_constructor']) {
+      expect((await call(toolId)).status).toBe(500)
+    }
+    expect(mocks.json).not.toHaveBeenCalled()
+  })
+})
+

apps/sim/lib/integrations/icon-mapping.ts

@@ -0,0 +1,54 @@
+import { z } from 'zod'
+import { OracleFusionProviderError } from '@/lib/internal/oracle-fusion/errors'
+import { executeOracleFusionSalesOperation } from '@/lib/internal/oracle-fusion-sales/operations'
+import type { InternalToolOperationHandler } from '@/lib/internal/tool-operations/types'
+import {
+  getOracleFusionSalesOperation,
+  ORACLE_FUSION_SALES_OPERATIONS,
+} from '@/tools/oracle_fusion_sales/shared'
+
+export const executeOracleFusionSalesTool: InternalToolOperationHandler = async ({
+  toolId,
+  input,
+  signal,
+}) => {
+  signal?.throwIfAborted()
+  const prefix = 'oracle_fusion_sales_'
+  const name = toolId.startsWith(prefix) ? toolId.slice(prefix.length) : ''
+  if (!Object.hasOwn(ORACLE_FUSION_SALES_OPERATIONS, name)) {
+    return Response.json(
+      { success: false, error: 'Unsupported Oracle Fusion Sales tool' },
+      { status: 500 }
+    )
+  }
+  const operation = getOracleFusionSalesOperation(name)
+  const retryable = operation.kind === 'list' || operation.kind === 'get'
+  try {
+    const result = await executeOracleFusionSalesOperation(name, input, signal)
+    signal?.throwIfAborted()
+    return Response.json(result)
+  } catch (error) {
+    signal?.throwIfAborted()
+    if (error instanceof z.ZodError) {
+      return Response.json(
+        {
+          success: false,
+          error: error.issues.map((issue) => `${issue.path.join('.')}: ${issue.message}`).join('; '),
+          retryable: false,
+        },
+        { status: 400 }
+      )
+    }
+    if (error instanceof OracleFusionProviderError) {
+      return Response.json(
+        { success: false, error: error.message, retryable },
+        { status: error.status }
+      )
+    }
+    return Response.json(
+      { success: false, error: 'Oracle Fusion Sales request failed', retryable },
+      { status: 500 }
+    )
+  }
+}
+