// Copyright 2018, Google Inc.
// All rights reserved.
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are
// met:
//
//     * Redistributions of source code must retain the above copyright
// notice, this list of conditions and the following disclaimer.
//     * Redistributions in binary form must reproduce the above
// copyright notice, this list of conditions and the following disclaimer
// in the documentation and/or other materials provided with the
// distribution.
//     * Neither the name of Google Inc. nor the names of its
// contributors may be used to endorse or promote products derived from
// this software without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

package gax

import (
	"context"
	"net/http"
	"testing"

	"github.com/google/go-cmp/cmp"
	"github.com/googleapis/gax-go/v2/callctx"
	"google.golang.org/grpc/metadata"
)

func TestXGoogHeader(t *testing.T) {
	for _, tst := range []struct {
		kv   []string
		want string
	}{
		{nil, ""},
		{[]string{"abc", "def"}, "abc/def"},
		{[]string{"abc", "def", "xyz", "123", "foo", ""}, "abc/def xyz/123 foo/"},
	} {
		got := XGoogHeader(tst.kv...)
		if got != tst.want {
			t.Errorf("Header(%q) = %q, want %q", tst.kv, got, tst.want)
		}
	}
}

func TestGoVersion(t *testing.T) {
	testVersion := func(v string) func() string {
		return func() string {
			return v
		}
	}
	for _, tst := range []struct {
		v    func() string
		want string
	}{
		{
			testVersion("go1.19"),
			"1.19.0",
		},
		{
			testVersion("go1.21-20230317-RC01"),
			"1.21.0-20230317-RC01",
		},
		{
			testVersion("devel +abc1234"),
			"abc1234",
		},
		{
			testVersion("this should be unknown"),
			versionUnknown,
		},
		{
			testVersion("go1.21-20230101-RC01 cl/1234567 +abc1234"),
			"1.21.0-20230101-RC01",
		},
	} {
		version = tst.v
		got := goVersion()
		if diff := cmp.Diff(got, tst.want); diff != "" {
			t.Errorf("got(-),want(+):\n%s", diff)
		}
	}
}

func TestInsertMetadataIntoOutgoingContext(t *testing.T) {
	for _, tst := range []struct {
		// User-provided metadata set in context
		userMd metadata.MD
		// User-provided headers set in context
		userHeaders []string
		// Client-provided headers passed to func
		clientHeaders []string
		want          metadata.MD
	}{
		{
			userMd: metadata.Pairs("key_1", "val_1", "key_2", "val_21"),
			want:   metadata.Pairs("key_1", "val_1", "key_2", "val_21"),
		},
		{
			userHeaders: []string{"key_2", "val_22"},
			want:        metadata.Pairs("key_2", "val_22"),
		},
		{
			clientHeaders: []string{"key_2", "val_23", "key_2", "val_24"},
			want:          metadata.Pairs("key_2", "val_23", "key_2", "val_24"),
		},
		{
			userMd:        metadata.Pairs("key_1", "val_1", "key_2", "val_21"),
			userHeaders:   []string{"key_2", "val_22"},
			clientHeaders: []string{"key_2", "val_23", "key_2", "val_24"},
			want:          metadata.Pairs("key_1", "val_1", "key_2", "val_21", "key_2", "val_22", "key_2", "val_23", "key_2", "val_24"),
		},
	} {
		ctx := context.Background()
		if tst.userMd != nil {
			ctx = metadata.NewOutgoingContext(ctx, tst.userMd)
		}
		ctx = callctx.SetHeaders(ctx, tst.userHeaders...)

		ctx = InsertMetadataIntoOutgoingContext(ctx, tst.clientHeaders...)

		got, _ := metadata.FromOutgoingContext(ctx)
		if diff := cmp.Diff(tst.want, got); diff != "" {
			t.Errorf("InsertMetadata(ctx, %q) mismatch (-want +got):\n%s", tst.clientHeaders, diff)
		}
	}
}

func TestBuildHeaders(t *testing.T) {
	// User-provided metadata set in context
	existingMd := metadata.Pairs("key_1", "val_1", "key_2", "val_21")
	ctx := metadata.NewOutgoingContext(context.Background(), existingMd)
	// User-provided headers set in context
	ctx = callctx.SetHeaders(ctx, "key_2", "val_22")
	// Client-provided headers
	keyvals := []string{"key_2", "val_23", "key_2", "val_24"}

	got := BuildHeaders(ctx, keyvals...)

	want := http.Header{"key_1": []string{"val_1"}, "key_2": []string{"val_21", "val_22", "val_23", "val_24"}}
	if diff := cmp.Diff(want, got); diff != "" {
		t.Errorf("InsertMetadata(ctx, %q) mismatch (-want +got):\n%s", keyvals, diff)
	}
}