mirror of
https://github.com/TecharoHQ/anubis.git
synced 2025-11-29 17:10:22 +08:00
00fa939acf* Implement FCrDNS and other DNS features * Redesign DNS cache and methods * Fix DNS cache * Rename regexSafe arg * Alter verifyFCrDNS(addr) behaviour * Remove unused dnsCache field from Server struct * Upd expressions docs * Update docs/docs/CHANGELOG.md Signed-off-by: Xe Iaso <me@xeiaso.net> * refactor(dns): simplify FCrDNS logging * docs: clarify verifyFCrDNS behavior Add a note to the documentation for `verifyFCrDNS` to clarify that it returns true when no PTR records are found for the given IP address. * fix(dns): Improve FCrDNS error handling and tests The `VerifyFCrDNS` function previously ignored errors returned from reverse DNS lookups. This could lead to incorrect passes when a DNS failure (other than a simple 'not found') occurred. This change ensures that any error from a reverse lookup will cause the FCrDNS check to fail. The test suite for FCrDNS has been updated to reflect this change. The mock DNS lookups now simulate both 'not found' errors and other generic DNS errors. The test cases have been updated to ensure that the function behaves correctly in both scenarios, resolving a situation where two test cases were effectively duplicates. * docs: Update FCrDNS documentation and spelling Corrected a typo in the `verifyFCrDNS` function documentation. Additionally, updated the spelling exception list to include new terms and remove redundant entries. * chore: update spelling Signed-off-by: Xe Iaso <me@xeiaso.net> --------- Signed-off-by: Xe Iaso <me@xeiaso.net> Co-authored-by: Xe Iaso <me@xeiaso.net>
70 lines
1.6 KiB
Go
70 lines
1.6 KiB
Go
package dns
|
|
|
|
import (
|
|
"log/slog"
|
|
"time"
|
|
|
|
"github.com/TecharoHQ/anubis/lib/store"
|
|
|
|
_ "github.com/TecharoHQ/anubis/lib/store/all"
|
|
)
|
|
|
|
type DnsCache struct {
|
|
forward store.JSON[[]string]
|
|
reverse store.JSON[[]string]
|
|
forwardTTL time.Duration
|
|
reverseTTL time.Duration
|
|
}
|
|
|
|
func NewDNSCache(forwardTTL int, reverseTTL int, backend store.Interface) *DnsCache {
|
|
return &DnsCache{
|
|
forward: store.JSON[[]string]{
|
|
Underlying: backend,
|
|
Prefix: "forwardDNS",
|
|
},
|
|
reverse: store.JSON[[]string]{
|
|
Underlying: backend,
|
|
Prefix: "reverseDNS",
|
|
},
|
|
forwardTTL: time.Duration(forwardTTL) * time.Second,
|
|
reverseTTL: time.Duration(reverseTTL) * time.Second,
|
|
}
|
|
}
|
|
|
|
func (d *Dns) getCachedForward(host string) ([]string, bool) {
|
|
if d.cache == nil {
|
|
return nil, false
|
|
}
|
|
if cached, err := d.cache.forward.Get(d.ctx, host); err == nil {
|
|
slog.Debug("DNS: forward cache hit", "name", host, "ips", cached)
|
|
return cached, true
|
|
}
|
|
slog.Debug("DNS: forward cache miss", "name", host)
|
|
return nil, false
|
|
}
|
|
|
|
func (d *Dns) getCachedReverse(addr string) ([]string, bool) {
|
|
if d.cache == nil {
|
|
return nil, false
|
|
}
|
|
if cached, err := d.cache.reverse.Get(d.ctx, addr); err == nil {
|
|
slog.Debug("DNS: reverse cache hit", "addr", addr, "names", cached)
|
|
return cached, true
|
|
}
|
|
slog.Debug("DNS: reverse cache miss", "addr", addr)
|
|
return nil, false
|
|
}
|
|
|
|
func (d *Dns) forwardCachePut(host string, entries []string) {
|
|
if d.cache == nil {
|
|
return
|
|
}
|
|
d.cache.forward.Set(d.ctx, host, entries, d.cache.forwardTTL)
|
|
}
|
|
|
|
func (d *Dns) reverseCachePut(addr string, entries []string) {
|
|
if d.cache == nil {
|
|
return
|
|
}
|
|
d.cache.reverse.Set(d.ctx, addr, entries, d.cache.reverseTTL)
|
|
}
|