event

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

type AggregateContent struct {
	ID   uint64
	CID  cid.Cid
	Name string
}

type AggregateContents struct {
	DBID     uint64
	UserID   uint
	Contents []AggregateContent
}

type CleanupPreparedRequest struct {
	DealDBID  uint
	AuthToken string
}

type CmdParams struct {
	AddPin                 *AddPin                 `json:",omitempty"`
	ComputeCommP           *ComputeCommP           `json:",omitempty"`
	TakeContent            *TakeContent            `json:",omitempty"`
	AggregateContent       *AggregateContents      `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 CommPFailed struct {
	Data cid.Cid
}

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

type ComputeCommP struct {
	Data cid.Cid
}

type ContentFetch struct {
	ID     uint64
	Cid    cid.Cid
	UserID uint
	Peers  []*peer.AddrInfo
}

type GarbageCheck struct {
	Contents []uint64
}

type Hello struct {
	Host                  string
	PeerID                string
	DiskSpaceFree         int64
	Address               address.Address
	AddrInfo              peer.AddrInfo
	Private               bool
	ContentAddingDisabled bool
	QueueEngEnabled       bool
}

type Hi struct {
	QueueEngEnabled bool
}

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

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

type PinComplete struct {
	DBID    uint64
	Size    int64
	CID     cid.Cid
	Objects []PinObj
}

type PinObj struct {
	Cid  cid.Cid
	Size uint64
}

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
	DealDBID  uint
	ContentID uint64
}

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

type SanityCheck struct {
	CID    cid.Cid
	ErrMsg string
}

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

type SplitComplete struct {
	ID uint64
}

type SplitContent struct {
	Content uint64
	Size    int64
}

type SplitFailed struct {
	ID uint64
}

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

type StorageDeal struct {
	Miner  address.Address
	DealID int64
}

type TakeContent struct {
	Contents []ContentFetch
}

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

type TransferStartedOrFinished struct {
	DealDBID uint
	Chanid   string
	State    *filclient.ChannelState
}

type TransferStatus struct {
	Message  string
	Chanid   string
	DealDBID uint
	State    *filclient.ChannelState
	Failed   bool
}

type UnpinContent struct {
	Contents []uint64
}

type UpdatePinStatus struct {
	DBID   uint64
	Status status.PinningStatus
}