Merge pull request #32 from blinklabs-io/chore/update-snek

chore: update blinklabs-io/snek to v0.9.1

Author: agaffney

go.mod

@@ -4,7 +4,7 @@ go 1.19
 
 require (
 	github.com/blinklabs-io/gouroboros v0.53.0
-	github.com/blinklabs-io/snek v0.5.0
+	github.com/blinklabs-io/snek v0.9.1
 	github.com/dgraph-io/badger/v4 v4.2.0
 	github.com/kelseyhightower/envconfig v1.4.0
 	github.com/miekg/dns v1.1.55

go.sum

@@ -3,8 +3,8 @@ github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03
 github.com/benbjohnson/clock v1.3.0 h1:ip6w0uFQkncKQ979AypyG0ER7mqUSBdKLOgAle/AT8A=
 github.com/blinklabs-io/gouroboros v0.53.0 h1:JRq7FJ2HP5Fv+RBREzHAskT74u3Es8Sra9ynW08sumo=
 github.com/blinklabs-io/gouroboros v0.53.0/go.mod h1:2wCCNNsHNYMT4gQB+bXS0Y99Oeu8+EM96hi7hW22C2w=
-github.com/blinklabs-io/snek v0.5.0 h1://vQo5dp3aRUHrBaywyBZRDgS+Skh3ZgNusMhBNgwo0=
-github.com/blinklabs-io/snek v0.5.0/go.mod h1:MScjJA0cu7pbqkfsIbK5i2ucF+4pgk7ybqFdiRlzIsU=
+github.com/blinklabs-io/snek v0.9.1 h1:PEREmUJVHKRJhq5vlF1AxGr1MJnBu20AN69VO34FuHY=
+github.com/blinklabs-io/snek v0.9.1/go.mod h1:+/Jw9UwgKP7eEWmmDRX1I/HjgsIOGY9ECwhLatH2Z1I=
 github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
 github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=

internal/indexer/indexer.go

@@ -102,12 +102,12 @@ func (i *Indexer) Start() error {
 	// Configure pipeline filters
 	// We only care about transaction events
 	filterEvent := filter_event.New(
-		filter_event.WithType("chainsync.transaction"),
+		filter_event.WithTypes([]string{"chainsync.transaction"}),
 	)
 	i.pipeline.AddFilter(filterEvent)
 	// We only care about transactions on a certain address
 	filterChainsync := filter_chainsync.New(
-		filter_chainsync.WithAddress(cfg.Indexer.ScriptAddress),
+		filter_chainsync.WithAddresses([]string{cfg.Indexer.ScriptAddress}),
 	)
 	i.pipeline.AddFilter(filterChainsync)
 	// Configure pipeline output