1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
// dynamic domain no-name system service
//
// a simple dynamic dns record updating utility which fetches your
// ip address from a source, and lets a provider know of the fresh
// address.
package main
import (
"flag"
"fmt"
"log/slog"
"os"
"git.rnrd.eu/ddnnss/provider"
"git.rnrd.eu/ddnnss/source"
)
const version = "1.0.0"
func main() {
configPath := flag.String("config", "/etc/ddnnss.json", "config file")
showVersion := flag.Bool("version", false, "print the version and exit")
flag.Parse()
if *showVersion {
fmt.Println("ddnnss", version)
return
}
slog.Info("ddnnss!", slog.String("version", version))
cfg, err := LoadConfig(*configPath)
if err != nil {
slog.Error("could not load config", slog.String("error", err.Error()))
os.Exit(1)
}
providers := map[string]provider.Provider{}
sources := map[string]source.Source{}
slog.Info("starting new cycle", slog.Int("records", len(cfg.Records)))
failed := false
for _, r := range cfg.Records {
fqdn := r.Name + "." + r.Zone
log := slog.With("record", fqdn, "type", r.Type)
log.Info(
"ensuring record",
slog.String("provider", r.Provider),
slog.String("source", r.Source),
)
p, ok := providers[r.Provider]
if !ok {
p, err = provider.New(log, cfg.Providers[r.Provider])
if err != nil {
log.Error("provider setup failed", "provider", r.Provider, "error", err)
failed = true
continue
}
providers[r.Provider] = p
}
s, ok := sources[r.Source]
if !ok {
s, err = source.New(log, cfg.Sources[r.Source])
if err != nil {
log.Error("source setup failed", "source", r.Source, "error", err)
failed = true
continue
}
sources[r.Source] = s
}
family := source.IPv4
if r.Type == provider.TypeAAAA {
family = source.IPv6
}
if !s.Supports(family) {
log.Error("source cannot provide the needed address family",
"source", r.Source, "family", family)
failed = true
continue
}
addr, err := s.Lookup(family)
if err != nil {
log.Error("address lookup failed", "source", r.Source, "error", err)
failed = true
continue
}
prev, changed, err := p.Ensure(r.Zone, r.Name, r.Type, addr)
switch {
case err != nil:
log.Error("update failed", "error", err)
failed = true
case changed && prev == "":
log.Info("record created", "addr", addr)
case changed:
log.Info("record updated", "from", prev, "to", addr)
default:
log.Info("record unchanged", "addr", addr)
}
}
slog.Info(
"cycle finished",
slog.Int("records", len(cfg.Records)),
slog.Bool("failed", failed),
)
if failed {
slog.Error("not all records were ensured successfully")
os.Exit(1)
}
}
|
