VCR and VDR clients

Author: reinkrul

nuts/discovery/bug.go

@@ -4,5 +4,5 @@ package discovery
 // When regenerating code, you need to alter it to map[string]interface{}
 // This function is there to make sure compilation fails if it's map[string]string
 var _ = SearchPresentationsParams{
-	Query: &map[string]interface{}{},
+	Query: &map[string]string{},
 }

nuts/discovery/generated.go

@@ -0,0 +1,35 @@
+package nuts
+
+import (
+	"errors"
+	"fmt"
+	"io"
+	"net"
+	"net/http"
+	"strings"
+)
+
+var ErrNutsNodeUnreachable = errors.New("nuts node unreachable")
+
+func UnwrapAPIError(err error) error {
+	if _, ok := err.(net.Error); ok {
+		return errors.Join(ErrNutsNodeUnreachable, err)
+	}
+	return err
+}
+
+func ParseResponse[T any](err error, httpResponse *http.Response, fn func(rsp *http.Response) (*T, error)) (*T, error) {
+	if err != nil {
+		return nil, fmt.Errorf("http request failed: %w", UnwrapAPIError(err))
+	}
+	if httpResponse.StatusCode < 200 || httpResponse.StatusCode >= 300 {
+		responseData, _ := io.ReadAll(httpResponse.Body)
+		detail := "Response data:\n----------------\n" + strings.TrimSpace(string(responseData)) + "\n----------------"
+		return nil, fmt.Errorf("non-OK status code (status=%s, url=%s)\n%s", httpResponse.Status, httpResponse.Request.URL, detail)
+	}
+	result, err := fn(httpResponse)
+	if err != nil {
+		return nil, fmt.Errorf("failed to parse response: %w", err)
+	}
+	return result, nil
+}

nuts/util.go

@@ -0,0 +1,53 @@
+package nuts
+
+import (
+	"github.com/stretchr/testify/require"
+	"io"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"testing"
+)
+
+func Test_ParseResponse(t *testing.T) {
+	fn := func(response *http.Response) (*string, error) {
+		data, _ := io.ReadAll(response.Body)
+		result := string(data)
+		return &result, nil
+	}
+	okResponse := func() *http.Response {
+		return &http.Response{
+			StatusCode: 200,
+			Status:     "200 OK",
+			Body:       io.NopCloser(strings.NewReader("http-test-response")),
+			Request:    httptest.NewRequest(http.MethodGet, "http://example.com", nil),
+		}
+	}
+	nokResponse := func() *http.Response {
+		return &http.Response{
+			StatusCode: 404,
+			Status:     "404 Not Found",
+			Body:       io.NopCloser(strings.NewReader("http-test-response")),
+			Request:    httptest.NewRequest(http.MethodGet, "http://example.com", nil),
+		}
+	}
+	t.Run("error", func(t *testing.T) {
+		_, err := ParseResponse(io.EOF, okResponse(), fn)
+		require.EqualError(t, err, "http request failed: EOF")
+	})
+	t.Run("parse error", func(t *testing.T) {
+		_, err := ParseResponse(nil, okResponse(), func(response *http.Response) (*string, error) {
+			return nil, io.EOF
+		})
+		require.EqualError(t, err, "failed to parse response: EOF")
+	})
+	t.Run("ok", func(t *testing.T) {
+		result, err := ParseResponse(nil, okResponse(), fn)
+		require.NoError(t, err)
+		require.Equal(t, "http-test-response", *result)
+	})
+	t.Run("non-ok status", func(t *testing.T) {
+		_, err := ParseResponse(nil, nokResponse(), fn)
+		require.EqualError(t, err, "non-OK status code (status=404 Not Found, url=http://example.com)\nResponse data:\n----------------\nhttp-test-response\n----------------")
+	})
+}

nuts/util_test.go

@@ -0,0 +1,3 @@
+//go:generate go run github.com/oapi-codegen/oapi-codegen/v2/cmd/oapi-codegen -o generated.go --config=config.yaml https://nuts-node.readthedocs.io/en/latest/_static/vcr/vcr_v2.yaml
+
+package vcr

nuts/vcr/codegen.go

@@ -0,0 +1,6 @@
+package: vcr
+generate:
+  models: true
+  client: true
+import-mapping:
+  "../common/ssi_types.yaml": "github.com/nuts-foundation/go-nuts-client/nuts/common"