chore(notifications): WIP integrate tonic

Cargo.toml

@@ -38,3 +38,5 @@ opentelemetry = { version = "0.20.0", features = ["trace", "rt-tokio"]}
 opentelemetry-semantic-conventions = "0.12.0"
 opentelemetry-http = "0.9.0"
 http = "0.2.9"
+tonic = "0.10.2"
+prost = "0.12"

core/notifications/BUCK

@@ -66,6 +66,9 @@ rust_library(
         "//third-party/rust:rand",
         "//third-party/rust:uuid",
         "//third-party/rust:serde_with",
+        "//third-party/rust:prost",
+        "//third-party/rust:tonic",
+        "//third-party/rust:tonic-build",
     ],
     srcs = glob([
       "src/**/*.rs",
@@ -75,7 +78,7 @@ rust_library(
     ]),
     env = {
         "CARGO_MANIFEST_DIR": ".",
-        "SQLX_OFFLINE": "true",
+        "SQLX_OFFLINE": "true"
     }
 )
 

core/notifications/Cargo.toml

@@ -37,3 +37,8 @@ mongodb = { workspace = true }
 rand = { workspace = true }
 uuid = { workspace = true }
 serde_with = { workspace = true }
+tonic = { workspace = true }
+prost = { workspace = true }
+
+[build-dependencies]
+tonic-build = { version = "0.10.2", features = ["prost"] }

core/notifications/build.rs

@@ -0,0 +1,7 @@
+fn main() -> Result<(), Box<dyn std::error::Error>> {
+    println!("cargo:rerun-if-changed=migrations");
+
+    // std::env::set_var("PROTOC", protobuf_src::protoc());
+    tonic_build::configure().compile(&["proto/notifications.proto"], &["proto"])?;
+    Ok(())
+}

core/notifications/proto/notifications.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+
+package helloworld;
+
+// The greeting service definition.
+service Greeter {
+  // Sends a greeting
+  rpc SayHello (HelloRequest) returns (HelloReply) {}
+}
+
+// The request message containing the user's name.
+message HelloRequest {
+  string name = 1;
+}
+
+// The response message containing the greetings.
+message HelloReply {
+  string message = 1;
+}
+

core/notifications/src/lib.rs

@@ -8,3 +8,8 @@ mod primitives;
 
 pub mod cli;
 pub mod graphql;
+
+#[allow(clippy::all)]
+pub mod proto {
+    tonic::include_proto!("helloworld");
+}

flake.nix

@@ -71,6 +71,7 @@
           cargo-watch
           reindeer
           gitMinimal
+          protobuf
         ]
         ++ buck2NativeBuildInputs
         ++ lib.optionals pkgs.stdenv.isLinux [