feat(yamux): Split incoming frame handling into multiple actions

Author: tizoc

node/src/action_kind.rs

@@ -460,6 +460,10 @@ pub enum ActionKind {
     P2pNetworkSelectTimeout,
     P2pNetworkYamuxIncomingData,
     P2pNetworkYamuxIncomingFrame,
+    P2pNetworkYamuxIncomingFrameData,
+    P2pNetworkYamuxIncomingFrameGoAway,
+    P2pNetworkYamuxIncomingFramePing,
+    P2pNetworkYamuxIncomingFrameWindowUpdate,
     P2pNetworkYamuxOpenStream,
     P2pNetworkYamuxOutgoingData,
     P2pNetworkYamuxOutgoingFrame,
@@ -720,7 +724,7 @@ pub enum ActionKind {
 }
 
 impl ActionKind {
-    pub const COUNT: u16 = 610;
+    pub const COUNT: u16 = 614;
 }
 
 impl std::fmt::Display for ActionKind {
@@ -1948,6 +1952,12 @@ impl ActionKindGet for P2pNetworkYamuxAction {
             Self::IncomingData { .. } => ActionKind::P2pNetworkYamuxIncomingData,
             Self::OutgoingData { .. } => ActionKind::P2pNetworkYamuxOutgoingData,
             Self::IncomingFrame { .. } => ActionKind::P2pNetworkYamuxIncomingFrame,
+            Self::IncomingFrameData { .. } => ActionKind::P2pNetworkYamuxIncomingFrameData,
+            Self::IncomingFramePing { .. } => ActionKind::P2pNetworkYamuxIncomingFramePing,
+            Self::IncomingFrameWindowUpdate { .. } => {
+                ActionKind::P2pNetworkYamuxIncomingFrameWindowUpdate
+            }
+            Self::IncomingFrameGoAway { .. } => ActionKind::P2pNetworkYamuxIncomingFrameGoAway,
             Self::OutgoingFrame { .. } => ActionKind::P2pNetworkYamuxOutgoingFrame,
             Self::PingStream { .. } => ActionKind::P2pNetworkYamuxPingStream,
             Self::OpenStream { .. } => ActionKind::P2pNetworkYamuxOpenStream,

p2p/src/network/yamux/p2p_network_yamux_actions.rs

@@ -22,6 +22,22 @@ pub enum P2pNetworkYamuxAction {
         addr: ConnectionAddr,
     },
     #[action_event(level = trace)]
+    IncomingFrameData {
+        addr: ConnectionAddr,
+    },
+    #[action_event(level = trace)]
+    IncomingFramePing {
+        addr: ConnectionAddr,
+    },
+    #[action_event(level = trace)]
+    IncomingFrameWindowUpdate {
+        addr: ConnectionAddr,
+    },
+    #[action_event(level = trace)]
+    IncomingFrameGoAway {
+        addr: ConnectionAddr,
+    },
+    #[action_event(level = trace)]
     OutgoingFrame {
         addr: ConnectionAddr,
         frame: YamuxFrame,
@@ -43,6 +59,10 @@ impl P2pNetworkYamuxAction {
             Self::IncomingData { addr, .. } => addr,
             Self::OutgoingData { addr, .. } => addr,
             Self::IncomingFrame { addr, .. } => addr,
+            Self::IncomingFrameData { addr, .. } => addr,
+            Self::IncomingFramePing { addr, .. } => addr,
+            Self::IncomingFrameWindowUpdate { addr, .. } => addr,
+            Self::IncomingFrameGoAway { addr, .. } => addr,
             Self::OutgoingFrame { addr, .. } => addr,
             Self::PingStream { addr, .. } => addr,
             Self::OpenStream { addr, .. } => addr,
@@ -72,7 +92,11 @@ impl redux::EnablingCondition<P2pState> for P2pNetworkYamuxAction {
             P2pNetworkYamuxAction::OutgoingData { stream_id, .. } => {
                 yamux_state.streams.contains_key(stream_id)
             }
-            P2pNetworkYamuxAction::IncomingFrame { .. } => true,
+            P2pNetworkYamuxAction::IncomingFrame { .. }
+            | P2pNetworkYamuxAction::IncomingFrameData { .. }
+            | P2pNetworkYamuxAction::IncomingFramePing { .. }
+            | P2pNetworkYamuxAction::IncomingFrameWindowUpdate { .. }
+            | P2pNetworkYamuxAction::IncomingFrameGoAway { .. } => !yamux_state.incoming.is_empty(),
             P2pNetworkYamuxAction::OutgoingFrame { .. } => true,
             P2pNetworkYamuxAction::PingStream { .. } => true,
             P2pNetworkYamuxAction::OpenStream { .. } => true,