feat(live-runner): keep metered sessions funded (single-shot, streams, reserved sessions)

src/livepeer_gateway/__init__.py

@@ -61,7 +61,7 @@
 )
 from .discovery import discover_orchestrators, discover_runners
 from .orch_info import get_orch_info
-from .remote_signer import LivePaymentSession, PaymentSession
+from .remote_signer import LivePaymentChallenge, LivePaymentSession, PaymentSession
 from .scope import start_scope
 from .selection import (
     RunnerSelectionCursor,
@@ -107,6 +107,7 @@
     "LiveRunnerSession",
     "LiveRunnerSessionCallback",
     "LiveRunnerSessionEvent",
+    "LivePaymentChallenge",
     "LivePaymentSession",
     "LiveRunnerProxy",
     "LivepeerGatewayError",

src/livepeer_gateway/http.py

@@ -305,9 +305,9 @@ async def _request_body(
 async def request_json(
     url: str,
     *,
-    method: Optional[str] = None,
-    payload: Optional[dict[str, Any]] = None,
-    headers: Optional[dict[str, str]] = None,
+    method: str | None = None,
+    payload: dict[str, Any] | None = None,
+    headers: dict[str, str] | None = None,
     timeout: float = 5.0,
 ) -> Any:
     """
@@ -403,6 +403,21 @@ async def get_json(
     return await request_json(url, headers=headers, timeout=timeout)
 
 
+async def _post_empty(
+    url: str,
+    *,
+    headers: dict[str, str] | None = None,
+    timeout: float = 5.0,
+) -> None:
+    """POST an empty body to ``url`` and discard the response."""
+    await _request_body(
+        url,
+        method="POST",
+        headers=headers,
+        timeout=timeout,
+    )
+
+
 def _parse_http_url(url: str, *, context: str = "URL") -> ParseResult:
     """
     Normalize a URL for HTTP(S) endpoints.