// Copyright 2018 Twitch Interactive, Inc.  All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License"). You may not
// use this file except in compliance with the License. A copy of the License is
// located at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// or in the "license" file accompanying this file. This file 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 twirp

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

func TestClientOptionsReadOpt(t *testing.T) {
	opts := &ClientOptions{}
	ok := false

	var fooNum int
	ok = opts.ReadOpt("fooNum", &fooNum)
	if ok {
		t.Errorf("option 'fooNum' does not exist, opts.ReadOpt should have returned false")
	}

	opts.setOpt("fooNum", 455)
	ok = opts.ReadOpt("fooNum", &fooNum)
	if !ok || fooNum != 455 {
		t.Errorf("option 'fooNum' expected to be 455")
	}

	var literalURLs bool
	ok = opts.ReadOpt("literalURLs", &literalURLs)
	if ok {
		t.Errorf("option 'literalURLs' does not exist, opts.ReadOpt should have returned false")
	}

	WithClientLiteralURLs(true)(opts)
	ok = opts.ReadOpt("literalURLs", &literalURLs)
	if !ok || !literalURLs {
		t.Errorf("option 'literalURLs' expected to be true, ok: %v, val: %v", ok, literalURLs)
	}

	WithClientLiteralURLs(false)(opts)
	ok = opts.ReadOpt("literalURLs", &literalURLs)
	if !ok || literalURLs {
		t.Errorf("option 'literalURLs' expected to be false, ok: %v, val: %v", ok, literalURLs)
	}
}

func TestChainClientHooks(t *testing.T) {
	var (
		hook1 = new(ClientHooks)
		hook2 = new(ClientHooks)
		hook3 = new(ClientHooks)

		responseReceivedCalled []string
		errorCalled            []string
	)

	const key = "key"

	hook1.RequestPrepared = func(ctx context.Context, req *http.Request) (context.Context, error) {
		return context.WithValue(ctx, key, []string{"hook1"}), nil
	}
	hook2.RequestPrepared = func(ctx context.Context, req *http.Request) (context.Context, error) {
		v := ctx.Value(key).([]string)
		return context.WithValue(ctx, key, append(v, "hook2")), nil
	}
	hook3.RequestPrepared = func(ctx context.Context, req *http.Request) (context.Context, error) {
		v := ctx.Value(key).([]string)
		return context.WithValue(ctx, key, append(v, "hook3")), nil
	}

	hook1.ResponseReceived = func(ctx context.Context) {
		responseReceivedCalled = append(responseReceivedCalled, "hook1")
	}

	hook2.Error = func(ctx context.Context, twerr Error) {
		errorCalled = append(errorCalled, "hook2")
	}

	chain := ChainClientHooks(hook1, hook2, hook3)

	ctx := context.Background()

	// When all three chained hooks have a handler, all should be called in order.
	want := []string{"hook1", "hook2", "hook3"}
	haveCtx, err := chain.RequestPrepared(ctx, new(http.Request))
	if err != nil {
		t.Fatalf("RequestPrepared chain has unexpected err %v", err)
	}
	have := haveCtx.Value(key)
	if !reflect.DeepEqual(have, want) {
		t.Errorf("RequestPrepared chain has unexpected ctx, have=%v, want=%v", have, want)
	}

	// When only the first chained hook has a handler, it should be called, and
	// there should be no panic.
	want = []string{"hook1"}
	chain.ResponseReceived(ctx)
	if have := responseReceivedCalled; !reflect.DeepEqual(have, want) {
		t.Errorf("unexpected hooks called, have: %v, want: %v", have, want)
	}

	// When only the second chained hook has a handler, it should be called, and
	// there should be no panic.
	want = []string{"hook2"}
	chain.Error(ctx, InternalError("whoops"))
	if have := errorCalled; !reflect.DeepEqual(have, want) {
		t.Errorf("unexpected hooks called, have: %v, want: %v", have, want)
	}

	// When none of the chained hooks has a handler there should be no panic.
	errorCalled = nil
	hook2.Error = nil
	chain.Error(ctx, InternalError("whoops"))
	if have, want := len(errorCalled), 0; have != want {
		t.Errorf("unexpected number of calls, have: %d, want: %d", have, want)
	}
}

func TestWithClientPathPrefix(t *testing.T) {
	opts := &ClientOptions{}

	// Default value
	if have, want := opts.PathPrefix(), "/twirp"; have != want {
		t.Errorf("unexpected default PathPrefix() on ClientOptions, have: %q, want: %q", have, want)
	}

	// Set a different prefix
	WithClientPathPrefix("/newprfx/foobar")(opts)
	if have, want := opts.PathPrefix(), "/newprfx/foobar"; have != want {
		t.Errorf("unexpected value after WithClientPathPrefix, have: %q, want: %q", have, want)
	}

	// Use empty value for no-prefix
	WithClientPathPrefix("")(opts)
	if have, want := opts.PathPrefix(), ""; have != want {
		t.Errorf("unexpected value after WithClientPathPrefix, have: %q, want: %q", have, want)
	}
}

func TestWithClientLiteralURLs(t *testing.T) {
	opts := &ClientOptions{}

	WithClientLiteralURLs(true)(opts)
	if have, want := opts.LiteralURLs, true; have != want {
		t.Errorf("unexpected value after WithClientLiteralURLs, have: %t, want: %t", have, want)
		return
	}

	WithClientLiteralURLs(false)(opts)
	if have, want := opts.LiteralURLs, false; have != want {
		t.Errorf("unexpected value after WithClientLiteralURLs, have: %t, want: %t", have, want)
		return
	}
}