91 lines
2.1 KiB
Go
91 lines
2.1 KiB
Go
package client
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"net/url"
|
|
"strings"
|
|
"time"
|
|
|
|
"go-mod.ewintr.nl/planner/item"
|
|
)
|
|
|
|
type HTTP struct {
|
|
baseURL string
|
|
apiKey string
|
|
c *http.Client
|
|
}
|
|
|
|
func New(url, apiKey string) *HTTP {
|
|
return &HTTP{
|
|
baseURL: url,
|
|
apiKey: apiKey,
|
|
c: &http.Client{
|
|
Timeout: 10 * time.Second,
|
|
},
|
|
}
|
|
}
|
|
|
|
func (c *HTTP) Update(items []item.Item) error {
|
|
body, err := json.Marshal(items)
|
|
if err != nil {
|
|
return fmt.Errorf("could not marhal body: %v", err)
|
|
}
|
|
req, err := http.NewRequest(http.MethodPost, fmt.Sprintf("%s/sync", c.baseURL), bytes.NewReader(body))
|
|
if err != nil {
|
|
return fmt.Errorf("could not create request: %v", err)
|
|
}
|
|
req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", c.apiKey))
|
|
|
|
res, err := c.c.Do(req)
|
|
if err != nil {
|
|
return fmt.Errorf("could not make request: %v", err)
|
|
}
|
|
if res.StatusCode != http.StatusNoContent {
|
|
body, _ := io.ReadAll(res.Body)
|
|
return fmt.Errorf("server returned status %d, body: %s", res.StatusCode, body)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *HTTP) Updated(ks []item.Kind, ts time.Time) ([]item.Item, error) {
|
|
ksStr := make([]string, 0, len(ks))
|
|
for _, k := range ks {
|
|
ksStr = append(ksStr, string(k))
|
|
}
|
|
u := fmt.Sprintf("%s/sync?ks=%s", c.baseURL, strings.Join(ksStr, ","))
|
|
if !ts.IsZero() {
|
|
u = fmt.Sprintf("%s&ts=%s", u, url.QueryEscape(ts.Format(time.RFC3339)))
|
|
}
|
|
req, err := http.NewRequest(http.MethodGet, u, nil)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("could not create request: %v", err)
|
|
}
|
|
req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", c.apiKey))
|
|
|
|
res, err := c.c.Do(req)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("could not get response: %v", err)
|
|
}
|
|
if res.StatusCode != http.StatusOK {
|
|
return nil, fmt.Errorf("server returned status %d", res.StatusCode)
|
|
}
|
|
|
|
defer res.Body.Close()
|
|
body, err := io.ReadAll(res.Body)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("could not read response body: %v", err)
|
|
}
|
|
|
|
var items []item.Item
|
|
if err := json.Unmarshal(body, &items); err != nil {
|
|
return nil, fmt.Errorf("could not unmarshal response body: %v", err)
|
|
}
|
|
|
|
return items, nil
|
|
}
|