tests/integration/pilot/piggyback_test.go

//go:build integ
// +build integ

// Copyright Istio Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package pilot

import (
	"testing"
)

import (
	xdsapi "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3"
)

import (
	"github.com/apache/dubbo-go-pixiu/pkg/test/framework"
	"github.com/apache/dubbo-go-pixiu/pkg/util/protomarshal"
)

func TestPiggyback(t *testing.T) {
	framework.
		NewTest(t).Features("usability.observability.proxy-status"). // TODO create new "agent-piggyback" feature
		RequiresSingleCluster().
		RequiresLocalControlPlane().
		RequireIstioVersion("1.10.0").
		Run(func(t framework.TestContext) {
			out, _, err := t.Clusters()[0].PodExec(
				apps.A[0].WorkloadsOrFail(t)[0].PodName(),
				apps.A.Config().Namespace.Name(),
				"istio-proxy",
				"pilot-agent request --debug-port 15004 GET /debug/syncz")
			if err != nil {
				t.Fatalf("couldn't curl sidecar: %v", err)
			}
			dr := xdsapi.DiscoveryResponse{}
			if err := protomarshal.Unmarshal([]byte(out), &dr); err != nil {
				t.Fatal(err)
			}
			if dr.TypeUrl != "istio.io/debug/syncz" {
				t.Fatalf("the output doesn't contain expected typeURL: %s", out)
			}
			if len(dr.Resources) < 1 {
				t.Fatalf("the output didn't unmarshal as expected (no resources): %s", out)
			}
			if dr.Resources[0].TypeUrl != "type.googleapis.com/envoy.service.status.v3.ClientConfig" {
				t.Fatalf("Resources[0] doesn't contain expected typeURL: %s", out)
			}
		})
}