dev leader deprecation (#2132)

## Description

Initial PR the remove leader/follower related code so we can build upon
implementing new `rover dev` command while keeping changes atomic.

src/command/dev/do_dev.rs

@@ -1,18 +1,8 @@
-use anyhow::{anyhow, Context};
 use camino::Utf8PathBuf;
-use futures::channel::mpsc::channel;
-use futures::future::join_all;
-use futures::stream::StreamExt;
-use futures::FutureExt;
-use rover_std::warnln;
 
-use crate::command::dev::protocol::FollowerMessage;
 use crate::utils::client::StudioClientConfig;
-use crate::utils::supergraph_config::get_supergraph_config;
 use crate::{RoverError, RoverOutput, RoverResult};
 
-use super::protocol::{FollowerChannel, FollowerMessenger, LeaderChannel, LeaderSession};
-use super::router::RouterConfigHandler;
 use super::Dev;
 
 pub fn log_err_and_continue(err: RoverError) -> RoverError {
@@ -26,143 +16,6 @@ impl Dev {
         override_install_path: Option<Utf8PathBuf>,
         client_config: StudioClientConfig,
     ) -> RoverResult<RoverOutput> {
-        self.opts
-            .plugin_opts
-            .prompt_for_license_accept(&client_config)?;
-
-        let router_config_handler = RouterConfigHandler::try_from(&self.opts.supergraph_opts)?;
-        let router_address = router_config_handler.get_router_address();
-        let raw_socket_name = router_config_handler.get_raw_socket_name();
-        let leader_channel = LeaderChannel::new();
-        let follower_channel = FollowerChannel::new();
-
-        let supergraph_config = get_supergraph_config(
-            &self.opts.supergraph_opts.graph_ref,
-            &self.opts.supergraph_opts.supergraph_config_path,
-            self.opts.supergraph_opts.federation_version.as_ref(),
-            client_config.clone(),
-            &self.opts.plugin_opts.profile,
-            false,
-        )
-        .await?;
-
-        if let Some(mut leader_session) = LeaderSession::new(
-            override_install_path,
-            &client_config,
-            leader_channel.clone(),
-            follower_channel.clone(),
-            self.opts.plugin_opts.clone(),
-            &supergraph_config,
-            router_config_handler,
-            self.opts.supergraph_opts.license.clone(),
-        )
-        .await?
-        {
-            warnln!(
-                "Do not run this command in production! It is intended for local development only."
-            );
-            let (ready_sender, mut ready_receiver) = channel(1);
-            let follower_messenger = FollowerMessenger::from_main_session(
-                follower_channel.clone().sender,
-                leader_channel.receiver,
-            );
-
-            tokio::task::spawn_blocking(move || {
-                ctrlc::set_handler(move || {
-                    eprintln!(
-                        "\nshutting down the `rover dev` session and all attached processes..."
-                    );
-                    let _ = follower_channel
-                        .sender
-                        .send(FollowerMessage::shutdown(true))
-                        .map_err(|e| {
-                            let e =
-                                RoverError::new(anyhow!("could not shut down router").context(e));
-                            log_err_and_continue(e)
-                        });
-                })
-                .context("could not set ctrl-c handler for main `rover dev` process")
-                .unwrap();
-            });
-
-            let subgraph_watcher_handle = tokio::task::spawn(async move {
-                let _ = leader_session
-                    .listen_for_all_subgraph_updates(ready_sender)
-                    .await
-                    .map_err(log_err_and_continue);
-            });
-
-            ready_receiver.next().await.unwrap();
-
-            let subgraph_watchers = self
-                .opts
-                .supergraph_opts
-                .get_subgraph_watchers(
-                    &client_config,
-                    supergraph_config,
-                    follower_messenger.clone(),
-                    self.opts.subgraph_opts.subgraph_polling_interval,
-                    &self.opts.plugin_opts.profile,
-                    self.opts.subgraph_opts.subgraph_retries,
-                )
-                .await
-                .transpose()
-                .unwrap_or_else(|| {
-                    self.opts
-                        .subgraph_opts
-                        .get_subgraph_watcher(
-                            router_address,
-                            &client_config,
-                            follower_messenger.clone(),
-                        )
-                        .map(|watcher| vec![watcher])
-                })?;
-
-            let futs = subgraph_watchers.into_iter().map(|mut watcher| async move {
-                let _ = watcher
-                    .watch_subgraph_for_changes(client_config.retry_period)
-                    .await
-                    .map_err(log_err_and_continue);
-            });
-            tokio::join!(join_all(futs), subgraph_watcher_handle.map(|_| ()));
-        } else {
-            let follower_messenger = FollowerMessenger::from_attached_session(&raw_socket_name);
-            let mut subgraph_refresher = self.opts.subgraph_opts.get_subgraph_watcher(
-                router_address,
-                &client_config,
-                follower_messenger.clone(),
-            )?;
-            tracing::info!(
-                "connecting to existing `rover dev` process by communicating via the interprocess socket located at {raw_socket_name}",
-            );
-
-            // start the interprocess socket health check in the background
-            let health_messenger = follower_messenger.clone();
-            tokio::task::spawn_blocking(move || {
-                let _ = health_messenger.health_check().map_err(|_| {
-                    eprintln!("shutting down...");
-                    std::process::exit(1);
-                });
-            });
-
-            // set up the ctrl+c handler to notify the main session to remove the killed subgraph
-            let kill_name = subgraph_refresher.get_name();
-            ctrlc::set_handler(move || {
-                eprintln!("\nshutting down...");
-                let _ = follower_messenger
-                    .remove_subgraph(&kill_name)
-                    .map_err(log_err_and_continue);
-                std::process::exit(1);
-            })
-            .context("could not set ctrl-c handler")?;
-
-            // watch for subgraph changes on the main thread
-            // it will take care of updating the main `rover dev` session
-            subgraph_refresher
-                .watch_subgraph_for_changes(client_config.retry_period)
-                .await?;
-        }
-
-        unreachable!("watch_subgraph_for_changes never returns")
+        todo!()
     }
 }

src/command/dev/introspect.rs

@@ -4,9 +4,11 @@ use anyhow::anyhow;
 use reqwest::Client;
 use rover_std::Style;
 
-use crate::command::dev::protocol::{SubgraphSdl, SubgraphUrl};
-use crate::command::graph::Introspect as GraphIntrospect;
-use crate::command::subgraph::Introspect as SubgraphIntrospect;
+use crate::command::{
+    dev::types::{SubgraphSdl, SubgraphUrl},
+    graph::Introspect as GraphIntrospect,
+    subgraph::Introspect as SubgraphIntrospect,
+};
 use crate::options::IntrospectOpts;
 use crate::{RoverError, RoverErrorSuggestion, RoverResult};
 

src/command/dev/mod.rs

@@ -19,23 +19,14 @@ mod do_dev;
 #[cfg(feature = "composition-js")]
 mod introspect;
 
-#[cfg(feature = "composition-js")]
-mod protocol;
-
 #[cfg(feature = "composition-js")]
 mod router;
 
-#[cfg(feature = "composition-js")]
-mod schema;
-
-#[cfg(feature = "composition-js")]
-mod netstat;
-
 #[cfg(not(feature = "composition-js"))]
 mod no_dev;
 
 #[cfg(feature = "composition-js")]
-mod watcher;
+mod types;
 
 #[derive(Debug, Serialize, Parser)]
 pub struct Dev {