Skip to content

Commit c6c30e2

Browse files
committed
multi: log server message
1 parent d76959d commit c6c30e2

File tree

5 files changed

+104
-67
lines changed

5 files changed

+104
-67
lines changed

loopin.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -180,6 +180,10 @@ func newLoopInSwap(globalCtx context.Context, cfg *swapConfig,
180180
return nil, fmt.Errorf("cannot store swap: %v", err)
181181
}
182182

183+
if swapResp.serverMessage != "" {
184+
swap.log.Infof("Server message: %v", swapResp.serverMessage)
185+
}
186+
183187
return swap, nil
184188
}
185189

loopout.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,10 @@ func newLoopOutSwap(globalCtx context.Context, cfg *swapConfig,
176176
return nil, fmt.Errorf("cannot store swap: %v", err)
177177
}
178178

179+
if swapResp.serverMessage != "" {
180+
swap.log.Infof("Server message: %v", swapResp.serverMessage)
181+
}
182+
179183
return swap, nil
180184
}
181185

looprpc/server.pb.go

Lines changed: 82 additions & 63 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

looprpc/server.proto

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,9 @@ message ServerLoopOutResponse {
7272
bytes sender_key = 3;
7373

7474
int32 expiry = 4;
75+
76+
// A human-readable message from the loop server.
77+
string server_message = 5;
7578
}
7679

7780
message ServerLoopOutQuoteRequest {
@@ -127,6 +130,9 @@ message ServerLoopInRequest {
127130
message ServerLoopInResponse {
128131
bytes receiver_key = 1;
129132
int32 expiry = 2;
133+
134+
// A human-readable message from the loop server.
135+
string server_message = 3;
130136
}
131137

132138
message ServerLoopInQuoteRequest {

swap_server_client.go

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -215,6 +215,7 @@ func (s *grpcSwapServerClient) NewLoopOutSwap(ctx context.Context,
215215
prepayInvoice: swapResp.PrepayInvoice,
216216
senderKey: senderKey,
217217
expiry: swapResp.Expiry,
218+
serverMessage: swapResp.ServerMessage,
218219
}, nil
219220
}
220221

@@ -268,8 +269,9 @@ func (s *grpcSwapServerClient) NewLoopInSwap(ctx context.Context,
268269
}
269270

270271
return &newLoopInResponse{
271-
receiverKey: receiverKey,
272-
expiry: swapResp.Expiry,
272+
receiverKey: receiverKey,
273+
expiry: swapResp.Expiry,
274+
serverMessage: swapResp.ServerMessage,
273275
}, nil
274276
}
275277

@@ -334,9 +336,11 @@ type newLoopOutResponse struct {
334336
prepayInvoice string
335337
senderKey [33]byte
336338
expiry int32
339+
serverMessage string
337340
}
338341

339342
type newLoopInResponse struct {
340-
receiverKey [33]byte
341-
expiry int32
343+
receiverKey [33]byte
344+
expiry int32
345+
serverMessage string
342346
}

0 commit comments

Comments
 (0)