feat(mcp-server): expose workflow tools in Forest MCP server (PRD-49)

packages/agent-testing/src/forest-admin-client-mock.ts

@@ -44,7 +44,7 @@
 export default class ForestAdminClientMock implements ForestAdminClient {
   readonly chartHandler: ChartHandlerInterface;
   readonly contextVariablesInstantiator: ContextVariablesInstantiatorInterface = {
     buildContextVariables: () => ({} as any), // TODO: return actual context variables
   };
 
   readonly modelCustomizationService: ModelCustomizationService;
@@ -62,8 +62,37 @@
     updateActivityLogStatus: () => Promise.resolve(),
   };
 
+  readonly workflowsService: ForestAdminClient['workflowsService'] = {
+    listMcpEnabledWorkflows: () => Promise.resolve([]),
+    getMcpWorkflowById: () =>
+      Promise.resolve({
+        workflowId: 'wf-1',
+        name: 'Refund order',
+        collectionName: 'orders',
+        mcpEnabled: true,
+      }),
+    triggerMcpWorkflow: () => Promise.resolve({ runId: '1', runState: 'loading' }),
+    getMcpWorkflowRun: () =>
+      Promise.resolve({
+        id: 1,
+        userId: 1,
+        renderingId: 1,
+        collectionId: 'orders',
+        workflowId: 'wf-1',
+        bpmnVersion: '1',
+        selectedRecordId: '1',
+        runState: 'loading',
+        engine: 'orchestrator',
+        triggerType: 'mcp',
+        lockedAt: null,
+        createdAt: '2024-01-01T00:00:00.000Z',
+        updatedAt: '2024-01-01T00:00:00.000Z',
+        workflowHistory: [],
+      }),
+  };
+
   readonly permissionService: any;
   readonly authService: any;
 
   constructor() {
     this.permissionService = {

packages/agent-testing/test/forest-admin-client-mock.test.ts

@@ -0,0 +1,66 @@
+import ForestAdminClientMock from '../src/forest-admin-client-mock';
+
+describe('ForestAdminClientMock', () => {
+  describe('workflowsService', () => {
+    it('should resolve an empty list of MCP-enabled workflows', async () => {
+      const client = new ForestAdminClientMock();
+
+      await expect(
+        client.workflowsService.listMcpEnabledWorkflows({
+          forestServerToken: 'token',
+          renderingId: '1',
+        }),
+      ).resolves.toEqual([]);
+    });
+
+    it('should resolve an mcp-enabled workflow when fetching one by id', async () => {
+      const client = new ForestAdminClientMock();
+
+      await expect(
+        client.workflowsService.getMcpWorkflowById({
+          forestServerToken: 'token',
+          renderingId: '1',
+          workflowId: 'wf-1',
+        }),
+      ).resolves.toEqual(
+        expect.objectContaining({
+          workflowId: 'wf-1',
+          mcpEnabled: true,
+        }),
+      );
+    });
+
+    it('should resolve a loading run when triggering a workflow', async () => {
+      const client = new ForestAdminClientMock();
+
+      await expect(
+        client.workflowsService.triggerMcpWorkflow({
+          forestServerToken: 'token',
+          renderingId: '1',
+          workflowId: 'wf-1',
+          recordId: '42',
+        }),
+      ).resolves.toEqual({ runId: '1', runState: 'loading' });
+    });
+
+    it('should resolve a loading hydrated run when fetching a workflow run', async () => {
+      const client = new ForestAdminClientMock();
+
+      await expect(
+        client.workflowsService.getMcpWorkflowRun({
+          forestServerToken: 'token',
+          renderingId: '1',
+          runId: '1',
+        }),
+      ).resolves.toEqual(
+        expect.objectContaining({
+          id: 1,
+          runState: 'loading',
+          engine: 'orchestrator',
+          triggerType: 'mcp',
+          workflowHistory: [],
+        }),
+      );
+    });
+  });
+});

packages/agent/src/agent.ts

@@ -390,6 +390,7 @@ export default class Agent<S extends TSchema = TSchema> extends FrameworkMounter
       const forestServerClient = new ForestServerClientImpl(
         this.options.forestAdminClient.schemaService,
         this.options.forestAdminClient.activityLogsService,
+        this.options.forestAdminClient.workflowsService,
         this.options.forestServerUrl,
       );
 

packages/agent/test/__factories__/forest-admin-client.ts

@@ -54,6 +54,12 @@ const forestAdminClientFactory = ForestAdminClientFactory.define(() => ({
     createMcpActivityLog: jest.fn(),
     updateActivityLogStatus: jest.fn(),
   },
+  workflowsService: {
+    listMcpEnabledWorkflows: jest.fn(),
+    getMcpWorkflowById: jest.fn(),
+    triggerMcpWorkflow: jest.fn(),
+    getMcpWorkflowRun: jest.fn(),
+  },
   subscribeToServerEvents: jest.fn(),
   close: jest.fn(),
   onRefreshCustomizations: jest.fn(),

packages/forestadmin-client/src/build-application-services.ts

@@ -22,6 +22,7 @@ import UserPermissionService from './permissions/user-permission';
 import SchemaService from './schema';
 import ContextVariablesInstantiator from './utils/context-variables-instantiator';
 import defaultLogger from './utils/default-logger';
+import WorkflowsService from './workflows';
 
 export default function buildApplicationServices(
   forestAdminServerInterface: ForestAdminServerInterface,
@@ -31,6 +32,7 @@ export default function buildApplicationServices(
   renderingPermission: RenderingPermissionService;
   schema: SchemaService;
   activityLogs: ActivityLogsService;
+  workflows: WorkflowsService;
   contextVariables: ContextVariablesInstantiator;
   ipWhitelist: IpWhiteListService;
   permission: PermissionService;
@@ -89,6 +91,7 @@ export default function buildApplicationServices(
     ipWhitelist: new IpWhiteListService(forestAdminServerInterface, optionsWithDefaults),
     schema: new SchemaService(forestAdminServerInterface, optionsWithDefaults),
     activityLogs: new ActivityLogsService(forestAdminServerInterface, optionsWithDefaults),
+    workflows: new WorkflowsService(forestAdminServerInterface, optionsWithDefaults),
     auth: forestAdminServerInterface.makeAuthService(optionsWithDefaults),
     modelCustomizationService: new ModelCustomizationFromApiService(
       forestAdminServerInterface,

packages/forestadmin-client/src/forest-admin-client-with-cache.ts

@@ -19,6 +19,7 @@ import type {
   PermissionService,
 } from './types';
 import type ContextVariablesInstantiator from './utils/context-variables-instantiator';
+import type WorkflowsService from './workflows';
 
 import verifyAndExtractApproval from './permissions/verify-approval';
 
@@ -37,6 +38,7 @@ export default class ForestAdminClientWithCache implements ForestAdminClient {
     public readonly mcpServerConfigService: McpServerConfigService,
     protected readonly eventsSubscription: BaseEventsSubscriptionService,
     protected readonly eventsHandler: RefreshEventsHandlerService,
+    public readonly workflowsService: WorkflowsService,
   ) {}
 
   verifySignedActionParameters<TSignedParameters>(signedParameters: string): TSignedParameters {

packages/forestadmin-client/src/index.ts

@@ -28,8 +28,26 @@ export {
   ActivityLogType,
   CreateActivityLogParams,
   UpdateActivityLogStatusParams,
+  McpWorkflow,
+  McpWorkflowLookup,
+  ListMcpWorkflowsParams,
+  GetMcpWorkflowByIdParams,
+  TriggerMcpWorkflowParams,
+  GetMcpWorkflowRunParams,
+  WorkflowRunState,
+  WorkflowRunEngine,
+  WorkflowRunTriggerType,
+  WorkflowStepType,
+  WorkflowTaskType,
+  WorkflowStepOutgoing,
+  WorkflowStepDefinition,
+  WorkflowHistoryStepContext,
+  WorkflowHistoryStep,
+  HydratedWorkflowRun,
+  WorkflowRunTriggerResult,
   // Service interfaces for MCP
   ActivityLogsServiceInterface,
+  WorkflowsServiceInterface,
   SchemaServiceInterface,
 } from './types';
 export { IpWhitelistConfiguration } from './ip-whitelist/types';
@@ -66,6 +84,7 @@ export default function createForestAdminClient(
     ipWhitelist,
     schema,
     activityLogs,
+    workflows,
     auth,
     modelCustomizationService,
     mcpServerConfigService,
@@ -87,6 +106,7 @@ export default function createForestAdminClient(
     mcpServerConfigService,
     eventsSubscription,
     eventsHandler,
+    workflows,
   );
 }
 
@@ -105,6 +125,7 @@ export { default as ServerUtils } from './utils/server';
 // export is necessary for the agent-generator package
 export { default as SchemaService, SchemaServiceOptions } from './schema';
 export { default as ActivityLogsService, ActivityLogsOptions } from './activity-logs';
+export { default as WorkflowsService, WorkflowsServiceOptions } from './workflows';
 
 export * from './auth/errors';
 export * from './utils/errors';