/*
 * Copyright 2019 the go-netty project
 *
 * 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
 *
 *      https://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 netty

import "testing"

type oneHandler struct{}

func (h oneHandler) HandleActive(ctx ActiveContext) { ctx.HandleActive() }

type twoHandler struct{}

func (h twoHandler) HandleRead(ctx InboundContext, message Message) { ctx.HandleRead(message) }

type threeHandler struct{}

func (h threeHandler) HandleWrite(ctx OutboundContext, message Message) { ctx.HandleWrite(message) }

type fourHandler struct{}

func (h fourHandler) HandleException(ctx ExceptionContext, ex Exception) { ctx.HandleException(ex) }

type fiveHandler struct{}

func (h fiveHandler) HandleInactive(ctx InactiveContext, ex Exception) { ctx.HandleInactive(ex) }

func TestPipeline(t *testing.T) {

	pl := NewPipeline()

	if 2 != pl.Size() {
		t.Fatal("headHandler / tailHandler")
	}

	pl.AddHandler(-1, twoHandler{})
	pl.AddFirst(oneHandler{})

	if -1 != pl.IndexOf(func(handler Handler) bool {
		return false
	}) {
		t.Fatal("unexpected index")
	}

	if -1 != pl.LastIndexOf(func(handler Handler) bool {
		return false
	}) {
		t.Fatal("unexpected index")
	}

	if nil != pl.ContextAt(-1) {
		t.Fatal("unexpected result")
	}

	twoIndex := pl.IndexOf(func(handler Handler) bool {
		_, ok := handler.(twoHandler)
		return ok
	})

	if 2 != twoIndex {
		t.Fatal("twoHandler:", twoIndex)
	}

	pl.AddHandler(twoIndex, threeHandler{}, fourHandler{}, fiveHandler{})

	for i := 1; i < pl.Size()-1; i++ {
		handler := pl.ContextAt(i).Handler()
		switch handler.(type) {
		case oneHandler:
			if 1 != i {
				t.Fatal("unexpected position: ", i, "want: ", 1)
			}
		case twoHandler:
			if 2 != i {
				t.Fatal("unexpected position: ", i, "want: ", 2)
			}
		case threeHandler:
			if 3 != i {
				t.Fatal("unexpected position: ", i, "want: ", 3)
			}
		case fourHandler:
			if 4 != i {
				t.Fatal("unexpected position: ", i, "want: ", 4)
			}
		case fiveHandler:
			if 5 != i {
				t.Fatal("unexpected position: ", i, "want: ", 5)
			}
		default:
			t.Fatal("invalid handler")
		}
	}

}

func BenchmarkPipeline(b *testing.B) {

	pl := NewPipeline().AddLast(oneHandler{}, twoHandler{}, threeHandler{}, fourHandler{}, fiveHandler{})

	b.ResetTimer()
	b.ReportAllocs()

	for i := 0; i < b.N; i++ {
		pl.FireChannelActive()
	}
}