storage

type CreateTxDto struct {
	PluginID      types.PluginID
	ChainID       common.Chain
	PolicyID      uuid.UUID
	TokenID       string
	FromPublicKey string
	ToPublicKey   string
	ProposedTxHex string
	Amount        string
}

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

type RowsStream[T any] struct {
	Row T
	Err error
}

type Tx struct {
	ID            uuid.UUID            `json:"id" validate:"required"`
	PluginID      types.PluginID       `json:"plugin_id" validate:"required"`
	TxHash        *string              `json:"tx_hash"`
	ChainID       int                  `json:"chain_id" validate:"required"`
	PolicyID      uuid.UUID            `json:"policy_id" validate:"required"`
	TokenID       string               `json:"token_id" validate:"required"`
	FromPublicKey string               `json:"from_public_key" validate:"required"`
	ToPublicKey   string               `json:"to_public_key" validate:"required"`
	ProposedTxHex string               `json:"proposed_tx_hex" validate:"required"`
	Amount        *string              `json:"amount"`
	Status        TxStatus             `json:"status" validate:"required"`
	StatusOnChain *rpc.TxOnChainStatus `json:"status_onchain"`
	ErrorMessage  *string              `json:"error_message"`
	Lost          bool                 `json:"lost"`
	BroadcastedAt *time.Time           `json:"broadcasted_at"`
	CreatedAt     time.Time            `json:"created_at"  validate:"required"`
	UpdatedAt     time.Time            `json:"updated_at" validate:"required"`
}

type TxIndexerRepo interface {
	SetStatus(ctx context.Context, id uuid.UUID, status TxStatus) error
	SetLost(ctx context.Context, id uuid.UUID, errorMessage string) error
	SetSignedAndBroadcasted(ctx context.Context, id uuid.UUID, txHash string) error
	SetOnChainStatus(ctx context.Context, id uuid.UUID, status rpc.TxOnChainStatus, errorMessage *string) error
	GetPendingTxs(ctx context.Context) <-chan RowsStream[Tx]
	CreateTx(ctx context.Context, req CreateTxDto) (Tx, error)
	GetTxByID(ctx context.Context, id uuid.UUID) (Tx, error)
	GetTxsInTimeRange(ctx context.Context, policyID uuid.UUID, from, to time.Time) <-chan RowsStream[Tx]
	GetByPolicyID(ctx context.Context, policyID uuid.UUID, skip, take uint32) <-chan RowsStream[Tx]
	CountByPolicyID(ctx context.Context, policyID uuid.UUID) (uint32, error)
	GetByPluginIDAndPublicKey(ctx context.Context, pluginID types.PluginID, publicKey string, skip, take uint32) <-chan RowsStream[Tx]
	CountByPluginIDAndPublicKey(ctx context.Context, pluginID types.PluginID, publicKey string) (uint32, error)
	GetByPublicKey(ctx context.Context, publicKey string, skip, take uint32) <-chan RowsStream[Tx]
	CountByPublicKey(ctx context.Context, publicKey string) (uint32, error)
}

type TxStatus string