Skip to content

Commit 0dfb2f5

Browse files
Renaming PENDING to NO_CONNECTION to match TS
1 parent 2da6ea7 commit 0dfb2f5

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

src/replit_river/common_session.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,21 +34,21 @@ class SessionState(enum.Enum):
3434
"""The state a session can be in.
3535
3636
Valid transitions:
37-
- PENDING -> {CONNECTING}
38-
- CONNECTING -> {PENDING, ACTIVE, CLOSING}
39-
- ACTIVE -> {PENDING, CONNECTING, CLOSING}
37+
- NO_CONNECTION -> {CONNECTING, CLOSING}
38+
- CONNECTING -> {NO_CONNECTION, ACTIVE, CLOSING}
39+
- ACTIVE -> {NO_CONNECTION, CONNECTING, CLOSING}
4040
- CLOSING -> {CLOSED}
4141
- CLOSED -> {}
4242
"""
4343

44-
PENDING = 0
44+
NO_CONNECTION = 0
4545
CONNECTING = 1
4646
ACTIVE = 2
4747
CLOSING = 3
4848
CLOSED = 4
4949

5050

51-
ConnectingStates = set([SessionState.PENDING, SessionState.CONNECTING])
51+
ConnectingStates = set([SessionState.NO_CONNECTION, SessionState.CONNECTING])
5252
TerminalStates = set([SessionState.CLOSING, SessionState.CLOSED])
5353

5454

src/replit_river/v2/session.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ def __init__(
145145
self._transport_options = transport_options
146146

147147
# session state
148-
self._state = SessionState.PENDING
148+
self._state = SessionState.NO_CONNECTION
149149
self._close_session_callback = close_session_callback
150150
self._close_session_after_time_secs: float | None = None
151151
self._connecting_task = None
@@ -298,7 +298,7 @@ async def _begin_close_session_countdown(self) -> None:
298298
self._transport_id,
299299
self._to_id,
300300
)
301-
self._state = SessionState.PENDING
301+
self._state = SessionState.NO_CONNECTION
302302
self._close_session_after_time_secs = close_session_after_time_secs
303303

304304
async def _get_current_time(self) -> float:
@@ -513,7 +513,7 @@ async def transition_connecting() -> None:
513513
self._state = SessionState.CONNECTING
514514

515515
async def connection_interrupted() -> None:
516-
self._state = SessionState.PENDING
516+
self._state = SessionState.NO_CONNECTION
517517
if self._ws:
518518
self._task_manager.create_task(self._ws.close())
519519
self._ws = None

0 commit comments

Comments
 (0)