view

type BridgeActivities interface {
	FindByLinkId(linkId string) (BridgeActivityReadRow, error)
	FindBy(filter BridgeActivitiesFindByFilter) (BridgeActivityReadRow, error)
	ListByChainAddress(
		chain string,
		address string,
		order BridgeActivitiesListOrder,
		pagination *pagination_interface.Pagination,
	) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
	List(
		addressFilter BridgeActivitiesListAddressFilter,
		filter BridgeActivitiesListFilter,
		order BridgeActivitiesListOrder,
		pagination *pagination_interface.Pagination,
	) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
	Insert(activity *BridgeActivityInsertRow) error
	Update(activity *BridgeActivityReadRow) error
}

type BridgeActivitiesFindByFilter struct {
	MaybeLinkId        *string
	MaybeTransactionId *string
}

type BridgeActivitiesListAddressFilter = []BridgeActivitiesListAddressFilterCond

type BridgeActivitiesListAddressFilterCond struct {
	Chain   string
	Address string
}

type BridgeActivitiesListFilter struct {
	MaybeStatus                 *types.Status
	MaybeIdGt                   *string
	MaybeCreatedAtLt            *utctime.UTCTime
	MaybeCreatedAtGt            *utctime.UTCTime
	MaybeUpdatedAtGt            *utctime.UTCTime
	MaybeSourceBlockTimeLt      *utctime.UTCTime
	MaybeSourceBlockTimeGt      *utctime.UTCTime
	MaybeDestinationBlockTimeGt *utctime.UTCTime
}

type BridgeActivitiesListOrder struct {
	MaybeSourceBlockTime *view.ORDER
}

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

type BridgeActivityInsertRow struct {
	BridgeType                           types.BridgeType `json:"bridgeType"`
	SourceBlockHeight                    int64            `json:"sourceBlockHeight"`
	SourceBlockTime                      *utctime.UTCTime `json:"sourceBlockTime"`
	SourceTransactionId                  string           `json:"sourceTransactionId"`
	SourceChain                          string           `json:"sourceChain"`
	SourceAddress                        string           `json:"sourceAddress"`
	MaybeSourceSmartContractAddress      *string          `json:"sourceSmartContractAddress"`
	MaybeDestinationBlockHeight          *int64           `json:"destinationBlockHeight"`
	MaybeDestinationBlockTime            *utctime.UTCTime `json:"destinationBlockTime"`
	MaybeDestinationTransactionId        *string          `json:"destinationTransactionId"`
	DestinationChain                     string           `json:"destinationChain"`
	DestinationAddress                   string           `json:"destinationAddress"`
	MaybeDestinationSmartContractAddress *string          `json:"destinationSmartContractAddress"`
	MaybeChannelId                       *string          `json:"channelId"`
	LinkId                               string           `json:"-"`
	Amount                               coin.Int         `json:"amount"`
	MaybeDenom                           *string          `json:"denom"`
	MaybeBridgeFeeAmount                 *coin.Int        `json:"bridgeFeeAmount"`
	MaybeBridgeFeeDenom                  *string          `json:"bridgeFeeDenom"`
	Status                               types.Status     `json:"status"`
}

type BridgeActivityReadRow struct {
	BridgeActivityInsertRow

	Id        int64            `json:"id"`
	UUID      string           `json:"uuid"`
	CreatedAt *utctime.UTCTime `json:"createdAt"`
	UpdatedAt *utctime.UTCTime `json:"updatedAt"`
}

type BridgePendingActivities interface {
	ListAllUnprocessedOutgoing() ([]BridgePendingActivityReadRow, error)
	ListAllUnprocessedIncoming() ([]BridgePendingActivityReadRow, error)
	List(
		filter BridgePendingActivitiesFilter,
		order BridgePendingActivitiesOrder,
	) ([]BridgePendingActivityReadRow, error)
	UpdateToProcessed(id int64) error
	Insert(activity *BridgePendingActivityInsertRow) error
}

type BridgePendingActivitiesFilter struct {
	MaybeDirections  []types.Direction
	MaybeIsProcessed *bool
}

type BridgePendingActivitiesOrder struct {
	MaybeId *view.ORDER
}

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

type BridgePendingActivityInsertRow struct {
	BlockHeight                   int64            `json:"blockHeight"`
	BlockTime                     *utctime.UTCTime `json:"blockTime"`
	MaybeTransactionId            *string          `json:"maybeTransactionId"`
	BridgeType                    types.BridgeType `json:"bridgeType"`
	LinkId                        string           `json:"linkId"`
	Direction                     types.Direction  `json:"direction"`
	FromChainId                   string           `json:"fromChainId"`
	MaybeFromAddress              *string          `json:"maybeFromAddress"`
	MaybeFromSmartContractAddress *string          `json:"maybeFromSmartContractAddress"`
	ToChainId                     string           `json:"toChainId"`
	ToAddress                     string           `json:"toAddress"`
	MaybeToSmartContractAddress   *string          `json:"maybeToSmartContractAddress"`
	MaybeChannelId                *string          `json:"maybeChannelId"`
	Amount                        coin.Int         `json:"amount"`
	MaybeDenom                    *string          `json:"maybeDenom"`
	MaybeBridgeFeeAmount          *coin.Int        `json:"maybeBridgeFeeAmount"`
	MaybeBridgeFeeDenom           *string          `json:"maybeBridgeFeeDenom"`
	Status                        types.Status     `json:"status"`
	IsProcessed                   bool             `json:"isProcessed"`
}

type BridgePendingActivityReadRow struct {
	BridgePendingActivityInsertRow

	Id        int64            `json:"id"`
	CreatedAt *utctime.UTCTime `json:"createdAt"`
	UpdatedAt *utctime.UTCTime `json:"updatedAt"`
}

type MockBridgeActivitiesView struct {
	mock.Mock
}

type MockBridgePendingActivitiesView struct {
	mock.Mock
}