bdoerfchen
ec66365b5e
Features: - CLI structure with verbs and resources - Application config and parameters - Output formatters - Initial resource: dishes Reviewed-on: #1 Co-authored-by: bdoerfchen <git@bissendorf.co> Co-committed-by: bdoerfchen <git@bissendorf.co>
67 lines
1.5 KiB
Go
67 lines
1.5 KiB
Go
package stwhbclient
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"git.bissendorf.co/bissendorf/unifood/m/v2/core/interfaces"
|
|
"git.bissendorf.co/bissendorf/unifood/m/v2/model/external/stwbremen"
|
|
)
|
|
|
|
type stwHBClientFactory struct{}
|
|
|
|
func NewFactory() *stwHBClientFactory { return &stwHBClientFactory{} }
|
|
|
|
func Create[T any]() *stwHBClient[T] {
|
|
return New[T]()
|
|
}
|
|
|
|
type stwHBClient[T any] struct {
|
|
interfaces.QueryClient[T]
|
|
|
|
client *http.Client
|
|
baseUrl string
|
|
}
|
|
|
|
func New[T any]() *stwHBClient[T] {
|
|
return &stwHBClient[T]{
|
|
client: http.DefaultClient,
|
|
baseUrl: "https://content.stw-bremen.de",
|
|
}
|
|
}
|
|
|
|
func (c *stwHBClient[T]) Get(ctx context.Context, queryStatement string, selectStatement string, allowCache bool) (*T, error) {
|
|
// Setup url
|
|
url := c.baseUrl + "/api/kql"
|
|
if !allowCache {
|
|
url = url + "nocache"
|
|
}
|
|
|
|
// Create request from query
|
|
fullQuery := fmt.Sprintf(`{"query": "%s", "select": %s}`, queryStatement, selectStatement)
|
|
req, err := http.NewRequestWithContext(ctx, http.MethodPost, url, strings.NewReader(fullQuery))
|
|
if err != nil {
|
|
return nil, fmt.Errorf("unable to create request: %w", err)
|
|
}
|
|
|
|
// Perform request
|
|
response, err := c.client.Do(req)
|
|
if err != nil || response.StatusCode != http.StatusOK {
|
|
return nil, fmt.Errorf("performing request failed: %w", err)
|
|
}
|
|
defer response.Body.Close()
|
|
|
|
// Read response
|
|
var result stwbremen.Result[T]
|
|
err = json.NewDecoder(response.Body).Decode(&result)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("unable to parse result: %w", err)
|
|
}
|
|
|
|
return &result.Result, nil
|
|
|
|
}
|