feat(node): per-file upload ceiling is an operator setting, default 8 GB

Was a 4 GB constant in webrtc_server.py, the same on a small board and on
a machine holding a library. Now max_upload_gb in node.toml, on the Node
page and via `meshbay-node transfers max-size`, read from the transport
context per chunk so a change reaches an upload already running.

MESHBAY_DESIGN.md §6.4; §15.3 records a defect found beside it.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

1 files changed, 22 insertions, 0 deletions

diff --git a/packages/meshbay-node/src/meshbay_node/ops.py b/packages/meshbay-node/src/meshbay_node/ops.py
index 2221bea..9f0e6d1 100644
--- a/packages/meshbay-node/src/meshbay_node/ops.py
+++ b/packages/meshbay-node/src/meshbay_node/ops.py
@@ -1301,6 +1301,7 @@ async def get_node_settings(state: dict) -> dict:
         "max_concurrent_streams": nd.max_concurrent_streams,
         "max_concurrent_downloads": nd.max_concurrent_downloads,
         "max_concurrent_uploads": nd.max_concurrent_uploads,
+        "max_upload_gb": nd.max_upload_gb,
         "transcode_incompatible_video": nd.transcode_incompatible_video,
         "stun_servers": nd.stun_servers if nd.stun_servers else list(DEFAULT_STUN_SERVERS),
         "ice_interfaces": nd.ice_interfaces,
@@ -1323,6 +1324,7 @@ async def set_node_settings(state: dict, settings: dict) -> dict:
         "max_concurrent_streams": ("int", roster.SETTING_MAX_STREAMS),
         "max_concurrent_downloads": ("int", roster.SETTING_MAX_DOWNLOADS),
         "max_concurrent_uploads": ("int", roster.SETTING_MAX_UPLOADS),
+        "max_upload_gb": ("size", roster.SETTING_MAX_UPLOAD_GB),
         "transcode_incompatible_video": ("bool", roster.SETTING_TRANSCODE),
         "stun_servers": ("stun_list", roster.SETTING_STUN_SERVERS),
         "ice_interfaces": ("list", roster.SETTING_ICE_INTERFACES),
@@ -1344,6 +1346,22 @@ async def set_node_settings(state: dict, settings: dict) -> dict:
             setattr(nd, key, v)
             await roster.set_node_setting(setting_key, str(v), set_by)
             updated[key] = v
+        elif kind == "size":
+            # A quantity, not a count: half a gigabyte is a legitimate ceiling
+            # on a small disk, so this one is not run through the `int` branch
+            # above, whose floor of 1 would round it to "refuse everything".
+            # bool before float, as config.py does it: `true` is not 1 GB.
+            if isinstance(value, bool):
+                raise OpError(f"{key} must be a number")
+            try:
+                fv = float(value)
+            except (TypeError, ValueError):
+                raise OpError(f"{key} must be a number")
+            if fv <= 0:
+                raise OpError(f"{key} must be greater than zero")
+            setattr(nd, key, fv)
+            await roster.set_node_setting(setting_key, repr(fv), set_by)
+            updated[key] = fv
         elif kind == "bool":
             v = bool(value)
             setattr(nd, key, v)
@@ -1382,6 +1400,10 @@ async def set_node_settings(state: dict, settings: dict) -> dict:
                         "max_concurrent_downloads"),
                     max_concurrent_uploads=updated.get(
                         "max_concurrent_uploads"))
+        if "max_upload_gb" in updated:
+            webrtc = state.get("webrtc")
+            if webrtc is not None:
+                webrtc.set_capacity(max_upload_gb=updated["max_upload_gb"])
         if "stun_servers" in updated:
             webrtc = state.get("webrtc")
             if webrtc and hasattr(webrtc, '_stun'):