package actuator

import (
	"log"
	"time"
)

/*
@Time : 2021/10/21 下午5:11
@Author : Zhouyc
*/

func main()  {
	for {

		commandList, err :=GetRunnableSlotList()
		if err != nil {
			log.Printf("getRunnableSlotList error:%v", err)
			logger.Printf("getRunnableSlotList error:%v", err)
		}else {

			if len(commandList) != 0 {
				for _, cmdPkg := range commandList {
					cmdPkg := cmdPkg
					go func() {
						err:=Instantiate(cmdPkg)
						if err!=nil{
							logger.Printf("Launch container failure:%v",err)
							return
						}
						err = SetSlotInitialized(cmdPkg)
						if err != nil {
							logger.Printf("setSlotInit grpc error:%v", err)
							return
						}
					}()
				}
			}
		}

		commandList,err=GetRunnableDaemonList()
		if err != nil {
			log.Printf("getRunnableDaemonList error:%v", err)
			logger.Printf("getRunnableDaemonList error:%v", err)
		}else {

			if len(commandList) != 0 {
				for _, cmdPkg := range commandList {
					cmdPkg := cmdPkg
					go func() {
						err:=Instantiate(cmdPkg)
						if err!=nil{
							logger.Printf("Launch container failure:%v",err)
							return
						}
						err = SetRunnableDaemonInitialized(cmdPkg)
						if err != nil {
							logger.Printf("setDaemonInit grpc error:%v", err)
							return
						}
					}()
				}
			}
		}

		commandList,err=GetTerminatedDaemonList()
		if err != nil {
			log.Printf("getTerminatedDaemonList error:%v", err)
			logger.Fatalf("getTerminatedDaemonList error:%v", err)
		}else {

			if len(commandList) != 0 {
				for _, cmdPkg := range commandList {
					cmdPkg := cmdPkg
					go func() {
						err:=Instantiate(cmdPkg)
						if err!=nil{
							logger.Printf("Launch container failure:%v",err)
							return
						}
						err = SetRunnableDaemonTerminated(cmdPkg)
						if err != nil {
							logger.Printf("setDaemonTerminated grpc error:%v", err)
							return
						}
					}()
				}
			}
		}


		time.Sleep(time.Second*120)
	}

}