nullnet-wallguard-server 0.2.3

use crate::proto::wallguard::Logs;
use crate::{grpc_server::server::WallGuardImpl, proto::wallguard::CommonResponse};
use nullnet_liberror::Error;
use tonic::{Request, Response};

impl WallGuardImpl {
    pub(crate) async fn handle_logs_impl(
        &self,
        request: Request<Logs>,
    ) -> Result<Response<CommonResponse>, Error> {
        let logs = request.into_inner();
        let (jwt_token, _) = Self::authenticate(logs.auth.clone())?;

        let _ = self.datastore.logs_insert(&jwt_token, logs.logs).await?;

        Ok(Response::new(CommonResponse {
            message: String::from("Logs successfully inserted"),
        }))
    }
}