Function coerceValueForConnectionType

worker/src/temporal/input-resolver.ts:93–143

(
  connectionType: ConnectionType,
  value: unknown,
)

}

function coerceValueForConnectionType(
  connectionType: ConnectionType,
  value: unknown,
): CoercionResult {
  if (connectionType.kind === 'primitive') {
    return coercePrimitiveValue(connectionType.name, value);
  }

  if (connectionType.kind === 'contract') {
    return { ok: true, value };
  }

  if (connectionType.kind === 'list') {
    if (!Array.isArray(value)) {
      return { ok: false, error: 'Expected array for list port' };
    }
    const coerced: unknown[] = [];
    for (const item of value) {
      if (!connectionType.element) {
        return { ok: false, error: 'Connection type element is null for list item' };
      }
      const result = coerceValueForConnectionType(connectionType.element, item);
      if (!result.ok) {
        return { ok: false, error: result.error ?? 'Failed to coerce list item' };
      }
      coerced.push(result.value);
    }
    return { ok: true, value: coerced };
  }

  if (connectionType.kind === 'map') {
    if (!value || typeof value !== 'object' || Array.isArray(value)) {
      return { ok: false, error: 'Expected object for map port' };
    }
    const inputRecord = value as Record<string, unknown>;
    const coerced: Record<string, unknown> = {};
    for (const [key, entry] of Object.entries(inputRecord)) {
      if (!connectionType.element) {
        return { ok: false, error: `Connection type element is null for key ${key}` };
      }
      const result = coerceValueForConnectionType(connectionType.element, entry);
      if (!result.ok) {
        return { ok: false, error: result.error ?? `Failed to coerce value for key ${key}` };
      }
      coerced[key] = result.value;
    }
    return { ok: true, value: coerced };
  }

  return { ok: true, value };
}

export function resolveInputValue(sourceOutput: unknown, sourceHandle: string): unknown {
  if (sourceOutput === null || sourceOutput === undefined) {