package tests

import (
	"testing"

	"github.com/fnproject/fn/api/id"
	"github.com/fnproject/fn_go/models"
	"reflect"
)

func TestCreateRouteEmptyType(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	_, err := createRoute(s.Context, s.Client, s.AppName, s.RoutePath, s.Image, "",
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
	if err == nil {
		t.Errorf("Should fail with Invalid route Type.")
	}
	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestCanCreateRoute(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestListRoutes(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
	if !assertContainsRoute(ListRoutes(t, s.Context, s.Client, s.AppName), s.RoutePath) {
		t.Errorf("Unable to find corresponding route `%v` in list", s.RoutePath)
	}
	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestInspectRoute(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)

	rObjects := []*models.Route{GetRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)}
	if !assertContainsRoute(rObjects, s.RoutePath) {
		t.Errorf("Unable to find corresponding route `%v` in list", s.RoutePath)
	}

	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestCanUpdateRouteType(t *testing.T) {
	newRouteType := "sync"
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)

	routeResp, err := UpdateRoute(
		t, s.Context, s.Client,
		s.AppName, s.RoutePath,
		s.Image, newRouteType, s.Format,
		s.Memory, s.RouteConfig, s.RouteHeaders, "")

	CheckRouteResponseError(t, err)
	assertRouteFields(t, routeResp.Payload.Route, s.RoutePath, s.Image, newRouteType, s.Format)

	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestCanUpdateRouteConfig(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)

	newRouteConf := map[string]string{
		"A": "a",
	}

	routeResp, err := UpdateRoute(
		t, s.Context, s.Client,
		s.AppName, s.RoutePath,
		s.Image, s.RouteType, s.Format,
		s.Memory, newRouteConf, s.RouteHeaders, "")

	CheckRouteResponseError(t, err)
	assertRouteFields(t, routeResp.Payload.Route, s.RoutePath, s.Image, s.RouteType, s.Format)

	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestCantUpdateRoutePath(t *testing.T) {

	t.Parallel()
	newRoutePath := id.New().String()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)

	_, err := UpdateRoute(
		t, s.Context, s.Client,
		s.AppName, s.RoutePath,
		s.Image, s.RouteType, s.Format,
		s.Memory, s.RouteConfig, s.RouteHeaders, newRoutePath)
	if err == nil {
		t.Errorf("Route path suppose to be immutable, but it's not.")
	}

	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestRouteDuplicate(t *testing.T) {
	t.Parallel()
	newRouteType := "async"
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)

	_, err := createRoute(s.Context, s.Client, s.AppName, s.Image, s.RoutePath,
		newRouteType, s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
	if err == nil {
		t.Errorf("Route duplicate error should appear, but it didn't")
	}

	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestCanDeleteRoute(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)

	DeleteRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)
	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestCantDeleteRoute(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})

	_, err := deleteRoute(s.Context, s.Client, s.AppName, "dummy-route")
	if err == nil {
		t.Error("Delete from missing route must fail.")
	}
	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestDeployNewApp(t *testing.T) {
	t.Parallel()
	s := SetupDefaultSuite()
	DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, s.RouteHeaders)
	GetApp(t, s.Context, s.Client, s.AppName)
	GetRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)
	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestDeployExistingApp(t *testing.T) {
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, s.RouteHeaders)
	GetApp(t, s.Context, s.Client, s.AppName)
	GetRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)
	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestDeployUpdate(t *testing.T) {
	newRouteType := "sync"
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
		s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)

	updatedRoute := DeployRoute(
		t, s.Context, s.Client,
		s.AppName, s.RoutePath,
		s.Image, newRouteType,
		s.Format, s.RouteConfig, s.RouteHeaders)
	assertRouteFields(t, updatedRoute, s.RoutePath, s.Image, newRouteType, s.Format)

	DeleteApp(t, s.Context, s.Client, s.AppName)
}

func TestMulpileDeployExistingApp(t *testing.T) {
	s := SetupDefaultSuite()
	CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
	routeHeaders := map[string][]string{}
	routeHeaders["A"] = []string{"a"}
	routeHeaders["B"] = []string{"b"}
	DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, routeHeaders)
	sameRoute := DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, routeHeaders)
	if ok := reflect.DeepEqual(sameRoute.Headers, routeHeaders); !ok {
		t.Error("Route headers should remain the same after multiple deploys with exact the same parameters")
	}
	DeleteApp(t, s.Context, s.Client, s.AppName)
}