"""
title: status_emitter
author: stefanpietrusky
author_url: https://downchurch.studio/
version: 0.1
"""

import asyncio


class Tools:
    def __init__(self):
        pass

    async def run(self, prompt: str, __user__: dict, __event_emitter__=None) -> str:
        """
        The user is informed about the progress through an event emitter.
        """
        # Show start status
        if __event_emitter__:
            await __event_emitter__(
                {
                    "type": "status",
                    "data": {"description": "Processing started...", "done": False},
                }
            )

        # Simulate multiple processing steps
        for i in range(1, 6):  # Simulate 5 steps
            await asyncio.sleep(1)  # Simulates a time-consuming step
            if __event_emitter__:
                await __event_emitter__(
                    {
                        "type": "status",
                        "data": {
                            "description": f"Step {i} of 5 completed...",
                            "done": False,
                        },
                    }
                )

        # View completion status
        if __event_emitter__:
            await __event_emitter__(
                {
                    "type": "status",
                    "data": {
                        "description": "Processing completed!",
                        "done": True,
                    },
                }
            )

        return "Processing was completed successfully."