From 7a5bc802a1d56930b8ed517884012522fbcde358 Mon Sep 17 00:00:00 2001 From: Dmitriy Ryajov Date: Fri, 27 Aug 2021 13:48:23 -0600 Subject: [PATCH] rename dataset to blockset --- dagger/dataset.nim | 62 ---------------------------------------------- 1 file changed, 62 deletions(-) delete mode 100644 dagger/dataset.nim diff --git a/dagger/dataset.nim b/dagger/dataset.nim deleted file mode 100644 index 48a23c03..00000000 --- a/dagger/dataset.nim +++ /dev/null @@ -1,62 +0,0 @@ -## Nim-Dagger -## Copyright (c) 2021 Status Research & Development GmbH -## Licensed under either of -## * Apache License, version 2.0, ([LICENSE-APACHE](LICENSE-APACHE)) -## * MIT license ([LICENSE-MIT](LICENSE-MIT)) -## at your option. -## This file may not be copied, modified, or distributed except according to -## those terms. - -{.push raises: [Defect].} - -import std/sequtils - -import pkg/libp2p -import pkg/stew/byteutils -import pkg/questionable -import pkg/questionable/results - -import ./blockstream - -type - BlockSetRef* = ref object of BlockStreamRef - stream*: BlockStreamRef - -proc hashBytes*(mh: MultiHash): seq[byte] = - mh.data.buffer[mh.dpos..(mh.dpos + mh.size - 1)] - -proc hashBytes*(b: Block): seq[byte] = - if mh =? b.cid.mhash: - mh.hashBytes() - -method nextBlock*(d: BlockSetRef): ?!Block = - d.stream.nextBlock() - -proc treeHash*(d: BlockSetRef): ?!MultiHash = - var - stack: seq[seq[byte]] - codec: MultiCodec = InvalidMultiCodec - - while true: - let (blk1, blk2) = (d.nextBlock().option, d.nextBlock().option) - if blk1.isNone and blk2.isNone and stack.len == 1: - let res = MultiHash.init($codec, stack[0]) - if mh =? res: - return success mh - - return failure($res.error) - - if blk1.isSome: stack.add((!blk1).hashBytes()) - if blk2.isSome: stack.add((!blk2).hashBytes()) - - codec = if codec == InvalidMultiCodec: (!blk1).cid.mcodec else: codec - while (stack.len mod 2) == 0: - let (b1, b2) = (stack.pop(), stack.pop()) - let res = MultiHash.init($codec, b1 & b2) - if mh =? res: - stack.add(mh.hashBytes()) - else: - return failure($res.error) - -proc new*(T: type BlockSetRef, blockStream: BlockStreamref) = - discard