StackExchange/dnscontrol
1
1
Fork 0
mirror of https://github.com/StackExchange/dnscontrol.git synced 2025-12-17 14:18:55 +08:00
Code Issues Projects Releases Packages Wiki Activity

Update api.go

Browse source
This commit is contained in:
Jonathan Beliën 2025-05-19 22:02:06 +02:00
parent 5c6325004d
commit 69edc60d8c
No known key found for this signature in database
GPG key ID: 110F3BF6C41BF92F
1 changed files with 48 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

75
providers/infomaniak/api.go
View file

@ -1,6 +1,7 @@
package infomaniak package infomaniak
import ( import (
"bytes"
"encoding/json" "encoding/json"
"fmt" "fmt"
"net/http" "net/http"
@ -42,6 +43,14 @@ type dnsRecord struct {
UpdatedAt int64 `json:"updated_at,omitempty"` UpdatedAt int64 `json:"updated_at,omitempty"`
} }
type dnsRecordCreate struct {
Source string `json:"source,omitempty"`
Type string `json:"type,omitempty"`
TTL int64 `json:"ttl,omitempty"`
Target string `json:"target,omitempty"`
}
// Get zone information
// See https://developer.infomaniak.com/docs/api/get/2/zones/%7Bzone%7D // See https://developer.infomaniak.com/docs/api/get/2/zones/%7Bzone%7D
func (p *infomaniakProvider) getDNSZone(zone string) (*dnsZone, error) { func (p *infomaniakProvider) getDNSZone(zone string) (*dnsZone, error) {
reqURL := fmt.Sprintf("%s/zones/%s", baseURL, zone) reqURL := fmt.Sprintf("%s/zones/%s", baseURL, zone)
@ -57,8 +66,9 @@ func (p *infomaniakProvider) getDNSZone(zone string) (*dnsZone, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
response := &dnsZoneResponse{} defer res.Body.Close()
response := &dnsZoneResponse{}
err = json.NewDecoder(res.Body).Decode(response) err = json.NewDecoder(res.Body).Decode(response)
if err != nil { if err != nil {
return nil, err return nil, err
@ -67,6 +77,7 @@ func (p *infomaniakProvider) getDNSZone(zone string) (*dnsZone, error) {
return &response.Data, nil return &response.Data, nil
} }
// Retrieve all dns record for a given zone
// See https://developer.infomaniak.com/docs/api/get/2/zones/%7Bzone%7D/records // See https://developer.infomaniak.com/docs/api/get/2/zones/%7Bzone%7D/records
func (p *infomaniakProvider) getDNSRecords(zone string) ([]dnsRecord, error) { func (p *infomaniakProvider) getDNSRecords(zone string) ([]dnsRecord, error) {
reqURL := fmt.Sprintf("%s/zones/%s/records", baseURL, zone) reqURL := fmt.Sprintf("%s/zones/%s/records", baseURL, zone)
@ -82,8 +93,9 @@ func (p *infomaniakProvider) getDNSRecords(zone string) ([]dnsRecord, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
response := &dnsRecordResponse{} defer res.Body.Close()
response := &dnsRecordResponse{}
err = json.NewDecoder(res.Body).Decode(response) err = json.NewDecoder(res.Body).Decode(response)
if err != nil { if err != nil {
return nil, err return nil, err
@ -92,6 +104,8 @@ func (p *infomaniakProvider) getDNSRecords(zone string) ([]dnsRecord, error) {
return response.Data, nil return response.Data, nil
} }
// Delete a dns record
// See https://developer.infomaniak.com/docs/api/delete/2/zones/%7Bzone%7D/records/%7Brecord%7D
func (p *infomaniakProvider) deleteDNSRecord(zone string, record string) error { func (p *infomaniakProvider) deleteDNSRecord(zone string, record string) error {
reqURL := fmt.Sprintf("%s/zones/%s/records/%s", baseURL, zone, record) reqURL := fmt.Sprintf("%s/zones/%s/records/%s", baseURL, zone, record)
@ -108,36 +122,43 @@ func (p *infomaniakProvider) deleteDNSRecord(zone string, record string) error {
} }
defer res.Body.Close() defer res.Body.Close()
response := &boolResponse{}
err = json.NewDecoder(res.Body).Decode(response)
if err != nil {
return err
}
return nil return nil
} }
// func (p *infomaniakProvider) createDNSRecord(zoneID string, rec *dnsRecordCreate) (*dnsRecord, error) { // Create a dns record in a given zone
// reqURL := fmt.Sprintf("%s/dns_zones/%s/dns_records", baseURL, zoneID) // See https://developer.infomaniak.com/docs/api/post/2/zones/%7Bzone%7D/records
func (p *infomaniakProvider) createDNSRecord(zone string, rec *dnsRecordCreate) (*dnsRecord, error) {
reqURL := fmt.Sprintf("%s/zones/%s/records", baseURL, zone)
// data, err := json.Marshal(rec) data, err := json.Marshal(rec)
// if err != nil { if err != nil {
// return nil, err return nil, err
// } }
// req, err := http.NewRequest(http.MethodPost, reqURL, bytes.NewReader(data)) req, err := http.NewRequest(http.MethodPost, reqURL, bytes.NewReader(data))
// if err != nil { if err != nil {
// return nil, err return nil, err
// } }
// req.Header.Add("Authorization", "Bearer "+n.apiToken) req.Header.Add("Authorization", "Bearer "+p.apiToken)
// req.Header.Add("Content-Type", "application/json") req.Header.Add("Content-Type", "application/json")
// res, err := http.DefaultClient.Do(req) res, err := http.DefaultClient.Do(req)
// if err != nil { if err != nil {
// return nil, err return nil, err
// } }
// defer res.Body.Close() defer res.Body.Close()
// record := &dnsRecord{} record := &dnsRecord{}
err = json.NewDecoder(res.Body).Decode(record)
if err != nil {
return nil, err
}
// err = json.NewDecoder(res.Body).Decode(record) return record, nil
// if err != nil { }
// return nil, err
// }
// return record, nil
// }