move types into client

bin/core/src/api/read/user.rs

@@ -0,0 +1,67 @@
+use anyhow::{anyhow, Context};
+use async_trait::async_trait;
+use monitor_client::{
+  api::read::{GetUser, GetUsername, GetUsernameResponse, GetUsers},
+  entities::user::User,
+};
+use mungos::{by_id::find_one_by_id, find::find_collect};
+use resolver_api::Resolve;
+
+use crate::{auth::RequestUser, state::State};
+
+#[async_trait]
+impl Resolve<GetUser, RequestUser> for State {
+  async fn resolve(
+    &self,
+    GetUser {}: GetUser,
+    user: RequestUser,
+  ) -> anyhow::Result<User> {
+    let mut user = find_one_by_id(&self.db.users, &user.id)
+      .await
+      .context("failed at mongo query")?
+      .context("no user found with id")?;
+    for secret in &mut user.secrets {
+      secret.hash = String::new();
+    }
+    Ok(user)
+  }
+}
+
+#[async_trait]
+impl Resolve<GetUsername, RequestUser> for State {
+  async fn resolve(
+    &self,
+    GetUsername { user_id }: GetUsername,
+    _: RequestUser,
+  ) -> anyhow::Result<GetUsernameResponse> {
+    let user = find_one_by_id(&self.db.users, &user_id)
+      .await
+      .context("failed at mongo query for user")?
+      .context("no user found with id")?;
+
+    Ok(GetUsernameResponse {
+      username: user.username,
+    })
+  }
+}
+
+#[async_trait]
+impl Resolve<GetUsers, RequestUser> for State {
+  async fn resolve(
+    &self,
+    GetUsers {}: GetUsers,
+    user: RequestUser,
+  ) -> anyhow::Result<Vec<User>> {
+    if !user.is_admin {
+      return Err(anyhow!("this route is only accessable by admins"));
+    }
+
+    let mut users = find_collect(&self.db.users, None, None)
+      .await
+      .context("failed to pull users from db")?;
+    users.iter_mut().for_each(|user| {
+      user.secrets = Vec::new();
+    });
+    Ok(users)
+  }
+}