From 2311377711c7ae0307a9cade7a43f3bd2b59015e Mon Sep 17 00:00:00 2001
From: Petru <smart__petea@mail.ru>
Date: Sun, 1 Oct 2023 08:37:30 +0300
Subject: [PATCH] issue-3 response from user service

---
 src/models/user.rs |  4 +++-
 src/startup.rs     | 29 ++++++++++++++++++++++++++---
 2 files changed, 29 insertions(+), 4 deletions(-)

diff --git a/src/models/user.rs b/src/models/user.rs
index 0c57db4..f345e40 100644
--- a/src/models/user.rs
+++ b/src/models/user.rs
@@ -1,4 +1,6 @@
-#[derive(Debug, Copy, Clone)]
+use serde::Deserialize;
+
+#[derive(Debug, Copy, Clone, Deserialize)]
 pub struct User {
     pub id: i32,
 }
diff --git a/src/startup.rs b/src/startup.rs
index 5999bae..615fcab 100644
--- a/src/startup.rs
+++ b/src/startup.rs
@@ -10,6 +10,7 @@ use actix_web::{
     HttpServer,
 };
 use actix_web_httpauth::{extractors::bearer::BearerAuth, middleware::HttpAuthentication};
+use reqwest::header::{ACCEPT, CONTENT_TYPE};
 use sqlx::PgPool;
 use std::net::TcpListener;
 
@@ -22,9 +23,31 @@ async fn bearer_guard(
     eprintln!("{credentials:?}");
     //todo check that credentials.token is a real. get in sync with auth server
     //todo get user from auth server
-    //todo save the server in the request state
-    //todo get the user in the rating route
-    let user = User { id: 1 };
+
+    let client = reqwest::Client::new();
+    let resp = client
+        .get("https://65190108818c4e98ac6000e4.mockapi.io/user/1") //todo add the right url
+        .bearer_auth(credentials.token())
+        .header(CONTENT_TYPE, "application/json")
+        .header(ACCEPT, "application/json")
+        .send()
+        .await
+        .unwrap() //todo process the response rightly. At moment it's some of something
+        ;
+    eprintln!("{resp:?}");
+
+    let user: User = match resp.status() {
+        reqwest::StatusCode::OK => match resp.json().await {
+            Ok(user) => user,
+            Err(err) => panic!("can't parse the user from json {err:?}"), //todo
+        },
+        other => {
+            //todo process the other status code accordingly
+            panic!("unexpected status code {other}");
+        }
+    };
+
+    //let user = User { id: 1 };
     tracing::info!("authentication middleware. {user:?}");
     let existent_user = req.extensions_mut().insert(user);
     if existent_user.is_some() {