+ {/* WebMCP Status Indicator */}
+
+
+ {isOpen && (
+
+ WebMCP
+
+ {isMcpActive ? 'Protocol Active' : 'Native API Missing'}
+
+
+ )}
+
+
{/* Settings Button - Only shown to Admin */}
{isLoggedIn && user?.role === "admin" && (
{
+ const [isMcpActive, setIsMcpActive] = useState(false);
+
+ useEffect(() => {
+ // Check if WebMCP is supported/active
+ if (mcpService.isActive()) {
+ setIsMcpActive(true);
+ console.log('[MCP] WebMCP Provider initialized and active.');
+ }
+ }, []);
+
+ const value = {
+ isMcpActive,
+ registerTool: (tool) => mcpService.registerTool(tool),
+ unregisterTool: (toolName) => mcpService.unregisterTool(toolName)
+ };
+
+ return (
+
+ {children}
+
+ );
+};
+
+export const useWebMcp = () => {
+ const context = useContext(WebMcpContext);
+ if (!context) {
+ throw new Error('useWebMcp must be used within a WebMcpProvider');
+ }
+ return context;
+};
diff --git a/reinstall_windows_agent.ps1 b/reinstall_windows_agent.ps1
new file mode 100644
index 0000000..cccf305
--- /dev/null
+++ b/reinstall_windows_agent.ps1
@@ -0,0 +1,12 @@
+$taskName = "CortexAgent"
+$pythonPath = "C:\CortexAgent\venv\Scripts\python.exe"
+$mainPath = "C:\CortexAgent\src\agent_node\main.py"
+$logPath = "C:\CortexAgent\agent.log"
+
+$action = New-ScheduledTaskAction -Execute "cmd.exe" -Argument "/c `"$pythonPath $mainPath >> $logPath 2>&1`""
+$principal = New-ScheduledTaskPrincipal -UserId "SYSTEM" -LogonType ServiceAccount -RunLevel Highest
+$settings = New-ScheduledTaskSettingsSet -AllowStartIfOnBatteries -DontStopIfGoingOnBatteries -StartWhenAvailable
+
+Unregister-ScheduledTask -TaskName $taskName -Confirm:$false -ErrorAction SilentlyContinue
+Register-ScheduledTask -TaskName $taskName -Action $action -Principal $principal -Settings $settings
+Start-ScheduledTask -TaskName $taskName
diff --git a/start_agent.bat b/start_agent.bat
new file mode 100644
index 0000000..692f498
--- /dev/null
+++ b/start_agent.bat
@@ -0,0 +1,4 @@
+@echo off
+cd C:\CortexAgent
+set PYTHONPATH=src
+venv\Scripts\python.exe -u src\agent_node\main.py
diff --git a/test_terminal.py b/test_terminal.py
new file mode 100644
index 0000000..1e14258
--- /dev/null
+++ b/test_terminal.py
@@ -0,0 +1,47 @@
+import asyncio
+import websockets
+import json
+import uuid
+
+async def test_terminal():
+ user_id = "37471c66-9da0-42a5-8b00-8b2f5bb46baa"
+ node_id = "media-windows-server"
+ uri = f"wss://ai.jerxie.com/api/v1/nodes/stream/all?user_id={user_id}"
+
+ async with websockets.connect(uri) as websocket:
+ print("Connected to Hub WebSocket")
+
+ # 1. Wait for initial snapshot
+ msg = await websocket.recv()
+ print(f"Recv: {msg[:100]}...")
+
+ # 2. Start a terminal session (implicitly by sending a character if session doesn't exist)
+ session_id = str(uuid.uuid4())
+ print(f"Using Session ID: {session_id}")
+
+ # 3. Send a command
+ cmd_msg = {
+ "action": "dispatch",
+ "node_id": node_id,
+ "session_id": session_id,
+ "command": "hostname"
+ }
+ await websocket.send(json.dumps(cmd_msg))
+ print("Sent hostname command")
+
+ # 4. Wait for output
+ while True:
+ try:
+ msg = await asyncio.wait_for(websocket.recv(), timeout=10.0)
+ data = json.loads(msg)
+ print(f"Event: {data.get('event')} | Data: {str(data.get('data'))[:100]}")
+ if data.get("event") in ("task_complete", "skill_event"):
+ if "hostname" in str(data.get("data")):
+ print("SUCCESS: Received hostname in output!")
+ return True
+ except asyncio.TimeoutError:
+ print("FAILED: Timeout waiting for output")
+ return False
+
+if __name__ == "__main__":
+ asyncio.run(test_terminal())