mirror of https://github.com/status-im/consul.git
92 lines
2.4 KiB
Go
92 lines
2.4 KiB
Go
|
// Copyright (c) HashiCorp, Inc.
|
||
|
|
// SPDX-License-Identifier: MPL-2.0
|
||
|
|
|
||
|
|
package api
|
||
|
|
|
||
|
|
import (
|
||
|
|
"encoding/json"
|
||
|
|
"fmt"
|
||
|
|
"strings"
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
"github.com/stretchr/testify/require"
|
||
|
|
"google.golang.org/protobuf/encoding/protojson"
|
||
|
|
|
||
|
|
pbmulticluster "github.com/hashicorp/consul/proto-public/pbmulticluster/v2"
|
||
|
|
"github.com/hashicorp/consul/proto-public/pbresource"
|
||
|
|
|
||
|
|
"github.com/hashicorp/consul/sdk/testutil"
|
||
|
|
)
|
||
|
|
|
||
|
|
type V2WriteRequest struct {
|
||
|
|
Metadata map[string]string `json:"metadata"`
|
||
|
|
Data map[string]any `json:"data"`
|
||
|
|
Owner *pbresource.ID `json:"owner"`
|
||
|
|
}
|
||
|
|
|
||
|
|
type V2WriteResponse struct {
|
||
|
|
Metadata map[string]string `json:"metadata"`
|
||
|
|
Data map[string]any `json:"data"`
|
||
|
|
Owner *pbresource.ID `json:"owner,omitempty"`
|
||
|
|
ID *pbresource.ID `json:"id"`
|
||
|
|
Version string `json:"version"`
|
||
|
|
Generation string `json:"generation"`
|
||
|
|
Status map[string]any `json:"status"`
|
||
|
|
}
|
||
|
|
|
||
|
|
// We are testing a v2 endpoint here in the v1 api module as a temporary measure to
|
||
|
|
// support v2 CRUD operations, until we have a final design for v2 api clients.
|
||
|
|
func TestAPI_RawV2ExportedServices(t *testing.T) {
|
||
|
|
t.Parallel()
|
||
|
|
c, s := makeClientWithConfig(t, nil, func(conf *testutil.TestServerConfig) {
|
||
|
|
conf.EnableDebug = true
|
||
|
|
})
|
||
|
|
|
||
|
|
defer s.Stop()
|
||
|
|
|
||
|
|
endpoint := strings.ToLower(fmt.Sprintf("/api/multicluster/v2/exportedservices/e1"))
|
||
|
|
wResp := &V2WriteResponse{}
|
||
|
|
|
||
|
|
var consumers []map[string]any
|
||
|
|
consumers = append(consumers, map[string]any{"peer": "p1"})
|
||
|
|
data := map[string]any{"consumers": consumers}
|
||
|
|
data["services"] = []string{"s1"}
|
||
|
|
wReq := &V2WriteRequest{
|
||
|
|
Metadata: nil,
|
||
|
|
Data: data,
|
||
|
|
Owner: nil,
|
||
|
|
}
|
||
|
|
|
||
|
|
_, err := c.Raw().Write(endpoint, wReq, wResp, &WriteOptions{Datacenter: "dc1"})
|
||
|
|
if err != nil {
|
||
|
|
t.Fatalf("err: %v", err)
|
||
|
|
}
|
||
|
|
if wResp.ID.Name == "" {
|
||
|
|
t.Fatalf("no write response")
|
||
|
|
}
|
||
|
|
|
||
|
|
qOpts := &QueryOptions{Datacenter: "dc1"}
|
||
|
|
var out map[string]interface{}
|
||
|
|
_, err = c.Raw().Query(endpoint, &out, qOpts)
|
||
|
|
if err != nil {
|
||
|
|
t.Fatalf("err: %v", err)
|
||
|
|
}
|
||
|
|
respData, _ := json.Marshal(out["data"])
|
||
|
|
readData := &pbmulticluster.ExportedServices{}
|
||
|
|
if err = protojson.Unmarshal(respData, readData); err != nil {
|
||
|
|
t.Fatalf("invalid read response")
|
||
|
|
}
|
||
|
|
if len(readData.Services) != 1 {
|
||
|
|
t.Fatalf("incorrect resource data")
|
||
|
|
}
|
||
|
|
|
||
|
|
_, err = c.Raw().Delete(endpoint, qOpts)
|
||
|
|
if err != nil {
|
||
|
|
t.Fatalf("err: %v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
out = make(map[string]interface{})
|
||
|
|
_, err = c.Raw().Query(endpoint, &out, qOpts)
|
||
|
|
require.ErrorContains(t, err, "404")
|
||
|
|
}
|