Base

1337 Based Ai

README.md

@@ -1,11 +1,171 @@
----
-title: AIYogaLive
-emoji: 😻
-colorFrom: blue
-colorTo: purple
-sdk: docker
-pinned: false
-license: apache-2.0
----
-
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# Maestro - A Framework for Claude Opus, GPT and local LLMs to Orchestrate Subagents
+
+
+This Python script demonstrates an AI-assisted task breakdown and execution workflow using the Anthropic API. It utilizes two AI models, Opus and Haiku, to break down an objective into sub-tasks, execute each sub-task, and refine the results into a cohesive final output.
+
+## New: Run locally with LMStudio or Ollama
+
+### Lmstudio
+
+First download the app here
+https://lmstudio.ai/
+
+Then run the local server using your preferred method. I also recommend removing any system prompt for the app (leave your prompt field empty so it can take advantage of the script prompts).
+
+Then
+```bash
+python maestro-lmstudio.py
+```
+
+
+### Ollama
+Mestro now runs locally thanks to the Ollama platform. Experience the power of Llama 3 locally! 
+
+Before running the script
+
+Install Ollama client from here
+https://ollama.com/download
+
+then
+
+```bash
+pip install ollama
+```
+And 
+
+```bash
+ollama.pull('llama3:70b')
+```
+This will depend on the model you want to use it, you only need to do it once or if you want to update the model when a new version it's out.
+In the script I am using both versions but you can customize the model you want to use
+
+ollama.pull('llama3:70b')
+ollama.pull('llama3:8b')
+
+Then
+
+```bash
+python maestro-ollama.py
+```
+
+## Highly requested features
+- GROQ SUPPORT
+Experience the power of maestro thanks to Groq super fast api responses.
+```bash
+pip install groq
+```
+Then
+
+```bash
+python maestro-groq.py
+```
+
+
+- SEARCH 🔍
+
+Now, when it's creating a task for its subagent, Claude Opus will perform a search and get the best answer to help the subagent solve that task even better.
+
+Make sure you replace your Tavil API for search to work
+
+Get one here https://tavily.com/
+  
+- GPT4 SUPPORT
+
+Add support for GPT-4 as an orchestrator in maestro-gpt.py
+Simply
+```bash
+python maestro-gpt.py
+```
+
+After you complete your installs.
+
+
+## Features
+
+- Breaks down an objective into manageable sub-tasks using the Opus model
+- Executes each sub-task using the Haiku model
+- Provides the Haiku model with memory of previous sub-tasks for context
+- Refines the sub-task results into a final output using the Opus model
+- Generates a detailed exchange log capturing the entire task breakdown and execution process
+- Saves the exchange log to a Markdown file for easy reference
+- Utilizes an improved prompt for the Opus model to better assess task completion
+- Creates code files and folders when working on code projects.
+
+## Prerequisites
+
+To run this script, you need to have the following:
+
+- Python installed
+- Anthropic API key
+- Required Python packages: `anthropic` and `rich`
+
+## Installation
+
+1. Clone the repository or download the script file.
+2. Install the required Python packages by running the following command:
+
+```bash
+pip install -r requirements.txt
+```
+
+3. Replace the placeholder API key in the script with your actual Anthropic API key:
+
+```python
+client = Anthropic(api_key="YOUR_API_KEY_HERE")
+```
+
+If using search, replace your Tavil API
+```python
+tavily = TavilyClient(api_key="YOUR API KEY HERE")
+```
+
+## Usage
+
+1. Open a terminal or command prompt and navigate to the directory containing the script.
+2. Run the script using the following command:
+
+```bash
+python maestro.py
+```
+
+3. Enter your objective when prompted:
+
+```bash
+Please enter your objective: Your objective here
+```
+
+The script will start the task breakdown and execution process. It will display the progress and results in the console using formatted panels.
+
+Once the process is complete, the script will display the refined final output and save the full exchange log to a Markdown file with a filename based on the objective.
+
+## Code Structure
+
+The script consists of the following main functions:
+
+- `opus_orchestrator(objective, previous_results=None)`: Calls the Opus model to break down the objective into sub-tasks or provide the final output. It uses an improved prompt to assess task completion and includes the phrase "The task is complete:" when the objective is fully achieved.
+- `haiku_sub_agent(prompt, previous_haiku_tasks=None)`: Calls the Haiku model to execute a sub-task prompt, providing it with the memory of previous sub-tasks.
+- `opus_refine(objective, sub_task_results)`: Calls the Opus model to review and refine the sub-task results into a cohesive final output.
+
+The script follows an iterative process, repeatedly calling the opus_orchestrator function to break down the objective into sub-tasks until the final output is provided. Each sub-task is then executed by the haiku_sub_agent function, and the results are stored in the task_exchanges and haiku_tasks lists.
+
+The loop terminates when the Opus model includes the phrase "The task is complete:" in its response, indicating that the objective has been fully achieved.
+
+Finally, the opus_refine function is called to review and refine the sub-task results into a final output. The entire exchange log, including the objective, task breakdown, and refined final output, is saved to a Markdown file.
+
+## Customization
+
+You can customize the script according to your needs:
+
+- Adjust the max_tokens parameter in the client.messages.create() function calls to control the maximum number of tokens generated by the AI models.
+- Change the models to what you prefer, like replacing Haiku with Sonnet or Opus.
+- Modify the console output formatting by updating the rich library's Panel and Console configurations.
+- Customize the exchange log formatting and file extension by modifying the relevant code sections.
+
+## License
+
+This script is released under the MIT License.
+
+## Acknowledgements
+
+- Anthropic for providing the AI models and API.
+- Rich for the beautiful console formatting.

maestro-gpt.py

