mirror of
https://github.com/StackExchange/dnscontrol.git
synced 2024-09-20 23:06:23 +08:00
82 lines
2.5 KiB
Go
82 lines
2.5 KiB
Go
package normalize
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/pkg/errors"
|
|
|
|
"github.com/StackExchange/dnscontrol/models"
|
|
"github.com/StackExchange/dnscontrol/pkg/spflib"
|
|
)
|
|
|
|
// hasSpfRecords returns true if this record requests SPF unrolling.
|
|
func flattenSPFs(cfg *models.DNSConfig) []error {
|
|
var cache spflib.CachingResolver
|
|
var errs []error
|
|
var err error
|
|
for _, domain := range cfg.Domains {
|
|
apexTXTs := domain.Records.Grouped()[models.RecordKey{Type: "TXT", NameFQDN: domain.Name}]
|
|
// flatten all spf records that have the "flatten" metadata
|
|
for _, txt := range apexTXTs {
|
|
var rec *spflib.SPFRecord
|
|
if txt.Metadata["flatten"] != "" || txt.Metadata["split"] != "" {
|
|
if cache == nil {
|
|
cache, err = spflib.NewCache("spfcache.json")
|
|
if err != nil {
|
|
return []error{err}
|
|
}
|
|
}
|
|
rec, err = spflib.Parse(txt.GetTargetField(), cache)
|
|
if err != nil {
|
|
errs = append(errs, err)
|
|
continue
|
|
}
|
|
}
|
|
if flatten, ok := txt.Metadata["flatten"]; ok && strings.HasPrefix(txt.GetTargetField(), "v=spf1") {
|
|
rec = rec.Flatten(flatten)
|
|
err = txt.SetTargetTXT(rec.TXT())
|
|
if err != nil {
|
|
errs = append(errs, err)
|
|
continue
|
|
}
|
|
}
|
|
// now split if needed
|
|
if split, ok := txt.Metadata["split"]; ok {
|
|
if !strings.Contains(split, "%d") {
|
|
errs = append(errs, Warning{errors.Errorf("Split format `%s` in `%s` is not proper format (should have %%d in it)", split, txt.GetLabelFQDN())})
|
|
continue
|
|
}
|
|
recs := rec.TXTSplit(split + "." + domain.Name)
|
|
for k, v := range recs {
|
|
if k == "@" {
|
|
txt.SetTargetTXT(v)
|
|
} else {
|
|
cp, _ := txt.Copy()
|
|
cp.SetTargetTXT(v)
|
|
cp.SetLabelFromFQDN(k, domain.Name)
|
|
domain.Records = append(domain.Records, cp)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if cache == nil {
|
|
return errs
|
|
}
|
|
// check if cache is stale
|
|
for _, e := range cache.ResolveErrors() {
|
|
errs = append(errs, Warning{errors.Errorf("problem resolving SPF record: %s", e)})
|
|
}
|
|
if len(cache.ResolveErrors()) == 0 {
|
|
changed := cache.ChangedRecords()
|
|
if len(changed) > 0 {
|
|
if err := cache.Save("spfcache.updated.json"); err != nil {
|
|
errs = append(errs, err)
|
|
} else {
|
|
errs = append(errs, Warning{errors.Errorf("%d spf record lookups are out of date with cache (%s).\nWrote changes to spfcache.updated.json. Please rename and commit:\n $ mv spfcache.updated.json spfcache.json\n $ git commit -m'Update spfcache.json' spfcache.json", len(changed), strings.Join(changed, ","))})
|
|
}
|
|
}
|
|
}
|
|
return errs
|
|
}
|