1 files changed, 174 insertions, 0 deletions

diff --git a/clients/netbox/http.go b/clients/netbox/http.go
new file mode 100644
index 0000000..21a2b4b
--- /dev/null
+++ b/clients/netbox/http.go
@@ -0,0 +1,174 @@
+package netbox
+
+import (
+        "bytes"
+        "context"
+        "encoding/json"
+        "fmt"
+        "net/http"
+        "net/url"
+)
+
+// NetboxHttpClient is an HTTP client for the Netbox API. It is very
+// low-level and should not be consumed by most clients. Instead use a
+// client implementing NetboxClient.
+type NetboxHttpClient struct {
+        ApiKey   string
+        Endpoint url.URL
+}
+
+func MustNewNetboxHttpClient(apiKey, endpoint string) *NetboxHttpClient {
+        u, err := url.Parse(endpoint)
+        if err != nil {
+                panic(err)
+        }
+        return &NetboxHttpClient{apiKey, *u}
+}
+
+func (c *NetboxHttpClient) Do(ctx context.Context, r NetboxRequest, out any) error {
+        u := c.Endpoint // Store a local copy, requests may mutate it
+        req, err := r.BuildRequest(ctx, &u)
+        if err != nil {
+                return err
+        }
+
+        req.Header.Add("Authorization", fmt.Sprintf("Token %s", c.ApiKey))
+
+        res, err := http.DefaultClient.Do(req)
+        if err != nil {
+                return err
+        }
+        defer res.Body.Close()
+
+        if res.StatusCode != http.StatusOK {
+                apiError := &ApiError{Status: res.StatusCode}
+                if err = json.NewDecoder(res.Body).Decode(apiError); err != nil {
+                        return fmt.Errorf("Netbox JSON decode error while parsing error with status %d: %w", res.StatusCode, err)
+                }
+                return apiError
+        }
+
+        if out != nil {
+                return json.NewDecoder(res.Body).Decode(out)
+        }
+
+        return nil
+}
+
+type NetboxRequest interface {
+        BuildRequest(context.Context, *url.URL) (*http.Request, error)
+}
+
+type NetboxGraphQLRequest struct {
+        Query string
+}
+
+var _ NetboxRequest = (*NetboxGraphQLRequest)(nil)
+
+func (r *NetboxGraphQLRequest) BuildRequest(ctx context.Context, host *url.URL) (*http.Request, error) {
+        q, err := json.Marshal(map[string]string{"query": r.Query})
+        if err != nil {
+                return nil, err
+        }
+
+        host.Path = "/graphql/"
+
+        req, err := http.NewRequestWithContext(
+                ctx,
+                http.MethodPost,
+                host.String(),
+                bytes.NewBuffer(q),
+        )
+        if err != nil {
+                return nil, err
+        }
+
+        req.Header.Add("Content-Type", "application/json")
+        req.Header.Add("Accept", "application/json")
+
+        return req, nil
+}
+
+type NetboxGetRequest struct {
+        url.Values
+        Path string
+}
+
+var _ NetboxRequest = (*NetboxGetRequest)(nil)
+
+func NewNetboxGetRequest(path string) *NetboxGetRequest {
+        return &NetboxGetRequest{url.Values{}, path}
+}
+
+func (r *NetboxGetRequest) BuildRequest(ctx context.Context, host *url.URL) (*http.Request, error) {
+        host.Path = r.Path
+        host.RawQuery = r.Encode()
+
+        req, err := http.NewRequestWithContext(
+                ctx,
+                http.MethodGet,
+                host.String(),
+                nil,
+        )
+        if err != nil {
+                return nil, err
+        }
+
+        req.Header.Add("Accept", "application/json")
+
+        return req, nil
+}
+
+type NetboxRawGet struct {
+        Url string
+}
+
+var _ NetboxRequest = (*NetboxRawGet)(nil)
+
+func (r *NetboxRawGet) BuildRequest(ctx context.Context, host *url.URL) (*http.Request, error) {
+        req, err := http.NewRequestWithContext(
+                ctx,
+                http.MethodGet,
+                r.Url,
+                nil,
+        )
+        if err != nil {
+                return nil, err
+        }
+
+        req.Header.Add("Accept", "application/json")
+
+        return req, nil
+}
+
+type NetboxJsonRequest struct {
+        Path   string
+        Method string
+        Body   any
+}
+
+var _ NetboxRequest = (*NetboxJsonRequest)(nil)
+
+func (r *NetboxJsonRequest) BuildRequest(ctx context.Context, host *url.URL) (*http.Request, error) {
+        host.Path = r.Path
+
+        body, err := json.Marshal(r.Body)
+        if err != nil {
+                return nil, err
+        }
+
+        req, err := http.NewRequestWithContext(
+                ctx,
+                r.Method,
+                host.String(),
+                bytes.NewBuffer(body),
+        )
+        if err != nil {
+                return nil, err
+        }
+
+        req.Header.Add("Content-Type", "application/json")
+        req.Header.Add("Accept", "application/json")
+
+        return req, nil
+}