Function execute

worker/src/components/core/file-loader.ts:68–108

({ inputs }, context)

    ],
  },
  async execute({ inputs }, context) {
    context.logger.info(`[FileLoader] Loading file with ID: ${inputs.fileId}`);

    // Use storage interface (not concrete implementation!)
    const storage = context.storage;

    if (!storage) {
      throw new ConfigurationError(
        'Storage service not available in execution context. Worker must provide IFileStorageService adapter.',
        { configKey: 'storage' },
      );
    }

    context.emitProgress('Fetching file from storage...');

    // Download file using interface
    const { buffer, metadata } = await storage.downloadFile(inputs.fileId);

    context.logger.info(
      `[FileLoader] Loaded file: ${metadata.fileName} (${metadata.size} bytes, ${metadata.mimeType})`,
    );

    context.emitProgress(`File loaded: ${metadata.fileName}`);

    // Convert to base64 for downstream components
    const content = buffer.toString('base64');

    // Also provide decoded text content
    const textContent = buffer.toString('utf-8');

    return {
      file: {
        id: metadata.id,
        name: metadata.fileName,
        mimeType: metadata.mimeType,
        size: metadata.size,
        content,
      },
      textContent,
    };
  },
});

componentRegistry.register(definition);