Add LSP functionality to Rover

Cargo.toml

@@ -73,6 +73,8 @@ apollo-encoder = "0.8"
 # https://github.com/apollographql/federation-rs
 apollo-federation-types = "0.14.1"
 
+apollo-language-server = { version = "0.3.4", default-features = false, features = ["tokio"] }
+
 # crates.io dependencies
 anyhow = "1"
 ariadne = "0.5"
@@ -168,6 +170,7 @@ zip = "2.0"
 anyhow = { workspace = true }
 assert_fs = { workspace = true }
 async-trait = { workspace = true }
+apollo-language-server = { workspace = true}
 apollo-federation-types = { workspace = true }
 apollo-parser = { workspace = true }
 billboard = { workspace = true }
@@ -223,6 +226,7 @@ tokio-stream = { workspace = true }
 tokio-util = { workspace = true }
 toml = { workspace = true }
 tower = { workspace = true }
+tower-lsp = { version = "0.20.0" }
 tracing = { workspace = true }
 which = { workspace = true }
 uuid = { workspace = true }

crates/robot-panic/src/lib.rs

@@ -93,7 +93,7 @@ macro_rules! setup_panic {
         #[cfg(not(debug_assertions))]
         match ::std::env::var("RUST_BACKTRACE") {
             Err(_) => {
-                panic::set_hook(Box::new(move |info: &PanicInfo| {
+                panic::set_hook(Box::new(move |info: &PanicHookInfo| {
                     let crash_report = get_report(&$meta, info);
                     print_msg(&crash_report, &$meta)
                         .expect("robot-panic: printing error message to console failed");
@@ -105,7 +105,7 @@ macro_rules! setup_panic {
 
     () => {
         #[allow(unused_imports)]
-        use std::panic::{self, PanicInfo};
+        use std::panic::{self, PanicHookInfo};
         #[allow(unused_imports)]
         use $crate::{get_report, print_msg, Metadata};
 
@@ -120,7 +120,7 @@ macro_rules! setup_panic {
                     repository: env!("CARGO_PKG_REPOSITORY").into(),
                 };
 
-                panic::set_hook(Box::new(move |info: &PanicInfo| {
+                panic::set_hook(Box::new(move |info: &PanicHookInfo| {
                     let crash_report = get_report(&meta, info);
                     print_msg(&crash_report, &meta)
                         .expect("robot-panic: printing error message to console failed");

crates/rover-std/Cargo.toml

@@ -14,11 +14,9 @@ notify = { workspace = true }
 tap = { workspace = true }
 tokio = { workspace = true, features = [ "macros", "rt", "rt-multi-thread", "time" ] }
 tokio-util = { workspace = true}
-tokio-stream = { workspace = true }
 thiserror = { workspace = true }
 tracing = { workspace = true }
 url = { workspace = true }
-console-subscriber = "0.4.0"
 
 [dev-dependencies]
 notify = { workspace = true }

deny.toml

@@ -64,6 +64,24 @@ version = "*"
 expression = "(Apache-2.0 OR MIT) AND BSD-3-Clause"
 license-files = [{ path = "COPYRIGHT", hash = 0x39f8ad31 }]
 
+[[licenses.clarify]]
+name = "apollo-language-server"
+version = "*"
+expression = "Elastic-2.0"
+license-files = [{ path = "LICENSE.md", hash = 0x5fc4a573 }]
+
+[[licenses.exceptions]]
+name = "apollo-language-server"
+allow = ["Elastic-2.0"]
+
+[[licenses.exceptions]]
+name = "apollo-federation"
+allow = ["Elastic-2.0"]
+
+[[licenses.exceptions]]
+name = "apollo-composition"
+allow = ["Elastic-2.0"]
+
 # This section is considered when running `cargo deny check bans`.
 # More documentation about the 'bans' section can be found here:
 # https://embarkstudios.github.io/cargo-deny/checks/bans/cfg.html

src/cli.rs

@@ -234,6 +234,8 @@ impl Rover {
             Command::Explain(command) => command.run(),
             Command::PersistedQueries(command) => command.run(self.get_client_config()?).await,
             Command::License(command) => command.run(self.get_client_config()?).await,
+            #[cfg(feature = "composition-js")]
+            Command::Lsp(command) => command.run(self.get_client_config()?).await,
         }
     }
 
@@ -432,6 +434,11 @@ pub enum Command {
 
     /// Commands for fetching offline licenses
     License(command::License),
+
+    /// Start the language server
+    #[cfg(feature = "composition-js")]
+    #[clap(hide = true)]
+    Lsp(command::Lsp),
 }
 
 #[derive(Default, ValueEnum, Debug, Serialize, Clone, Copy, Eq, PartialEq)]

src/command/dev/next/mod.rs

@@ -15,6 +15,7 @@ use rover_std::{errln, infoln, warnln};
 use semver::Version;
 use tower::ServiceExt;
 
+use crate::composition::supergraph::binary::OutputTarget;
 use crate::{
     command::{
         dev::{OVERRIDE_DEV_COMPOSITION_VERSION, OVERRIDE_DEV_ROUTER_VERSION},
@@ -171,6 +172,8 @@ impl Dev {
                 fetch_remote_subgraph_factory.boxed_clone(),
                 self.opts.subgraph_opts.subgraph_polling_interval,
                 tmp_config_dir_path.clone(),
+                OutputTarget::Stdout,
+                false,
             )
             .await?;
 

src/command/lsp/errors.rs

@@ -0,0 +1,25 @@
+use anyhow::Error;
+use camino::{FromPathBufError, Utf8PathBuf};
+
+use crate::composition::pipeline::CompositionPipelineError;
+use crate::composition::supergraph::config::resolver::ResolveSupergraphConfigError;
+use crate::composition::supergraph::install::InstallSupergraphError;
+use crate::composition::CompositionError;
+
+#[derive(thiserror::Error, Debug)]
+pub enum StartCompositionError {
+    #[error("Could not convert Supergraph path to URL")]
+    SupergraphYamlUrlConversionFailed(Utf8PathBuf),
+    #[error("Could not create HTTP service")]
+    HttpServiceCreationFailed(#[from] Error),
+    #[error("Could not initialise the composition pipeline")]
+    InitialisingCompositionPipelineFailed(#[from] CompositionPipelineError),
+    #[error("Could not run initial composition")]
+    InitialCompositionFailed(#[from] CompositionError),
+    #[error("Could not install supergraph plugin")]
+    InstallSupergraphPluginFailed(#[from] InstallSupergraphError),
+    #[error("Could not resolve Supergraph Config")]
+    ResolvingSupergraphConfigFailed(#[from] ResolveSupergraphConfigError),
+    #[error("Could not establish temporary directory")]
+    TemporaryDirectoryCouldNotBeEstablished(#[from] FromPathBufError),
+}