package v1alpha3

import (
	"time"

	"k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"
)

// StackList is a list of stacks
type StackList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Items []Stack `json:"items" protobuf:"bytes,2,rep,name=items"`
}

// Stack is v1alpha3's representation of a Stack
type Stack struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   *StackSpec   `json:"spec,omitempty"`
	Status *StackStatus `json:"status,omitempty"`
}

// DeepCopyObject clones the stack
func (s *Stack) DeepCopyObject() runtime.Object {
	return s.clone()
}

// DeepCopyObject clones the stack list
func (s *StackList) DeepCopyObject() runtime.Object {
	if s == nil {
		return nil
	}
	result := new(StackList)
	result.TypeMeta = s.TypeMeta
	result.ListMeta = s.ListMeta
	if s.Items == nil {
		return result
	}
	result.Items = make([]Stack, len(s.Items))
	for ix, s := range s.Items {
		result.Items[ix] = *s.clone()
	}
	return result
}

func (s *Stack) clone() *Stack {
	if s == nil {
		return nil
	}
	result := new(Stack)
	result.TypeMeta = s.TypeMeta
	result.ObjectMeta = s.ObjectMeta
	result.Spec = s.Spec.DeepCopy()
	result.Status = s.Status.clone()
	return result
}

// StackSpec defines the desired state of Stack
// +k8s:deepcopy-gen=true
type StackSpec struct {
	Services []ServiceConfig            `json:"services,omitempty"`
	Secrets  map[string]SecretConfig    `json:"secrets,omitempty"`
	Configs  map[string]ConfigObjConfig `json:"configs,omitempty"`
}

// ServiceConfig is the configuration of one service
// +k8s:deepcopy-gen=true
type ServiceConfig struct {
	Name string `json:"name,omitempty"`

	CapAdd              []string                 `json:"cap_add,omitempty"`
	CapDrop             []string                 `json:"cap_drop,omitempty"`
	Command             []string                 `json:"command,omitempty"`
	Configs             []ServiceConfigObjConfig `json:"configs,omitempty"`
	Deploy              DeployConfig             `json:"deploy,omitempty"`
	Entrypoint          []string                 `json:"entrypoint,omitempty"`
	Environment         map[string]*string       `json:"environment,omitempty"`
	ExtraHosts          []string                 `json:"extra_hosts,omitempty"`
	Hostname            string                   `json:"hostname,omitempty"`
	HealthCheck         *HealthCheckConfig       `json:"health_check,omitempty"`
	Image               string                   `json:"image,omitempty"`
	Ipc                 string                   `json:"ipc,omitempty"`
	Labels              map[string]string        `json:"labels,omitempty"`
	Pid                 string                   `json:"pid,omitempty"`
	Ports               []ServicePortConfig      `json:"ports,omitempty"`
	Privileged          bool                     `json:"privileged,omitempty"`
	ReadOnly            bool                     `json:"read_only,omitempty"`
	Secrets             []ServiceSecretConfig    `json:"secrets,omitempty"`
	StdinOpen           bool                     `json:"stdin_open,omitempty"`
	StopGracePeriod     *time.Duration           `json:"stop_grace_period,omitempty"`
	Tmpfs               []string                 `json:"tmpfs,omitempty"`
	Tty                 bool                     `json:"tty,omitempty"`
	User                *int64                   `json:"user,omitempty"`
	Volumes             []ServiceVolumeConfig    `json:"volumes,omitempty"`
	WorkingDir          string                   `json:"working_dir,omitempty"`
	PullSecret          string                   `json:"pull_secret,omitempty"`
	PullPolicy          string                   `json:"pull_policy,omitempty"`
	InternalPorts       []InternalPort           `json:"internal_ports,omitempty"`
	InternalServiceType InternalServiceType      `json:"internal_service_type,omitempty"`
}

// InternalServiceType defines the strategy for defining the Service Type to use for inter-service networking
type InternalServiceType string

const (
	// InternalServiceTypeAuto behavior is the same as InternalServiceTypeHeadless if InternalPorts is empty, InternalServiceTypeClusterIP otherwise
	InternalServiceTypeAuto = InternalServiceType("")
	// InternalServiceTypeHeadless always create a Headless service
	InternalServiceTypeHeadless = InternalServiceType("Headless")
	// InternalServiceTypeClusterIP always create a ClusterIP service
	InternalServiceTypeClusterIP = InternalServiceType("ClusterIP")
)

// ServicePortConfig is the port configuration for a service
// +k8s:deepcopy-gen=true
type ServicePortConfig struct {
	Mode      string `json:"mode,omitempty"`
	Target    uint32 `json:"target,omitempty"`
	Published uint32 `json:"published,omitempty"`
	Protocol  string `json:"protocol,omitempty"`
}

// FileObjectConfig is a config type for a file used by a service
// +k8s:deepcopy-gen=true
type FileObjectConfig struct {
	Name     string            `json:"name,omitempty"`
	File     string            `json:"file,omitempty"`
	External External          `json:"external,omitempty"`
	Labels   map[string]string `json:"labels,omitempty"`
}

// SecretConfig for a secret
// +k8s:deepcopy-gen=true
type SecretConfig FileObjectConfig

