Flow Generator

nx g @frontmcp/nx:flow audit-log --project crm

import { Flow, FlowBase, FlowHooksOf, z, type FlowPlan, type FlowRunOptions } from '@frontmcp/sdk';

const name = 'audit-log' as const;

const inputSchema = z.object({
  // TODO: describe the flow input
  value: z.string().default(''),
});

const outputSchema = z.object({
  // TODO: describe the flow output
  result: z.string(),
});

const stateSchema = z.object({
  result: z.string().default(''),
});

const plan = {
  pre: ['pre'],
  execute: ['execute'],
  post: ['post'],
  finalize: ['finalize'],
} as const satisfies FlowPlan<string>;

declare global {
  interface ExtendFlows {
    [name]: FlowRunOptions<AuditLogFlow, typeof plan, typeof inputSchema, typeof outputSchema, typeof stateSchema>;
  }
}

const { Stage } = FlowHooksOf<typeof name>(name);

@Flow({
  name,
  description: 'TODO: describe what this flow does',
  plan,
  inputSchema,
  outputSchema,
  access: 'public',
})
export default class AuditLogFlow extends FlowBase<typeof name> {
  @Stage('pre')
  async pre() {
    // TODO: pre-processing logic
  }

  @Stage('execute')
  async execute() {
    // TODO: main execution logic
    this.state.set('result', this.rawInput.value ?? '');
  }

  @Stage('post')
  async post() {
    // TODO: post-processing logic
  }

  @Stage('finalize')
  async finalize() {
    this.respond({ result: this.state.result ?? '' });
  }
}