Create app.py

app.py

@@ -0,0 +1,95 @@
+import gradio as gr
+import os
+import sys
+from datetime import datetime
+
+# Add the src directory to the path
+sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), 'src')))
+
+# Import Ashus AI components
+from src.orchestration.task_manager import TaskManager, TaskStatus
+from src.orchestration.agent_manager import AgentManager
+from src.orchestration.message_router import MessageRouter
+from src.agents.executor import ExecutorAgent
+from src.tools.registry import ToolRegistry
+from src.tools.web_browser import WebBrowserTool
+from src.tools.file_system import FileSystemTool
+from src.tools.code_execution import CodeExecutionTool
+
+# Initialize components
+task_manager = TaskManager()
+agent_manager = AgentManager()
+message_router = MessageRouter()
+tool_registry = ToolRegistry()
+
+# Register tools
+tool_registry.register_tool(WebBrowserTool())
+tool_registry.register_tool(FileSystemTool())
+tool_registry.register_tool(CodeExecutionTool())
+
+# Initialize executor agent
+executor_agent = ExecutorAgent(
+    agent_id="executor",
+    name="Executor Agent",
+    task_manager=task_manager,
+    tool_registry=tool_registry
+)
+
+agent_manager.register_agent("executor", executor_agent)
+message_router.subscribe("executor", executor_agent.process_message)
+
+# Chat history
+chat_history = []
+
+def process_message(message, history):
+    task = task_manager.create_task(
+        description=message,
+        user_id="web_user"
+    )
+    processed_task = executor_agent.process_task(task)
+    if processed_task.status == TaskStatus.COMPLETED and processed_task.result:
+        response = processed_task.result.get("message", "Task completed successfully.")
+    else:
+        response = "I'm sorry, I couldn't process your request."
+
+    timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+    history.append((message, response))
+    return history
+
+def clear_chat():
+    chat_history.clear()
+    return []
+
+with gr.Blocks(title="Ashus AI", theme=gr.themes.Soft()) as demo:
+    gr.Markdown("# Ashus AI")
+    gr.Markdown("Welcome to Ashus AI, an open-source autonomous agent system.")
+
+    with gr.Row():
+        with gr.Column(scale=3):
+            chatbot = gr.Chatbot(label="Chat with Ashus AI")
+            msg = gr.Textbox(placeholder="Ask me anything...", show_label=False)
+
+            with gr.Row():
+                submit_btn = gr.Button("Submit", variant="primary")
+                clear_btn = gr.Button("Clear")
+
+        with gr.Column(scale=1):
+            gr.Markdown("### About Ashus AI")
+            gr.Markdown("""
+Ashus AI is an open-source autonomous agent system.
+
+**Features:**
+- Multi-agent architecture
+- Tools: Web browsing, file system, code execution
+- Task-based processing
+- FastAPI backend
+
+[View on GitHub](https://github.com/yourusername/ashus-ai)
+            """)
+
+    submit_btn.click(process_message, inputs=[msg, chatbot], outputs=[chatbot])
+    msg.submit(process_message, inputs=[msg, chatbot], outputs=[chatbot])
+    clear_btn.click(clear_chat, outputs=[chatbot])
+
+if __name__ == "__main__":
+    demo.launch()