@@ -0,0 +1,236 @@
+import os
+from anthropic import Anthropic
+from openai import OpenAI
+import re
+from rich.console import Console
+from rich.panel import Panel
+from datetime import datetime
+import json
+
+# Set up the Anthropic API client
+anthropic_client = Anthropic(api_key="YOUR ANTHROPIC API KEY")
+
+# Set up the OpenAI API client
+openai_client = OpenAI(api_key="YOUR OPENAI API KEY")
+
+# Set the Claude model to use for the sub-agent
+claude_model = "claude-3-opus-20240229"
+
+# Initialize the Rich Console
+console = Console()
+
+def opus_orchestrator(objective, file_content=None, previous_results=None):
+    console.print(f"\n[bold]Calling Orchestrator for your objective[/bold]")
+    previous_results_text = "\n".join(previous_results) if previous_results else "None"
+    if file_content:
+        console.print(Panel(f"File content:\n{file_content}", title="[bold blue]File Content[/bold blue]", title_align="left", border_style="blue"))
+    messages = [
+        {
+            "role": "user",
+            "content": [
+                {"type": "text", "text": f"Based on the following objective{' and file content' if file_content else ''}, and the previous sub-task results (if any), please break down the objective into the next sub-task, and create a concise and detailed prompt for a subagent so it can execute that task. IMPORTANT!!! when dealing with code tasks make sure you check the code for errors and provide fixes and support as part of the next sub-task. If you find any bugs or have suggestions for better code, please include them in the next sub-task prompt. Please assess if the objective has been fully achieved. If the previous sub-task results comprehensively address all aspects of the objective, include the phrase 'The task is complete:' at the beginning of your response. If the objective is not yet fully achieved, break it down into the next sub-task and create a concise and detailed prompt for a subagent to execute that task.:\n\nObjective: {objective}" + ('\\nFile content:\\n' + file_content if file_content else '') + f"\n\nPrevious sub-task results:\n{previous_results_text}"}
+            ]
+        }
+    ]
+
+    if orchestrator_model == "Claude Opus":
+        opus_response = anthropic_client.messages.create(
+            model="claude-3-opus-20240229",
+            max_tokens=4096,
+            messages=messages
+        )
+        response_text = opus_response.content[0].text
+    else:  # GPT-4
+        gpt4_response = openai_client.chat.completions.create(
+            model="gpt-4-0125-preview",
+            messages=messages
+        )
+        response_text = gpt4_response.choices[0].message.content
+
+    console.print(Panel(response_text, title=f"[bold green]{orchestrator_model} Orchestrator[/bold green]", title_align="left", border_style="green", subtitle="Sending task to subagent 👇"))
+    return response_text, file_content
+
+def subagent(prompt, previous_subagent_tasks=None):
+    if previous_subagent_tasks is None:
+        previous_subagent_tasks = []
+
+    system_message = "Previous subagent tasks:\n" + "\n".join(previous_subagent_tasks)
+
+    messages = [
+        {
+            "role": "user",
+            "content": [
+                {"type": "text", "text": prompt}
+            ]
+        }
+    ]
+
+    subagent_response = anthropic_client.messages.create(
+        model=claude_model,
+        max_tokens=4096,
+        messages=messages,
+        system=system_message
+    )
+
+    response_text = subagent_response.content[0].text
+    console.print(Panel(response_text, title="[bold blue]Subagent Result[/bold blue]", title_align="left", border_style="blue", subtitle="Task completed, sending result to Maestro 👇"))
+    return response_text
+
+def opus_refine(objective, sub_task_results, filename, projectname):
+    print("\nCalling Opus to provide the refined final output for your objective:")
+    messages = [
+        {
+            "role": "user",
+            "content": [
+                {"type": "text", "text": "Objective: " + objective + "\n\nSub-task results:\n" + "\n".join(sub_task_results) + "\n\nPlease review and refine the sub-task results into a cohesive final output. Add any missing information or details as needed. When working on code projects, ONLY AND ONLY IF THE PROJECT IS CLEARLY A CODING ONE please provide the following:\n1. Project Name: Create a concise and appropriate project name that fits the project based on what it's creating. The project name should be no more than 20 characters long.\n2. Folder Structure: Provide the folder structure as a valid JSON object, where each key represents a folder or file, and nested keys represent subfolders. Use null values for files. Ensure the JSON is properly formatted without any syntax errors. Please make sure all keys are enclosed in double quotes, and ensure objects are correctly encapsulated with braces, separating items with commas as necessary.\nWrap the JSON object in <folder_structure> tags.\n3. Code Files: For each code file, include ONLY the file name NEVER EVER USE THE FILE PATH OR ANY OTHER FORMATTING YOU ONLY USE THE FOLLOWING format 'Filename: <filename>' followed by the code block enclosed in triple backticks, with the language identifier after the opening backticks, like this:\n\n​python\n<code>\n​"}
+            ]
+        }
+    ]
+
+    opus_response = anthropic_client.messages.create(
+        model="claude-3-opus-20240229",
+        max_tokens=4096,
+        messages=messages
+    )
+
+    response_text = opus_response.content[0].text
+    console.print(Panel(response_text, title="[bold green]Final Output[/bold green]", title_align="left", border_style="green"))
+    return response_text
+
+def create_folder_structure(project_name, folder_structure, code_blocks):
+    # Create the project folder
+    try:
+        os.makedirs(project_name, exist_ok=True)
+        console.print(Panel(f"Created project folder: [bold]{project_name}[/bold]", title="[bold green]Project Folder[/bold green]", title_align="left", border_style="green"))
+    except OSError as e:
+        console.print(Panel(f"Error creating project folder: [bold]{project_name}[/bold]\nError: {e}", title="[bold red]Project Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        return
+
+    # Recursively create the folder structure and files
+    create_folders_and_files(project_name, folder_structure, code_blocks)
+
+def create_folders_and_files(current_path, structure, code_blocks):
+    for key, value in structure.items():
+        path = os.path.join(current_path, key)
+        if isinstance(value, dict):
+            try:
+                os.makedirs(path, exist_ok=True)
+                console.print(Panel(f"Created folder: [bold]{path}[/bold]", title="[bold blue]Folder Creation[/bold blue]", title_align="left", border_style="blue"))
+                create_folders_and_files(path, value, code_blocks)
+            except OSError as e:
+                console.print(Panel(f"Error creating folder: [bold]{path}[/bold]\nError: {e}", title="[bold red]Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        else:
+            code_content = next((code for file, code in code_blocks if file == key), None)
+            if code_content:
+                try:
+                    with open(path, 'w') as file:
+                        file.write(code_content)
+                    console.print(Panel(f"Created file: [bold]{path}[/bold]", title="[bold green]File Creation[/bold green]", title_align="left", border_style="green"))
+                except IOError as e:
+                    console.print(Panel(f"Error creating file: [bold]{path}[/bold]\nError: {e}", title="[bold red]File Creation Error[/bold red]", title_align="left", border_style="red"))
+            else:
+                console.print(Panel(f"Code content not found for file: [bold]{key}[/bold]", title="[bold yellow]Missing Code Content[/bold yellow]", title_align="left", border_style="yellow"))
+
+def read_file(file_path):
+    with open(file_path, 'r') as file:
+        content = file.read()
+    return content
+
+# Ask the user for the orchestrator model choice
+orchestrator_model = input("Please choose the orchestrator model (Claude Opus or GPT-4): ")
+while orchestrator_model not in ["Claude Opus", "GPT-4"]:
+    orchestrator_model = input("Invalid choice. Please enter 'Claude Opus' or 'GPT-4': ")
+
+# Get the objective from user input
+objective = input("Please enter your objective with or without a text file path: ")
+
+# Check if the input contains a file path
+if "./" in objective or "/" in objective:
+    # Extract the file path from the objective
+    file_path = re.findall(r'[./\w]+\.[\w]+', objective)[0]
+    # Read the file content
+    with open(file_path, 'r') as file:
+        file_content = file.read()
+    # Update the objective string to remove the file path
+    objective = objective.split(file_path)[0].strip()
+else:
+    file_content = None
+
+task_exchanges = []
+subagent_tasks = []
+
+while True:
+    # Call Orchestrator to break down the objective into the next sub-task or provide the final output
+    previous_results = [result for _, result in task_exchanges]
+    if not task_exchanges:
+        # Pass the file content only in the first iteration if available
+        opus_result, file_content_for_subagent = opus_orchestrator(objective, file_content, previous_results)
+    else:
+        opus_result, _ = opus_orchestrator(objective, previous_results=previous_results)
+
+    if "The task is complete:" in opus_result:
+        # If Opus indicates the task is complete, exit the loop
+        final_output = opus_result.replace("The task is complete:", "").strip()
+        break
+    else:
+        sub_task_prompt = opus_result
+        # Include file content in the first subagent call if available
+        if file_content_for_subagent and not subagent_tasks:
+            sub_task_prompt += "\n\nFile content:\n" + file_content_for_subagent
+        sub_task_result = subagent(sub_task_prompt, subagent_tasks)
+        subagent_tasks.append(f"Task: {sub_task_prompt}\nResult: {sub_task_result}")
+        task_exchanges.append((sub_task_prompt, sub_task_result))
+        # Ensure file content is not passed in subsequent calls
+        file_content_for_subagent = None
+
+# Create the .md filename
+sanitized_objective = re.sub(r'\W+', '_', objective)
+timestamp = datetime.now().strftime("%H-%M-%S")
+
+# Call Opus to review and refine the sub-task results
+refined_output = opus_refine(objective, [result for _, result in task_exchanges], timestamp, sanitized_objective)
+
+# Extract the project name from the refined output
+project_name_match = re.search(r'Project Name: (.*)', refined_output)
+project_name = project_name_match.group(1).strip() if project_name_match else sanitized_objective
+
+# Extract the folder structure from the refined output
+folder_structure_match = re.search(r'<folder_structure>(.*?)</folder_structure>', refined_output, re.DOTALL)
+folder_structure = {}
+if folder_structure_match:
+    json_string = folder_structure_match.group(1).strip()
+    try:
+        folder_structure = json.loads(json_string)
+    except json.JSONDecodeError as e:
+        console.print(Panel(f"Error parsing JSON: {e}", title="[bold red]JSON Parsing Error[/bold red]", title_align="left", border_style="red"))
+        console.print(Panel(f"Invalid JSON string: [bold]{json_string}[/bold]", title="[bold red]Invalid JSON String[/bold red]", title_align="left", border_style="red"))
+
+# Extract code files from the refined output
+code_blocks = re.findall(r'Filename: (\S+)\s*```[\w]*\n(.*?)\n```', refined_output, re.DOTALL)
+
+# Create the folder structure and code files
+create_folder_structure(project_name, folder_structure, code_blocks)
+
+# Truncate the sanitized_objective to a maximum of 50 characters
+max_length = 40
+truncated_objective = sanitized_objective[:max_length] if len(sanitized_objective) > max_length else sanitized_objective
+
+# Update the filename to include the project name
+filename = f"{timestamp}_{truncated_objective}.md"
+
+# Prepare the full exchange log
+exchange_log = f"Objective: {objective}\n\n"
+exchange_log += "=" * 40 + " Task Breakdown " + "=" * 40 + "\n\n"
+for i, (prompt, result) in enumerate(task_exchanges, start=1):
+    exchange_log += f"Task {i}:\n"
+    exchange_log += f"Prompt: {prompt}\n"
+    exchange_log += f"Result: {result}\n\n"
+
+exchange_log += "=" * 40 + " Refined Final Output " + "=" * 40 + "\n\n"
+exchange_log += refined_output
+
+console.print(f"\n[bold]Refined Final output:[/bold]\n{refined_output}")
+
+with open(filename, 'w') as file:
+    file.write(exchange_log)
+print(f"\nFull exchange log saved to {filename}")

maestro-groq.py

@@ -0,0 +1,235 @@
+import os
+import re
+from rich.console import Console
+from rich.panel import Panel
+from datetime import datetime
+import json
+
+# Set up the Groq API client
+from groq import Groq
+import os
+
+client = Groq(api_key="YOUR API KEY")
+
+# Define the models to use for each agent
+ORCHESTRATOR_MODEL = "mixtral-8x7b-32768"
+SUB_AGENT_MODEL = "mixtral-8x7b-32768"
+REFINER_MODEL = "llama3-70b-8192"
+
+# Initialize the Rich Console
+console = Console()
+
+def opus_orchestrator(objective, file_content=None, previous_results=None):
+    console.print(f"\n[bold]Calling Orchestrator for your objective[/bold]")
+    previous_results_text = "\n".join(previous_results) if previous_results else "None"
+    if file_content:
+        console.print(Panel(f"File content:\n{file_content}", title="[bold blue]File Content[/bold blue]", title_align="left", border_style="blue"))
+    messages = [
+        {
+            "role": "system",
+            "content": "You are an AI orchestrator that breaks down objectives into sub-tasks."
+        },
+        {
+            "role": "user",
+            "content": f"Based on the following objective{' and file content' if file_content else ''}, and the previous sub-task results (if any), please break down the objective into the next sub-task, and create a concise and detailed prompt for a subagent so it can execute that task. IMPORTANT!!! when dealing with code tasks make sure you check the code for errors and provide fixes and support as part of the next sub-task. If you find any bugs or have suggestions for better code, please include them in the next sub-task prompt. Please assess if the objective has been fully achieved. If the previous sub-task results comprehensively address all aspects of the objective, include the phrase 'The task is complete:' at the beginning of your response. If the objective is not yet fully achieved, break it down into the next sub-task and create a concise and detailed prompt for a subagent to execute that task.:\n\nObjective: {objective}" + ('\\nFile content:\\n' + file_content if file_content else '') + f"\n\nPrevious sub-task results:\n{previous_results_text}"
+        }
+    ]
+
+    opus_response = client.chat.completions.create(
+        model=ORCHESTRATOR_MODEL,
+        messages=messages,
+        max_tokens=8000
+    )
+
+    response_text = opus_response.choices[0].message.content
+    console.print(Panel(response_text, title=f"[bold green]Groq Orchestrator[/bold green]", title_align="left", border_style="green", subtitle="Sending task to Subagent 👇"))
+    return response_text, file_content
+
+def haiku_sub_agent(prompt, previous_haiku_tasks=None, continuation=False):
+    if previous_haiku_tasks is None:
+        previous_haiku_tasks = []
+
+    continuation_prompt = "Continuing from the previous answer, please complete the response."
+    system_message = "Previous Haiku tasks:\n" + "\n".join(f"Task: {task['task']}\nResult: {task['result']}" for task in previous_haiku_tasks)
+    if continuation:
+        prompt = continuation_prompt
+
+    messages = [
+        {
+            "role": "system",
+            "content": system_message
+        },
+        {
+            "role": "user",
+            "content": prompt
+        }
+    ]
+
+    haiku_response = client.chat.completions.create(
+        model=SUB_AGENT_MODEL,
+        messages=messages,
+        max_tokens=8000
+    )
+
+    response_text = haiku_response.choices[0].message.content
+    console.print(Panel(response_text, title="[bold blue]Groq Sub-agent Result[/bold blue]", title_align="left", border_style="blue", subtitle="Task completed, sending result to Orchestrator 👇"))
+    return response_text
+
+def opus_refine(objective, sub_task_results, filename, projectname, continuation=False):
+    console.print("\nCalling Opus to provide the refined final output for your objective:")
+    messages = [
+        {
+            "role": "system",
+            "content": "You are an AI assistant that refines sub-task results into a cohesive final output."
+        },
+        {
+            "role": "user",
+            "content": "Objective: " + objective + "\n\nSub-task results:\n" + "\n".join(sub_task_results) + "\n\nPlease review and refine the sub-task results into a cohesive final output. Add any missing information or details as needed. Make sure the code files are completed. When working on code projects, ONLY AND ONLY IF THE PROJECT IS CLEARLY A CODING ONE please provide the following:\n1. Project Name: Create a concise and appropriate project name that fits the project based on what it's creating. The project name should be no more than 20 characters long.\n2. Folder Structure: Provide the folder structure as a valid JSON object, where each key represents a folder or file, and nested keys represent subfolders. Use null values for files. Ensure the JSON is properly formatted without any syntax errors. Please make sure all keys are enclosed in double quotes, and ensure objects are correctly encapsulated with braces, separating items with commas as necessary.\nWrap the JSON object in <folder_structure> tags.\n3. Code Files: For each code file, include ONLY the file name in this format 'Filename: <filename>' NEVER EVER USE THE FILE PATH OR ANY OTHER FORMATTING YOU ONLY USE THE FOLLOWING format 'Filename: <filename>' followed by the code block enclosed in triple backticks, with the language identifier after the opening backticks, like this:\n\n​python\n<code>\n​"
+        }
+    ]
+
+    opus_response = client.chat.completions.create(
+        model=REFINER_MODEL,
+        messages=messages,
+        max_tokens=8000
+    )
+
+    response_text = opus_response.choices[0].message.content
+    console.print(Panel(response_text, title="[bold green]Final Output[/bold green]", title_align="left", border_style="green"))
+    return response_text
+
+def create_folder_structure(project_name, folder_structure, code_blocks):
+    # Create the project folder
+    try:
+        os.makedirs(project_name, exist_ok=True)
+        console.print(Panel(f"Created project folder: [bold]{project_name}[/bold]", title="[bold green]Project Folder[/bold green]", title_align="left", border_style="green"))
+    except OSError as e:
+        console.print(Panel(f"Error creating project folder: [bold]{project_name}[/bold]\nError: {e}", title="[bold red]Project Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        return
+
+    # Recursively create the folder structure and files
+    create_folders_and_files(project_name, folder_structure, code_blocks)
+
+def create_folders_and_files(current_path, structure, code_blocks):
+    for key, value in structure.items():
+        path = os.path.join(current_path, key)
+        if isinstance(value, dict):
+            try:
+                os.makedirs(path, exist_ok=True)
+                console.print(Panel(f"Created folder: [bold]{path}[/bold]", title="[bold blue]Folder Creation[/bold blue]", title_align="left", border_style="blue"))
+                create_folders_and_files(path, value, code_blocks)
+            except OSError as e:
+                console.print(Panel(f"Error creating folder: [bold]{path}[/bold]\nError: {e}", title="[bold red]Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        else:
+            code_content = next((code for file, code in code_blocks if file == key), None)
+            if code_content:
+                try:
+                    with open(path, 'w') as file:
+                        file.write(code_content)
+                    console.print(Panel(f"Created file: [bold]{path}[/bold]", title="[bold green]File Creation[/bold green]", title_align="left", border_style="green"))
+                except IOError as e:
+                    console.print(Panel(f"Error creating file: [bold]{path}[/bold]\nError: {e}", title="[bold red]File Creation Error[/bold red]", title_align="left", border_style="red"))
+            else:
+                console.print(Panel(f"Code content not found for file: [bold]{key}[/bold]", title="[bold yellow]Missing Code Content[/bold yellow]", title_align="left", border_style="yellow"))
+
+def read_file(file_path):
+    with open(file_path, 'r') as file:
+        content = file.read()
+    return content
+
+# Get the objective from user input
+objective = input("Please enter your objective with or without a text file path: ")
+
+# Check if the input contains a file path
+if "./" in objective or "/" in objective:
+    # Extract the file path from the objective
+    file_path = re.findall(r'[./\w]+\.[\w]+', objective)[0]
+    # Read the file content
+    with open(file_path, 'r') as file:
+        file_content = file.read()
+    # Update the objective string to remove the file path
+    objective = objective.split(file_path)[0].strip()
+else:
+    file_content = None
+
+task_exchanges = []
+haiku_tasks = []
+
+while True:
+    # Call Orchestrator to break down the objective into the next sub-task or provide the final output
+    previous_results = [result for _, result in task_exchanges]
+    if not task_exchanges:
+        # Pass the file content only in the first iteration if available
+        opus_result, file_content_for_haiku = opus_orchestrator(objective, file_content, previous_results)
+    else:
+        opus_result, _ = opus_orchestrator(objective, previous_results=previous_results)
+
+    if "The task is complete:" in opus_result:
+        # If Opus indicates the task is complete, exit the loop
+        final_output = opus_result.replace("The task is complete:", "").strip()
+        break
+    else:
+        sub_task_prompt = opus_result
+        # Append file content to the prompt for the initial call to haiku_sub_agent, if applicable
+        if file_content_for_haiku and not haiku_tasks:
+            sub_task_prompt = f"{sub_task_prompt}\n\nFile content:\n{file_content_for_haiku}"
+        # Call haiku_sub_agent with the prepared prompt and record the result
+        sub_task_result = haiku_sub_agent(sub_task_prompt, haiku_tasks)
+        # Log the task and its result for future reference
+        haiku_tasks.append({"task": sub_task_prompt, "result": sub_task_result})
+        # Record the exchange for processing and output generation
+        task_exchanges.append((sub_task_prompt, sub_task_result))
+        # Prevent file content from being included in future haiku_sub_agent calls
+        file_content_for_haiku = None
+
+# Create the .md filename
+sanitized_objective = re.sub(r'\W+', '_', objective)
+timestamp = datetime.now().strftime("%H-%M-%S")
+
+# Call Opus to review and refine the sub-task results
+refined_output = opus_refine(objective, [result for _, result in task_exchanges], timestamp, sanitized_objective)
+
+# Extract the project name from the refined output
+project_name_match = re.search(r'Project Name: (.*)', refined_output)
+project_name = project_name_match.group(1).strip() if project_name_match else sanitized_objective
+
+# Extract the folder structure from the refined output
+folder_structure_match = re.search(r'<folder_structure>(.*?)</folder_structure>', refined_output, re.DOTALL)
+folder_structure = {}
+if folder_structure_match:
+    json_string = folder_structure_match.group(1).strip()
+    try:
+        folder_structure = json.loads(json_string)
+    except json.JSONDecodeError as e:
+        console.print(Panel(f"Error parsing JSON: {e}", title="[bold red]JSON Parsing Error[/bold red]", title_align="left", border_style="red"))
+        console.print(Panel(f"Invalid JSON string: [bold]{json_string}[/bold]", title="[bold red]Invalid JSON String[/bold red]", title_align="left", border_style="red"))
+
+# Extract code files from the refined output
+code_blocks = re.findall(r'Filename: (\S+)\s*```[\w]*\n(.*?)\n```', refined_output, re.DOTALL)
+
+# Create the folder structure and code files
+create_folder_structure(project_name, folder_structure, code_blocks)
+
+# Truncate the sanitized_objective to a maximum of 50 characters
+max_length = 25
+truncated_objective = sanitized_objective[:max_length] if len(sanitized_objective) > max_length else sanitized_objective
+
+# Update the filename to include the project name
+filename = f"{timestamp}_{truncated_objective}.md"
+
+# Prepare the full exchange log
+exchange_log = f"Objective: {objective}\n\n"
+exchange_log += "=" * 40 + " Task Breakdown " + "=" * 40 + "\n\n"
+for i, (prompt, result) in enumerate(task_exchanges, start=1):
+    exchange_log += f"Task {i}:\n"
+    exchange_log += f"Prompt: {prompt}\n"
+    exchange_log += f"Result: {result}\n\n"
+
+exchange_log += "=" * 40 + " Refined Final Output " + "=" * 40 + "\n\n"
+exchange_log += refined_output
+
+console.print(f"\n[bold]Refined Final output:[/bold]\n{refined_output}")
+
+with open(filename, 'w') as file:
+    file.write(exchange_log)
+print(f"\nFull exchange log saved to {filename}")

maestro-lmstudio.py

@@ -0,0 +1,284 @@
+import os
+import re
+from rich.console import Console
+from rich.panel import Panel
+from datetime import datetime
+import json
+from tavily import TavilyClient
+from openai import OpenAI
+
+# Set up the LM Studio API client
+client = OpenAI(base_url="http://localhost:1234/v1", api_key="lm-studio")
+
+# Available models (replace with your own model names)
+ORCHESTRATOR_MODEL = "lmstudio-community/Meta-Llama-3-8B-Instruct-GGUF"
+SUB_AGENT_MODEL = "lmstudio-community/Meta-Llama-3-8B-Instruct-GGUF"
+REFINER_MODEL = "lmstudio-community/Meta-Llama-3-8B-Instruct-GGUF"
+
+# Initialize the Rich Console
+console = Console()
+
+def opus_orchestrator(objective, file_content=None, previous_results=None, use_search=False):
+    console.print(f"\n[bold]Calling Orchestrator for your objective[/bold]")
+    previous_results_text = "\n".join(previous_results) if previous_results else "None"
+    if file_content:
+        console.print(Panel(f"File content:\n{file_content}", title="[bold blue]File Content[/bold blue]", title_align="left", border_style="blue"))
+    
+    messages = [
+        {
+            "role": "system",
+            "content": "You are an orchestrator responsible for breaking down complex tasks into smaller sub-tasks."
+        },
+        {
+            "role": "user",
+            "content": f"Based on the following objective{' and file content' if file_content else ''}, and the previous sub-task results (if any), please break down the objective into the next sub-task, and create a concise and detailed prompt for a subagent so it can execute that task. IMPORTANT!!! when dealing with code tasks make sure you check the code for errors and provide fixes and support as part of the next sub-task. If you find any bugs or have suggestions for better code, please include them in the next sub-task prompt. Please assess if the objective has been fully achieved. If the previous sub-task results comprehensively address all aspects of the objective, include the phrase 'The task is complete:' at the beginning of your response. If the objective is not yet fully achieved, break it down into the next sub-task and create a concise and detailed prompt for a subagent to execute that task.:\n\nObjective: {objective}" + ('\\nFile content:\\n' + file_content if file_content else '') + f"\n\nPrevious sub-task results:\n{previous_results_text}"
+        }
+    ]
+    if use_search:
+        messages.append({
+            "role": "user",
+            "content": "Please also generate a JSON object containing a single 'search_query' key, which represents a question that, when asked online, would yield important information for solving the subtask. The question should be specific and targeted to elicit the most relevant and helpful resources. Format your JSON like this, with no additional text before or after:\n{\"search_query\": \"<question>\"}\n"
+        })
+
+    opus_response = client.chat.completions.create(
+        model=ORCHESTRATOR_MODEL,
+        messages=messages,
+        temperature=0.7,
+    )
+
+    response_text = opus_response.choices[0].message.content
+
+    search_query = None
+    if use_search:
+        # Extract the JSON from the response
+        json_match = re.search(r'{.*}', response_text, re.DOTALL)
+        if json_match:
+            json_string = json_match.group()
+            try:
+                search_query = json.loads(json_string)["search_query"]
+                console.print(Panel(f"Search Query: {search_query}", title="[bold blue]Search Query[/bold blue]", title_align="left", border_style="blue"))
+                response_text = response_text.replace(json_string, "").strip()
+            except json.JSONDecodeError as e:
+                console.print(Panel(f"Error parsing JSON: {e}", title="[bold red]JSON Parsing Error[/bold red]", title_align="left", border_style="red"))
+                console.print(Panel(f"Skipping search query extraction.", title="[bold yellow]Search Query Extraction Skipped[/bold yellow]", title_align="left", border_style="yellow"))
+        else:
+            search_query = None
+
+    console.print(Panel(response_text, title=f"[bold green]Orchestrator[/bold green]", title_align="left", border_style="green", subtitle="Sending task to Haiku 👇"))
+    return response_text, file_content, search_query
+
+
+def haiku_sub_agent(prompt, search_query=None, previous_haiku_tasks=None, use_search=False, continuation=False):
+    if previous_haiku_tasks is None:
+        previous_haiku_tasks = []
+
+    continuation_prompt = "Continuing from the previous answer, please complete the response."
+    system_message = "Previous Haiku tasks:\n" + "\n".join(f"Task: {task['task']}\nResult: {task['result']}" for task in previous_haiku_tasks)
+    if continuation:
+        prompt = continuation_prompt
+
+    qna_response = None
+    if search_query and use_search:
+        # Initialize the Tavily client
+        tavily = TavilyClient(api_key="YOUR API KEY HERE")
+        # Perform a QnA search based on the search query
+        qna_response = tavily.qna_search(query=search_query)
+        console.print(f"QnA response: {qna_response}", style="yellow")
+
+    # Prepare the messages array with only the prompt initially
+    messages = [
+        {
+            "role": "system",
+            "content": system_message
+        },
+        {
+            "role": "user",
+            "content": prompt
+        }
+    ]
+
+    # Add search results to the messages if there are any
+    if qna_response:
+        messages.append({
+            "role": "user",
+            "content": f"\nSearch Results:\n{qna_response}"
+        })
+
+    haiku_response = client.chat.completions.create(
+        model=SUB_AGENT_MODEL,
+        messages=messages,
+        temperature=0.7,
+    )
+
+    response_text = haiku_response.choices[0].message.content
+
+    console.print(Panel(response_text, title="[bold blue]Sub-agent Result[/bold blue]", title_align="left", border_style="blue", subtitle="Task completed, sending result to Opus 👇"))
+    return response_text
+
+def opus_refine(objective, sub_task_results, filename, projectname, continuation=False):
+    print("\nCalling Opus to provide the refined final output for your objective:")
+    messages = [
+        {
+            "role": "system",
+            "content": "You are responsible for refining the sub-task results into a cohesive final output."
+        },
+        {
+            "role": "user",
+            "content": "Objective: " + objective + "\n\nSub-task results:\n" + "\n".join(sub_task_results) + "\n\nPlease review and refine the sub-task results into a cohesive final output. Add any missing information or details as needed. When working on code projects, ONLY AND ONLY IF THE PROJECT IS CLEARLY A CODING ONE please provide the following:\n1. Project Name: Create a concise and appropriate project name that fits the project based on what it's creating. The project name should be no more than 20 characters long.\n2. Folder Structure: Provide the folder structure as a valid JSON object, where each key represents a folder or file, and nested keys represent subfolders. Use null values for files. Ensure the JSON is properly formatted without any syntax errors. Please make sure all keys are enclosed in double quotes, and ensure objects are correctly encapsulated with braces, separating items with commas as necessary.\nWrap the JSON object in <folder_structure> tags.\n3. Code Files: For each code file, include ONLY the file name NEVER EVER USE THE FILE PATH OR ANY OTHER FORMATTING YOU ONLY USE THE FOLLOWING format 'Filename: <filename>' followed by the code block enclosed in triple backticks, with the language identifier after the opening backticks, like this:\n\n​python\n<code>\n​"
+        }
+    ]
+
+    opus_response = client.chat.completions.create(
+        model=REFINER_MODEL,
+        messages=messages,
+        temperature=0.7,
+    )
+
+    response_text = opus_response.choices[0].message.content.strip()
+
+    if opus_response.usage.total_tokens >= 4000:  # Threshold set to 4000 as a precaution
+        console.print("[bold yellow]Warning:[/bold yellow] Output may be truncated. Attempting to continue the response.")
+        continuation_response_text = opus_refine(objective, sub_task_results, filename, projectname, continuation=True)
+        response_text += continuation_response_text
+
+    console.print(Panel(response_text, title="[bold green]Final Output[/bold green]", title_align="left", border_style="green"))
+    return response_text
+
+def create_folder_structure(project_name, folder_structure, code_blocks):
+    # Create the project folder
+    try:
+        os.makedirs(project_name, exist_ok=True)
+        console.print(Panel(f"Created project folder: [bold]{project_name}[/bold]", title="[bold green]Project Folder[/bold green]", title_align="left", border_style="green"))
+    except OSError as e:
+        console.print(Panel(f"Error creating project folder: [bold]{project_name}[/bold]\nError: {e}", title="[bold red]Project Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        return
+
+    # Recursively create the folder structure and files
+    create_folders_and_files(project_name, folder_structure, code_blocks)
+
+def create_folders_and_files(current_path, structure, code_blocks):
+    for key, value in structure.items():
+        path = os.path.join(current_path, key)
+        if isinstance(value, dict):
+            try:
+                os.makedirs(path, exist_ok=True)
+                console.print(Panel(f"Created folder: [bold]{path}[/bold]", title="[bold blue]Folder Creation[/bold blue]", title_align="left", border_style="blue"))
+                create_folders_and_files(path, value, code_blocks)
+            except OSError as e:
+                console.print(Panel(f"Error creating folder: [bold]{path}[/bold]\nError: {e}", title="[bold red]Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        else:
+            code_content = next((code for file, code in code_blocks if file == key), None)
+            if code_content:
+                try:
+                    with open(path, 'w') as file:
+                        file.write(code_content)
+                    console.print(Panel(f"Created file: [bold]{path}[/bold]", title="[bold green]File Creation[/bold green]", title_align="left", border_style="green"))
+                except IOError as e:
+                    console.print(Panel(f"Error creating file: [bold]{path}[/bold]\nError: {e}", title="[bold red]File Creation Error[/bold red]", title_align="left", border_style="red"))
+            else:
+                console.print(Panel(f"Code content not found for file: [bold]{key}[/bold]", title="[bold yellow]Missing Code Content[/bold yellow]", title_align="left", border_style="yellow"))
+
+def read_file(file_path):
+    with open(file_path, 'r') as file:
+        content = file.read()
+    return content
+
+# Get the objective from user input
+objective = input("Please enter your objective with or without a text file path: ")
+
+# Check if the input contains a file path
+if "./" in objective or "/" in objective:
+    # Extract the file path from the objective
+    file_path = re.findall(r'[./\w]+\.[\w]+', objective)[0]
+    # Read the file content
+    with open(file_path, 'r') as file:
+        file_content = file.read()
+    # Update the objective string to remove the file path
+    objective = objective.split(file_path)[0].strip()
+else:
+    file_content = None
+
+# Ask the user if they want to use search
+use_search = input("Do you want to use search? (y/n): ").lower() == 'y'
+
+task_exchanges = []
+haiku_tasks = []
+
+while True:
+    # Call Orchestrator to break down the objective into the next sub-task or provide the final output
+    previous_results = [result for _, result in task_exchanges]
+    if not task_exchanges:
+        # Pass the file content only in the first iteration if available
+        opus_result, file_content_for_haiku, search_query = opus_orchestrator(objective, file_content, previous_results, use_search)
+    else:
+        opus_result, _, search_query = opus_orchestrator(objective, previous_results=previous_results, use_search=use_search)
+
+    if "The task is complete:" in opus_result:
+        # If Opus indicates the task is complete, exit the loop
+        final_output = opus_result.replace("The task is complete:", "").strip()
+        break
+    else:
+        sub_task_prompt = opus_result
+        # Append file content to the prompt for the initial call to haiku_sub_agent, if applicable
+        if file_content_for_haiku and not haiku_tasks:
+            sub_task_prompt = f"{sub_task_prompt}\n\nFile content:\n{file_content_for_haiku}"
+        # Call haiku_sub_agent with the prepared prompt, search query, and record the result
+        sub_task_result = haiku_sub_agent(sub_task_prompt, search_query, haiku_tasks, use_search)
+        # Log the task and its result for future reference
+        haiku_tasks.append({"task": sub_task_prompt, "result": sub_task_result})
+        # Record the exchange for processing and output generation
+        task_exchanges.append((sub_task_prompt, sub_task_result))
+        # Prevent file content from being included in future haiku_sub_agent calls
+        file_content_for_haiku = None
+
+# Create the .md filename
+sanitized_objective = re.sub(r'\W+', '_', objective)
+timestamp = datetime.now().strftime("%H-%M-%S")
+
+# Call Opus to review and refine the sub-task results
+refined_output = opus_refine(objective, [result for _, result in task_exchanges], timestamp, sanitized_objective)
+
+# Extract the project name from the refined output
+project_name_match = re.search(r'Project Name: (.*)', refined_output)
+project_name = project_name_match.group(1).strip() if project_name_match else sanitized_objective
+
+# Extract the folder structure from the refined output
+folder_structure_match = re.search(r'<folder_structure>(.*?)</folder_structure>', refined_output, re.DOTALL)
+folder_structure = {}
+if folder_structure_match:
+    json_string = folder_structure_match.group(1).strip()
+    try:
+        folder_structure = json.loads(json_string)
+    except json.JSONDecodeError as e:
+        console.print(Panel(f"Error parsing JSON: {e}", title="[bold red]JSON Parsing Error[/bold red]", title_align="left", border_style="red"))
+        console.print(Panel(f"Invalid JSON string: [bold]{json_string}[/bold]", title="[bold red]Invalid JSON String[/bold red]", title_align="left", border_style="red"))
+
+# Extract code files from the refined output
+code_blocks = re.findall(r'Filename: (\S+)\s*```[\w]*\n(.*?)\n```', refined_output, re.DOTALL)
+
+# Create the folder structure and code files
+create_folder_structure(project_name, folder_structure, code_blocks)
+
+# Truncate the sanitized_objective to a maximum of 50 characters
+max_length = 25
+truncated_objective = sanitized_objective[:max_length] if len(sanitized_objective) > max_length else sanitized_objective
+
+# Update the filename to include the project name
+filename = f"{timestamp}_{truncated_objective}.md"
+
+# Prepare the full exchange log
+exchange_log = f"Objective: {objective}\n\n"
+exchange_log += "=" * 40 + " Task Breakdown " + "=" * 40 + "\n\n"
+for i, (prompt, result) in enumerate(task_exchanges, start=1):
+    exchange_log += f"Task {i}:\n"
+    exchange_log += f"Prompt: {prompt}\n"
+    exchange_log += f"Result: {result}\n\n"
+
+exchange_log += "=" * 40 + " Refined Final Output " + "=" * 40 + "\n\n"
+exchange_log += refined_output
+
+console.print(f"\n[bold]Refined Final output:[/bold]\n{refined_output}")
+
+with open(filename, 'w') as file:
+    file.write(exchange_log)
+print(f"\nFull exchange log saved to {filename}")

maestro-ollama.py

@@ -0,0 +1,285 @@
+import os
+import re
+from datetime import datetime
+import json
+from rich.console import Console
+from rich.panel import Panel
+import ollama
+from ollama import Client  # Import the Ollama client
+import argparse
+
+# Only for the first time run based on the model you want to use
+# ollama.pull('llama3:70b')
+# ollama.pull('llama3:8b')
+# ollama.pull('llama3:8b')
+# ollama.pull('llama3:70b-instruct')
+# ollama.pull('llama3:instruct')
+
+# Define model identifiers as variables at the top of the script
+ORCHESTRATOR_MODEL = 'llama3:70b-instruct'
+SUBAGENT_MODEL = 'llama3:instruct'
+REFINER_MODEL = 'llama3:70b-instruct'
+
+# check and pull models if they don't exist yet
+for model in [ORCHESTRATOR_MODEL, SUBAGENT_MODEL, REFINER_MODEL]:
+    try:
+        print(f"Checking for model: {model}")
+        m = ollama.show(model)
+    except ollama._types.ResponseError as e:
+        print(f"Pulling model from ollama: {model}")
+        ollama.pull(model)
+
+# Initialize the Ollama client
+client = Client(host='http://localhost:11434')
+
+console = Console()
+
+def opus_orchestrator(objective, file_content=None, previous_results=None):
+    console.print(f"\n[bold]Calling Ollama Orchestrator for your objective[/bold]")
+    previous_results_text = "\n".join(previous_results) if previous_results else "None"
+    if file_content:
+        console.print(Panel(f"File content:\n{file_content}", title="[bold blue]File Content[/bold blue]", title_align="left", border_style="blue"))
+    
+    response = client.chat(
+        model=ORCHESTRATOR_MODEL,
+        messages=[
+            {
+                "role": "user",
+                "content": f"Based on the following objective{' and file content' if file_content else ''}, and the previous sub-task results (if any), please break down the objective into the next sub-task, and create a concise and detailed prompt for a subagent so it can execute that task. Focus solely on the objective and avoid engaging in casual conversation with the subagent.\n\nWhen dealing with code tasks, make sure to check the code for errors and provide fixes and support as part of the next sub-task. If you find any bugs or have suggestions for better code, please include them in the next sub-task prompt.\n\nPlease assess if the objective has been fully achieved. If the previous sub-task results comprehensively address all aspects of the objective, include the phrase 'The task is complete:' at the beginning of your response. If the objective is not yet fully achieved, break it down into the next sub-task and create a concise and detailed prompt for a subagent to execute that task.\n\nObjective: {objective}" + (f'\nFile content:\n{file_content}' if file_content else '') + f"\n\nPrevious sub-task results:\n{previous_results_text}"
+            }
+        ]
+    )
+    
+    response_text = response['message']['content']
+    console.print(Panel(response_text, title="[bold green]Ollama Orchestrator[/bold green]", title_align="left", border_style="green", subtitle="Sending task to Ollama sub-agent 👇"))
+    return response_text, file_content
+
+def haiku_sub_agent(prompt, previous_haiku_tasks=None, continuation=False):
+    if previous_haiku_tasks is None:
+        previous_haiku_tasks = []
+
+    continuation_prompt = "Continuing from the previous answer, please complete the response."
+    if continuation:
+        prompt = continuation_prompt
+
+    # Compile previous tasks into a readable format
+    previous_tasks_summary = "Previous Sub-agent tasks:\n" + "\n".join(f"Task: {task['task']}\nResult: {task['result']}" for task in previous_haiku_tasks)
+    
+    # Append previous tasks summary to the prompt
+    full_prompt = f"{previous_tasks_summary}\n\n{prompt}"
+
+    # Ensure prompt is not empty
+    if not full_prompt.strip():
+        raise ValueError("Prompt cannot be empty")
+
+    response = client.chat(
+        model=SUBAGENT_MODEL, 
+        messages=[{"role": "user", "content": full_prompt}]
+    )
+    
+    response_text = response['message']['content']
+    
+    if len(response_text) >= 4000:  # Threshold set to 4000 as a precaution
+        console.print("[bold yellow]Warning:[/bold yellow] Output may be truncated. Attempting to continue the response.")
+        continuation_response_text = haiku_sub_agent(continuation_prompt, previous_haiku_tasks, continuation=True)
+        response_text += continuation_response_text
+
+    console.print(Panel(response_text, title="[bold blue]Ollama Sub-agent Result[/bold blue]", title_align="left", border_style="blue", subtitle="Task completed, sending result to Ollama Orchestrator 👇"))
+    return response_text
+
+def opus_refine(objective, sub_task_results, filename, projectname, continuation=False):
+    console.print("\nCalling Ollama to provide the refined final output for your objective:")
+    
+    response = client.chat(
+        model=REFINER_MODEL,
+        messages=[
+            {
+                "role": "user",
+                "content": "Objective: " + objective + "\n\nSub-task results:\n" + "\n".join(sub_task_results) + "\n\nPlease review and refine the sub-task results into a cohesive final output. Add any missing information or details as needed.\n\nWhen working on code projects, ONLY AND ONLY IF THE PROJECT IS CLEARLY A CODING ONE, please provide the following:\n\n1. Project Name: Create a concise and appropriate project name that fits the project based on what it's creating. The project name should be no more than 20 characters long.\n\n2. Folder Structure: Provide the folder structure as a valid JSON object, where each key represents a folder or file, and nested keys represent subfolders. Use null values for files. Ensure the JSON is properly formatted without any syntax errors. Please make sure all keys are enclosed in double quotes, and ensure objects are correctly encapsulated with braces, separating items with commas as necessary. Wrap the JSON object in <folder_structure> tags.\n\n3. Code Files: For each code file, include ONLY the file name, NEVER EVER USE THE FILE PATH OR ANY OTHER FORMATTING. YOU ONLY USE THE FOLLOWING format 'Filename: <filename>' followed by the code block enclosed in triple backticks, with the language identifier after the opening backticks, like this:\n\npython\n<code>\n\n\nFocus solely on the objective and avoid engaging in casual conversation. Ensure the final output is clear, concise, and addresses all aspects of the objective.​"
+            }
+        ]
+    )
+    
+    response_text = response['message']['content']
+    
+    if len(response_text) >= 4000:  # Threshold set to 4000 as a precaution
+        console.print("[bold yellow]Warning:[/bold yellow] Output may be truncated. Attempting to continue the response.")
+        continuation_response_text = opus_refine(objective, sub_task_results, filename, projectname, continuation=True)
+        response_text += continuation_response_text
+
+    console.print(Panel(response_text, title="[bold green]Final Output[/bold green]", title_align="left", border_style="green"))
+    return response_text
+
+def create_folder_structure(project_name, folder_structure, code_blocks):
+    try:
+        os.makedirs(project_name, exist_ok=True)
+        console.print(Panel(f"Created project folder: [bold]{project_name}[/bold]", title="[bold blue]Project Folder Creation[/bold blue]", title_align="left", border_style="blue"))
+    except OSError as e:
+        console.print(Panel(f"Error creating project folder: [bold]{project_name}[/bold]\nError: {e}", title="[bold red]Project Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+
+    create_folders_and_files(project_name, folder_structure, code_blocks)
+
+def create_folders_and_files(current_path, structure, code_blocks):
+    for key, value in structure.items():
+        path = os.path.join(current_path, key)
+        if isinstance(value, dict):
+            try:
+                os.makedirs(path, exist_ok=True)
+                console.print(Panel(f"Created folder: [bold]{path}[/bold]", title="[bold blue]Folder Creation[/bold blue]", title_align="left", border_style="blue"))
+                create_folders_and_files(path, value, code_blocks)
+            except OSError as e:
+                console.print(Panel(f"Error creating folder: [bold]{path}[/bold]\nError: {e}", title="[bold red]Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        else:
+            code_content = next((code for file, code in code_blocks if file == key), None)
+            if code_content:
+                try:
+                    with open(path, 'w') as file:
+                        file.write(code_content)
+                    console.print(Panel(f"Created file: [bold]{path}[/bold]", title="[bold green]File Creation[/bold green]", title_align="left", border_style="green"))
+                except IOError as e:
+                    console.print(Panel(f"Error creating file: [bold]{path}[/bold]\nError: {e}", title="[bold red]File Creation Error[/bold red]", title_align="left", border_style="red"))
+            else:
+                console.print(Panel(f"Code content not found for file: [bold]{key}[/bold]", title="[bold yellow]Missing Code Content[/bold yellow]", title_align="left", border_style="yellow"))
+
+def read_file(file_path):
+    with open(file_path, 'r') as file:
+        content = file.read()
+    return content
+   
+def has_task_data():
+    return os.path.exists('task_data.json')
+
+def read_task_data():
+    with open('task_data.json', 'r') as file:
+        task_data = json.load(file)
+    return task_data
+
+
+def write_task_data(task_data):
+    with open('task_data.json', 'w') as file:
+        json.dump(task_data, file)
+
+
+continue_from_last_task = False
+tmp_task_data = {}
+
+# parse args
+parser = argparse.ArgumentParser()
+parser.add_argument('-p', '--prompt', type=str, help='Please enter your objective with or without a text file path')
+args = parser.parse_args()
+
+if args.prompt is not None:
+    objective = args.prompt
+else:
+    # Check if there is a task data file
+    if has_task_data():
+        continue_from_last_task = input("Do you want to continue from the last task? (y/n): ").lower() == 'y'
+
+    if continue_from_last_task:
+        tmp_task_data = read_task_data()
+        objective = tmp_task_data['objective']
+        task_exchanges = tmp_task_data['task_exchanges']
+        console.print(Panel(f"Resuming from last task: {objective}", title="[bold blue]Resuming from last task[/bold blue]", title_align="left", border_style="blue"))
+    else:
+        # Get the objective from user input
+        objective = input("Please enter your objective with or without a text file path: ")
+        tmp_task_data['objective'] = objective
+        tmp_task_data['task_exchanges'] = []
+
+# Check if the input contains a file path
+if "./" in objective or "/" in objective:
+    # Extract the file path from the objective
+    file_path = re.findall(r'[./\w]+\.[\w]+', objective)[0]
+    # Read the file content
+    with open(file_path, 'r') as file:
+        file_content = file.read()
+    # Update the objective string to remove the file path
+    objective = objective.split(file_path)[0].strip()
+else:
+    file_content = None
+
+task_exchanges = []
+haiku_tasks = []
+
+while True:
+    # Call Orchestrator to break down the objective into the next sub-task or provide the final output
+    previous_results = [result for _, result in task_exchanges]
+    if not task_exchanges:
+        # Pass the file content only in the first iteration if available
+        opus_result, file_content_for_haiku = opus_orchestrator(objective, file_content, previous_results)
+    else:
+        opus_result, _ = opus_orchestrator(objective, previous_results=previous_results)
+
+    if "The task is complete:" in opus_result:
+        # If Opus indicates the task is complete, exit the loop
+        final_output = opus_result.replace("The task is complete:", "").strip()
+        break
+    else:
+        sub_task_prompt = opus_result
+        # Append file content to the prompt for the initial call to haiku_sub_agent, if applicable
+        if file_content_for_haiku and not haiku_tasks:
+            sub_task_prompt = f"{sub_task_prompt}\n\nFile content:\n{file_content_for_haiku}"
+        # Call haiku_sub_agent with the prepared prompt and record the result
+        sub_task_result = haiku_sub_agent(sub_task_prompt, haiku_tasks)
+        # Log the task and its result for future reference
+        haiku_tasks.append({"task": sub_task_prompt, "result": sub_task_result})
+        # Record the exchange for processing and output generation
+        task_exchanges.append((sub_task_prompt, sub_task_result))
+        # Update the task data with the new task exchanges
+        tmp_task_data['task_exchanges'] = task_exchanges
+        # Save the task data to a JSON file for resuming later
+        write_task_data(tmp_task_data)
+        # Prevent file content from being included in future haiku_sub_agent calls
+        file_content_for_haiku = None
+
+# Create the .md filename
+sanitized_objective = re.sub(r'\W+', '_', objective)
+timestamp = datetime.now().strftime("%H-%M-%S")
+
+# Call Opus to review and refine the sub-task results
+refined_output = opus_refine(objective, [result for _, result in task_exchanges], timestamp, sanitized_objective)
+
+# Extract the project name from the refined output
+project_name_match = re.search(r'Project Name: (.*)', refined_output)
+project_name = project_name_match.group(1).strip() if project_name_match else sanitized_objective
+
+# Extract the folder structure from the refined output
+folder_structure_match = re.search(r'<folder_structure>(.*?)</folder_structure>', refined_output, re.DOTALL)
+folder_structure = {}
+if folder_structure_match:
+    json_string = folder_structure_match.group(1).strip()
+    try:
+        folder_structure = json.loads(json_string)
+    except json.JSONDecodeError as e:
+        console.print(Panel(f"Error parsing JSON: {e}", title="[bold red]JSON Parsing Error[/bold red]", title_align="left", border_style="red"))
+        console.print(Panel(f"Invalid JSON string: [bold]{json_string}[/bold]", title="[bold red]Invalid JSON String[/bold red]", title_align="left", border_style="red"))
+
+# Extract code files from the refined output
+code_blocks = re.findall(r'Filename: (\S+)\s*```[\w]*\n(.*?)\n```', refined_output, re.DOTALL)
+
+# Create the folder structure and code files
+create_folder_structure(project_name, folder_structure, code_blocks)
+
+# Truncate the sanitized_objective to a maximum of 50 characters
+max_length = 25
+truncated_objective = sanitized_objective[:max_length] if len(sanitized_objective) > max_length else sanitized_objective
+
+# Update the filename to include the project name
+filename = f"{timestamp}_{truncated_objective}.md"
+
+# Prepare the full exchange log
+exchange_log = f"Objective: {objective}\n\n"
+exchange_log += "=" * 40 + " Task Breakdown " + "=" * 40 + "\n\n"
+for i, (prompt, result) in enumerate(task_exchanges, start=1):
+    exchange_log += f"Task {i}:\n"
+    exchange_log += f"Prompt: {prompt}\n"
+    exchange_log += f"Result: {result}\n\n"
+
+exchange_log += "=" * 40 + " Refined Final Output " + "=" * 40 + "\n\n"
+exchange_log += refined_output
+
+console.print(f"\n[bold]Refined Final output:[/bold]\n{refined_output}")
+
+with open(filename, 'w') as file:
+    file.write(exchange_log)
+print(f"\nFull exchange log saved to {filename}")

maestro.py

@@ -0,0 +1,304 @@
+import os
+from anthropic import Anthropic
+import re
+from rich.console import Console
+from rich.panel import Panel
+from datetime import datetime
+import json
+from tavily import TavilyClient
+
+# Set up the Anthropic API client
+client = Anthropic(api_key="YOUR API KEY")
+
+# Available Claude models:
+# Claude 3 Opus	    claude-3-opus-20240229
+# Claude 3 Sonnet	claude-3-sonnet-20240229
+# Claude 3 Haiku	claude-3-haiku-20240307
+
+ORCHESTRATOR_MODEL = "claude-3-opus-20240229"
+SUB_AGENT_MODEL = "claude-3-sonnet-20240229"
+REFINER_MODEL = "claude-3-opus-20240229"
+
+def calculate_subagent_cost(model, input_tokens, output_tokens):
+    # Pricing information per model
+    pricing = {
+        "claude-3-opus-20240229": {"input_cost_per_mtok": 15.00, "output_cost_per_mtok": 75.00},
+        "claude-3-haiku-20240307": {"input_cost_per_mtok": 0.25, "output_cost_per_mtok": 1.25},
+        "claude-3-sonnet-20240229": {"input_cost_per_mtok": 3.00, "output_cost_per_mtok": 15.00},
+    }
+
+    # Calculate cost
+    input_cost = (input_tokens / 1_000_000) * pricing[model]["input_cost_per_mtok"]
+    output_cost = (output_tokens / 1_000_000) * pricing[model]["output_cost_per_mtok"]
+    total_cost = input_cost + output_cost
+
+    return total_cost
+
+# Initialize the Rich Console
+console = Console()
+
+def opus_orchestrator(objective, file_content=None, previous_results=None, use_search=False):
+    console.print(f"\n[bold]Calling Orchestrator for your objective[/bold]")
+    previous_results_text = "\n".join(previous_results) if previous_results else "None"
+    if file_content:
+        console.print(Panel(f"File content:\n{file_content}", title="[bold blue]File Content[/bold blue]", title_align="left", border_style="blue"))
+    
+    messages = [
+        {
+            "role": "user",
+            "content": [
+                {"type": "text", "text": f"Based on the following objective{' and file content' if file_content else ''}, and the previous sub-task results (if any), please break down the objective into the next sub-task, and create a concise and detailed prompt for a subagent so it can execute that task. IMPORTANT!!! when dealing with code tasks make sure you check the code for errors and provide fixes and support as part of the next sub-task. If you find any bugs or have suggestions for better code, please include them in the next sub-task prompt. Please assess if the objective has been fully achieved. If the previous sub-task results comprehensively address all aspects of the objective, include the phrase 'The task is complete:' at the beginning of your response. If the objective is not yet fully achieved, break it down into the next sub-task and create a concise and detailed prompt for a subagent to execute that task.:\n\nObjective: {objective}" + ('\\nFile content:\\n' + file_content if file_content else '') + f"\n\nPrevious sub-task results:\n{previous_results_text}"}
+            ]
+        }
+    ]
+    if use_search:
+        messages[0]["content"].append({"type": "text", "text": "Please also generate a JSON object containing a single 'search_query' key, which represents a question that, when asked online, would yield important information for solving the subtask. The question should be specific and targeted to elicit the most relevant and helpful resources. Format your JSON like this, with no additional text before or after:\n{\"search_query\": \"<question>\"}\n"})
+
+    opus_response = client.messages.create(
+        model=ORCHESTRATOR_MODEL,
+        max_tokens=4096,
+        messages=messages
+    )
+
+    response_text = opus_response.content[0].text
+    console.print(f"Input Tokens: {opus_response.usage.input_tokens}, Output Tokens: {opus_response.usage.output_tokens}")
+    total_cost = calculate_subagent_cost(ORCHESTRATOR_MODEL, opus_response.usage.input_tokens, opus_response.usage.output_tokens)
+    console.print(f"Orchestrator Cost: ${total_cost:.4f}")
+
+    search_query = None
+    if use_search:
+        # Extract the JSON from the response
+        json_match = re.search(r'{.*}', response_text, re.DOTALL)
+        if json_match:
+            json_string = json_match.group()
+            try:
+                search_query = json.loads(json_string)["search_query"]
+                console.print(Panel(f"Search Query: {search_query}", title="[bold blue]Search Query[/bold blue]", title_align="left", border_style="blue"))
+                response_text = response_text.replace(json_string, "").strip()
+            except json.JSONDecodeError as e:
+                console.print(Panel(f"Error parsing JSON: {e}", title="[bold red]JSON Parsing Error[/bold red]", title_align="left", border_style="red"))
+                console.print(Panel(f"Skipping search query extraction.", title="[bold yellow]Search Query Extraction Skipped[/bold yellow]", title_align="left", border_style="yellow"))
+        else:
+            search_query = None
+
+    console.print(Panel(response_text, title=f"[bold green]Opus Orchestrator[/bold green]", title_align="left", border_style="green", subtitle="Sending task to Haiku 👇"))
+    return response_text, file_content, search_query
+
+
+def haiku_sub_agent(prompt, search_query=None, previous_haiku_tasks=None, use_search=False, continuation=False):
+    if previous_haiku_tasks is None:
+        previous_haiku_tasks = []
+
+    continuation_prompt = "Continuing from the previous answer, please complete the response."
+    system_message = "Previous Haiku tasks:\n" + "\n".join(f"Task: {task['task']}\nResult: {task['result']}" for task in previous_haiku_tasks)
+    if continuation:
+        prompt = continuation_prompt
+
+    qna_response = None
+    if search_query and use_search:
+        # Initialize the Tavily client
+        tavily = TavilyClient(api_key="YOUR API KEY HERE")
+        # Perform a QnA search based on the search query
+        qna_response = tavily.qna_search(query=search_query)
+        console.print(f"QnA response: {qna_response}", style="yellow")
+
+    # Prepare the messages array with only the prompt initially
+    messages = [
+        {
+            "role": "user",
+            "content": [{"type": "text", "text": prompt}]
+        }
+    ]
+
+    # Add search results to the messages if there are any
+    if qna_response:
+        messages[0]["content"].append({"type": "text", "text": f"\nSearch Results:\n{qna_response}"})
+
+    haiku_response = client.messages.create(
+        model=SUB_AGENT_MODEL,
+        max_tokens=4096,
+        messages=messages,
+        system=system_message
+    )
+
+    response_text = haiku_response.content[0].text
+    console.print(f"Input Tokens: {haiku_response.usage.input_tokens}, Output Tokens: {haiku_response.usage.output_tokens}")
+    total_cost = calculate_subagent_cost(SUB_AGENT_MODEL, haiku_response.usage.input_tokens, haiku_response.usage.output_tokens)
+    console.print(f"Sub-agent Cost: ${total_cost:.4f}")
+
+    if haiku_response.usage.output_tokens >= 4000:  # Threshold set to 4000 as a precaution
+        console.print("[bold yellow]Warning:[/bold yellow] Output may be truncated. Attempting to continue the response.")
+        continuation_response_text = haiku_sub_agent(prompt, search_query, previous_haiku_tasks, use_search, continuation=True)
+        response_text += continuation_response_text
+
+    console.print(Panel(response_text, title="[bold blue]Haiku Sub-agent Result[/bold blue]", title_align="left", border_style="blue", subtitle="Task completed, sending result to Opus 👇"))
+    return response_text
+
+def opus_refine(objective, sub_task_results, filename, projectname, continuation=False):
+    print("\nCalling Opus to provide the refined final output for your objective:")
+    messages = [
+        {
+            "role": "user",
+            "content": [
+                {"type": "text", "text": "Objective: " + objective + "\n\nSub-task results:\n" + "\n".join(sub_task_results) + "\n\nPlease review and refine the sub-task results into a cohesive final output. Add any missing information or details as needed. When working on code projects, ONLY AND ONLY IF THE PROJECT IS CLEARLY A CODING ONE please provide the following:\n1. Project Name: Create a concise and appropriate project name that fits the project based on what it's creating. The project name should be no more than 20 characters long.\n2. Folder Structure: Provide the folder structure as a valid JSON object, where each key represents a folder or file, and nested keys represent subfolders. Use null values for files. Ensure the JSON is properly formatted without any syntax errors. Please make sure all keys are enclosed in double quotes, and ensure objects are correctly encapsulated with braces, separating items with commas as necessary.\nWrap the JSON object in <folder_structure> tags.\n3. Code Files: For each code file, include ONLY the file name NEVER EVER USE THE FILE PATH OR ANY OTHER FORMATTING YOU ONLY USE THE FOLLOWING format 'Filename: <filename>' followed by the code block enclosed in triple backticks, with the language identifier after the opening backticks, like this:\n\n​python\n<code>\n​"}
+            ]
+        }
+    ]
+
+    opus_response = client.messages.create(
+        model=REFINER_MODEL,
+        max_tokens=4096,
+        messages=messages
+    )
+
+    response_text = opus_response.content[0].text.strip()
+    console.print(f"Input Tokens: {opus_response.usage.input_tokens}, Output Tokens: {opus_response.usage.output_tokens}")
+    total_cost = calculate_subagent_cost(REFINER_MODEL, opus_response.usage.input_tokens, opus_response.usage.output_tokens)
+    console.print(f"Refine Cost: ${total_cost:.4f}")
+
+    if opus_response.usage.output_tokens >= 4000 and not continuation:  # Threshold set to 4000 as a precaution
+        console.print("[bold yellow]Warning:[/bold yellow] Output may be truncated. Attempting to continue the response.")
+        continuation_response_text = opus_refine(objective, sub_task_results + [response_text], filename, projectname, continuation=True)
+        response_text += "\n" + continuation_response_text
+
+    console.print(Panel(response_text, title="[bold green]Final Output[/bold green]", title_align="left", border_style="green"))
+    return response_text
+
+def create_folder_structure(project_name, folder_structure, code_blocks):
+    # Create the project folder
+    try:
+        os.makedirs(project_name, exist_ok=True)
+        console.print(Panel(f"Created project folder: [bold]{project_name}[/bold]", title="[bold green]Project Folder[/bold green]", title_align="left", border_style="green"))
+    except OSError as e:
+        console.print(Panel(f"Error creating project folder: [bold]{project_name}[/bold]\nError: {e}", title="[bold red]Project Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        return
+
+    # Recursively create the folder structure and files
+    create_folders_and_files(project_name, folder_structure, code_blocks)
+
+def create_folders_and_files(current_path, structure, code_blocks):
+    for key, value in structure.items():
+        path = os.path.join(current_path, key)
+        if isinstance(value, dict):
+            try:
+                os.makedirs(path, exist_ok=True)
+                console.print(Panel(f"Created folder: [bold]{path}[/bold]", title="[bold blue]Folder Creation[/bold blue]", title_align="left", border_style="blue"))
+                create_folders_and_files(path, value, code_blocks)
+            except OSError as e:
+                console.print(Panel(f"Error creating folder: [bold]{path}[/bold]\nError: {e}", title="[bold red]Folder Creation Error[/bold red]", title_align="left", border_style="red"))
+        else:
+            code_content = next((code for file, code in code_blocks if file == key), None)
+            if code_content:
+                try:
+                    with open(path, 'w') as file:
+                        file.write(code_content)
+                    console.print(Panel(f"Created file: [bold]{path}[/bold]", title="[bold green]File Creation[/bold green]", title_align="left", border_style="green"))
+                except IOError as e:
+                    console.print(Panel(f"Error creating file: [bold]{path}[/bold]\nError: {e}", title="[bold red]File Creation Error[/bold red]", title_align="left", border_style="red"))
+            else:
+                console.print(Panel(f"Code content not found for file: [bold]{key}[/bold]", title="[bold yellow]Missing Code Content[/bold yellow]", title_align="left", border_style="yellow"))
+
+def read_file(file_path):
+    with open(file_path, 'r') as file:
+        content = file.read()
+    return content
+
+# Get the objective from user input
+objective = input("Please enter your objective with or without a text file path: ")
+
+# Check if the input contains a file path
+if "./" in objective or "/" in objective:
+    # Extract the file path from the objective
+    file_path = re.findall(r'[./\w]+\.[\w]+', objective)[0]
+    # Read the file content
+    with open(file_path, 'r') as file:
+        file_content = file.read()
+    # Update the objective string to remove the file path
+    objective = objective.split(file_path)[0].strip()
+else:
+    file_content = None
+
+# Ask the user if they want to use search
+use_search = input("Do you want to use search? (y/n): ").lower() == 'y'
+
+task_exchanges = []
+haiku_tasks = []
+
+while True:
+    # Call Orchestrator to break down the objective into the next sub-task or provide the final output
+    previous_results = [result for _, result in task_exchanges]
+    if not task_exchanges:
+        # Pass the file content only in the first iteration if available
+        opus_result, file_content_for_haiku, search_query = opus_orchestrator(objective, file_content, previous_results, use_search)
+    else:
+        opus_result, _, search_query = opus_orchestrator(objective, previous_results=previous_results, use_search=use_search)
+
+    if "The task is complete:" in opus_result:
+        # If Opus indicates the task is complete, exit the loop
+        final_output = opus_result.replace("The task is complete:", "").strip()
+        break
+    else:
+        sub_task_prompt = opus_result
+        # Append file content to the prompt for the initial call to haiku_sub_agent, if applicable
+        if file_content_for_haiku and not haiku_tasks:
+            sub_task_prompt = f"{sub_task_prompt}\n\nFile content:\n{file_content_for_haiku}"
+        # Call haiku_sub_agent with the prepared prompt, search query, and record the result
+        sub_task_result = haiku_sub_agent(sub_task_prompt, search_query, haiku_tasks, use_search)
+        # Log the task and its result for future reference
+        haiku_tasks.append({"task": sub_task_prompt, "result": sub_task_result})
+        # Record the exchange for processing and output generation
+        task_exchanges.append((sub_task_prompt, sub_task_result))
+        # Prevent file content from being included in future haiku_sub_agent calls
+        file_content_for_haiku = None
+
+# Create the .md filename
+sanitized_objective = re.sub(r'\W+', '_', objective)
+timestamp = datetime.now().strftime("%H-%M-%S")
+
+# Call Opus to review and refine the sub-task results
+refined_output = opus_refine(objective, [result for _, result in task_exchanges], timestamp, sanitized_objective)
+
+# Extract the project name from the refined output
+project_name_match = re.search(r'Project Name: (.*)', refined_output)
+project_name = project_name_match.group(1).strip() if project_name_match else sanitized_objective
+
+# Extract the folder structure from the refined output
+folder_structure_match = re.search(r'<folder_structure>(.*?)</folder_structure>', refined_output, re.DOTALL)
+folder_structure = {}
+if folder_structure_match:
+    json_string = folder_structure_match.group(1).strip()
+    try:
+        folder_structure = json.loads(json_string)
+    except json.JSONDecodeError as e:
+        console.print(Panel(f"Error parsing JSON: {e}", title="[bold red]JSON Parsing Error[/bold red]", title_align="left", border_style="red"))
+        console.print(Panel(f"Invalid JSON string: [bold]{json_string}[/bold]", title="[bold red]Invalid JSON String[/bold red]", title_align="left", border_style="red"))
+
+# Extract code files from the refined output
+code_blocks = re.findall(r'Filename: (\S+)\s*```[\w]*\n(.*?)\n```', refined_output, re.DOTALL)
+
+# Create the folder structure and code files
+create_folder_structure(project_name, folder_structure, code_blocks)
+
+# Truncate the sanitized_objective to a maximum of 50 characters
+max_length = 25
+truncated_objective = sanitized_objective[:max_length] if len(sanitized_objective) > max_length else sanitized_objective
+
+# Update the filename to include the project name
+filename = f"{timestamp}_{truncated_objective}.md"
+
+# Prepare the full exchange log
+exchange_log = f"Objective: {objective}\n\n"
+exchange_log += "=" * 40 + " Task Breakdown " + "=" * 40 + "\n\n"
+for i, (prompt, result) in enumerate(task_exchanges, start=1):
+    exchange_log += f"Task {i}:\n"
+    exchange_log += f"Prompt: {prompt}\n"
+    exchange_log += f"Result: {result}\n\n"
+
+exchange_log += "=" * 40 + " Refined Final Output " + "=" * 40 + "\n\n"
+exchange_log += refined_output
+
+console.print(f"\n[bold]Refined Final output:[/bold]\n{refined_output}")
+
+with open(filename, 'w') as file:
+    file.write(exchange_log)
+print(f"\nFull exchange log saved to {filename}")

requirements.txt

@@ -0,0 +1,5 @@
+anthropic
+rich
+tavily-python
+ollama
+groq