txpool

type Chain interface {
	GetGenesisTxs(context.Context) (ld.Txs, error)
	GetAccount(context.Context, ids.Address) (*ld.Account, error)
	PreVerifyTxs(context.Context, ld.Txs) error
}

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

type Object struct {
	Raw []byte
	// -2: rejected, will be remove at expiration time
	// -1: wait for build, will be remove if not accepted before expiration time
	// 0: processing, will be remove if not accepted before expiration time, except genesis tx objects;
	// > 0: accepted, the height of block, the object is permanently stored.
	Height int64
}

type Objects []*Object

type POS interface {
	GetObject(ctx context.Context, bucket string, hash ids.ID32) (*Object, error)
	PutObject(ctx context.Context, bucket string, objectRaw []byte) error
	RemoveObject(ctx context.Context, bucket string, hash ids.ID32) error
	BatchAcquire(ctx context.Context, bucket string, hashList ids.IDList[ids.ID32]) error
	BatchAccept(ctx context.Context, bucket string, height uint64, hashList ids.IDList[ids.ID32]) error
	ListUnaccept(ctx context.Context, bucket, token string) (hashList ids.IDList[ids.ID32], nextToken string, err error)
}

type RequestParams struct {
	Payload cbor.RawMessage                `cbor:"p,omitempty"`
	CWT     *cose.Sign1Message[cwt.Claims] `cbor:"t,omitempty"`
}

type TxOrBatch struct {
	Tx           *ld.TxData  `cbor:"tx,omitempty"`
	Signatures   signer.Sigs `cbor:"ss,omitempty"`
	ExSignatures signer.Sigs `cbor:"es,omitempty"`
	Batch        ld.Txs      `cbor:"ba,omitempty"`
}

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

type TxPoolOptions struct {
	Builder     ids.Address
	CWTAudience string
	CWTExData   []byte
}

type TxsBuildStatus struct {
	Unknown  ids.IDList[ids.ID32] `cbor:"u,omitempty"`
	Rejected ids.IDList[ids.ID32] `cbor:"r,omitempty"`
}