mirror of
https://github.com/StackExchange/dnscontrol.git
synced 2024-09-20 23:06:23 +08:00
825ba2d081
* Replaced errors.Wrap with fmt.Errorf (#589) * Find: errors\.Wrap\(([^,]+),\s+(["`][^"`]*)(["`])\) Replace: fmt.Errorf($2: %w$3, $1) * Replaced errors.Wrapf with fmt.Errorf (#589) * Find: errors\.Wrapf\(([^,]+),\s+(["`][^"`]*)(["`])\) Replace: fmt.Errorf($2: %w$3, $1) * Find: errors\.Wrapf\(([^,]+),\s+(["`][^"`]*)(["`])(,[^)]+)\) * Replace: fmt.Errorf($2: %w$3$4, $1) * Replaced errors.Errorf with fmt.Errorf (#589) * Find: errors\.Errorf Replace: fmt.Errorf * Cleaned up remaining imports * Cleanup * Regenerate provider support matrix This was broken by #533 ... and it's now the third time this has been missed.
81 lines
2.4 KiB
Go
81 lines
2.4 KiB
Go
package normalize
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/StackExchange/dnscontrol/v2/models"
|
|
"github.com/StackExchange/dnscontrol/v2/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.GroupedByKey()[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{fmt.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{fmt.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{fmt.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
|
|
}
|