From f1a527e22d6f085284d723a910d947ac5d7520e8 Mon Sep 17 00:00:00 2001
From: Noor <noormohammedb@protonmail.com>
Date: Mon, 10 Feb 2025 19:56:39 +0530
Subject: [PATCH] Integrating authendication

rename register_node to register_app_node
---
 Cargo.lock  |  2 +-
 src/grpc.rs | 14 ++++++++++----
 2 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 76631e4..b77319b 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -418,7 +418,7 @@ dependencies = [
 [[package]]
 name = "detee-shared"
 version = "0.1.0"
-source = "git+ssh://git@gitea.detee.cloud/noormohammedb/detee-shared?branch=stable_01#fce57884937a4ec02acbf2f5b370ab879b1af657"
+source = "git+ssh://git@gitea.detee.cloud/noormohammedb/detee-shared?branch=stable_01#65bfa113a44251dd13e5d895014f4a773e367d2e"
 dependencies = [
  "base64",
  "prost",
diff --git a/src/grpc.rs b/src/grpc.rs
index 6e69c69..1f6c355 100644
--- a/src/grpc.rs
+++ b/src/grpc.rs
@@ -426,14 +426,14 @@ impl BrainAppCli for BrainAppCliMock {
 
 #[tonic::async_trait]
 impl BrainAppDaemon for BrainAppDaemonMock {
-    type RegisterNodeStream = Pin<Box<dyn Stream<Item = Result<AppContract, Status>> + Send>>;
+    type RegisterAppNodeStream = Pin<Box<dyn Stream<Item = Result<AppContract, Status>> + Send>>;
     type BrainMessagesStream = Pin<Box<dyn Stream<Item = Result<BrainMessageApp, Status>> + Send>>;
 
-    async fn register_node(
+    async fn register_app_node(
         &self,
         req: tonic::Request<RegisterAppNodeReq>,
-    ) -> Result<tonic::Response<Self::RegisterNodeStream>, Status> {
-        let req_data = req.into_inner();
+    ) -> Result<tonic::Response<Self::RegisterAppNodeStream>, Status> {
+        let req_data = check_sig_from_req(req)?;
         log::info!(
             "registering app node_key : {}, owner_key: {}",
             &req_data.node_pubkey,
@@ -569,6 +569,12 @@ impl PubkeyGetter for AirdropReq {
     }
 }
 
+impl PubkeyGetter for RegisterAppNodeReq {
+    fn get_pubkey(&self) -> Option<String> {
+        None
+    }
+}
+
 fn check_sig_from_req<T: std::fmt::Debug + PubkeyGetter>(req: Request<T>) -> Result<T, Status> {
     let time = match req.metadata().get("timestamp") {
         Some(t) => t.clone(),