// +build integration

package hcn

import (
	"encoding/json"
	"github.com/Microsoft/go-winio/pkg/guid"
	"testing"
)

func TestMissingNetworkByName(t *testing.T) {
	_, err := GetNetworkByName("Not found name")
	if err == nil {
		t.Fatal("Error was not thrown.")
	}
	if !IsNotFoundError(err) {
		t.Fatal("Unrelated error was thrown.", err)
	}
	if _, ok := err.(NetworkNotFoundError); !ok {
		t.Fatal("Wrong error type was thrown.", err)
	}
	if err.Error() != `Network name "Not found name" not found` {
		t.Fatal("Wrong error message was returned", err.Error())
	}
}

func TestMissingNetworkById(t *testing.T) {
	// Random guid
	_, err := GetNetworkByID("5f0b1190-63be-4e0c-b974-bd0f55675a42")
	if err == nil {
		t.Fatal("Error was not thrown.")
	}
	if !IsNotFoundError(err) {
		t.Fatal("Unrelated error was thrown.", err)
	}
	if _, ok := err.(NetworkNotFoundError); !ok {
		t.Fatal("Wrong error type was thrown.", err)
	}
	if err.Error() != `Network ID "5f0b1190-63be-4e0c-b974-bd0f55675a42" not found` {
		t.Fatal("Wrong error message was returned", err.Error())
	}
}

func TestMissingNamespaceById(t *testing.T) {
	// Random guid
	_, err := GetNamespaceByID("5f0b1190-63be-4e0c-b974-bd0f55675a42")
	if err == nil {
		t.Fatal("Error was not thrown.")
	}

	if !IsNotFoundError(err) {
		t.Fatal("Unrelated error was thrown.", err)
	}
	if _, ok := err.(NamespaceNotFoundError); !ok {
		t.Fatal("Wrong error type was thrown.", err)
	}
	if err.Error() != `Namespace ID "5f0b1190-63be-4e0c-b974-bd0f55675a42" not found` {
		t.Fatal("Wrong error message was returned.", err.Error())
	}
}

func TestEndpointAlreadyExistsError(t *testing.T) {
	testNetwork, err := CreateTestOverlayNetwork()
	if err != nil {
		t.Fatal("Failed to create overlay network for setup.", err)
	}
	defer testNetwork.Delete()
	portMappingSetting := PortMappingPolicySetting{
		Protocol:     17,
		InternalPort: 45678,
		ExternalPort: 56789,
	}
	settingString, _ := json.Marshal(portMappingSetting)
	portMappingPolicy := EndpointPolicy{
		Type:     PortMapping,
		Settings: settingString,
	}

	endpoint, err := HcnCreateTestEndpointWithPolicies(testNetwork, []EndpointPolicy{portMappingPolicy})
	if err != nil {
		t.Fatal("Failed to create endpoint for setup.", err)
	}
	defer endpoint.Delete()

	endpoint2, err := HcnCreateTestEndpointWithPolicies(testNetwork, []EndpointPolicy{portMappingPolicy})
	if err == nil {
		t.Fatal("Endpoint should have failed with duplicate port mapping.", err)
		defer endpoint2.Delete()
	}

	if !IsPortAlreadyExistsError(err) {
		t.Fatal("Error is not a PortAlreadyExists Error", err)
	}
}

func TestNotFoundError(t *testing.T) {
	namespaceGuid, _ := guid.FromString("5f0b1190-63be-4e0c-b974-bd0f55675a42")
	_, err := getNamespace(namespaceGuid, "")
	if !IsElementNotFoundError(err) {
		t.Fatal("Error is not a ElementNotFound Error.", err)
	}
}