refactor(workflow-executor): extract findField helper to deduplicate field resolution

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: alban bertolini

packages/workflow-executor/src/executors/read-record-step-executor.ts

@@ -9,6 +9,7 @@ import { z } from 'zod';
 
 import { NoReadableFieldsError, NoResolvedFieldsError, WorkflowExecutorError } from '../errors';
 import BaseStepExecutor from './base-step-executor';
+import { findField } from '../types/record';
 
 const READ_RECORD_SYSTEM_PROMPT = `You are an AI agent reading fields from a record to answer a user request.
 Select the field(s) that best answer the request. You can read one field or multiple fields at once.
@@ -32,10 +33,7 @@ export default class ReadRecordStepExecutor extends BaseStepExecutor<AiTaskStepD
       schema = await this.getCollectionSchema(selectedRecordRef.collectionName);
       const selectedDisplayNames = await this.selectFields(schema, step.prompt);
       const resolvedFieldNames = selectedDisplayNames
-        .map(
-          name =>
-            schema.fields.find(f => f.fieldName === name || f.displayName === name)?.fieldName,
-        )
+        .map(name => findField(schema, name)?.fieldName)
         .filter((name): name is string => name !== undefined);
 
       if (resolvedFieldNames.length === 0) {
@@ -135,7 +133,7 @@ export default class ReadRecordStepExecutor extends BaseStepExecutor<AiTaskStepD
     fieldNames: string[],
   ): FieldReadResult[] {
     return fieldNames.map(name => {
-      const field = schema.fields.find(f => f.fieldName === name || f.displayName === name);
+      const field = findField(schema, name);
 
       if (!field) return { error: `Field not found: ${name}`, fieldName: name, displayName: name };
 

packages/workflow-executor/src/executors/update-record-step-executor.ts

@@ -9,6 +9,7 @@ import { z } from 'zod';
 
 import { NoWritableFieldsError, WorkflowExecutorError } from '../errors';
 import BaseStepExecutor from './base-step-executor';
+import { findField } from '../types/record';
 
 const UPDATE_RECORD_SYSTEM_PROMPT = `You are an AI agent updating a field on a record based on a user request.
 Select the field to update and provide the new value.
@@ -195,9 +196,7 @@ export default class UpdateRecordStepExecutor extends BaseStepExecutor<AiTaskSte
   }
 
   private resolveFieldName(schema: CollectionSchema, displayName: string): string {
-    const field = schema.fields.find(
-      f => f.displayName === displayName || f.fieldName === displayName,
-    );
+    const field = findField(schema, displayName);
 
     if (!field) {
       throw new WorkflowExecutorError(

packages/workflow-executor/src/index.ts

@@ -34,6 +34,7 @@ export type {
   RecordRef,
   RecordData,
 } from './types/record';
+export { findField } from './types/record';
 
 export type {
   Step,

packages/workflow-executor/src/types/record.ts

@@ -21,6 +21,11 @@ export interface CollectionSchema {
   actions: ActionSchema[];
 }
 
+/** Find a field by fieldName or displayName. */
+export function findField(schema: CollectionSchema, name: string): FieldSchema | undefined {
+  return schema.fields.find(f => f.fieldName === name || f.displayName === name);
+}
+
 // -- Record types (data — source: AgentPort/RunStore) --
 
 /** Lightweight pointer to a specific record. */