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

@@ -237,6 +237,7 @@ import { MSSQLBlock, MSSQLBlockMeta } from '@/blocks/blocks/mssql'
 import { MySQLBlock, MySQLBlockMeta } from '@/blocks/blocks/mysql'
 import { Neo4jBlock, Neo4jBlockMeta } from '@/blocks/blocks/neo4j'
 import { NetSuiteBlock, NetSuiteBlockMeta } from '@/blocks/blocks/netsuite'
+import { OracleFusionScmBlock, OracleFusionScmBlockMeta } from '@/blocks/blocks/oracle_fusion_scm'
 import { NeverBounceBlock, NeverBounceBlockMeta } from '@/blocks/blocks/neverbounce'
 import { NewRelicBlock, NewRelicBlockMeta } from '@/blocks/blocks/new_relic'
 import { NoteBlock } from '@/blocks/blocks/note'
@@ -584,6 +585,7 @@ export const BLOCK_REGISTRY: Record<string, BlockConfig> = {
   mysql: MySQLBlock,
   neo4j: Neo4jBlock,
   netsuite: NetSuiteBlock,
+  oracle_fusion_scm: OracleFusionScmBlock,
   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_scm: OracleFusionScmBlockMeta,
   neverbounce: NeverBounceBlockMeta,
   new_relic: NewRelicBlockMeta,
   notion: NotionBlockMeta,

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

@@ -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/copilot/generated/docs-manifest.ts

@@ -0,0 +1,84 @@
+import { OracleFusionProviderError } from '@/lib/internal/oracle-fusion/errors'
+import {
+  executeOracleFusionScmReadOperation,
+  isOracleFusionScmReadToolId,
+  executeOracleFusionScmUpdateItem,
+  executeOracleFusionScmCreateSupplyRequest,
+  executeOracleFusionScmUpdateSupplyRequest,
+  executeOracleFusionScmUpdateTransferOrder,
+  executeOracleFusionScmUpdateTransferOrderLine,
+  executeOracleFusionScmCreateManufacturingWorkOrder,
+  executeOracleFusionScmUpdateManufacturingWorkOrder,
+  executeOracleFusionScmCreateMaintenanceWorkOrder,
+  executeOracleFusionScmUpdateMaintenanceWorkOrder,
+  executeOracleFusionScmCreateSalesOrder,
+  executeOracleFusionScmUpdateSalesOrder,
+  executeOracleFusionScmDeleteSalesOrder,
+  executeOracleFusionScmPickReleaseShipmentLines,
+  executeOracleFusionScmConfirmQuickShipLines,
+} 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 Error && error.name === '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,32 @@
+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 }
+}

apps/sim/lib/internal/oracle-fusion-scm/execute-tool.ts

@@ -0,0 +1,54 @@
+import { z } from 'zod'
+import { requestOracleFusionJson } from '@/lib/internal/oracle-fusion/client'
+import {
+  oracleFusionScmCollectionPath,
+  projectOracleFusionScmResource,
+  unexpectedOracleFusionScmResponse,
+} from '@/lib/internal/oracle-fusion-scm/operations/read-resource'
+import {
+  oracleFusionScmIntegerInput,
+  oracleFusionScmMutationInputSchema,
+} from '@/lib/internal/oracle-fusion-scm/schema'
+import type { ToolResponse } from '@/tools/types'
+
+// Contract: op-maintenanceworkorders-post.html
+const bodySchema = z.object({
+  InventoryItemId: oracleFusionScmIntegerInput('int64'),
+  PlannedStartQuantity: z.number().finite(),
+  UOMCode: z.string().max(3).min(1),
+  WorkOrderTypeCode: z.string().max(30).min(1),
+  OrganizationId: oracleFusionScmIntegerInput('int64').optional(),
+  OrganizationCode: z.string().max(255).nullable().optional(),
+  WorkOrderNumber: z.string().max(120).nullable().optional(),
+  WorkOrderDescription: z.string().max(240).nullable().optional(),
+  WorkOrderStatusCode: z.string().max(255).nullable().optional(),
+  WorkOrderSubTypeCode: z.string().max(30).nullable().optional(),
+  WorkOrderPriority: z.number().finite().nullable().optional(),
+  PlannedStartDate: z.string().datetime({ offset: true }).nullable().optional(),
+  PlannedCompletionDate: z.string().datetime({ offset: true }).nullable().optional(),
+  WorkDefinitionId: oracleFusionScmIntegerInput('int64').nullable().optional(),
+  AssetId: oracleFusionScmIntegerInput('int64').nullable().optional(),
+  AssetNumber: z.string().nullable().optional(),
+}).strict()
+
+const inputSchema = oracleFusionScmMutationInputSchema(bodySchema, [])
+
+/** Creates the documented maintenance work order fields without numeric identifier rounding. */
+export async function executeOracleFusionScmCreateMaintenanceWorkOrder(
+  rawInput: unknown,
+  signal?: AbortSignal
+): Promise<ToolResponse> {
+  const input = inputSchema.parse(rawInput)
+  const collection = oracleFusionScmCollectionPath('maintenanceWorkOrders', input)
+  const relativePath = collection
+  const payload = await requestOracleFusionJson(input, {
+    method: 'POST',
+    address: { family: 'fscm', relativePath },
+    mediaType: 'application/vnd.oracle.adf.resourceitem+json',
+    body: input.body,
+  }, signal)
+  const item = unexpectedOracleFusionScmResponse(() =>
+    projectOracleFusionScmResource('maintenanceWorkOrders', payload, input.instanceUrl, collection)
+  )
+  return { success: true, output: { maintenanceWorkOrder: item } }
+}