H-3552: graph: Integrate harpc into the graph (#5577)

Co-authored-by: Tim Diekmann <[email protected]>
hashintel · Nov 6, 2024 · 10447a2 · 10447a2
1 parent 7631610
commit 10447a2
Show file tree

Hide file tree

Showing 32 changed files with 1,815 additions and 59 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/apps/hash-graph/libs/api/Cargo.toml b/apps/hash-graph/libs/api/Cargo.toml
@@ -20,17 +20,23 @@ graph = { workspace = true, public = true, features = ["utoipa"] }
 graph-types = { workspace = true, public = true, features = ["utoipa"] }
 hash-graph-store = { workspace = true, features = ["utoipa"] }
 temporal-client = { workspace = true, public = true }
+harpc-server = { workspace = true, public = true }
+harpc-client = { workspace = true, public = true }
 
 # Public third-party dependencies
 axum = { workspace = true, public = true }
 axum-core = { workspace = true, public = true }
 http = { workspace = true, public = true }
 tower-http = { workspace = true, public = true }
 tracing = { workspace = true, public = true }
+error-stack = { workspace = true, features = ["futures", "spantrace", "unstable"] }
 
 # Private workspace dependencies
-error-stack = { workspace = true, features = ["spantrace"] }
 graph-type-defs = { workspace = true }
+harpc-codec = { workspace = true }
+harpc-service = { workspace = true }
+harpc-tower = { workspace = true }
+harpc-types = { workspace = true }
 hash-status = { workspace = true }
 temporal-versioning = { workspace = true }
 type-system = { workspace = true, features = ["utoipa"] }
@@ -39,6 +45,10 @@ validation = { workspace = true, features = ["utoipa"] }
 # Private third-party dependencies
 async-trait = { workspace = true }
 bytes = { workspace = true }
+derive-where = { workspace = true }
+derive_more = { version = "1.0.0", features = ["display", "error"] }
+frunk = "0.4.3"
+futures = { workspace = true }
 hyper = { workspace = true }
 include_dir = { workspace = true }
 mime = { workspace = true }
@@ -48,6 +58,7 @@ sentry = { workspace = true }
 serde = { workspace = true, features = ['derive'] }
 serde_json = { workspace = true }
 time = { workspace = true }
+tower = { workspace = true }
 tracing-opentelemetry = { workspace = true }
 utoipa = { workspace = true }
 uuid = { workspace = true }

diff --git a/apps/hash-graph/libs/api/package.json b/apps/hash-graph/libs/api/package.json
@@ -14,6 +14,12 @@
     "@rust/graph": "0.0.0-private",
     "@rust/graph-type-defs": "0.0.0-private",
     "@rust/graph-types": "0.0.0-private",
+    "@rust/harpc-client": "0.0.0-private",
+    "@rust/harpc-codec": "0.0.0-private",
+    "@rust/harpc-server": "0.0.0-private",
+    "@rust/harpc-service": "0.0.0-private",
+    "@rust/harpc-tower": "0.0.0-private",
+    "@rust/harpc-types": "0.0.0-private",
     "@rust/hash-graph-store": "0.0.0-private",
     "@rust/hash-status": "0.0.0-private",
     "@rust/temporal-client": "0.0.0-private",

diff --git a/apps/hash-graph/libs/api/src/lib.rs b/apps/hash-graph/libs/api/src/lib.rs
@@ -1,5 +1,11 @@
-#![feature(impl_trait_in_assoc_type)]
+#![feature(
+    impl_trait_in_assoc_type,
+    never_type,
+    return_type_notation,
+    error_generic_member_access
+)]
 
 extern crate alloc;
 
 pub mod rest;
+pub mod rpc;
diff --git a/apps/hash-graph/libs/api/src/rest/mod.rs b/apps/hash-graph/libs/api/src/rest/mod.rs
@@ -62,7 +62,7 @@ use hash_graph_store::{
 use hash_status::Status;
 use include_dir::{Dir, include_dir};
 use sentry::integrations::tower::{NewSentryLayer, SentryHttpLayer};
-use serde::Serialize;
+use serde::{Deserialize, Serialize};
 use temporal_client::TemporalClient;
 use temporal_versioning::{
     ClosedTemporalBound, DecisionTime, LeftClosedTemporalInterval, LimitedTemporalBound,
@@ -116,9 +116,9 @@ impl<S> FromRequestParts<S> for AuthenticatedUserHeader {
     }
 }
 
-#[derive(Debug, Serialize, ToSchema)]
+#[derive(Debug, Serialize, Deserialize, ToSchema)]
 pub struct PermissionResponse {
-    has_permission: bool,
+    pub has_permission: bool,
 }
 
 pub trait RestApiStore: Store + TypeFetcher {