Renaming channel id for peerd

LNP-WG · Nov 5, 2020 · e67a136 · e67a136
1 parent 48b05aa
commit e67a136
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 10 deletions.
diff --git a/src/channeld/runtime.rs b/src/channeld/runtime.rs
@@ -570,6 +570,11 @@ impl Runtime {
             ServiceId::Lnpd,
             Request::UpdateChannelId(self.channel_id),
         )?;
+        self.send_ctl(
+            senders,
+            self.peer_service.clone(),
+            Request::UpdateChannelId(self.channel_id),
+        )?;
         self.identity = self.channel_id.into();
         let msg = format!(
             "{} set to {}",
@@ -750,8 +755,6 @@ impl Runtime {
         info!("{}", msg);
         let _ = self.report_progress_to(senders, &enquirer, msg);
 
-        self.update_channel_id(senders)?;
-
         Ok(funding_created)
     }
 

diff --git a/src/peerd/runtime.rs b/src/peerd/runtime.rs
@@ -173,7 +173,7 @@ pub struct Runtime {
     local_socket: Option<InetSocketAddr>,
     remote_socket: InetSocketAddr,
 
-    routing: HashMap<ServiceId, MessageFilter>,
+    routing: HashMap<ServiceId, ServiceId>,
     sender: PeerSender,
     connect: bool,
 
@@ -245,17 +245,13 @@ impl Runtime {
         match &request {
             Request::PeerMessage(Messages::FundingSigned(
                 message::FundingSigned { channel_id, .. },
-            ))
-            | Request::PeerMessage(Messages::FundingLocked(
-                message::FundingLocked { channel_id, .. },
             )) => {
                 debug!(
                     "Renaming channeld service from temporary id {:#} to channel id #{:#}", 
                     source, channel_id
                 );
                 self.routing.remove(&source);
-                self.routing
-                    .insert(channel_id.clone().into(), MessageFilter {});
+                self.routing.insert(channel_id.clone().into(), source);
             }
             _ => {}
         }
@@ -287,6 +283,15 @@ impl Runtime {
         request: Request,
     ) -> Result<(), Error> {
         match request {
+            Request::UpdateChannelId(channel_id) => {
+                debug!(
+                    "Renaming channeld service from temporary id {:#} to channel id #{:#}",
+                    source, channel_id
+                );
+                self.routing.remove(&source);
+                self.routing.insert(channel_id.clone().into(), source);
+            }
+
             Request::GetInfo => {
                 let info = PeerInfo {
                     local_id: self.local_id,
@@ -381,7 +386,7 @@ impl Runtime {
             Request::PeerMessage(Messages::AcceptChannel(accept_channel)) => {
                 let channeld: ServiceId =
                     accept_channel.temporary_channel_id.into();
-                self.routing.insert(channeld.clone(), MessageFilter {});
+                self.routing.insert(channeld.clone(), channeld.clone());
                 senders.send_to(
                     ServiceBus::Msg,
                     self.identity(),
@@ -425,10 +430,11 @@ impl Runtime {
             | Request::PeerMessage(Messages::AssignFunds(
                 message::AssignFunds { channel_id, .. },
             )) => {
+                let channeld: ServiceId = channel_id.clone().into();
                 senders.send_to(
                     ServiceBus::Msg,
                     self.identity(),
-                    channel_id.clone().into(),
+                    self.routing.get(&channeld).cloned().unwrap_or(channeld),
                     request,
                 )?;
             }