70 lines
1.5 KiB
Go
70 lines
1.5 KiB
Go
package nameservers
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"errors"
|
|
"io"
|
|
"log"
|
|
"net/http"
|
|
"net/url"
|
|
"strconv"
|
|
)
|
|
|
|
type Njalla struct {
|
|
HTTPClient *http.Client
|
|
Key string
|
|
}
|
|
|
|
type njallaValue struct {
|
|
A string `json:"A"`
|
|
}
|
|
|
|
type njallaResponse struct {
|
|
Status int `json:"status"`
|
|
Message string `json:"message"`
|
|
Value njallaValue `json:"value"`
|
|
}
|
|
|
|
func (n *Njalla) SetRecord(ctx context.Context, domain string, overrideIp string) (string, error) {
|
|
u, _ := url.Parse("https://njal.la/update/")
|
|
values := url.Values{
|
|
"h": {domain},
|
|
"k": {n.Key},
|
|
}
|
|
if len(overrideIp) > 0 {
|
|
|
|
values["a"] = []string{overrideIp}
|
|
} else {
|
|
values["auto"] = []string{""}
|
|
}
|
|
u.RawQuery = values.Encode()
|
|
|
|
req, err := http.NewRequestWithContext(ctx, "GET", u.String(), nil)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
resp, err := n.HTTPClient.Do(req)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
body, err := io.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
decoded := njallaResponse{}
|
|
err = json.Unmarshal(body, &decoded)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
log.Printf("debug: [njalla ddns] Response: %s", string(body))
|
|
|
|
if resp.StatusCode < 200 || resp.StatusCode > 299 {
|
|
return "", errors.New("Not nice status code: " + strconv.Itoa(resp.StatusCode) + " with body: " + string(body))
|
|
}
|
|
if decoded.Status < 200 || decoded.Status > 299 {
|
|
return "", errors.New("Not nice JSON status: " + strconv.Itoa(decoded.Status) + " with body: " + string(body))
|
|
}
|
|
return decoded.Value.A, nil
|
|
}
|