Skip to content

Commit 8447f58

Browse files
committed
multi: do not rename swapserverrpc to looprpc
Many imports renamed it, but it was not needed.
1 parent 6db2a39 commit 8447f58

File tree

10 files changed

+196
-195
lines changed

10 files changed

+196
-195
lines changed

instantout/actions.go

+8-7
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import (
1515
"github.com/lightninglabs/loop/instantout/reservation"
1616
"github.com/lightninglabs/loop/loopdb"
1717
"github.com/lightninglabs/loop/swap"
18-
loop_rpc "github.com/lightninglabs/loop/swapserverrpc"
18+
"github.com/lightninglabs/loop/swapserverrpc"
1919
"github.com/lightningnetwork/lnd/lnrpc"
2020
"github.com/lightningnetwork/lnd/lnrpc/walletrpc"
2121
"github.com/lightningnetwork/lnd/lntypes"
@@ -137,7 +137,7 @@ func (f *FSM) InitInstantOutAction(eventCtx fsm.EventContext) fsm.EventType {
137137
// Send the instantout request to the server.
138138
instantOutResponse, err := f.cfg.InstantOutClient.RequestInstantLoopOut(
139139
f.ctx,
140-
&loop_rpc.InstantLoopOutRequest{
140+
&swapserverrpc.InstantLoopOutRequest{
141141
ReceiverKey: keyRes.PubKey.SerializeCompressed(),
142142
SwapHash: swapHash[:],
143143
Expiry: initCtx.cltvExpiry,
@@ -259,7 +259,8 @@ func (f *FSM) PollPaymentAcceptedAction(_ fsm.EventContext) fsm.EventType {
259259

260260
case <-timer.C:
261261
res, err := f.cfg.InstantOutClient.PollPaymentAccepted(
262-
f.ctx, &loop_rpc.PollPaymentAcceptedRequest{
262+
f.ctx,
263+
&swapserverrpc.PollPaymentAcceptedRequest{
263264
SwapHash: f.InstantOut.SwapHash[:],
264265
},
265266
)
@@ -292,7 +293,7 @@ func (f *FSM) BuildHTLCAction(eventCtx fsm.EventContext) fsm.EventType {
292293
// Send the server the client nonces.
293294
htlcInitRes, err := f.cfg.InstantOutClient.InitHtlcSig(
294295
f.ctx,
295-
&loop_rpc.InitHtlcSigRequest{
296+
&swapserverrpc.InitHtlcSigRequest{
296297
SwapHash: f.InstantOut.SwapHash[:],
297298
HtlcClientNonces: htlcClientNonces,
298299
},
@@ -331,7 +332,7 @@ func (f *FSM) BuildHTLCAction(eventCtx fsm.EventContext) fsm.EventType {
331332
// Send the server the htlc signatures.
332333
htlcRes, err := f.cfg.InstantOutClient.PushHtlcSig(
333334
f.ctx,
334-
&loop_rpc.PushHtlcSigRequest{
335+
&swapserverrpc.PushHtlcSigRequest{
335336
SwapHash: f.InstantOut.SwapHash[:],
336337
ClientSigs: htlcSigs,
337338
},
@@ -377,7 +378,7 @@ func (f *FSM) PushPreimageAction(eventCtx fsm.EventContext) fsm.EventType {
377378

378379
pushPreImageRes, err := f.cfg.InstantOutClient.PushPreimage(
379380
f.ctx,
380-
&loop_rpc.PushPreimageRequest{
381+
&swapserverrpc.PushPreimageRequest{
381382
Preimage: f.InstantOut.swapPreimage[:],
382383
ClientNonces: coopClientNonces,
383384
ClientSweepAddr: f.InstantOut.sweepAddress.String(),
@@ -615,7 +616,7 @@ func (f *FSM) handleErrorAndUnlockReservations(err error) fsm.EventType {
615616
ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
616617
defer cancel()
617618
_, cancelErr := f.cfg.InstantOutClient.CancelInstantSwap(
618-
ctx, &loop_rpc.CancelInstantSwapRequest{
619+
ctx, &swapserverrpc.CancelInstantSwapRequest{
619620
SwapHash: f.InstantOut.SwapHash[:],
620621
},
621622
)

instantout/fsm.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import (
77
"github.com/btcsuite/btcd/chaincfg"
88
"github.com/lightninglabs/lndclient"
99
"github.com/lightninglabs/loop/fsm"
10-
loop_rpc "github.com/lightninglabs/loop/swapserverrpc"
10+
"github.com/lightninglabs/loop/swapserverrpc"
1111
"github.com/lightningnetwork/lnd/input"
1212
)
1313

@@ -28,8 +28,8 @@ func CurrentProtocolVersion() ProtocolVersion {
2828
}
2929

3030
// CurrentRpcProtocolVersion returns the current rpc protocol version.
31-
func CurrentRpcProtocolVersion() loop_rpc.InstantOutProtocolVersion {
32-
return loop_rpc.InstantOutProtocolVersion(CurrentProtocolVersion())
31+
func CurrentRpcProtocolVersion() swapserverrpc.InstantOutProtocolVersion {
32+
return swapserverrpc.InstantOutProtocolVersion(CurrentProtocolVersion())
3333
}
3434

3535
const (
@@ -163,7 +163,7 @@ type Config struct {
163163
Wallet lndclient.WalletKitClient
164164

165165
// InstantOutClient is used to communicate with the swap server.
166-
InstantOutClient loop_rpc.InstantSwapServerClient
166+
InstantOutClient swapserverrpc.InstantSwapServerClient
167167

168168
// ReservationManager is used to get the reservations and lock them.
169169
ReservationManager ReservationManager

instantout/manager.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"github.com/btcsuite/btcd/btcutil"
1111
"github.com/lightninglabs/loop/fsm"
1212
"github.com/lightninglabs/loop/instantout/reservation"
13-
looprpc "github.com/lightninglabs/loop/swapserverrpc"
13+
"github.com/lightninglabs/loop/swapserverrpc"
1414
"github.com/lightningnetwork/lnd/lntypes"
1515
)
1616

@@ -234,7 +234,7 @@ func (m *Manager) GetInstantOutQuote(ctx context.Context,
234234

235235
// Get the service fee.
236236
quoteRes, err := m.cfg.InstantOutClient.GetInstantOutQuote(
237-
ctx, &looprpc.GetInstantOutQuoteRequest{
237+
ctx, &swapserverrpc.GetInstantOutQuoteRequest{
238238
Amount: uint64(amt),
239239
},
240240
)

instantout/reservation/actions.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66
"github.com/btcsuite/btcd/btcec/v2"
77
"github.com/btcsuite/btcd/btcutil"
88
"github.com/lightninglabs/loop/fsm"
9-
looprpc "github.com/lightninglabs/loop/swapserverrpc"
9+
"github.com/lightninglabs/loop/swapserverrpc"
1010
"github.com/lightningnetwork/lnd/chainntnfs"
1111
)
1212

@@ -40,7 +40,7 @@ func (f *FSM) InitAction(eventCtx fsm.EventContext) fsm.EventType {
4040
log.Debugf("Dispatching reservation to server: %x",
4141
reservationRequest.reservationID)
4242

43-
request := &looprpc.ServerOpenReservationRequest{
43+
request := &swapserverrpc.ServerOpenReservationRequest{
4444
ReservationId: reservationRequest.reservationID[:],
4545
ClientKey: keyRes.PubKey.SerializeCompressed(),
4646
}

instantout/reservation/fsm.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55

66
"github.com/lightninglabs/lndclient"
77
"github.com/lightninglabs/loop/fsm"
8-
looprpc "github.com/lightninglabs/loop/swapserverrpc"
8+
"github.com/lightninglabs/loop/swapserverrpc"
99
)
1010

1111
const (
@@ -26,7 +26,7 @@ type Config struct {
2626

2727
// ReservationClient is the client used to communicate with the
2828
// swap server.
29-
ReservationClient looprpc.ReservationServiceClient
29+
ReservationClient swapserverrpc.ReservationServiceClient
3030

3131
// FetchL402 is the function used to fetch the l402 token.
3232
FetchL402 func(context.Context) error

0 commit comments

Comments
 (0)