logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-01-02 21:43:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix error messages and do not return error when the download session is already cancelled

Browse Source
This commit is contained in:
Arnaud 2025-10-21 05:53:49 +02:00
parent 425e221774
commit 68967d1e5e
No known key found for this signature in database
GPG Key ID: B8FBC178F10CA7AE
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
library/codex_thread_requests/requests/node_download_request.nim
View File

@ -221,16 +221,16 @@ proc stream(
let cid = Cid.init($cCid)
if cid.isErr:
return err("Failed to download locally: cannot parse cid: " & $cCid)
return err("Failed to stream: cannot parse cid: " & $cCid)
if not downloadSessions.contains($cid):
return err("Failed to download stream: no session for cid " & $cid)
return err("Failed to stream: no session for cid " & $cid)
var session: DownloadSession
try:
session = downloadSessions[$cid]
except KeyError:
return err("Failed to download stream: no session for cid " & $cid)
return err("Failed to stream: no session for cid " & $cid)
let node = codex[].node
@ -241,9 +241,9 @@ proc stream(
except LPStreamError as e:
return err("Failed to stream file: " & $e.msg)
except IOError as e:
return err("Failed to write to file: " & $e.msg)
return err("Failed to stream file: " & $e.msg)
except CancelledError:
return err("Failed to download locally: download cancelled.")
return err("Failed to stream file: download cancelled.")
finally:
if session.stream != nil:
await session.stream.close()
@ -260,16 +260,18 @@ proc cancel(
let cid = Cid.init($cCid)
if cid.isErr:
return err("Failed to download locally: cannot parse cid: " & $cCid)
return err("Failed to cancel : cannot parse cid: " & $cCid)
if not downloadSessions.contains($cid):
return err("Failed to download chunk: no session for cid " & $cid)
# The session is already cancelled
return ok("")
var session: DownloadSession
try:
session = downloadSessions[$cid]
except KeyError:
return err("Failed to download chunk: no session for cid " & $cid)
# The session is already cancelled
return ok("")
let stream = session.stream
await stream.close()