feat(oracle-fusion-scm): add supply chain 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_scm: NetSuiteIcon,
   outlook: OutlookIcon,
   pagerduty: PagerDutyIcon,
   parallel_ai: ParallelIcon,

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

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

apps/docs/content/docs/integrations/oracle_fusion_scm.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 { OracleFusionScmBlock, OracleFusionScmBlockMeta } from '@/blocks/blocks/oracle_fusion_scm'
 import { OutlookBlock, OutlookBlockMeta } from '@/blocks/blocks/outlook'
 import { PagerDutyBlock, PagerDutyBlockMeta } from '@/blocks/blocks/pagerduty'
 import { ParallelBlock, ParallelBlockMeta } from '@/blocks/blocks/parallel'
@@ -593,6 +594,7 @@ export const BLOCK_REGISTRY: Record<string, BlockConfig> = {
   onedrive: OneDriveBlock,
   onepassword: OnePasswordBlock,
   openai: OpenAIBlock,
+  oracle_fusion_scm: OracleFusionScmBlock,
   outlook: OutlookBlock,
   pagerduty: PagerDutyBlock,
   parallel_ai: ParallelBlock,
@@ -914,6 +916,7 @@ export const BLOCK_META_REGISTRY: Record<string, BlockMeta> = {
   onedrive: OneDriveBlockMeta,
   onepassword: OnePasswordBlockMeta,
   openai: OpenAIBlockMeta,
+  oracle_fusion_scm: OracleFusionScmBlockMeta,
   outlook: OutlookBlockMeta,
   pagerduty: PagerDutyBlockMeta,
   parallel_ai: ParallelBlockMeta,

apps/sim/blocks/blocks/oracle_fusion_scm.ts

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

apps/sim/blocks/registry-maps.ts

@@ -68,6 +68,8 @@ 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': [],
+  /** SCM likewise presents the shared Fusion service account through its block. */
+  'oracle-fusion-service-account': [],
   'pipedrive-service-account': ['pipedrive'],
   'salesforce-service-account': ['salesforce'],
   'shopify-service-account': ['shopify'],

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_scm: NetSuiteIcon,
   outlook: OutlookIcon,
   pagerduty: PagerDutyIcon,
   parallel_ai: ParallelIcon,

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

@@ -0,0 +1,92 @@
+import { ZodError } from 'zod'
+import { OracleFusionProviderError } from '@/lib/internal/oracle-fusion/errors'
+import {
+  executeOracleFusionScmConfirmQuickShipLines,
+  executeOracleFusionScmCreateMaintenanceWorkOrder,
+  executeOracleFusionScmCreateManufacturingWorkOrder,
+  executeOracleFusionScmCreateSalesOrder,
+  executeOracleFusionScmCreateSupplyRequest,
+  executeOracleFusionScmDeleteSalesOrder,
+  executeOracleFusionScmPickReleaseShipmentLines,
+  executeOracleFusionScmReadOperation,
+  executeOracleFusionScmUpdateItem,
+  executeOracleFusionScmUpdateMaintenanceWorkOrder,
+  executeOracleFusionScmUpdateManufacturingWorkOrder,
+  executeOracleFusionScmUpdateSalesOrder,
+  executeOracleFusionScmUpdateSupplyRequest,
+  executeOracleFusionScmUpdateTransferOrder,
+  executeOracleFusionScmUpdateTransferOrderLine,
+  isOracleFusionScmReadToolId,
+} from '@/lib/internal/oracle-fusion-scm/operations'
+import type { InternalToolOperationHandler } from '@/lib/internal/tool-operations/types'
+
+export const executeOracleFusionScmTool: InternalToolOperationHandler = async ({
+  toolId,
+  input,
+  signal,
+}) => {
+  signal?.throwIfAborted()
+  try {
+    if (isOracleFusionScmReadToolId(toolId)) {
+      return Response.json(await executeOracleFusionScmReadOperation(toolId, input, signal))
+    }
+    switch (toolId) {
+      case 'oracle_fusion_scm_update_item':
+        return Response.json(await executeOracleFusionScmUpdateItem(input, signal))
+      case 'oracle_fusion_scm_create_supply_request':
+        return Response.json(await executeOracleFusionScmCreateSupplyRequest(input, signal))
+      case 'oracle_fusion_scm_update_supply_request':
+        return Response.json(await executeOracleFusionScmUpdateSupplyRequest(input, signal))
+      case 'oracle_fusion_scm_update_transfer_order':
+        return Response.json(await executeOracleFusionScmUpdateTransferOrder(input, signal))
+      case 'oracle_fusion_scm_update_transfer_order_line':
+        return Response.json(await executeOracleFusionScmUpdateTransferOrderLine(input, signal))
+      case 'oracle_fusion_scm_create_manufacturing_work_order':
+        return Response.json(
+          await executeOracleFusionScmCreateManufacturingWorkOrder(input, signal)
+        )
+      case 'oracle_fusion_scm_update_manufacturing_work_order':
+        return Response.json(
+          await executeOracleFusionScmUpdateManufacturingWorkOrder(input, signal)
+        )
+      case 'oracle_fusion_scm_create_maintenance_work_order':
+        return Response.json(await executeOracleFusionScmCreateMaintenanceWorkOrder(input, signal))
+      case 'oracle_fusion_scm_update_maintenance_work_order':
+        return Response.json(await executeOracleFusionScmUpdateMaintenanceWorkOrder(input, signal))
+      case 'oracle_fusion_scm_create_sales_order':
+        return Response.json(await executeOracleFusionScmCreateSalesOrder(input, signal))
+      case 'oracle_fusion_scm_update_sales_order':
+        return Response.json(await executeOracleFusionScmUpdateSalesOrder(input, signal))
+      case 'oracle_fusion_scm_delete_sales_order':
+        return Response.json(await executeOracleFusionScmDeleteSalesOrder(input, signal))
+      case 'oracle_fusion_scm_pick_release_shipment_lines':
+        return Response.json(await executeOracleFusionScmPickReleaseShipmentLines(input, signal))
+      case 'oracle_fusion_scm_confirm_quick_ship_lines':
+        return Response.json(await executeOracleFusionScmConfirmQuickShipLines(input, signal))
+      default:
+        return Response.json(
+          { success: false, output: {}, error: 'Unsupported Oracle Fusion SCM tool' },
+          { status: 500 }
+        )
+    }
+  } catch (error) {
+    signal?.throwIfAborted()
+    if (error instanceof OracleFusionProviderError) {
+      return Response.json(
+        { success: false, output: {}, error: error.message },
+        { status: error.status }
+      )
+    }
+    const validationFailure = error instanceof ZodError
+    return Response.json(
+      {
+        success: false,
+        output: {},
+        error: validationFailure
+          ? 'Invalid Oracle Fusion SCM input'
+          : 'Oracle Fusion SCM request failed',
+      },
+      { status: validationFailure ? 400 : 500 }
+    )
+  }
+}

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

@@ -0,0 +1,47 @@
+import { z } from 'zod'
+import { requestOracleFusionJson } from '@/lib/internal/oracle-fusion/client'
+import { unexpectedOracleFusionScmResponse } from '@/lib/internal/oracle-fusion-scm/operations/read-resource'
+import { oracleFusionScmMutationInputSchema } from '@/lib/internal/oracle-fusion-scm/schema'
+import type { ToolResponse } from '@/tools/types'
+
+const inputSchema = oracleFusionScmMutationInputSchema(
+  z
+    .object({
+      details: z
+        .array(
+          z
+            .object({
+              ShipmentLine: z.string().min(1).max(128),
+            })
+            .strict()
+        )
+        .min(1)
+        .max(100),
+    })
+    .strict()
+)
+
+/** Oracle documents a dynamic result map, not a fixed status/message envelope. */
+const responseSchema = z.object({
+  result: z.record(z.string(), z.array(z.record(z.string(), z.string()))),
+})
+
+/** Confirms only quick-ship eligible lines in a quick-ship enabled organization. */
+export async function executeOracleFusionScmConfirmQuickShipLines(
+  rawInput: unknown,
+  signal?: AbortSignal
+): Promise<ToolResponse> {
+  const input = inputSchema.parse(rawInput)
+  const payload = await requestOracleFusionJson(
+    input,
+    {
+      method: 'POST',
+      address: { family: 'fscm', relativePath: 'shipmentLineChangeRequests/action/confirm' },
+      mediaType: 'application/vnd.oracle.adf.action+json',
+      body: input.body,
+    },
+    signal
+  )
+  const output = unexpectedOracleFusionScmResponse(() => responseSchema.parse(payload))
+  return { success: true, output }
+}