blizcore

type BlizObjectMeta struct {
	Name       string         // 名称
	Length     uint64         // 长度
	Permission uint64         // （rw）权限
	Owner      common.Address // 对象属主（tenant)

	// 根据 length 可以计算出当前占用了多少个 slice
	SliceInfos []SliceInfo // 内容所在的所有slice信息
}

type BuffFromSharerCSData struct {
	ID   string
	Buff []byte
}

type DataQuery interface {
	SetQuerId(queryId uint64)
}

type DiscReason uint

type ErrCode int

type FarmerSliceOp struct {
	ChunkId uint64
	SliceId uint32
	OpId    uint64
}

type FarmerSliceOpReq struct {
	ObjUId     string
	SliceInfos []SliceInfo
}

type FarmerSliceOpRsp struct {
	ObjUId         string
	FarmerSliceOps []FarmerSliceOp
	NodeId         discover.NodeID
}

type GetBuffFromSharerCSData struct {
	Sharer    string
	ObjId     uint64
	Offset    uint64
	Len       uint64
	SigPeerId string
}

type GetHeaderHashMsgData struct {
	Chunk uint64
	Slice uint32
}

type GetSegmentDataMsgData struct {
	Chunk   uint64
	Slice   uint32
	Segment uint32 // 获取的起始 Segment index
	Count   uint32 // 获取 Segment 数量

	QueryId uint64
}

type GetSliceInfoMsgData struct {
	Chunk uint64
	Slice uint32

	QueryId uint64
}

type GetSliceMetaFromFarmerReqData struct {
	Address common.Address
}

type GetWriteDataMsgData struct {
	Chunk uint64
	Slice uint32
}

type GetWriteOpMsgData struct {
	Chunk     uint64
	Slice     uint32
	FromWopId uint64
	Count     uint32 // 暂时不考虑，默认为1

	QueryId uint64
}

type HeaderHashMsgData struct {
	Rsp        *GetHeaderHashMsgData
	HeaderHash common.Hash
	OpId       uint64
}

type HeartBeatMsgData struct {
	Ts      uint64
	ChunkId uint64
	Progs   []*SliceWopProg

	// Signature values( for Id & Hash(Datas) & Infos & Chunk & Slice)
	Signature []byte
}

type ReadOperReqData struct {
	Id     uint64
	Chunk  uint64
	Slice  uint32
	Offset uint32
	Length uint32
	Type   uint8 // 0: data, 1: hash
	NodeId discover.NodeID
	ObjId  string
}

type ReadOperRspData struct {
	ReadOperReqData
	ErrBytes []byte
	Data     []byte
}

type SegmentDataMsgData struct {
	Chunk   uint64
	Slice   uint32
	Segment uint32 // 返回的起始 Segment Index
	Count   uint32 // 获取 Segment 数量

	QueryId uint64
	// contains filtered or unexported fields
}

type SliceInfo struct {
	ChunkId uint64
	SliceId uint32
}

type SliceInfoMsgData struct {
	Chunk uint64
	Slice uint32

	QueryId uint64

	WopProg      uint64   // 当前slice的 wopId 进度
	SegmentHashs [][]byte // 当前slice中所有 segment 的 hash 值列表

	Signature []byte // tenant 为 WopProg + Hash(SegmentHashs) 的签名，可以由上面两个值来计算校验
}

type SliceWopProg struct {
	Slice uint32
	WopId uint64
}

type WopData struct {
	WopId uint64
}

type WopInfo struct {
	WopId uint64
	WopTs uint64

	Chunk uint64 // 该 Wop 涉及的Chunk:Slice
	Slice uint32

	Infos *[]*WriteDataInfoS // 一组写入数据的相关Info

	Type       uint8 // 0: write data, 1: checked header hash
	HeaderHash common.Hash

	// Signature values( for Id & Hash(Datas) & Infos & Chunk & Slice)
	V *big.Int //`json:"v" gencodec:"required"`
	R *big.Int //`json:"r" gencodec:"required"`
	S *big.Int //`json:"s" gencodec:"required"`

	AuthAddress   common.Address
	AuthDeadlineC uint64
	RC            *big.Int // comming from client
	SC            *big.Int // comming from client
	VC            *big.Int // comming from client
}

type WriteDataInfoS struct {
	Offset uint32
	Length uint32
	Hash   []byte // Data 的 hash, 取末尾4字节
}

type WriteDataMsgData struct {
	Rsp    *GetWriteDataMsgData
	Header *storagecore.SliceHeader
	Data   []byte
}

type WriteOpMsgData struct {
	QueryId uint64

	Info  *WopInfo
	Datas [][]byte // 一组写入数据（跟Infos一一对应）
}

type WriteOperReqData struct {
	Info   *WopInfo
	Datas  [][]byte // 一组写入数据（跟Infos一一对应）
	ObjUId string
	Sign   []byte
}

type WriteOperRspData struct {
	Chunk      uint64
	Slice      uint32
	Id         uint64 // WopId
	Status     uint32 // return status: success or fail
	ErrBytes   []byte
	Type       uint8       // 0: write data, 1: checked data hash, stored at local
	HeaderHash common.Hash // for signing
	ObjUId     string
	Infos      *[]*WriteDataInfoS
}