diff options
| author | Nate Sesti <sestinj@gmail.com> | 2023-06-30 17:25:35 -0700 |
|---|---|---|
| committer | Nate Sesti <sestinj@gmail.com> | 2023-06-30 17:25:35 -0700 |
| commit | 81a5ed86119b81a07daf31144e8f09fe6b66246d (patch) | |
| tree | 7c1c66842a251069336591f0d67bac297de81534 /continuedev/src/continuedev/server | |
| parent | 965d7f2ac778b9f7f0bca0e26eb474bb69a0ece3 (diff) | |
| download | sncontinue-81a5ed86119b81a07daf31144e8f09fe6b66246d.tar.gz sncontinue-81a5ed86119b81a07daf31144e8f09fe6b66246d.tar.bz2 sncontinue-81a5ed86119b81a07daf31144e8f09fe6b66246d.zip | |
the fix. and others.
Diffstat (limited to 'continuedev/src/continuedev/server')
| -rw-r--r-- | continuedev/src/continuedev/server/ide.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/continuedev/src/continuedev/server/ide.py b/continuedev/src/continuedev/server/ide.py index 3c3555f1..e1f19447 100644 --- a/continuedev/src/continuedev/server/ide.py +++ b/continuedev/src/continuedev/server/ide.py @@ -110,7 +110,8 @@ class IdeProtocolServer(AbstractIdeProtocolServer): session_manager: SessionManager sub_queue: AsyncSubscriptionQueue = AsyncSubscriptionQueue() - def __init__(self, session_manager: SessionManager): + def __init__(self, session_manager: SessionManager, websocket: WebSocket): + self.websocket = websocket self.session_manager = session_manager async def _send_json(self, message_type: str, data: Any): @@ -354,8 +355,7 @@ async def websocket_endpoint(websocket: WebSocket): print("Accepted websocket connection from, ", websocket.client) await websocket.send_json({"messageType": "connected", "data": {}}) - ideProtocolServer = IdeProtocolServer(session_manager) - ideProtocolServer.websocket = websocket + ideProtocolServer = IdeProtocolServer(session_manager, websocket) while AppStatus.should_exit is False: message = await websocket.receive_text() |