logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-01-14 03:18:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

better exception handling in node

Browse Source
This commit is contained in:
Marcin Czenko 2025-03-29 11:12:59 +01:00
parent b0be205765
commit edf4627dbd
No known key found for this signature in database
GPG Key ID: 33DEA0C8E30937C0
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
codex/node.nim
View File

@ -88,8 +88,6 @@ type
BatchProc* = proc(blocks: seq[bt.Block]): Future[?!void] {.
gcsafe, async: (raises: [CancelledError])
.}
PieceProc* =
proc(blocks: seq[bt.Block], pieceIndex: int): ?!void {.gcsafe, raises: [].}
func switch*(self: CodexNodeRef): Switch =
return self.switch
@ -167,12 +165,11 @@ proc fetchManifest*(
proc fetchTorrentManifest*(
self: CodexNodeRef, infoHashCid: Cid
): Future[?!BitTorrentManifest] {.async.} =
): Future[?!BitTorrentManifest] {.async: (raises: [CancelledError]).} =
if err =? infoHashCid.isTorrentInfoHash.errorOption:
return failure "CID has invalid content type for torrent info hash {$cid}"
trace "Retrieving torrent manifest for infoHashCid", infoHashCid
without blk =? await self.networkStore.getBlock(BlockAddress.init(infoHashCid)), err:
trace "Error retrieve manifest block", infoHashCid, err = err.msg
return failure err
@ -248,7 +245,7 @@ proc fetchBatched*(
# )
while not iter.finished:
let blockFutures = collect:
let blockFutures: seq[Future[?!bt.Block].Raising([CancelledError])] = collect:
for i in 0 ..< batchSize:
if not iter.finished:
let address = BlockAddress.init(cid, iter.next())
@ -406,7 +403,7 @@ proc getTorrentDownloader*(
proc retrieveTorrent*(
self: CodexNodeRef, infoHash: MultiHash
): Future[?!Torrent] {.async.} =
): Future[?!Torrent] {.async: (raises: [CancelledError]).} =
without infoHashCid =? Cid.init(CIDv1, InfoHashV1Codec, infoHash).mapFailure, error:
trace "Unable to create CID for BitTorrent info hash"
return failure(error)