reservation

type BaseDB interface {
	Querier

	// ExecTx allows for executing a function in the context of a database
	// transaction.
	ExecTx(ctx context.Context, txOptions loopdb.TxOptions,
		txBody func(Querier) error) error
}

type Config struct {
	// Store is the database store for the reservations.
	Store Store

	// Wallet handles the key derivation for the reservation.
	Wallet lndclient.WalletKitClient

	// ChainNotifier is used to subscribe to block notifications.
	ChainNotifier lndclient.ChainNotifierClient

	// ReservationClient is the client used to communicate with the
	// swap server.
	ReservationClient swapserverrpc.ReservationServiceClient

	// NotificationManager is the manager that handles the notification
	// subscriptions.
	NotificationManager NotificationManager
}

type FSM struct {
	*fsm.StateMachine
	// contains filtered or unexported fields
}

type ID [IdLength]byte

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

type Manager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type NotificationManager interface {
	SubscribeReservations(context.Context,
	) <-chan *swapserverrpc.ServerReservationNotification
}

type ProtocolVersion uint32

type Querier interface {
	// CreateReservation stores the reservation in the database.
	CreateReservation(ctx context.Context,
		arg sqlc.CreateReservationParams) error

	// GetReservation retrieves the reservation from the database.
	GetReservation(ctx context.Context,
		reservationID []byte) (sqlc.Reservation, error)

	// GetReservationUpdates fetches all updates for a reservation.
	GetReservationUpdates(ctx context.Context,
		reservationID []byte) ([]sqlc.ReservationUpdate, error)

	// GetReservations lists all existing reservations the client has ever
	// made.
	GetReservations(ctx context.Context) ([]sqlc.Reservation, error)

	// InsertReservationUpdate inserts a new reservation update.
	InsertReservationUpdate(ctx context.Context,
		arg sqlc.InsertReservationUpdateParams) error

	// UpdateReservation updates a reservation.
	UpdateReservation(ctx context.Context,
		arg sqlc.UpdateReservationParams) error
}

type Reservation struct {
	// ID is the unique identifier of the reservation.
	ID ID

	// ProtocolVersion is the version of the protocol used for the
	// reservation.
	ProtocolVersion ProtocolVersion

	// State is the current state of the reservation.
	State fsm.StateType

	// ClientPubkey is the client's pubkey.
	ClientPubkey *btcec.PublicKey

	// ServerPubkey is the server's pubkey.
	ServerPubkey *btcec.PublicKey

	// Value is the amount of the reservation.
	Value btcutil.Amount

	// Expiry is the absolute block height at which the reservation expires.
	Expiry uint32

	// KeyLocator is the key locator of the client's key.
	KeyLocator keychain.KeyLocator

	// Outpoint is the outpoint of the reservation.
	Outpoint *wire.OutPoint

	// InitiationHeight is the height at which the reservation was
	// initiated.
	InitiationHeight int32

	// ConfirmationHeight is the height at which the reservation was
	// confirmed.
	ConfirmationHeight uint32
}

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

type Store interface {
	// CreateReservation stores the reservation in the database.
	CreateReservation(ctx context.Context, reservation *Reservation) error

	// UpdateReservation updates the reservation in the database.
	UpdateReservation(ctx context.Context, reservation *Reservation) error

	// GetReservation retrieves the reservation from the database.
	GetReservation(ctx context.Context, id ID) (*Reservation, error)

	// ListReservations lists all existing reservations the client has ever
	// made.
	ListReservations(ctx context.Context) ([]*Reservation, error)
}