Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ require (
github.com/caddyserver/certmagic v0.21.6
github.com/coreos/go-semver v0.3.0
github.com/ethereum/go-ethereum v1.17.3
github.com/ethersphere/batch-archive v0.0.9
github.com/ethersphere/batch-archive v0.1.0
github.com/ethersphere/go-price-oracle-abi v0.6.9
github.com/ethersphere/go-storage-incentives-abi v0.9.4
github.com/ethersphere/go-sw3-abi v0.6.9
Expand Down
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -246,8 +246,8 @@ github.com/ethereum/go-bigmodexpfix v0.0.0-20250911101455-f9e208c548ab/go.mod h1
github.com/ethereum/go-ethereum v1.10.4/go.mod h1:nEE0TP5MtxGzOMd7egIrbPJMQBnhVU3ELNxhBglIzhg=
github.com/ethereum/go-ethereum v1.17.3 h1:Ev/sQHH+UdKZHWjuVzhu2pxhi/sXaPZl23Q+Q5LDd4Q=
github.com/ethereum/go-ethereum v1.17.3/go.mod h1:f2EhRwqewIZkGoQekywI2Y2RZAMTSavLNkD9qItFy1A=
github.com/ethersphere/batch-archive v0.0.9 h1:lhVbwHmbngJgwXq3gtRCpxkICghPqSrDVy0WIiR6QGM=
github.com/ethersphere/batch-archive v0.0.9/go.mod h1:41BPb192NoK9CYjNB8BAE1J2MtiI/5aq0Wtas5O7A7Q=
github.com/ethersphere/batch-archive v0.1.0 h1:zxGK6i1FHg5kEq11NcEjR6Ykw0UxWaAPR9tlpdTQ+xI=
github.com/ethersphere/batch-archive v0.1.0/go.mod h1:41BPb192NoK9CYjNB8BAE1J2MtiI/5aq0Wtas5O7A7Q=
github.com/ethersphere/go-price-oracle-abi v0.6.9 h1:bseen6he3PZv5GHOm+KD6s4awaFmVSD9LFx+HpB6rCU=
github.com/ethersphere/go-price-oracle-abi v0.6.9/go.mod h1:sI/Qj4/zJ23/b1enzwMMv0/hLTpPNVNacEwCWjo6yBk=
github.com/ethersphere/go-storage-incentives-abi v0.9.4 h1:mSIWXQXg5OQmH10QvXMV5w0vbSibFMaRlBL37gPLTM0=
Expand Down
10 changes: 10 additions & 0 deletions pkg/postage/snapshot/snapshot.go
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,16 @@ func (f *SnapshotLogFilterer) loadSnapshot() error {
return nil
}

// parseLogs decodes the snapshot NDJSON into types.Log entries.
//
// The snapshot is produced by ethersphere/batch-export, whose default slim
// encoding carries only the types.Log fields Bee reads today: address, topics,
// data, blockNumber, transactionHash (and logIndex). Any other field —
// BlockHash, TxIndex, Removed — decodes to its zero value here with no error.
// Before consuming a new types.Log field anywhere downstream of this filterer
// (FilterLogs callers, listener.processEvent, transaction.ParseEvent), extend
// SlimLog in batch-export's pkg/filestore and republish the snapshot first;
// otherwise the field is silently empty for snapshot-sourced logs.
func (f *SnapshotLogFilterer) parseLogs(reader io.Reader) error {
var parsedLogs []types.Log
var currentMaxBlockHeight uint64
Expand Down
Loading