Skip to content

Commit d7a64dc

Browse files
authored
cmd/devp2p: add node filter for snap + fix arg error (#21950)
1 parent 0b2f144 commit d7a64dc

File tree

1 file changed

+15
-4
lines changed

1 file changed

+15
-4
lines changed

cmd/devp2p/nodesetcmd.go

Lines changed: 15 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,7 @@ var filterFlags = map[string]nodeFilterC{
9595
"-min-age": {1, minAgeFilter},
9696
"-eth-network": {1, ethFilter},
9797
"-les-server": {0, lesFilter},
98+
"-snap": {0, snapFilter},
9899
}
99100

100101
func parseFilters(args []string) ([]nodeFilter, error) {
@@ -104,15 +105,15 @@ func parseFilters(args []string) ([]nodeFilter, error) {
104105
if !ok {
105106
return nil, fmt.Errorf("invalid filter %q", args[0])
106107
}
107-
if len(args) < fc.narg {
108-
return nil, fmt.Errorf("filter %q wants %d arguments, have %d", args[0], fc.narg, len(args))
108+
if len(args)-1 < fc.narg {
109+
return nil, fmt.Errorf("filter %q wants %d arguments, have %d", args[0], fc.narg, len(args)-1)
109110
}
110-
filter, err := fc.fn(args[1:])
111+
filter, err := fc.fn(args[1 : 1+fc.narg])
111112
if err != nil {
112113
return nil, fmt.Errorf("%s: %v", args[0], err)
113114
}
114115
filters = append(filters, filter)
115-
args = args[fc.narg+1:]
116+
args = args[1+fc.narg:]
116117
}
117118
return filters, nil
118119
}
@@ -191,3 +192,13 @@ func lesFilter(args []string) (nodeFilter, error) {
191192
}
192193
return f, nil
193194
}
195+
196+
func snapFilter(args []string) (nodeFilter, error) {
197+
f := func(n nodeJSON) bool {
198+
var snap struct {
199+
_ []rlp.RawValue `rlp:"tail"`
200+
}
201+
return n.N.Load(enr.WithEntry("snap", &snap)) == nil
202+
}
203+
return f, nil
204+
}

0 commit comments

Comments
 (0)