fix dbin header

streamingfast · Oct 3, 2023 · 9ad49bc · 9ad49bc
1 parent 626bab9
commit 9ad49bc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/accountresolver/bundlerreader.go b/accountresolver/bundlerreader.go
@@ -56,7 +56,7 @@ func (r *BundleReader) PushBlock(block *bstream.Block) error {
 	}
 
 	if !r.headerWritten {
-		header := data[:bstream.GetBlockWriterHeaderLen]
+		header := []byte{'d', 'b', 'i', 'n', byte(0), 's', 'o', 'l', 0, 1}
 		r.blockData <- header
 		r.headerWritten = true
 	}
@@ -113,7 +113,7 @@ func (r *BundleReader) fillBuffer() error {
 		return fmt.Errorf("one-block-file corrupt: expected header size of %d, but file size is only %d bytes", bstream.GetBlockWriterHeaderLen, len(data))
 	}
 
-	data = data[:bstream.GetBlockWriterHeaderLen]
+	data = data[bstream.GetBlockWriterHeaderLen:]
 	r.readBuffer = data
 	r.readBufferOffset = 0
 	return nil