Strip is_server from Session __init__

Author: blast-hardcheese

src/replit_river/client_transport.py

@@ -225,7 +225,6 @@ async def _create_new_session(
             session_id=hs_request.sessionId,
             websocket=new_ws,
             transport_options=self._transport_options,
-            is_server=False,
             close_session_callback=self._delete_session,
             retry_connection_callback=self._retry_connection,
         )

src/replit_river/server_session.py

@@ -49,7 +49,6 @@ def __init__(
         session_id: str,
         websocket: websockets.WebSocketCommonProtocol,
         transport_options: TransportOptions,
-        is_server: bool,
         handlers: dict[tuple[str, str], tuple[str, GenericRpcHandlerBuilder]],
         close_session_callback: Callable[["Session"], Coroutine[Any, Any, Any]],
         retry_connection_callback: (
@@ -66,10 +65,10 @@ def __init__(
             session_id=session_id,
             websocket=websocket,
             transport_options=transport_options,
-            is_server=is_server,
             close_session_callback=close_session_callback,
             retry_connection_callback=retry_connection_callback,
         )
+        self._is_server = True
         self._handlers = handlers
 
     async def start_serve_responses(self) -> None:

src/replit_river/server_transport.py

@@ -133,7 +133,6 @@ async def _get_or_create_session(
                     session_id,
                     websocket,
                     self._transport_options,
-                    True,
                     self._handlers,
                     close_session_callback=self._delete_session,
                 )
@@ -154,7 +153,6 @@ async def _get_or_create_session(
                         session_id,
                         websocket,
                         self._transport_options,
-                        True,
                         self._handlers,
                         close_session_callback=self._delete_session,
                     )

src/replit_river/session.py

@@ -37,6 +37,7 @@
 
 class Session:
     """Common functionality shared between client_session and server_session"""
+    _is_server: bool
 
     def __init__(
         self,
@@ -45,7 +46,6 @@ def __init__(
         session_id: str,
         websocket: websockets.WebSocketCommonProtocol,
         transport_options: TransportOptions,
-        is_server: bool,
         close_session_callback: Callable[["Session"], Coroutine[Any, Any, Any]],
         retry_connection_callback: (
             Callable[
@@ -58,7 +58,7 @@ def __init__(
         self._transport_id = transport_id
         self._to_id = to_id
         self.session_id = session_id
-        self._is_server = is_server
+        self._is_server = False
         self._transport_options = transport_options
 
         # session state, only modified during closing