swap_server_client: call server with SwapPublicationDeadline set

pull/129/head
Johan T. Halseth 4 years ago
parent b2d1d99521
commit d5c9a66c60
No known key found for this signature in database
GPG Key ID: 15BAADA29DA20D26

@ -369,7 +369,9 @@ func (s *Client) LoopOutQuote(ctx context.Context,
return nil, ErrSwapAmountTooHigh return nil, ErrSwapAmountTooHigh
} }
quote, err := s.Server.GetLoopOutQuote(ctx, request.Amount) quote, err := s.Server.GetLoopOutQuote(
ctx, request.Amount, request.SwapPublicationDeadline,
)
if err != nil { if err != nil {
return nil, err return nil, err
} }

@ -94,8 +94,8 @@ func (s *serverMock) GetLoopOutTerms(ctx context.Context) (
}, nil }, nil
} }
func (s *serverMock) GetLoopOutQuote(ctx context.Context, amt btcutil.Amount) ( func (s *serverMock) GetLoopOutQuote(ctx context.Context, amt btcutil.Amount,
*LoopOutQuote, error) { _ time.Time) (*LoopOutQuote, error) {
dest := [33]byte{1, 2, 3} dest := [33]byte{1, 2, 3}

@ -22,7 +22,8 @@ type swapServerClient interface {
GetLoopOutTerms(ctx context.Context) ( GetLoopOutTerms(ctx context.Context) (
*LoopOutTerms, error) *LoopOutTerms, error)
GetLoopOutQuote(ctx context.Context, amt btcutil.Amount) ( GetLoopOutQuote(ctx context.Context, amt btcutil.Amount,
swapPublicationDeadline time.Time) (
*LoopOutQuote, error) *LoopOutQuote, error)
GetLoopInTerms(ctx context.Context) ( GetLoopInTerms(ctx context.Context) (
@ -93,13 +94,15 @@ func (s *grpcSwapServerClient) GetLoopOutTerms(ctx context.Context) (
} }
func (s *grpcSwapServerClient) GetLoopOutQuote(ctx context.Context, func (s *grpcSwapServerClient) GetLoopOutQuote(ctx context.Context,
amt btcutil.Amount) (*LoopOutQuote, error) { amt btcutil.Amount, swapPublicationDeadline time.Time) (
*LoopOutQuote, error) {
rpcCtx, rpcCancel := context.WithTimeout(ctx, globalCallTimeout) rpcCtx, rpcCancel := context.WithTimeout(ctx, globalCallTimeout)
defer rpcCancel() defer rpcCancel()
quoteResp, err := s.server.LoopOutQuote(rpcCtx, quoteResp, err := s.server.LoopOutQuote(rpcCtx,
&looprpc.ServerLoopOutQuoteRequest{ &looprpc.ServerLoopOutQuoteRequest{
Amt: uint64(amt), Amt: uint64(amt),
SwapPublicationDeadline: swapPublicationDeadline.Unix(),
}, },
) )
if err != nil { if err != nil {

Loading…
Cancel
Save