fabaccess-bffh/bffhd/capnp/user_system.rs

use api::users_capnp::users;
use capnp::capability::{Promise, FromClientHook};
use capnp_rpc::pry;
use tracing::Span;
use api::user_capnp;

use crate::capnp::user::User;

use crate::session::SessionHandle;
use crate::users::{db, UserRef};

const TARGET: &str = "bffh::api::usersystem";

#[derive(Clone)]
pub struct Users {
    span: Span,
    session: SessionHandle,
}

impl Users {
    pub fn new(session: SessionHandle) -> Self {
        let span = tracing::info_span!(target: TARGET, "UserSystem",);
        Self { span, session }
    }
}

impl users::Server for Users {
    fn list(
        &mut self,
        _: users::ListParams,
        mut result: users::ListResults,
    ) -> Promise<(), ::capnp::Error> {
        let _guard = self.span.enter();
        let _span = tracing::trace_span!(target: TARGET, "getUserList",).entered();
        tracing::trace!("method call");

        let userdb = self.session.users.into_inner();
        let users = pry!(userdb
            .get_all()
            .map_err(|e| capnp::Error::failed(format!("UserDB error: {:?}", e))));
        let mut builder = result.get().init_users(users.len() as u32);
        for (i, (id, userdata)) in users.into_iter().enumerate() {
            let user = db::User { id, userdata };
            let cap: user_capnp::user::Client = capnp_rpc::new_client(User::fill(self.session.clone(), user));
            builder.reborrow().set(i as u32, cap.into_client_hook());
        }

        tracing::trace!("method return");
        Promise::ok(())
    }

    fn add_user(
        &mut self,
        params: users::AddUserParams,
        mut result: users::AddUserResults,
    ) -> Promise<(), ::capnp::Error> {
        let _guard = self.span.enter();
        let _span = tracing::trace_span!(target: TARGET, "addUserFallible").entered();

        let params = pry!(params.get());
        let username = pry!(params.get_username());
        let password = pry!(params.get_password());
        // FIXME: saslprep passwords & usernames before storing them

        tracing::trace!(
            params.username = username,
            params.password = "<redacted>",
            "method call"
        );

        let mut builder = result.get();

        if !username.is_empty() && !password.is_empty() {
            if self.session.users.get_user(username).is_none() {
                let user = db::User::new_with_plain_pw(username, password);
                self.session.users.put_user(username, &user);
                builder.set_user(capnp_rpc::new_client(User::fill(self.session.clone(), user)));
            } else {
                let mut builder = builder.init_error();
                builder.set_exists(());
                tracing::warn!("Failed to add user: Username taken");
            }
        } else {
            if username.is_empty() {
                let mut builder = builder.init_error();
                builder.set_username_invalid(());
                tracing::warn!("Failed to add user: Username empty");
            } else if password.is_empty() {
                let mut builder = builder.init_error();
                builder.set_password_invalid(());
                tracing::warn!("Failed to add user: Password empty");
            }
        }

        tracing::trace!("method return");
        Promise::ok(())
    }

}