package components
  

  import "google.golang.org/protobuf/reflect/protoreflect"
  

  //-----------------
  //----net start----
  //-----------------
  type (
  	//网络包头
  	IHead interface {
  		GetDataLen() uint32  //获取消息数据段长度
  		GetMsgID() uint32    //获取消息ID
  		GetErrCode() int32   //获取消息错误码
  		GetPreserve() uint32 //获取预留数据
  	}
  	//网络包
  	IMessage interface {

  		GetHeader() IHead       //获取消息头
  		SetHeader(header IHead) //设置消息头
  
  		GetData() []byte //获取消息内容
  		SetData([]byte)  //设置消息内容
  
  		SetSession(IConnection)  //设置连接
  		GetSession() IConnection //获取连接
  	}
  	//网络拆包解包器
  	ISplitter interface {
  		UnPack([]byte) (IMessage, error)
  		Pack(cmd uint32, data []byte, errcode int32, preserve uint32) ([]byte, error)
  		ParseMsg(data []byte, atEOF bool) (advance int, token []byte, err error)
  		GetHeadLen() uint32
  	}

  	//加解密
  	IEncipher interface {
  		Encrypt([]byte) ([]byte, error)
  		Decrypt([]byte) ([]byte, error)
  	}
  

  	ConnectionCallback func(IConnection)
  	CloseCallback      func(IConnection)
  	MessageCallback    func(IMessage)
  	TimerCallback      func(IConnection)
  	//链接
  	IConnection interface {

  		GetID() uint32

  		Start()
  		Stop()

  		Send(errCode int32, cmd uint32, b []byte) error

  
  		SetConnectionCallback(ConnectionCallback)
  		SetMessageCallback(MessageCallback)
  		SetCloseCallback(CloseCallback)
  		SetTimerCallback(TimerCallback)
  	}

  	//connManage
  	IConnManage interface {

  		AddConn(id uint32, connection IConnection)
  		GetConn(id uint32) IConnection
  		DelConn(id uint32) IConnection

  		Range(f func(key interface{}, value interface{}) bool)
  		StopAllConns()
  	}

  	//server
  	IServer interface {
  		Start() error
  		Stop()
  
  		GetSplitter() ISplitter

  		GetPlugin() IPlugin
  		GetAction(uint32) interface{}

  		SetActions(map[interface{}]interface{})

  		GetConnManage() IConnManage

  
  		SetConnectionCallback(ConnectionCallback)
  		SetMessageCallback(MessageCallback)
  		SetCloseCallback(CloseCallback)
  		SetTimerCallback(TimerCallback)
  	}
  

  	//Connector
  	IConnector interface {
  		Connect() error
  		DisConnect()
  
  		Send(cmd uint32, b []byte)
  	}
  

  	//httpserver
  	IHttp interface {
  		Start() error
  		Stop()
  		BindHandler(interface{})
  	}

  	ActionHandler func(msg IMessage) (int32, interface{})

  	//用于热更逻辑的插件接口
  	IPlugin interface {
  		LoadPlugin() error
  		SetActions(map[interface{}]interface{})
  		GetAction(uint32) interface{}
  	}

  )
  
  //-----------------
  //-----db start----
  //-----------------
  type (
  	IDB interface {
  		CreateTable() error
  
  		Create() (interface{}, error)

  		Save() error

  		Load() error
  		FindOne() error
  		UpdateProperty(key string, val interface{}) error
  		UpdateProperties(properties map[string]interface{}) error
  
  		SetUnique(key string) (string, error)
  	}
  
  	ISchema interface {
  		Init()
  		GetDB() IDB
  
  		GetPri() interface{}
  		GetSchema() interface{}
  		GetSchemaName() string
  
  		Load() error
  		Create() error

  		Save() error

  		Update()
  
  		SetProperty(key string, val interface{})
  		SetProperties(properties map[string]interface{})

  		ParseFields(message protoreflect.Message, properties map[string]interface{}) []int32

  	}
  )
  
  //-----------------
  //-----db end------
  //-----------------