sendnrw/fritzbox_dyndns
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: sendnrw:master
Branches Tags
sendnrw:main sendnrw:master
..
compare: sendnrw:2d95e92f93264b61ce5c8aa2138f4e5c0e2d9129
Branches Tags
sendnrw:main sendnrw:master

8 Commits
master ... 2d95e92f93

Author SHA1 Message Date
groot
2d95e92f93 Dockerfile aktualisiert
All checks were successful
release-tag / release-image (push) Successful in 44s
Details
2025-01-13 20:52:18 +00:00
groot
353a525b0c Dockerfile aktualisiert
All checks were successful
release-tag / release-image (push) Successful in 44s
Details
2025-01-13 20:50:04 +00:00
groot
21ec339b2d main.go aktualisiert
All checks were successful
release-tag / release-image (push) Successful in 1m30s
Details
2025-01-13 20:44:41 +00:00
groot
81fff6b9ac Dockerfile aktualisiert
All checks were successful
release-tag / release-image (push) Successful in 44s
Details
2025-01-13 20:40:47 +00:00
groot
f60e808281 Dockerfile aktualisiert
All checks were successful
release-tag / release-image (push) Successful in 42s
Details
2025-01-13 20:21:49 +00:00
groot
2e42bf6e20 Merge pull request 'added dyndns dns function' (#2) from master into main
Some checks failed
release-tag / release-image (push) Failing after 29s
Details 
Reviewed-on: #2
 2025-01-13 20:19:17 +00:00
groot
2359ff4bd2 Dockerfile aktualisiert
All checks were successful
release-tag / release-image (push) Successful in 1m29s
Details
2025-01-12 18:49:27 +00:00
groot
b8f8c3d0ce Merge pull request 'master' (#1) from master into main
Some checks failed
release-tag / release-image (push) Failing after 59s
Details 
Reviewed-on: #1
 2025-01-12 18:46:52 +00:00
3 changed files with 40 additions and 140 deletions
Expand all files Collapse all files

2
Dockerfile
View File

@@ -1,4 +1,6 @@
FROM golang:1.23.3
RUN mkdir /data
COPY data/* /data
WORKDIR /app
COPY go.mod go.sum ./
RUN go mod download

11
data/data.json
View File

@@ -1,10 +1 @@
{
"friedhof8.hilden.de.": {
"dns": "friedhof8.hilden.de",
"ipv4": "1.1.1.2",
"ipv6": "2001::5b:41",
"user": "friedhof",
"token": "ef797c8118f02dfb649607dd5d3f8c7623048c9c063d532cc95c5ed7a898a64f",
"lastseen": "2025-01-14 06:53:45.7690632 +0100 CET m=+27.298316601"
}
}
{}

167
main.go
View File

@@ -6,7 +6,6 @@ import (
"encoding/json"
"fmt"
"log"
"net"
"net/http"
"os"
"os/signal"
@@ -21,8 +20,6 @@ type DB map[string]dns_entry
var D map[string]dns_entry
var DEBUG bool = false
type dns_entry struct {
Dns string `json:"dns"`
Ipv4 string `json:"ipv4"`
@@ -37,14 +34,14 @@ func writeToFile(filename string, data DB) error {
// JSON konvertieren
jsonData, err := json.MarshalIndent(data, "", " ")
if err != nil {
fmt.Println("!", "Fehler beim Serialisieren: ", err)
fmt.Println("Fehler beim Serialisieren: ", err)
return err
}
// Datei öffnen/erstellen
err = os.WriteFile(filename, jsonData, 0644)
if err != nil {
fmt.Println("!", "Fehler beim Schreiben der Datei: ", err)
fmt.Println("Fehler beim Schreiben der Datei: ", err)
return err
}
@@ -56,7 +53,7 @@ func readFromFile(filename string) (DB, error) {
// Datei lesen
jsonData, err := os.ReadFile(filename)
if err != nil {
fmt.Println("!", "Fehler beim Lesen der Datei: ", err)
fmt.Println("Fehler beim Lesen der Datei: ", err)
return nil, err
}
@@ -64,7 +61,7 @@ func readFromFile(filename string) (DB, error) {
var data DB
err = json.Unmarshal(jsonData, &data)
if err != nil {
fmt.Println("!", "Fehler beim Parsen von JSON: ", err)
fmt.Println("Fehler beim Parsen von JSON: ", err)
return nil, err
}
@@ -82,41 +79,6 @@ func VerifyToken(token, storedHash string) bool {
return HashToken(token) == storedHash
}
func reverseString(s string) string {
// Konvertiere den String in eine Rune-Slice, um Unicode-Zeichen zu unterstützen
runes := []rune(s)
n := len(runes)
// Tausche die Elemente, um den String umzudrehen
for i := 0; i < n/2; i++ {
runes[i], runes[n-1-i] = runes[n-1-i], runes[i]
}
// Konvertiere die Rune-Slice zurück in einen String
return string(runes)
}
func IPv6ToPTR(ipv6 string) (string, error) {
// Parse the IPv6 address to validate it
parsedIP := net.ParseIP(ipv6)
if parsedIP == nil || parsedIP.To16() == nil || parsedIP.To4() != nil {
return "", fmt.Errorf("invalid IPv6 address: %s", ipv6)
}
// Expand the IPv6 address to its full form
expanded := parsedIP.To16()
// Convert to a reversed nibble format for PTR
var nibbles []string
for i := len(expanded) - 1; i >= 0; i-- {
hexByte := fmt.Sprintf("%02x", expanded[i])
// Add the nibbles in reverse order
nibbles = append(nibbles, string(hexByte[1]), string(hexByte[0]))
}
// Join the nibbles with dots and append the reverse domain
reversed := strings.Join(nibbles, ".")
return reversed + ".ip6.arpa.", nil
}
func handler(w http.ResponseWriter, r *http.Request) {
Dns := r.URL.Query().Get("DDNS")
Ip := r.URL.Query().Get("IP")
@@ -130,7 +92,7 @@ func handler(w http.ResponseWriter, r *http.Request) {
if strings.EqualFold(Dns, "") || strings.EqualFold(Ip, "") || strings.EqualFold(User, "") || strings.EqualFold(Token, "") {
/* strings.ToLower(Dns) != strings.ToLower("") && strings.ToLower(Ip) != strings.ToLower("") && strings.ToLower(User) != strings.ToLower("") && strings.ToLower(Token) != strings.ToLower("")*/
fmt.Println("!", "Eintrag unvollständig: ", D[Dns])
fmt.Println("Eintrag unvollständig: ", D[Dns])
w.WriteHeader(200)
w.Write([]byte("nochg"))
@@ -139,33 +101,33 @@ func handler(w http.ResponseWriter, r *http.Request) {
if entry, exists := D[Dns+"."]; exists {
if User == entry.User && VerifyToken(Token, entry.Token) {
D[Dns+"."] = dns_entry{Dns: Dns, Ipv4: Ip, Ipv6: Ip6, User: User, Token: entry.Token, LastSeen: time.Now().String()}
fmt.Println("~", "Eintrag aktualisiert: ", entry, D[Dns+"."])
fmt.Println("Eintrag aktualisiert: ", entry, D[Dns+"."])
// Datei speichern
filename := "data/data.json"
filename := "/data/data.json"
err := writeToFile(filename, D)
if err != nil {
fmt.Println("!", "Fehler beim Schreiben:", err)
fmt.Println("Fehler beim Schreiben:", err)
return
}
fmt.Println("~", "Daten erfolgreich in Datei geschrieben.")
fmt.Println("Daten erfolgreich in Datei geschrieben.")
w.WriteHeader(200)
w.Write([]byte("good"))
} else {
fmt.Println("!", "Eintrag aktualisieren abgelehnt (Benutzer/Passwort ungültig): ", entry, D[Dns])
fmt.Println("Eintrag aktualisieren abgelehnt (Benutzer/Passwort ungültig): ", entry, D[Dns])
w.WriteHeader(200)
w.Write([]byte("nochg"))
}
} else {
D[Dns+"."] = dns_entry{Dns: Dns, Ipv4: Ip, Ipv6: Ip6, User: User, Token: HashToken(Token), LastSeen: time.Now().String()}
fmt.Println("~", "Eintrag erstellt: ", entry, D[Dns+"."])
fmt.Println("Eintrag erstellt: ", entry, D[Dns+"."])
// Datei speichern
filename := "data/data.json"
filename := "/data/data.json"
err := writeToFile(filename, D)
if err != nil {
fmt.Println("!", "Fehler beim Schreiben:", err)
fmt.Println("Fehler beim Schreiben:", err)
return
}
fmt.Println("~", "Daten erfolgreich in Datei geschrieben.")
fmt.Println("Daten erfolgreich in Datei geschrieben.")
w.WriteHeader(200)
w.Write([]byte("good"))
}
@@ -174,15 +136,7 @@ func handler(w http.ResponseWriter, r *http.Request) {
}
func handlerIP(w http.ResponseWriter, r *http.Request) {
remoteIP := r.Header.Get("X-Forwarded-For")
if remoteIP == "" {
remoteIP = r.RemoteAddr // Fallback, wenn kein Header gesetzt ist
}
if DEBUG {
fmt.Println("~", "Remote-IP:", remoteIP)
}
w.WriteHeader(200)
w.Write([]byte(remoteIP))
}
func handleDNSRequest(w dns.ResponseWriter, r *dns.Msg) {
@@ -199,14 +153,10 @@ func handleDNSRequest(w dns.ResponseWriter, r *dns.Msg) {
if exists {
rr, err := dns.NewRR(q.Name + " A " + ip.Ipv4)
if err == nil {
if DEBUG {
fmt.Println("~", "handleDNSRequest", "case dns.TypeA", "D[q.Name]", D[q.Name], "q.Name", q.Name)
}
fmt.Println("Antwort (IPv4):", rr, q.Name)
msg.Answer = append(msg.Answer, rr)
} else {
if DEBUG {
fmt.Println("!", "handleDNSRequest", "case dns.TypeA", "IPv4", "error", err)
}
fmt.Println("Fehler beim Erstellen der Antwort (4):", err)
}
}
case dns.TypeAAAA: // IPv6-Anfrage
@@ -215,53 +165,14 @@ func handleDNSRequest(w dns.ResponseWriter, r *dns.Msg) {
if exists && !strings.EqualFold(ip.Ipv6, "") {
rr, err := dns.NewRR(q.Name + " AAAA " + ip.Ipv6)
if err == nil {
if DEBUG {
fmt.Println("~", "handleDNSRequest", "case dns.TypeAAAA", "D[q.Name]", D[q.Name], "q.Name", q.Name)
}
fmt.Println("Antwort (IPv6):", rr, q.Name)
msg.Answer = append(msg.Answer, rr)
} else {
if DEBUG {
fmt.Println("!", "handleDNSRequest", "case dns.TypeAAAA", "IPv6", "error", err)
}
}
}
case dns.TypePTR:
for a, b := range D {
iptocheck := reverseString(b.Ipv4)
if iptocheck+".in-addr.arpa." == q.Name {
rr, err := dns.NewRR(q.Name + " PTR " + a)
if err == nil {
if DEBUG {
fmt.Println("~", "handleDNSRequest", "case dns.TypePTR", "IPv4", "found match", a, b)
}
msg.Answer = append(msg.Answer, rr)
} else {
if DEBUG {
fmt.Println("!", "handleDNSRequest", "case dns.TypePTR", "IPv4", "error", err)
}
}
}
ip6tocheck, _ := IPv6ToPTR(b.Ipv6)
if ip6tocheck == q.Name {
rr, err := dns.NewRR(q.Name + " PTR " + a)
if err == nil {
if DEBUG {
fmt.Println("~", "handleDNSRequest", "case dns.TypePTR", "IPv6", "found match", a, b)
}
msg.Answer = append(msg.Answer, rr)
} else {
if DEBUG {
fmt.Println("!", "handleDNSRequest", "case dns.TypePTR", "IPv6", "error", err)
}
}
fmt.Println("Fehler beim Erstellen der Antwort (6):", err)
}
}
default:
if DEBUG {
fmt.Println("+", "unhandledDNSRequest", r.Question, q.Name, q.Qclass, q.Qtype)
}
// Ignoriere nicht unterstützte Typen
}
}
@@ -270,15 +181,15 @@ func handleDNSRequest(w dns.ResponseWriter, r *dns.Msg) {
}
func prepareExit() {
fmt.Println("~", "Running exit tasks...")
fmt.Println("Running exit tasks...")
fmt.Println("~", "Exit completed.")
fmt.Println("Exit completed.")
}
func StopServer(e error) {
fmt.Println("~", "Stopping server...")
fmt.Println("Stopping server...")
prepareExit()
fmt.Println("~", "Server stopped!")
fmt.Println("Server stopped!")
}
func main() {
@@ -288,20 +199,16 @@ func main() {
HTTP_TLS_PRIVATEKEY := os.Getenv("HTTP_TLS_PRIVATEKEY")
HTTP_TLS_CERTIFICATE := os.Getenv("HTTP_TLS_CERTIFICATE")
if os.Getenv("DEBUG") == "1" {
DEBUG = true
}
if strings.EqualFold(HTTP_TLS, "") || strings.EqualFold(HTTP_PORT, "") || strings.EqualFold(HTTP_TLS_PRIVATEKEY, "") || strings.EqualFold(HTTP_TLS_CERTIFICATE, "") {
fmt.Println("~", "No port or mode defined. Fallback to TLS=0 & Port=8080")
fmt.Println("~", "ENV's: [HTTP_PORT=8080|443], [HTTP_TLS=0|1],[HTTP_TLS_PRIVATEKEY=#],[HTTP_TLS_CERTIFICATE=#]")
fmt.Println("~", "Remember to set unused ENVs like [HTTP_TLS_PRIVATEKEY] or [HTTP_TLS_CERTIFICATE] to '#'")
fmt.Println("No port or mode defined. Fallback to TLS=0 & Port=8080")
fmt.Println("ENV's: [HTTP_PORT=8080|443], [HTTP_TLS=0|1],[HTTP_TLS_PRIVATEKEY=#],[HTTP_TLS_CERTIFICATE=#]")
fmt.Println("Remember to set unused ENVs like [HTTP_TLS_PRIVATEKEY] or [HTTP_TLS_CERTIFICATE] to '#'")
HTTP_PORT = "8080"
HTTP_TLS = "0"
HTTP_TLS_CERTIFICATE = ""
HTTP_TLS_PRIVATEKEY = ""
} else {
fmt.Println("~", "Port and mode defined.")
fmt.Println("Port and mode defined.")
}
// Signal-Kanal einrichten
@@ -311,19 +218,19 @@ func main() {
// Goroutine, die auf Signale wartet
go func() {
<-stop
fmt.Println("~", "Received stop signal")
fmt.Println("Received stop signal")
prepareExit()
os.Exit(0)
}()
D = make(map[string]dns_entry)
// Datei lesen
filename := "data/data.json"
filename := "/data/data.json"
readData, err := readFromFile(filename)
if err != nil {
fmt.Println("!", "Fehler beim Lesen:", err)
fmt.Println("Fehler beim Lesen:", err)
} else {
fmt.Println("~", "Daten erfolgreich aus Datei gelesen.")
fmt.Println("Daten erfolgreich aus Datei gelesen.")
D = readData
}
@@ -336,7 +243,7 @@ func main() {
serverUDP := &dns.Server{Addr: ":53", Net: "udp"}
go func() {
log.Println("~", "Starting DNS server on UDP :53")
log.Println("Starting DNS server on UDP :53")
if err := serverUDP.ListenAndServe(); err != nil {
log.Fatalf("Failed to start UDP server: %v", err)
}
@@ -344,7 +251,7 @@ func main() {
serverTCP := &dns.Server{Addr: ":53", Net: "tcp"}
go func() {
log.Println("~", "Starting DNS server on TCP :53")
log.Println("Starting DNS server on TCP :53")
if err := serverTCP.ListenAndServe(); err != nil {
log.Fatalf("Failed to start TCP server: %v", err)
}
@@ -352,13 +259,13 @@ func main() {
/* HTTP-PART */
fmt.Println("~", "Server listening on port :"+HTTP_PORT)
fmt.Println("Server listening on port :" + HTTP_PORT)
if HTTP_TLS == "0" {
fmt.Println("~", "Protocol is http (insecure)")
fmt.Println("Protocol is http (insecure)")
StopServer(http.ListenAndServe(":"+HTTP_PORT, nil))
}
if HTTP_TLS == "1" {
fmt.Println("~", "Protocol is https (secure)")
fmt.Println("Protocol is https (secure)")
StopServer(http.ListenAndServeTLS(":"+HTTP_PORT, HTTP_TLS_CERTIFICATE, HTTP_TLS_PRIVATEKEY, nil))
}