simple_file_executor.py

"""
Simple executor for launch detection workflow that just logs completion
"""

import logging
from typing import Optional, Any

from src.domain.executor.base_executor import Executor

logger = logging.getLogger(__name__)


class SimpleFileExecutor(Executor):
    """
    Simple executor that just logs the completion of file storage operations.

    Used by the SimpleLaunchDetectionProcessor workflow when files are saved
    by the SimpleFileStorageStage - no additional action needed beyond logging.
    """

    async def initialize(self):
        """Initialize the executor"""
        logger.info("✅ SimpleFileExecutor initialized")

    async def execute(self, action: Any) -> None:
        """
        Execute simple logging for completed file operations

        Args:
            action: Usually a string containing the saved JSON file path from SimpleLaunchDetectionProcessor
        """
        try:
            if isinstance(action, str):
                # Log successful file storage
                logger.info(f"✅ Token data saved to file: {action}")
                print(f"💾 Saved: {action}")
            else:
                logger.debug(f"📝 Execution completed: {action}")

        except Exception as e:
            logger.error(f"❌ Error in SimpleFileExecutor: {e}")
            raise