streams&refactor

[Okm165]

No description provided.

[rkdud007]

As mentioned on Slack, Two thing to note on:

1. like appraoch with streams
   But let's have method to expose publish / receive so that can able to test does message sending among delegator and executor node is indeed working fine or not before merge

• add link might be helpful ( this have publish / swarm runner as a example with mpsc )
  : How do I call into libp2p rather than having it call my functions in a loop? libp2p/rust-libp2p#2024 (reply in thread)

2. But personally don't agree with de-abstracting node as both delegator and executor share pretty much same logic to run, just config enum can be different

let node_config = NodeConfig::new(
        NodeType::Delegator,
        Network::Sepolia,
        p2p_local_keypair,
        Vec::new(),
        store,
    );
    let node = Node::new(node_config).await.unwrap();
    ```

[rkdud007]

lgtm