package util

import (
	"fmt"

	"basic.com/pubsub/protomsg.git"
	"basic.com/r/dbapi.git"
	"basic.com/valib/gopherdiscovery.git"
	"github.com/gogo/protobuf/proto"
)

/*************************
* 1. store all struct data
* 2. define function for get difference data type
* 3. recive data from sqlite process. and call conpos function.
***********************/

var camval dbapi.CameraApi
var taskapi dbapi.TaskApi
var sdkapi dbapi.SdkApi
var IsInit bool

var CameraIds []protomsg.Camera
var CameraTasks []protomsg.CameraAndTaskInfo

var TaskSdks []protomsg.TaskSdkInfo
var Sdklist []string

var urlServer = "tcp://192.168.1.11:40007"
var urlPubSub = "tcp://192.168.1.11:50007"
var peers chan []string

var newsdkmsg = &protomsg.DbChangeMessage{}

func Getdata(opt []byte, initchan chan bool) {

	if err := proto.Unmarshal(opt, newsdkmsg); err != nil {
		fmt.Println("publichshMessage ", err)
		return
	}

	if !IsInit {
		fmt.Println("enter init.")
		CameraIds = camval.FindAll()

		fmt.Println("==============camera camera with task ================")
		CameraTasks = camval.FindAllCameraAndTask()
		fmt.Println(CameraTasks)

		TaskSdks = taskapi.FindAll()

		Sdklist = sdkapi.GetAllSdkIds()
		fmt.Println(Sdklist)
		IsInit = true
		initchan <- true
		return
	}

	switch newsdkmsg.Table {
	case protomsg.TableChanged_T_Camera:
		CameraIds = camval.FindAll()
	case protomsg.TableChanged_T_CameraTask:
		CameraTasks = camval.FindAllCameraAndTask()
	case protomsg.TableChanged_T_TaskSdk:
		TaskSdks = taskapi.FindAll()
	case protomsg.TableChanged_T_Sdk:
		Sdklist = sdkapi.GetAllSdkIds()
	}

	fmt.Println(newsdkmsg)
}

func Init(initchan chan bool) {
	clientOne, _ := gopherdiscovery.ClientWithSub(urlServer, urlPubSub, "ip:192.168.1.124")
	peers, _ = clientOne.Peers()
	for x := range peers {
		Getdata([]byte(x[0]), initchan)
	}
}