common

type BatchReadReply struct {
	Err     string
	Replies []ReadReply
}

type BatchReadRequest struct {
	Args       []EncodedReadArgs // Set of Read requests
	SeqNoRange Range
	ReplyChan  chan *BatchReadReply `json:"-"`
}

type Config struct {
	// How many buckets are in the server?
	NumBuckets uint64
	// How many items are in a bucket?
	BucketDepth uint64
	// How many bytes are in an item?
	DataSize uint64 // Number of bytes
	// False positive rate of interest vectors
	BloomFalsePositive float64
	// Minimum period between writes
	WriteInterval time.Duration `json:",string"`
	// Minimum period between reads
	ReadInterval time.Duration `json:",string"`
	// On what multiple of write intervals will new interest vectors be computed
	InterestMultiple uint64
	// Base seed for hashing interest vectors
	InterestSeed int64
	// Max fraction of DB capacity that can store messages
	MaxLoadFactor float64

	/** @todo remove below **/
	// What fraction of items should be removed from the DB when items are removed?
	LoadFactorStep float64
}

type EncodedReadArgs struct {
	ClientKey [32]byte
	Nonce     [24]byte
	PirArgs   [][]byte //An encrypted PirArgs for each trust domain
}

type Error string

type FrontendInterface interface {
	GetName(args *interface{}, reply *string) error
	GetConfig(args *interface{}, reply *Config) error
	Write(args *WriteArgs, reply *WriteReply) error
	Read(args *EncodedReadArgs, reply *ReadReply) error
	GetUpdates(args *GetUpdatesArgs, reply *GetUpdatesReply) error
}

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

type GetUpdatesArgs struct {
}

type GetUpdatesReply struct {
	Err            string
	InterestVector []byte
	Signature      [][32]byte
}

type Logger struct {
	Trace *log.Logger
	Info  *log.Logger
	Warn  *log.Logger
	Error *log.Logger
	// contains filtered or unexported fields
}

type PirArgs struct {
	RequestVector []byte
	PadSeed       []byte
}

type PrivateTrustDomainConfig struct {
	*TrustDomainConfig
	PrivateKey     [32]byte
	SignPrivateKey [64]byte
}

type Range struct {
	Start   uint64 //inclusive
	End     uint64 //exclusive
	Aborted []uint64
}

type ReadArgs struct {
	TD []PirArgs
}

type ReadReply struct {
	Err            string
	Data           []byte
	GlobalSeqNo    Range
	LastInterestSN uint64
}

type ReadRequest struct {
	Args      *EncodedReadArgs
	ReplyChan chan *ReadReply
}

type ReplicaInterface interface {
	Write(args *ReplicaWriteArgs, reply *ReplicaWriteReply) error
	BatchRead(args *BatchReadRequest, reply *BatchReadReply) error
}

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

type ReplicaWriteArgs struct {
	WriteArgs
	EpochFlag    bool
	InterestFlag bool
}

type ReplicaWriteReply struct {
	Err         string
	GlobalSeqNo uint64
	InterestVec []byte
	Signature   []byte
}

type TrustDomainConfig struct {
	Name          string
	Address       string
	IsValid       bool
	IsDistributed bool
	PublicKey     [32]byte // For PIR Encryption
	SignPublicKey [32]byte // For Signing Interest Vectors
	// contains filtered or unexported fields
}

type WriteArgs struct {
	Bucket1        uint64
	Bucket2        uint64
	Data           []byte
	InterestVector []byte // sha256 hash - expect 32bytes
	//Internal
	GlobalSeqNo uint64
	ReplyChan   chan *WriteReply `json:"-"`
}

type WriteReply struct {
	Err         string
	GlobalSeqNo uint64
}