Skip to content

Commit

Permalink
Merge pull request #131 from ineiti/typo
Browse files Browse the repository at this point in the history
Correct typo in message name
  • Loading branch information
ineiti authored Nov 5, 2024
2 parents eda6fff + c52f669 commit 2c0ea00
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions flmodules/src/overlay/broker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ impl OverlayRandom {
OverlayOut::NodeInfosConnected(infos)
}
RandomOut::NetworkWrapperFromNetwork(id, module_message) => {
OverlayOut::NetworkMapperFromNetwork(id, module_message)
OverlayOut::NetworkWrapperFromNetwork(id, module_message)
}
_ => return None,
};
Expand Down Expand Up @@ -91,7 +91,7 @@ impl OverlayDirect {
return match out {
NetworkOut::MessageFromNode(id, msg_str) => {
serde_yaml::from_str(&msg_str).ok().map(|module_message| {
OverlayOut::NetworkMapperFromNetwork(id, module_message).into()
OverlayOut::NetworkWrapperFromNetwork(id, module_message).into()
})
}
NetworkOut::NodeListFromWS(vec) => {
Expand Down
2 changes: 1 addition & 1 deletion flmodules/src/overlay/messages.rs
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ pub enum OverlayOut {
NodeInfoAvailable(Vec<NodeInfo>),
NodeIDsConnected(NodeIDs),
NodeInfosConnected(Vec<NodeInfo>),
NetworkMapperFromNetwork(NodeID, NetworkWrapper),
NetworkWrapperFromNetwork(NodeID, NetworkWrapper),
}

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
Expand Down
6 changes: 3 additions & 3 deletions flmodules/src/web_proxy/broker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ impl Translate {
OverlayOut::NodeInfosConnected(list) => {
Some(WebProxyIn::NodeInfoConnected(list).into())
}
OverlayOut::NetworkMapperFromNetwork(id, msg) => msg
OverlayOut::NetworkWrapperFromNetwork(id, msg) => msg
.unwrap_yaml(MODULE_NAME)
.map(|msg| WebProxyIn::FromNetwork(id, msg).into()),
_ => None,
Expand Down Expand Up @@ -230,7 +230,7 @@ mod tests {
{
log::debug!("Sending to WP: {msg:?}");
wp_rnd
.emit_msg(OverlayMessage::Output(OverlayOut::NetworkMapperFromNetwork(
.emit_msg(OverlayMessage::Output(OverlayOut::NetworkWrapperFromNetwork(
dst, msg,
)))
.expect("sending to wp");
Expand All @@ -241,7 +241,7 @@ mod tests {
{
log::debug!("Sending to CL: {msg:?}");
cl_rnd
.emit_msg(OverlayMessage::Output(OverlayOut::NetworkMapperFromNetwork(
.emit_msg(OverlayMessage::Output(OverlayOut::NetworkWrapperFromNetwork(
dst, msg,
)))
.expect("sending to wp");
Expand Down

0 comments on commit 2c0ea00

Please sign in to comment.