package cmd

import (
	"testing"

	fn "knative.dev/func/pkg/functions"
	. "knative.dev/func/pkg/testing"
)

func TestSubscribeWithAll(t *testing.T) {
	root := FromTempDirectory(t)

	_, err := fn.New().Init(fn.Function{Runtime: "go", Root: root})
	if err != nil {
		t.Fatal(err)
	}

	cmd := NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "foo=go"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err := fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Source != "my-broker" {
		t.Fatalf("Expected subscription for broker to be 'my-broker', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[0].Filters["foo"] != "go" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'go', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}
}

func TestSubscribeWithMultiple(t *testing.T) {
	root := FromTempDirectory(t)

	_, err := fn.New().Init(fn.Function{Runtime: "go", Root: root})
	if err != nil {
		t.Fatal(err)
	}

	cmd := NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "foo=go"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err := fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Source != "my-broker" {
		t.Fatalf("Expected subscription for broker to be 'my-broker', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[0].Filters["foo"] != "go" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'go', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}

	cmd = NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "bar=foo"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err = fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Source != "my-broker" {
		t.Fatalf("Expected subscription for broker to be 'my-broker', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[0].Filters["foo"] != "go" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'go', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}
	if f.Deploy.Subscriptions[0].Filters["bar"] != "foo" {
		t.Fatalf("Expected subscription filter for 'bar' to be 'foo', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}

}

func TestSubscribeWithMultipleBrokersAndOverride(t *testing.T) {
	root := FromTempDirectory(t)

	_, err := fn.New().Init(fn.Function{Runtime: "go", Root: root})
	if err != nil {
		t.Fatal(err)
	}

	cmd := NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "foo=go"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err := fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Source != "my-broker" {
		t.Fatalf("Expected subscription for broker to be 'my-broker', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[0].Filters["foo"] != "go" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'go', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}

	cmd = NewSubscribeCmd()
	cmd.SetArgs([]string{"--filter", "bar=foo"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err = fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[1].Source != "default" {
		t.Fatalf("Expected subscription for broker to be 'default', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[1].Filters["bar"] != "foo" {
		t.Fatalf("Expected subscription filter for 'bar' to be 'foo', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}

	cmd = NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "foo=golang"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err = fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Source != "my-broker" {
		t.Fatalf("Expected subscription for broker to be 'my-broker', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[0].Filters["foo"] != "golang" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'golang', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}
}

func TestSubscribeWithNoExplicitSourceAll(t *testing.T) {
	root := FromTempDirectory(t)

	_, err := fn.New().Init(fn.Function{Runtime: "go", Root: root})
	if err != nil {
		t.Fatal(err)
	}

	cmd := NewSubscribeCmd()
	cmd.SetArgs([]string{"--filter", "foo=go"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err := fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Source != "default" {
		t.Fatalf("Expected subscription for broker to be 'default', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[0].Filters["foo"] != "go" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'go', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}
}

func TestSubscribeWithDuplicated(t *testing.T) {
	root := FromTempDirectory(t)

	_, err := fn.New().Init(fn.Function{Runtime: "go", Root: root})
	if err != nil {
		t.Fatal(err)
	}

	cmd := NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "foo=go"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err := fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if f.Deploy.Subscriptions == nil {
		t.Fatal("Expected subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Source != "my-broker" {
		t.Fatalf("Expected subscription for broker to be 'my-broker', but got '%v'", f.Deploy.Subscriptions[0].Source)
	}

	if f.Deploy.Subscriptions[0].Filters["foo"] != "go" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'go', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}

	// call it again with same
	cmd = NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "foo=go"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}
	// Now load the function and ensure that the subscription is set correctly.
	f, err = fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if len(f.Deploy.Subscriptions) > 1 {
		t.Fatal("Expected only one subscription to be present ")
	}

	// call it again and override
	cmd = NewSubscribeCmd()
	cmd.SetArgs([]string{"--source", "my-broker", "--filter", "foo=gogo"})

	if err := cmd.Execute(); err != nil {
		t.Fatal(err)
	}

	// Now load the function and ensure that the subscription is set correctly.
	f, err = fn.NewFunction(root)
	if err != nil {
		t.Fatal(err)
	}

	if len(f.Deploy.Subscriptions) > 1 {
		t.Fatal("Expected only one subscription to be present ")
	}
	if f.Deploy.Subscriptions[0].Filters["foo"] != "gogo" {
		t.Fatalf("Expected subscription filter for 'foo' to be 'gogo', but got '%v'", f.Deploy.Subscriptions[0].Filters["foo"])
	}

}