store

type MigrationStatus struct {
	ID        string     `json:"id"`
	Applied   bool       `json:"applied"`
	AppliedAt *time.Time `json:"appliedAt,omitempty"`
}

type Migrator interface {
	MigrateUp() (int, error)
	MigrateDown() (int, error)
	MigrationStatus() ([]MigrationStatus, error)
}

type Packet struct {
	ID        int64
	CreatedAt time.Time
	UpdatedAt time.Time

	Status RelayStatus

	SourceChainID      string
	DestinationChainID string
	SourceTxHash       string
	SourceTxTime       time.Time

	PacketSequenceNumber      uint64
	PacketSourceClientID      string
	PacketDestinationClientID string
	PacketTimeoutTimestamp    time.Time

	RecvTxHash           *string
	RecvTxTime           *time.Time
	RecvTxRelayerAddress *string

	WriteAckTxHash *string
	WriteAckTxTime *time.Time
	WriteAckStatus *WriteAckStatus

	AckTxHash           *string
	AckTxTime           *time.Time
	AckTxRelayerAddress *string

	TimeoutTxHash           *string
	TimeoutTxTime           *time.Time
	TimeoutTxRelayerAddress *string
}

type PacketFilter struct {
	Statuses            []RelayStatus
	SourceChainID       string
	DestinationChainID  string
	SourceClientID      string
	DestinationClientID string
	SourceTxHash        string
	SequenceNumber      uint64
}

type PacketKey struct {
	SourceChainID  string
	SourceClientID string
	Sequence       uint64
}

type PacketTx struct {
	Hash           string
	Time           time.Time
	RelayerAddress string
}

type Page struct {
	Limit  int64
	Before int64
}

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

type RelayStatus string

type Repository interface {
	// UpsertPacket records a packet. A new packet is inserted; an existing
	// NOT_SELECTED packet is refreshed with the input's metadata and status,
	// but only when the input status is NOT_SELECTED or PENDING, the latter
	// selecting it for relay. Existing packets in any other status are never
	// modified.
	UpsertPacket(ctx context.Context, input UpsertPacket) error

	ListPacketsBySourceTx(ctx context.Context, chainID string, txHash string) ([]Packet, error)

	ListPackets(ctx context.Context, filter PacketFilter, page Page) ([]Packet, error)

	// ListDispatchablePackets returns selected packets that have not reached a terminal status.
	ListDispatchablePackets(ctx context.Context) ([]Packet, error)

	UpdatePacketStatus(ctx context.Context, key PacketKey, status RelayStatus) error

	UpdatePacketRecvTx(ctx context.Context, key PacketKey, tx PacketTx) error
	ClearPacketRecvTx(ctx context.Context, key PacketKey) error

	UpdatePacketWriteAck(ctx context.Context, key PacketKey, ack WriteAck) error

	UpdatePacketAckTx(ctx context.Context, key PacketKey, tx PacketTx) error
	ClearPacketAckTx(ctx context.Context, key PacketKey) error

	UpdatePacketTimeoutTx(ctx context.Context, key PacketKey, tx PacketTx) error
	ClearPacketTimeoutTx(ctx context.Context, key PacketKey) error
}

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

type Store interface {
	Repository
	Migrator

	// Transact runs call in a transaction; call's Repository is bound to it and rolled back on error.
	Transact(ctx context.Context, call func(repo Repository) error) error

	Ping(ctx context.Context) error
	Close() error
}

type UpsertPacket struct {
	Status                    RelayStatus
	SourceChainID             string
	DestinationChainID        string
	SourceTxHash              string
	SourceTxTime              time.Time
	PacketSequenceNumber      uint64
	PacketSourceClientID      string
	PacketDestinationClientID string
	PacketTimeoutTimestamp    time.Time
}

type WriteAck struct {
	TxHash string
	TxTime time.Time
	Status WriteAckStatus
}

type WriteAckStatus string