distributed

type Client struct {
	ProtoBuf *sync.Map //ct id -> protocol instance *Protocol

	//comms
	ServerAddr *net.TCPAddr
	Network    latency.Network

	Box cipherUtils.CkksBox
	// contains filtered or unexported fields
}

type DistributedBtp struct {
	// contains filtered or unexported fields
}

type LocalMaster struct {
	ProtoBuf *sync.Map //ct id -> protocol instance *Protocol

	Cpk     *rlwe.PublicKey
	Params  ckks.Parameters
	Parties int
	Network latency.Network
	//comms
	Addr        *net.TCPAddr
	PartiesAddr []*net.TCPAddr

	Done chan bool //flag caller that master is done with all instances
	// contains filtered or unexported fields
}

type LocalPlayer struct {
	Remote
	PCKS *dckks.PCKSProtocol    //PubKeySwitch
	BTP  *dckks.RefreshProtocol //Bootstrap

	Cpk    *rlwe.PublicKey
	Params ckks.Parameters
	Id     int
	Addr   *net.TCPAddr
	Conn   net.Listener
	// contains filtered or unexported fields
}

type MaskProtocol struct {
	Ct *ckks.Ciphertext //ct to be blindly decrypted
	//Mask         *ckks.Plaintext  //used for masking
	Mask         *ring.Poly      //used for masking
	Pt           *ckks.Plaintext //result of decryption by server
	FeedbackChan chan *ckks.Plaintext
}

type PCKSExt struct {
	Pk []byte `json:"pk"` //Pub Key from Querier -> PubKeySwitch
}

type Protocol struct {
	Protocol interface{}      //instance of protocol
	Crp      drlwe.CKSCRP     //Common reference poly if any
	Ct       *ckks.Ciphertext //ciphertext of the protocol

	Shares       []interface{}         //collects shares from parties
	Completion   int                   //counter to completion
	FeedbackChan chan *ckks.Ciphertext //final result of protocol
	// contains filtered or unexported fields
}

type ProtocolMsg struct {
	Type ProtocolType `json:"type"`
	Id   int          `json:"id"` //this is the id of the ct in the Enc Block Matrix, like i*row+j
	Ct   []byte       `json:"ct"` //ciphertext

	//Protocol Dependent
	Extension interface{} `json:"extension"`
}

type ProtocolResp struct {
	ProtoId  int          `json:"protoId"`
	Type     ProtocolType `json:"type"`
	PlayerId int          `json:"playerId"`
	Share    []byte       `json:"share"`
}

type ProtocolType int16

type RefreshExt struct {
	Crp       []byte  `json:"crp"`       //Common poly from CRS -> Refresh
	Precision int     `json:"precision"` //Precision for instance of Refresh Protocol
	MinLevel  int     `json:"minlevel"`
	Scale     float64 `json:"scale"`
}

type Remote interface {
	Listen()
}

type Server struct {
	Remote
	Box  cipherUtils.CkksBox
	Addr *net.TCPAddr
	Conn net.Listener
}

type ServerMsg struct {
	Sk *rlwe.SecretKey `json:"sk,omitempty"`
}

type SetupMsg struct {
	SkShare *rlwe.SecretKey `json:"skShare,omitempty"`
	Pk      *rlwe.PublicKey `json:"pk,omitempty"`
	Id      int             `json:"id,omitempty"`
}