wip

node/src/node.rs

@@ -109,16 +109,7 @@ where
     S: Store,
 {
     /// Creates and starts a new celestia node with a given config.
-    async fn new(config: NodeConfig<B, S>) -> Result<Self> {
-        let (node, _) = Node::new_subscribed(config).await?;
-        Ok(node)
-    }
-
-    /// Creates and starts a new celestia node with a given config.
-    ///
-    /// Returns `Node` alogn with `EventSubscriber`. Use this to avoid missing any
-    /// events that will be generated on the construction of the node.
-    async fn new_subscribed(config: NodeConfig<B, S>) -> Result<(Self, EventSubscriber)> {
+    async fn start(config: NodeConfig<B, S>) -> Result<(Self, EventSubscriber)> {
         let event_channel = EventChannel::new();
         let event_sub = event_channel.subscribe();
         let store = Arc::new(config.store);

node/src/node/builder.rs

@@ -59,8 +59,8 @@ where
 {
     /// Creates and starts a new Celestia [`Node`].
     pub async fn start(self) -> Result<Node<B, S>> {
-        let config = self.build_config()?;
-        Node::new(config).await
+        let (node, _) = self.start_subscribed().await?;
+        Ok(node)
     }
 
     /// Creates and starts a new Celestia [`Node`].
@@ -69,7 +69,7 @@ where
     /// any events that will be generated on the construction of the node.
     pub async fn start_subscribed(self) -> Result<(Node<B, S>, EventSubscriber)> {
         let config = self.build_config()?;
-        Node::new_subscribed(config).await
+        Node::start(config).await
     }
 
     /// Set the [`Blockstore`] for Bitswap.