/*
Copyright 2019 The Kubeedge Authors.

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

    http://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 util

import (
	"fmt"
	"os/exec"

	types "elcli/cmd/common"

)

//CentOS struct objects shall have information of the tools version to be installed
//on Hosts having Ubuntu OS.
//It implements OSTypeInstaller interface
type CentOS struct {
	DockerVersion     string
	KubernetesVersion string
	IsEdgeNode        bool //True - Edgenode False - Cloudnode
	K8SImageRepository string
	K8SPodNetworkCidr  string
}

//SetDockerVersion sets the Docker version for the objects instance
func (c *CentOS) SetDockerVersion(version string) {
	c.DockerVersion = version
}

//SetK8SVersionAndIsNodeFlag sets the K8S version for the objects instance
//It also sets if this host shall act as edge node or not
func (c *CentOS) SetK8SVersionAndIsNodeFlag(version string, flag bool) {
	c.KubernetesVersion = version
	c.IsEdgeNode = flag
}

//SetK8SImageRepoAndPodNetworkCidr sets the K8S image Repository and pod network
// cidr.
func (c *CentOS) SetK8SImageRepoAndPodNetworkCidr(repo, cidr string) {
	c.K8SImageRepository = repo
	c.K8SPodNetworkCidr = cidr
}

//IsDockerInstalled checks if docker is installed in the host or not
func (c *CentOS) IsDockerInstalled(string) (types.InstallState, error) {
	//yum list installed | grep docker-ce | awk '{print $2}' | cut -d'-' -f 1
	//18.06.1.ce

	return types.VersionNAInRepo, nil
	
}

//InstallDocker will install the specified docker in the host
func (c *CentOS) InstallDocker() error {
	fmt.Println("InstallDocker called")
	// yum install -y yum-utils
	// yum-config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo
	// yum makecache
	// yum list --showduplicates 'docker-ce' | grep '17.06.0' | head -1 | awk '{print $2}'
	// yum install -y docker-ce-17.06.0.ce-1.el7.centos
	// [root@localhost ~]# systemctl start docker
	// [root@localhost ~]# ---> Always restart  systemctl restart docker
	// [root@localhost ~]#
	// IF downgrade yum downgrade -y docker-ce-17.06.0.ce-1.el7.centos
	// Check always for version, if it is a downgrade or upgrade

	return nil
}

//IsToolVerInRepo checks if the tool mentioned in available in OS repo or not
func (c *CentOS) IsToolVerInRepo(toolName, version string) (bool, error) {
	//yum --cacheonly list | grep openssl
	//For K8S, dont check in repo, just install
	fmt.Println("IsToolVerInRepo called")
	return false, nil
}

//InstallMQTT checks if MQTT is already installed and running, if not then install it from OS repo
//Information is used from https://www.digitalocean.com/community/tutorials/how-to-install-and-secure-the-mosquitto-mqtt-messaging-broker-on-centos-7
func (c *CentOS) InstallMQTT() error {

	//yum -y install epel-release
	cmd := &Command{Cmd: exec.Command("sh", "-c", "yum -y install epel-release")}
	err := cmd.ExecuteCmdShowOutput()
	stdout := cmd.GetStdOutput()
	errout := cmd.GetStdErr()
	if err != nil || errout != "" {
		return fmt.Errorf("%s", errout)
	}
	fmt.Println(stdout)

	//yum -y install mosquitto	
	cmd = &Command{Cmd: exec.Command("sh", "-c", "yum -y install mosquitto")}
	err = cmd.ExecuteCmdShowOutput()
	stdout = cmd.GetStdOutput()
	errout = cmd.GetStdErr()
	if err != nil || errout != "" {
		return fmt.Errorf("%s", errout)
	}
	fmt.Println(stdout)


	//systemctl start mosquitto
	cmd = &Command{Cmd: exec.Command("sh", "-c", "systemctl start mosquitto")}
	cmd.ExecuteCommand()
	stdout = cmd.GetStdOutput()
	errout = cmd.GetStdErr()
	if errout != "" {
		return fmt.Errorf("%s", errout)
	}
	fmt.Println(stdout)

	//systemctl enable mosquitto
	cmd = &Command{Cmd: exec.Command("sh", "-c", "systemctl enable mosquitto")}
	cmd.ExecuteCommand()
	stdout = cmd.GetStdOutput()
	errout = cmd.GetStdErr()
	if errout != "" {
		return fmt.Errorf("%s", errout)
	}
	fmt.Println(stdout)


	return nil
}

//IsK8SComponentInstalled checks if said K8S version is already installed in the host
func (c *CentOS) IsK8SComponentInstalled(component, defVersion string) (types.InstallState, error) {
	// 	[root@localhost ~]# yum list installed | grep kubeadm | awk '{print $2}' | cut -d'-' -f 1
	// 1.14.1
	// [root@localhost ~]#
	// [root@localhost ~]# yum list installed | grep kubeadm
	// kubeadm.x86_64                          1.14.1-0                       @kubernetes
	// [root@localhost ~]#

	return types.VersionNAInRepo, nil
}

//InstallK8S will install kubeadm, kudectl and kubelet for the cloud node
func (c *CentOS) InstallK8S() error {
	fmt.Println("InstallK8S called")
	//Follow https://kubernetes.io/docs/setup/independent/install-kubeadm/
	return nil
}

//StartK8Scluster will do "kubeadm init" and cluster will be started
func (c *CentOS) StartK8Scluster() error {
	return nil
}