drpc

type AddPin struct {
	DBID   uint
	UserId uint
	Cid    cid.Cid
	Peers  []*peer.AddrInfo
}

type AggregateContent struct {
	DBID     uint
	UserID   uint
	Contents []uint
	Root     cid.Cid
	ObjData  []byte
}

type CleanupPreparedRequest struct {
	DealDBID  uint
	AuthToken string
}

type CmdParams struct {
	AddPin                 *AddPin                 `json:",omitempty"`
	ComputeCommP           *ComputeCommP           `json:",omitempty"`
	TakeContent            *TakeContent            `json:",omitempty"`
	AggregateContent       *AggregateContent       `json:",omitempty"`
	StartTransfer          *StartTransfer          `json:",omitempty"`
	PrepareForDataRequest  *PrepareForDataRequest  `json:",omitempty"`
	CleanupPreparedRequest *CleanupPreparedRequest `json:",omitempty"`
	ReqTxStatus            *ReqTxStatus            `json:",omitempty"`
	SplitContent           *SplitContent           `json:",omitempty"`
	RetrieveContent        *RetrieveContent        `json:",omitempty"`
	UnpinContent           *UnpinContent           `json:",omitempty"`
	RestartTransfer        *RestartTransfer        `json:",omitempty"`
}

type CommPComplete struct {
	Data    cid.Cid
	CommP   cid.Cid
	CarSize uint64
	Size    abi.UnpaddedPieceSize
}

type Command struct {
	Op           string
	Params       CmdParams
	TraceCarrier *TraceCarrier `json:",omitempty"`
}

type ComputeCommP struct {
	Data cid.Cid
}

type ContentFetch struct {
	ID     uint
	Cid    cid.Cid
	UserID uint
}

type GarbageCheck struct {
	Contents []uint
}

type Hello struct {
	Host   string
	PeerID string

	DiskSpaceFree int64

	Address  address.Address
	AddrInfo peer.AddrInfo
	Private  bool
}

type Message struct {
	Op           string
	Params       MsgParams
	TraceCarrier *TraceCarrier `json:",omitempty"`
}

type MsgParams struct {
	UpdatePinStatus *UpdatePinStatus `json:",omitempty"`
	PinComplete     *PinComplete     `json:",omitempty"`
	CommPComplete   *CommPComplete   `json:",omitempty"`
	TransferStatus  *TransferStatus  `json:",omitempty"`
	TransferStarted *TransferStarted `json:",omitempty"`
	ShuttleUpdate   *ShuttleUpdate   `json:",omitempty"`
	GarbageCheck    *GarbageCheck    `json:",omitempty"`
	SplitComplete   *SplitComplete   `json:",omitempty"`
}

type PinComplete struct {
	DBID uint
	Size int64

	Objects []PinObj
}

type PinObj struct {
	Cid  cid.Cid
	Size int
}

type PrepareForDataRequest struct {
	DealDBID    uint
	AuthToken   string
	ProposalCid cid.Cid
	PayloadCid  cid.Cid
	Size        uint64
}

type ReqTxStatus struct {
	DealDBID uint
	ChanID   string
}

type RestartTransfer struct {
	ChanID datatransfer.ChannelID
}

type RetrieveContent struct {
	Content uint
	Cid     cid.Cid
	Deals   []StorageDeal
}

type ShuttleUpdate struct {
	BlockstoreSize uint64
	BlockstoreFree uint64
	NumPins        int64
	PinQueueSize   int
}

type SplitComplete struct {
	ID uint
}

type SplitContent struct {
	Content uint
	Size    int64
}

type StartTransfer struct {
	DealDBID  uint
	ContentID uint
	Miner     address.Address
	PropCid   cid.Cid
	DataCid   cid.Cid
}

type StorageDeal struct {
	Miner  address.Address
	DealID int64
}

type TakeContent struct {
	Contents []ContentFetch
	Sources  []peer.AddrInfo
}

type TraceCarrier struct {
	TraceID trace.TraceID `json:"traceID"`
	SpanID  trace.SpanID  `json:"spanID"`
	Remote  bool          `json:"remote"`
}

type TransferStarted struct {
	DealDBID uint
	Chanid   string
}

type TransferStatus struct {
	Chanid   string
	DealDBID uint

	State *filclient.ChannelState

	Failed  bool
	Message string
}

type UnpinContent struct {
	Contents []uint
}

type UpdatePinStatus struct {
	DBID   uint
	Status types.PinningStatus
}