Skip to content

Commit ce6a125

Browse files
committed
Add a MessageSendInstructions::ForReply
In order to allow onion message handlers to reply asynchronously without introducing a circular dependency graph, the message handlers need to be able to send replies described by `MessageSendInstructions`. This allows them to send replies via the normal message queuing (i.e. without making a function call to `OnionMessenger`). Here we enable that by adding a `MessageSendInstructions::ForReply` variant which holds `ReplyInstruction`s. Fixes #3178
1 parent 19394c2 commit ce6a125

File tree

1 file changed

+13
-11
lines changed

1 file changed

+13
-11
lines changed

lightning/src/onion_message/messenger.rs

+13-11
Original file line numberDiff line numberDiff line change
@@ -367,7 +367,7 @@ impl Responder {
367367
/// Use when the recipient doesn't need to send back a reply to us.
368368
pub fn respond(self) -> ResponseInstruction {
369369
ResponseInstruction {
370-
send_path: self.reply_path,
370+
destination: Destination::BlindedPath(self.reply_path),
371371
context: None,
372372
}
373373
}
@@ -377,7 +377,7 @@ impl Responder {
377377
/// Use when the recipient needs to send back a reply to us.
378378
pub fn respond_with_reply_path(self, context: MessageContext) -> ResponseInstruction {
379379
ResponseInstruction {
380-
send_path: self.reply_path,
380+
destination: Destination::BlindedPath(self.reply_path),
381381
context: Some(context),
382382
}
383383
}
@@ -386,17 +386,13 @@ impl Responder {
386386
/// Instructions for how and where to send the response to an onion message.
387387
#[derive(Clone)]
388388
pub struct ResponseInstruction {
389-
send_path: BlindedMessagePath,
389+
destination: Destination,
390390
context: Option<MessageContext>,
391391
}
392392

393393
impl ResponseInstruction {
394394
fn into_instructions(self) -> MessageSendInstructions {
395-
let destination = Destination::BlindedPath(self.send_path);
396-
match self.context {
397-
Some(context) => MessageSendInstructions::WithReplyPath { destination, context },
398-
None => MessageSendInstructions::WithoutReplyPath { destination },
399-
}
395+
MessageSendInstructions::ForReply { instructions: self }
400396
}
401397
}
402398

@@ -425,7 +421,11 @@ pub enum MessageSendInstructions {
425421
WithoutReplyPath {
426422
/// The desination where we need to send our message.
427423
destination: Destination,
428-
}
424+
},
425+
/// Indicates that a message is being sent as a reply to a received message.
426+
ForReply {
427+
instructions: ResponseInstruction,
428+
},
429429
}
430430

431431
/// A trait defining behavior for routing an [`OnionMessage`].
@@ -1158,7 +1158,8 @@ where
11581158
let (destination, reply_path) = match instructions {
11591159
MessageSendInstructions::WithSpecifiedReplyPath { destination, reply_path } =>
11601160
(destination, Some(reply_path)),
1161-
MessageSendInstructions::WithReplyPath { destination, context } => {
1161+
MessageSendInstructions::WithReplyPath { destination, context }|
1162+
MessageSendInstructions::ForReply { instructions: ResponseInstruction { destination, context: Some(context) } } => {
11621163
match self.create_blinded_path(context) {
11631164
Ok(reply_path) => (destination, Some(reply_path)),
11641165
Err(err) => {
@@ -1171,7 +1172,8 @@ where
11711172
}
11721173
}
11731174
},
1174-
MessageSendInstructions::WithoutReplyPath { destination } =>
1175+
MessageSendInstructions::WithoutReplyPath { destination }|
1176+
MessageSendInstructions::ForReply { instructions: ResponseInstruction { destination, context: None } } =>
11751177
(destination, None),
11761178
};
11771179

0 commit comments

Comments
 (0)