Method executeOperation

api/src/flows.ts:506–600

(
		operation: Operation,
		keyedData: Record<string, unknown>,
		context: Record<string, unknown> = {},
	)

	}

	private async executeOperation(
		operation: Operation,
		keyedData: Record<string, unknown>,
		context: Record<string, unknown> = {},
	): Promise<{
		successor: Operation | null;
		status: 'resolve' | 'reject' | 'unknown';
		data: unknown;
		options: Record<string, any> | null;
	}> {
		const logger = useLogger();

		if (!this.operations.has(operation.type)) {
			logger.warn(`Couldn't find operation ${operation.type}`);

			return { successor: null, status: 'unknown', data: null, options: null };
		}

		const handler = this.operations.get(operation.type)!;

		let optionData = keyedData;

		if (operation.type === 'log') {
			optionData = redactObject(
				keyedData,
				{
					keys: [
						['**', 'headers', 'authorization'],
						['**', 'headers', 'cookie'],
						['**', 'query', 'access_token'],
						['**', 'payload', 'password'],
						['**', 'payload', 'token'],
						['**', 'payload', 'tfa_secret'],
						['**', 'payload', 'external_identifier'],
						['**', 'payload', 'auth_data'],
						['**', 'payload', 'credentials'],
						['**', 'payload', 'ai_openai_api_key'],
						['**', 'payload', 'ai_anthropic_api_key'],
						['**', 'payload', 'ai_google_api_key'],
						['**', 'payload', 'ai_openai_compatible_api_key'],
					],
				},
				getRedactedString,
			);
		}

		let options = operation.options;

		try {
			options = applyOptionsData(options, optionData);

			let result = await handler(options, {
				services,
				env: useEnv(),
				database: getDatabase(),
				logger,
				getSchema,
				data: keyedData,