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

Handlers in place for start and end file transfer

Browse Source
This commit is contained in:
Darren Burns
2024-08-06 14:13:34 +01:00
parent d8e20ce21f
commit 6a4e4a7dd8
1 changed files with 21 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/textual_serve/app_service.py
View File

@@ -232,12 +232,13 @@ class AppService:
sys.stdout.write(error_text.decode("utf-8", "replace"))
readexactly = stdout.readexactly
int_from_bytes = int.from_bytes
while True:
type_bytes = await stdout.readexactly(1)
size_bytes = await stdout.readexactly(4)
size = int.from_bytes(size_bytes, "big")
payload = await stdout.readexactly(size)
type_bytes = await readexactly(1)
size_bytes = await readexactly(4)
size = int_from_bytes(size_bytes, "big")
payload = await readexactly(size)
if type_bytes == DATA:
await self.on_data(payload)
elif type_bytes == META:
@@ -291,6 +292,12 @@ class AppService:
]
)
await self.remote_write_str(payload)
elif meta_type == "deliver_file_start":
# Let's start the file transfer process
pass
elif meta_type == "deliver_file_end":
# End the file transfer process
pass
else:
log.warning(
f"Unknown meta type: {meta_type!r}. You may need to update `textual-serve`."
@@ -302,3 +309,12 @@ class AppService:
Args:
payload: Encoded packed data.
"""
"""
{
"type": "deliver_file_start",
"key": key,
"path": str(path.resolve()),
"open_method": open_method,
}
"""