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

set default value of the encryption parameter in "store" proc to nil (default: no encryption)

Browse Source
This commit is contained in:
Marcin Czenko 2025-07-04 19:28:50 +02:00
parent 1fb3f83f45
commit d039ab69b3
No known key found for this signature in database
GPG Key ID: 33DEA0C8E30937C0
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
codex/node.nim
View File

@ -404,7 +404,7 @@ proc store*(
filename: ?string = string.none, filename: ?string = string.none,
mimetype: ?string = string.none, mimetype: ?string = string.none,
blockSize = DefaultBlockSize, blockSize = DefaultBlockSize,
encryption: CodexEncryption, encryption: CodexEncryption = nil,
): Future[?!Cid] {.async.} = ): Future[?!Cid] {.async.} =
## Save stream contents as dataset with given blockSize ## Save stream contents as dataset with given blockSize
## to nodes's BlockStore, and return Cid of its manifest ## to nodes's BlockStore, and return Cid of its manifest
@ -422,15 +422,21 @@ proc store*(
try: try:
while (let chunk = await chunker.getBytes(); chunk.len > 0): while (let chunk = await chunker.getBytes(); chunk.len > 0):
let encryptedChunk = encryption.encryptBlock(chunk, blockIndex) echo "chunk[", blockIndex, "]: ", byteutils.toHex(chunk)
let blockData =
if isNil(encryption):
chunk
else:
encryption.encryptBlock(chunk, blockIndex).get()
echo "blockData[", blockIndex, "]: ", byteutils.toHex(blockData)
blockIndex.inc() blockIndex.inc()
without mhash =? MultiHash.digest($hcodec, encryptedChunk).mapFailure, err: without mhash =? MultiHash.digest($hcodec, blockData).mapFailure, err:
return failure(err) return failure(err)
without cid =? Cid.init(CIDv1, dataCodec, mhash).mapFailure, err: without cid =? Cid.init(CIDv1, dataCodec, mhash).mapFailure, err:
return failure(err) return failure(err)
without blk =? bt.Block.new(cid, encryptedChunk, verify = false): without blk =? bt.Block.new(cid, blockData, verify = false):
return failure("Unable to init block from chunk!") return failure("Unable to init block from chunk!")
cids.add(cid) cids.add(cid)