hyper is dead! long live hyper! (#1924)

Summary:
Pull Request resolved: #1924

Revive the hyper command:

* rip out old dependencies, whittle it down to 'list' and 'show'
* support for proc enumeration and state inspection

... to be continued
ghstack-source-id: 327072953
exported-using-ghexport

Reviewed By: vidhyav

Differential Revision: D87370648

fbshipit-source-id: 5d734b5629e0f8e7bdaccc39545a76ed3079af77

Author: mariusae

hyper/Cargo.toml

@@ -1,4 +1,4 @@
-# This file is manually maintained to maintain the abilith to build hyper
+# This file is manually maintained to maintain the ability to build hyper
 # using cargo. The code is annotated with fbcode_build conditionals such that
 # it works with both cargo (all oss deps) and buck (full meta deps).
 [package]
@@ -15,7 +15,7 @@ chrono = { version = "0.4.41", features = ["clock", "serde", "std"], default-fea
 clap = { version = "4.5.30", features = ["derive", "env", "string", "unicode", "wrap_help"] }
 console = "0.15.7"
 hyperactor = { path = "../hyperactor" }
-hyperactor_multiprocess = { path = "../hyperactor_multiprocess" }
+hyperactor_mesh = { path = "../hyperactor_mesh" }
 serde = { version = "1.0.185", features = ["derive", "rc"] }
 serde_json = { version = "1.0.132", features = ["float_roundtrip", "unbounded_depth"] }
 tabwriter = { version = "1.2.1", features = ["ansi_formatting"] }

hyper/src/commands.rs

@@ -6,9 +6,5 @@
  * LICENSE file in the root directory of this source tree.
  */
 
-pub mod demo;
-pub mod procs;
-pub mod serve;
+pub mod list;
 pub mod show;
-#[cfg(fbcode_build)]
-pub mod top;

hyper/src/commands/demo.rs

@@ -0,0 +1,45 @@
+/*
+ * Copyright (c) Meta Platforms, Inc. and affiliates.
+ * All rights reserved.
+ *
+ * This source code is licensed under the BSD-style license found in the
+ * LICENSE file in the root directory of this source tree.
+ */
+
+use hyperactor::ActorRef;
+use hyperactor::channel::ChannelAddr;
+use hyperactor::reference::ProcId;
+use hyperactor_mesh::proc_mesh::global_root_client;
+use hyperactor_mesh::resource::ListClient;
+use hyperactor_mesh::v1::host_mesh::mesh_agent::HostMeshAgent;
+
+#[derive(clap::Args, Debug)]
+pub struct ListCommand {
+    /// The reference to the resource to list.
+    /// TODO: this is a temporary workaround:  
+    /// formalize parsing host refs, etc.
+    reference: String,
+}
+
+impl ListCommand {
+    pub async fn run(self) -> anyhow::Result<()> {
+        let host: ChannelAddr = self.reference.parse().map_err(|e| {
+            anyhow::anyhow!(
+                "could not parse '{}' as a host reference: {}",
+                self.reference,
+                e
+            )
+        })?;
+
+        let client = global_root_client();
+
+        // Codify obtaining a proc's agent in `hyperactor_mesh` somewhere.
+        let agent: ActorRef<HostMeshAgent> =
+            ActorRef::attest(ProcId::Direct(host, "service".to_string()).actor_id("agent", 0));
+
+        let resources = agent.list(&client).await?;
+        println!("{}", serde_json::to_string_pretty(&resources)?);
+
+        Ok(())
+    }
+}