Add support for using an alternative hash function with raw nodes.

License: MIT
Signed-off-by: Kevin Atkinson <k@kevina.org>

importer/helpers/dagbuilder.go

@@ -165,10 +165,21 @@ func (db *DagBuilderHelper) GetNextDataNode() (*UnixfsNode, error) {
 	}
 
 	if db.rawLeaves {
-		return &UnixfsNode{
-			rawnode: dag.NewRawNode(data),
-			raw:     true,
-		}, nil
+		if db.prefix == nil {
+			return &UnixfsNode{
+				rawnode: dag.NewRawNode(data),
+				raw:     true,
+			}, nil
+		} else {
+			rawnode, err := dag.NewRawNodeWPrefix(data, *db.prefix)
+			if err != nil {
+				return nil, err
+			}
+			return &UnixfsNode{
+				rawnode: rawnode,
+				raw:     true,
+			}, nil
+		}
 	} else {
 		blk := db.NewUnixfsBlock()
 		blk.SetData(data)

merkledag/merkledag.go

@@ -116,7 +116,7 @@ func decodeBlock(b blocks.Block) (node.Node, error) {
 		decnd.Prefix = b.Cid().Prefix()
 		return decnd, nil
 	case cid.Raw:
-		return NewRawNode(b.RawData()), nil
+		return NewRawNodeWPrefix(b.RawData(), b.Cid().Prefix())
 	case cid.DagCBOR:
 		return ipldcbor.Decode(b.RawData())
 	default:

merkledag/raw.go

@@ -20,6 +20,22 @@ func NewRawNode(data []byte) *RawNode {
 	return &RawNode{blk}
 }
 
+func NewRawNodeWPrefix(data []byte, prefix cid.Prefix) (*RawNode, error) {
+	prefix.Codec = cid.Raw
+	if prefix.Version == 0 {
+		prefix.Version = 1
+	}
+	c, err := prefix.Sum(data)
+	if err != nil {
+		return nil, err
+	}
+	blk, err := blocks.NewBlockWithCid(data, c)
+	if err != nil {
+		return nil, err
+	}
+	return &RawNode{blk}, nil
+}
+
 func (rn *RawNode) Links() []*node.Link {
 	return nil
 }