Fix: provider filter potential panic
This commit is contained in:
parent
1401a82bb0
commit
b1bed7623d
2 changed files with 7 additions and 3 deletions
|
@ -60,5 +60,5 @@ func ParseProxyProvider(name string, mapping map[string]interface{}) (types.Prox
|
|||
|
||||
interval := time.Duration(uint(schema.Interval)) * time.Second
|
||||
filter := schema.Filter
|
||||
return NewProxySetProvider(name, interval, filter, vehicle, hc), nil
|
||||
return NewProxySetProvider(name, interval, filter, vehicle, hc)
|
||||
}
|
||||
|
|
|
@ -96,7 +96,11 @@ func stopProxyProvider(pd *ProxySetProvider) {
|
|||
pd.fetcher.Destroy()
|
||||
}
|
||||
|
||||
func NewProxySetProvider(name string, interval time.Duration, filter string, vehicle types.Vehicle, hc *HealthCheck) *ProxySetProvider {
|
||||
func NewProxySetProvider(name string, interval time.Duration, filter string, vehicle types.Vehicle, hc *HealthCheck) (*ProxySetProvider, error) {
|
||||
if _, err := regexp.Compile(filter); err != nil {
|
||||
return nil, fmt.Errorf("invalid filter regex: %w", err)
|
||||
}
|
||||
|
||||
if hc.auto() {
|
||||
go hc.process()
|
||||
}
|
||||
|
@ -150,7 +154,7 @@ func NewProxySetProvider(name string, interval time.Duration, filter string, veh
|
|||
|
||||
wrapper := &ProxySetProvider{pd}
|
||||
runtime.SetFinalizer(wrapper, stopProxyProvider)
|
||||
return wrapper
|
||||
return wrapper, nil
|
||||
}
|
||||
|
||||
// for auto gc
|
||||
|
|
Loading…
Reference in a new issue