Hook up service.

.gitignore

@@ -1,6 +1,7 @@
 /target
 node_modules/
 .nx
+bazel-remote
 
 # Yarn
 .yarn/*

.moon/workspace.yml

@@ -35,3 +35,6 @@ docker:
     include:
       - '*.config.js'
       - '*.json'
+
+unstable_remote:
+  host: 'http://moon:[email protected]:8585'

crates/app/Cargo.toml

@@ -25,6 +25,7 @@ moon_plugin = { path = "../plugin" }
 moon_project = { path = "../project" }
 moon_project_graph = { path = "../project-graph" }
 moon_query = { path = "../query" }
+moon_remote = { path = "../remote" }
 moon_task = { path = "../task" }
 moon_toolchain = { path = "../toolchain" }
 moon_toolchain_plugin = { path = "../toolchain-plugin" }

crates/app/src/session.rs

@@ -15,6 +15,7 @@ use moon_env::MoonEnvironment;
 use moon_extension_plugin::*;
 use moon_plugin::PluginId;
 use moon_project_graph::{ProjectGraph, ProjectGraphBuilder};
+use moon_remote::RemoteService;
 use moon_toolchain_plugin::*;
 use moon_vcs::{BoxedVcs, Git};
 use once_cell::sync::OnceCell;
@@ -35,7 +36,6 @@ pub struct CliSession {
 
     // Components
     pub console: Console,
-    pub moonbase: Option<Arc<Moonbase>>,
     pub moon_env: Arc<MoonEnvironment>,
     pub proto_env: Arc<ProtoEnvironment>,
 
@@ -65,7 +65,6 @@ impl CliSession {
             cli_version: Version::parse(&cli_version).unwrap(),
             console: Console::new(cli.quiet),
             extension_registry: OnceCell::new(),
-            moonbase: None,
             moon_env: Arc::new(MoonEnvironment::default()),
             project_graph: OnceCell::new(),
             proto_env: Arc::new(ProtoEnvironment::default()),
@@ -243,7 +242,11 @@ impl AppSession for CliSession {
         if !is_test_env() && is_ci() {
             let vcs = self.get_vcs_adapter()?;
 
-            self.moonbase = startup::signin_to_moonbase(&vcs).await?;
+            startup::signin_to_moonbase(&vcs).await?;
+        }
+
+        if let Some(remote_config) = &self.workspace_config.remote {
+            RemoteService::connect(remote_config).await?;
         }
 
         Ok(())

crates/cli/src/main.rs

@@ -30,7 +30,16 @@ fn get_version() -> String {
 }
 
 fn get_tracing_modules() -> Vec<String> {
-    let mut modules = string_vec!["moon", "proto", "schematic", "starbase", "warpgate"];
+    let mut modules = string_vec![
+        "moon",
+        "proto",
+        "schematic",
+        "starbase",
+        "warpgate",
+        "tonic",
+        "hyper",
+        "h2"
+    ];
 
     if env::var("MOON_DEBUG_WASM").is_ok() {
         modules.push("extism".into());

crates/remote/src/cache_api.rs

@@ -17,6 +17,7 @@ use tonic::transport::Channel;
 
 const INSTANCE_NAME: &str = "moon_task_outputs";
 
+#[derive(Debug)]
 pub struct Cache {
     cas_client: RwLock<ContentAddressableStorageClient<Channel>>,
     fetch_client: RwLock<FetchClient<Channel>>,
@@ -71,6 +72,8 @@ impl Cache {
     ) -> miette::Result<()> {
         let digest = self.create_digest(hash, path)?;
 
+        dbg!(&task.target.id, hash, &digest);
+
         // Upload the blob to the CAS
         if let Err(error) = self
             .cas_client
@@ -87,6 +90,10 @@ impl Cache {
             })
             .await
         {
+            dbg!(&error);
+            dbg!(error.code());
+            dbg!(error.metadata());
+            dbg!(error.message());
             // TODO handle error
             panic!("{:?}", error);
         }

crates/remote/src/remote_service.rs

@@ -2,11 +2,12 @@ use crate::cache_api::Cache;
 use miette::IntoDiagnostic;
 use moon_config::RemoteConfig;
 use std::sync::{Arc, OnceLock};
-use tonic::transport::Endpoint;
+use tonic::transport::{ClientTlsConfig, Endpoint};
 // use tonic::transport::{Certificate, Channel, ClientTlsConfig, Endpoint};
 
 static INSTANCE: OnceLock<Arc<RemoteService>> = OnceLock::new();
 
+#[derive(Debug)]
 pub struct RemoteService {
     pub cache: Cache,
     pub config: RemoteConfig,
@@ -17,8 +18,8 @@ impl RemoteService {
         INSTANCE.get().cloned()
     }
 
-    pub async fn new(config: &RemoteConfig) -> miette::Result<Arc<RemoteService>> {
-        let endpoint = Endpoint::from_shared(config.host.clone()).into_diagnostic()?;
+    pub async fn connect(config: &RemoteConfig) -> miette::Result<Arc<RemoteService>> {
+        let mut endpoint = Endpoint::from_shared(config.host.clone()).into_diagnostic()?;
 
         // Support TLS connections
         // if let Some(tls) = &config.tls {
@@ -31,13 +32,19 @@ impl RemoteService {
         //         .with_enabled_roots();
         // }
 
+        // endpoint = endpoint
+        //     .tls_config(ClientTlsConfig::new().with_enabled_roots())
+        //     .unwrap();
+
         let channel = endpoint.connect().await.into_diagnostic()?;
 
         let service = Arc::new(Self {
             cache: Cache::new(channel, config).await?,
             config: config.to_owned(),
         });
 
+        dbg!(&service);
+
         let _ = INSTANCE.set(Arc::clone(&service));
 
         Ok(service)

justfile

@@ -72,3 +72,6 @@ moon-check:
 
 schemas:
 	cargo run -p moon_config_schema --features typescript
+
+bazel-remote:
+	./bazel-remote --dir ~/.moon/bazel-cache --max_size 10 --storage_mode uncompressed --http_address 0.0.0.0:8585 --htpasswd_file ./scripts/data/.htpasswd

scripts/data/.htpasswd

@@ -0,0 +1 @@
+moon:$apr1$dyMnHSrA$x0xn6BrnYQyw8pwXnbEnq1