* dnsforward: use new dnsfilter interface
This commit is contained in:
parent
5ec747b30b
commit
096a959987
@ -202,14 +202,20 @@ func (s *Server) startInternal(config *ServerConfig) error {
|
|||||||
// Initializes the DNS filter
|
// Initializes the DNS filter
|
||||||
func (s *Server) initDNSFilter() error {
|
func (s *Server) initDNSFilter() error {
|
||||||
log.Tracef("Creating dnsfilter")
|
log.Tracef("Creating dnsfilter")
|
||||||
s.dnsFilter = dnsfilter.New(&s.conf.Config)
|
|
||||||
// add rules only if they are enabled
|
var filters map[int]string
|
||||||
|
filters = nil
|
||||||
if s.conf.FilteringEnabled {
|
if s.conf.FilteringEnabled {
|
||||||
err := s.dnsFilter.AddRules(s.conf.Filters)
|
filters = make(map[int]string)
|
||||||
if err != nil {
|
for _, f := range s.conf.Filters {
|
||||||
return errorx.Decorate(err, "could not initialize dnsfilter")
|
filters[int(f.ID)] = string(f.Data)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
s.dnsFilter = dnsfilter.New(&s.conf.Config, filters)
|
||||||
|
if s.dnsFilter == nil {
|
||||||
|
return fmt.Errorf("could not initialize dnsfilter")
|
||||||
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user