alihan/textual-web
1
0
Fork 0
mirror of https://github.com/Textualize/textual-web.git synced 2025-10-17 02:36:40 +03:00
Code Issues Packages Projects Releases Wiki Activity

Moving stuff

Browse Source
This commit is contained in:
Darren Burns
2024-08-13 15:02:15 +01:00
parent 0e6158f33c
commit 77cdf62db7
1 changed files with 18 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/textual_web/ganglion_client.py
View File

@@ -419,24 +419,6 @@ class GanglionClient(Handlers):
"""An info message (higher priority log) sent by the server.""" """An info message (higher priority log) sent by the server."""
log.info(f"<ganglion> {packet.message}") log.info(f"<ganglion> {packet.message}")
async def on_request_deliver_chunk(
self, packet: packets.RequestDeliverChunk
) -> None:
"""The Ganglion server requested a chunk of a file. Forward that to the running app session.
When the meta is sent to the Textual app, it will be handled inside the WebDriver.
"""
route_key = RouteKey(packet.route_key)
session_process = self.session_manager.get_session_by_route_key(route_key)
if session_process is not None:
await session_process.send_meta(
{
"type": "deliver_chunk_request",
"key": packet.delivery_key,
"size": packet.chunk_size,
}
)
async def on_session_open(self, packet: packets.SessionOpen) -> None: async def on_session_open(self, packet: packets.SessionOpen) -> None:
route_key = packet.route_key route_key = packet.route_key
session_process = await self.session_manager.new_session( session_process = await self.session_manager.new_session(
@@ -492,3 +474,21 @@ class GanglionClient(Handlers):
) )
if session_process is not None: if session_process is not None:
await session_process.send_meta({"type": "blur"}) await session_process.send_meta({"type": "blur"})
async def on_request_deliver_chunk(
self, packet: packets.RequestDeliverChunk
) -> None:
"""The Ganglion server requested a chunk of a file. Forward that to the running app session.
When the meta is sent to the Textual app, it will be handled inside the WebDriver.
"""
route_key = RouteKey(packet.route_key)
session_process = self.session_manager.get_session_by_route_key(route_key)
if session_process is not None:
await session_process.send_meta(
{
"type": "deliver_chunk_request",
"key": packet.delivery_key,
"size": packet.chunk_size,
}
)