fix(hub): increase StreamReader limit and add volumes/expandvars support

fuzzforge-common/src/fuzzforge_common/hub/client.py

@@ -243,7 +243,7 @@ class HubClient:
 
         # Add volumes
         for volume in config.volumes:
-            cmd.extend(["-v", os.path.expanduser(volume)])
+            cmd.extend(["-v", os.path.expandvars(os.path.expanduser(volume))])
 
         # Add environment variables
         for key, value in config.environment.items():
@@ -256,6 +256,7 @@ class HubClient:
             stdin=subprocess.PIPE,
             stdout=subprocess.PIPE,
             stderr=subprocess.PIPE,
+            limit=4 * 1024 * 1024,  # 4 MB — default 64 KB breaks large YARA/capa results
         )
 
         try:
@@ -300,6 +301,7 @@ class HubClient:
             stdout=subprocess.PIPE,
             stderr=subprocess.PIPE,
             env=env,
+            limit=4 * 1024 * 1024,  # 4 MB — default 64 KB breaks large tool results
         )
 
         try:

fuzzforge-mcp/src/fuzzforge_mcp/tools/hub.py

@@ -237,6 +237,7 @@ async def add_hub_server(
     description: str | None = None,
     capabilities: list[str] | None = None,
     environment: dict[str, str] | None = None,
+    volumes: list[str] | None = None,
 ) -> dict[str, Any]:
     """Add a new MCP server to the hub.
 
@@ -252,6 +253,7 @@ async def add_hub_server(
     :param description: Human-readable description.
     :param capabilities: Docker capabilities to add (e.g., ["NET_RAW"]).
     :param environment: Environment variables to pass.
+    :param volumes: Docker volume mounts (e.g., ["~/.fuzzforge/hub/workspace:/data"]).
     :return: Information about the added server.
 
     Examples:
@@ -290,6 +292,7 @@ async def add_hub_server(
             description=description,
             capabilities=capabilities or [],
             environment=environment or {},
+            volumes=volumes or [],
         )
 
         server = executor.add_server(config)