from auth.client import register_user, login_user, get_user_info # Register a new user user_data = register_user( username="john_doe", password="secure_password", email="john@example.com", role="client" ) # Login to get a token token = login_user("john_doe", "secure_password") # Get user information user_info = get_user_info(token) print(f"Logged in as: {user_info['username']} (Role: {user_info['role']})")

from fastapi import FastAPI, Depends from fastapi.security import AgentAuthSecurity from discussion.manager import DiscussionManager from e2b_interpreter.client import E2BClient from workflows.manager import WorkflowManager # Initialize components app = FastAPI() auth_security = AgentAuthSecurity() discussion_mgr = DiscussionManager(vector_db_type="pinecone") e2b_client = E2BClient() workflow_mgr = WorkflowManager( discussion_manager=discussion_mgr, e2b_client=e2b_client ) # Secure endpoint example @app.post("/chat") async def chat(message: str, user=Depends(auth_security)): # Store the user's message discussion_mgr.add_discussion(user["user_id"], message) # Execute code if needed if "run code:" in message: code = message.split("run code:")[1].strip() result = await e2b_client.execute_code(code, user["user_id"]) return {"message": "Code executed", "result": result} # Get relevant discussions discussions = discussion_mgr.get_relevant_discussions(user["user_id"], message) return {"message": "Message stored", "relevant_discussions": discussions}

# In views.py from django.http import JsonResponse from django.contrib.auth.decorators import login_required from django.discussion import add_discussion, get_relevant_discussions from django.e2b import execute_code @login_required def chat_view(request): message = request.POST.get("message", "") # Store the user's message add_discussion(request, message) # Execute code if needed if "run code:" in message: code = message.split("run code:")[1].strip() result = execute_code(request, code) return JsonResponse({"message": "Code executed", "result": result}) # Get relevant discussions discussions = get_relevant_discussions(request, message) return JsonResponse({"message": "Message stored", "relevant_discussions": discussions})

from workflows.models import StepType from workflows.manager import WorkflowManager # Initialize workflow manager workflow_mgr = WorkflowManager( discussion_manager=discussion_mgr, e2b_client=e2b_client ) # Create a data analysis workflow workflow = workflow_mgr.create_workflow( name="Data Analysis", description="Analyze CSV data", steps=[ { "name": "Load Data", "type": StepType.CODE_EXECUTION.value, "config": { "code": "import pandas as pd\ndata = pd.read_csv('data.csv')\ndata.head()", "language": "python" } }, { "name": "Analyze", "type": StepType.CODE_EXECUTION.value, "config": { "code": "data.describe()", "language": "python" }, "depends_on": ["load-data"] } ] ) # Execute the workflow result = await workflow_mgr.execute_workflow(workflow.id)

# Authentication exceptions from auth.exceptions import ( AuthException, # Base exception InvalidCredentialsError, # Wrong username/password TokenExpiredError, # Expired token AdminRequiredError # Admin role required ) # Discussion exceptions from discussion.exceptions import ( DiscussionException, # Base exception VectorDBError, # Vector database issues UserDiscussionAccessError # Access control violation ) # Code execution exceptions from e2b_interpreter.exceptions import ( CodeInterpreterException, # Base exception SandboxError, # Sandbox issues ExecutionError # Code execution failure ) # Workflow exceptions from workflows.exceptions import ( WorkflowError, # Base exception WorkflowNotFoundError, # Workflow not found WorkflowExecutionError # Execution failure )