ISSUES FIXED: #4

@@ -0,0 +2,4 @@
+
+A powerful, reactive Agent Framework using RxPy streams for complex AI agent orchestration and message routing.
+
+[![PyPI Package](https://img.shields.io/pypi/v/cleveragents.svg)](https://pypi.org/project/cleveragents/)

@@ -0,0 +3,4 @@
+A powerful, reactive Agent Framework using RxPy streams for complex AI agent orchestration and message routing.
+
+[![PyPI Package](https://img.shields.io/pypi/v/cleveragents.svg)](https://pypi.org/project/cleveragents/)
+[![Travis-CI Build Status](https://img.shields.io/travis/cleverthis/cleveragents.svg)](https://travis-ci.org/cleverthis/cleveragents)

@@ -0,0 +29,4 @@
+### Install from PyPI
+
+```bash
+pip install cleveragents

@@ -0,0 +210,4 @@
+      provider: openai
+      model: gpt-4
+      api_key: "sk-your-key-here"
+```

@@ -0,0 +273,4 @@
+
+```bash
+# Run all tests
+python -m behave tests/features

@@ -0,0 +276,4 @@
+python -m behave tests/features
+
+# Run with coverage
+python -m pytest --cov=cleveragents

@@ -0,0 +279,4 @@
+python -m pytest --cov=cleveragents
+
+# Run with tox for multiple environments
+tox

@@ -0,0 +41,4 @@
+  - sources: [source_streams]
+    target: target_stream
+
+splits:

@@ -0,0 +61,4 @@
+  global:
+    variable_name: value
+```
+

@@ -0,0 +104,4 @@
+      safe_mode: true
+      timeout: 30
+```
+

@@ -0,0 +130,4 @@
+        input: sub_agent1
+        output: sub_stream1
+```
+

@@ -0,0 +145,4 @@
+    operators:
+      - type: map
+        params:
+          agent: agent_name

@@ -0,0 +177,4 @@
+- `replay`: Replay all previous values
+
+**Operators:**
+- `map`: Transform messages using agents or functions

@@ -0,0 +220,4 @@
+    parallel_execution: true
+    state_class: "my_module.MyState"
+```
+

@@ -0,0 +253,4 @@
+      preserve_subscriptions: true
+      preserve_checkpointing: true
+```
+

@@ -0,0 +1,190 @@
+agents:

@@ -0,0 +1,274 @@
+# Multi-Agent Paper Writer - Multiple Specialized Agents Working Together

@@ -294,7 +294,14 @@ class ReactiveCleverAgentsApp:
 
             # Set up observers for output and errors
             def on_output(msg: StreamMessage):

@@ -298,0 +300,4 @@
+                    print(f"\n[DEBUG] Empty output received\n")
+                else:
+                    # Check for tool execution commands
+                    processed_content = self._process_tool_commands(content_str)

@@ -338,3 +345,3 @@
 
                     # Give streams time to process
-                    await asyncio.sleep(0.1)
+                    await asyncio.sleep(2.0)

@@ -668,6 +664,151 @@ class ReactiveCleverAgentsApp:
             self.langgraph_bridge.create_hybrid_pipeline(config_dict)
             self.logger.debug(f"Created hybrid pipeline: {pipeline_name}")
 
+    def _sanitize_json_string(self, json_str: str) -> str:

@@ -671,0 +677,4 @@
+        Returns:
+            Sanitized JSON string with control characters properly escaped
+        """
+        import re

@@ -671,0 +678,4 @@
+            Sanitized JSON string with control characters properly escaped
+        """
+        import re
+        import json

@@ -671,0 +679,4 @@
+        """
+        import re
+        import json
+        

@@ -671,0 +686,4 @@
+            return json_str  # Already valid, no sanitization needed
+        except json.JSONDecodeError:
+            pass  # Need to sanitize
+        

@@ -671,0 +689,4 @@
+        
+        # Strategy: Find all quoted string values and escape control characters within them
+        # We need to be careful to only escape content inside string values, not the JSON structure
+        

@@ -671,0 +690,4 @@
+        # Strategy: Find all quoted string values and escape control characters within them
+        # We need to be careful to only escape content inside string values, not the JSON structure
+        
+        def escape_string_content(match):

@@ -671,0 +695,4 @@
+            # match.group(0) is the full match including quotes
+            # match.group(1) is the content inside the quotes
+            content = match.group(1)
+            

@@ -671,0 +705,4 @@
+            content = content.replace('\b', '\\b')
+            content = content.replace('\f', '\\f')
+            content = content.replace('"', '\\"')  # Escape quotes
+            

@@ -671,0 +712,4 @@
+        # Pattern to match quoted strings (both keys and values)
+        # This matches: "anything including newlines and special chars"
+        # We use a negative lookbehind to avoid matching escaped quotes
+        pattern = r'"((?:[^"\\]|\\.)*)"|"([^"]*(?:\n[^"]*)*)"'

@@ -671,0 +721,4 @@
+        
+        return sanitized
+    
+    def _process_tool_commands(self, content: str) -> str:

@@ -671,0 +727,4 @@
+        
+        Detects [TOOL_EXECUTE:tool_name] commands and executes actual tools.
+        """
+        import re

@@ -671,0 +728,4 @@
+        Detects [TOOL_EXECUTE:tool_name] commands and executes actual tools.
+        """
+        import re
+        import json

@@ -671,0 +729,4 @@
+        """
+        import re
+        import json
+        import asyncio

@@ -671,0 +734,4 @@
+        # Pattern to match tool execution commands
+        pattern = r'\[TOOL_EXECUTE:(\w+)\]\s*(\{[^}]+\})\s*\[/TOOL_EXECUTE\]'
+        
+        def execute_tool_sync(tool_name, tool_params):

@@ -671,0 +755,4 @@
+                
+                # Try to get the current running loop
+                try:
+                    loop = asyncio.get_running_loop()

@@ -671,0 +757,4 @@
+                try:
+                    loop = asyncio.get_running_loop()
+                    # We're already in an async context, create a task
+                    import concurrent.futures

@@ -671,0 +767,4 @@
+                    # No running loop, we can use asyncio.run
+                    result = asyncio.run(file_manager.process_message(tool_request, context))
+                
+                return f"\n✅ {result}"

@@ -671,0 +769,4 @@
+                
+                return f"\n✅ {result}"
+                
+            except Exception as e:

@@ -671,0 +770,4 @@
+                return f"\n✅ {result}"
+                
+            except Exception as e:
+                self.logger.error(f"Tool execution failed: {e}")

@@ -671,0 +790,4 @@
+                # Sanitize JSON string before parsing to handle LLM-generated malformed JSON
+                sanitized_params_str = self._sanitize_json_string(tool_params_str)
+                tool_params = json.loads(sanitized_params_str)
+                tool_result = execute_tool_sync(tool_name, tool_params)

@@ -671,0 +799,4 @@
+                    result_content[match.end():]
+                )
+            except json.JSONDecodeError as e:
+                self.logger.error(f"Failed to parse tool params: {e}")

@@ -671,0 +800,4 @@
+                )
+            except json.JSONDecodeError as e:
+                self.logger.error(f"Failed to parse tool params: {e}")
+                error_msg = f"\n❌ Error: Invalid tool parameters format"