// ConfigObjConfig is the config for the swarm "Config" object
// +k8s:deepcopy-gen=true
type ConfigObjConfig FileObjectConfig

// External identifies a Volume or Network as a reference to a resource that is
// not managed, and should already exist.
// External.name is deprecated and replaced by Volume.name
// +k8s:deepcopy-gen=true
type External struct {
	Name     string `json:"name,omitempty"`
	External bool   `json:"external,omitempty"`
}

// FileReferenceConfig for a reference to a swarm file object
// +k8s:deepcopy-gen=true
type FileReferenceConfig struct {
	Source string  `json:"source,omitempty"`
	Target string  `json:"target,omitempty"`
	UID    string  `json:"uid,omitempty"`
	GID    string  `json:"gid,omitempty"`
	Mode   *uint32 `json:"mode,omitempty"`
}

// ServiceConfigObjConfig is the config obj configuration for a service
// +k8s:deepcopy-gen=true
type ServiceConfigObjConfig FileReferenceConfig

// ServiceSecretConfig is the secret configuration for a service
// +k8s:deepcopy-gen=true
type ServiceSecretConfig FileReferenceConfig

// DeployConfig is the deployment configuration for a service
// +k8s:deepcopy-gen=true
type DeployConfig struct {
	Mode          string            `json:"mode,omitempty"`
	Replicas      *uint64           `json:"replicas,omitempty"`
	Labels        map[string]string `json:"labels,omitempty"`
	UpdateConfig  *UpdateConfig     `json:"update_config,omitempty"`
	Resources     Resources         `json:"resources,omitempty"`
	RestartPolicy *RestartPolicy    `json:"restart_policy,omitempty"`
	Placement     Placement         `json:"placement,omitempty"`
}

// UpdateConfig is the service update configuration
// +k8s:deepcopy-gen=true
type UpdateConfig struct {
	Parallelism *uint64 `json:"paralellism,omitempty"`
}

// Resources the resource limits and reservations
// +k8s:deepcopy-gen=true
type Resources struct {
	Limits       *Resource `json:"limits,omitempty"`
	Reservations *Resource `json:"reservations,omitempty"`
}

// Resource is a resource to be limited or reserved
// +k8s:deepcopy-gen=true
type Resource struct {
	NanoCPUs    string `json:"cpus,omitempty"`
	MemoryBytes int64  `json:"memory,omitempty"`
}

// RestartPolicy is the service restart policy
// +k8s:deepcopy-gen=true
type RestartPolicy struct {
	Condition string `json:"condition,omitempty"`
}

// Placement constraints for the service
// +k8s:deepcopy-gen=true
type Placement struct {
	Constraints *Constraints `json:"constraints,omitempty"`
}

// Constraints lists constraints that can be set on the service
// +k8s:deepcopy-gen=true
type Constraints struct {
	OperatingSystem *Constraint
	Architecture    *Constraint
	Hostname        *Constraint
	MatchLabels     map[string]Constraint
}

// Constraint defines a constraint and it's operator (== or !=)
// +k8s:deepcopy-gen=true
type Constraint struct {
	Value    string
	Operator string
}

// HealthCheckConfig the healthcheck configuration for a service
// +k8s:deepcopy-gen=true
type HealthCheckConfig struct {
	Test     []string       `json:"test,omitempty"`
	Timeout  *time.Duration `json:"timeout,omitempty"`
	Interval *time.Duration `json:"interval,omitempty"`
	Retries  *uint64        `json:"retries,omitempty"`
}

// ServiceVolumeConfig are references to a volume used by a service
// +k8s:deepcopy-gen=true
type ServiceVolumeConfig struct {
	Type     string `json:"type,omitempty"`
	Source   string `json:"source,omitempty"`
	Target   string `json:"target,omitempty"`
	ReadOnly bool   `json:"read_only,omitempty"`
}

// StackPhase is the deployment phase of a stack
type StackPhase string

// These are valid conditions of a stack.
const (
	// StackAvailable means the stack is available.
	StackAvailable StackPhase = "Available"
	// StackProgressing means the deployment is progressing.
	StackProgressing StackPhase = "Progressing"
	// StackFailure is added in a stack when one of its members fails to be created
	// or deleted.
	StackFailure StackPhase = "Failure"
	// StackReconciliationPending means the stack has not yet been reconciled
	StackReconciliationPending StackPhase = "ReconciliationPending"
)

// StackStatus defines the observed state of Stack
type StackStatus struct {
	// Current condition of the stack.
	// +optional
	Phase StackPhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=StackPhase"`
	// A human readable message indicating details about the stack.
	// +optional
	Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}

func (s *StackStatus) clone() *StackStatus {
	if s == nil {
		return nil
	}
	result := *s
	return &result
}

// Clone clones a Stack
func (s *Stack) Clone() *Stack {
	return s.clone()
}

// InternalPort describes a Port exposed internally to other services
// in the stack
// +k8s:deepcopy-gen=true
type InternalPort struct {
	Port     int32       `json:"port,omitempty"`
	Protocol v1.Protocol `json:"protocol,omitempty"`
}