logs panel to logs system hook up, cleanup
This commit is contained in:
45
src/logs.rs
45
src/logs.rs
@@ -1,10 +1,11 @@
|
|||||||
use std::fmt::Display;
|
|
||||||
|
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
use strum::{AsRefStr, IntoStaticStr};
|
use strum::IntoStaticStr;
|
||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
use crate::{database, users::User};
|
use crate::{
|
||||||
|
database::{self, DatabaseError},
|
||||||
|
users::User,
|
||||||
|
};
|
||||||
|
|
||||||
#[derive(Debug)]
|
#[derive(Debug)]
|
||||||
pub struct LogEntry {
|
pub struct LogEntry {
|
||||||
@@ -14,21 +15,45 @@ pub struct LogEntry {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl LogEntry {
|
impl LogEntry {
|
||||||
pub fn new(actor: User, data: LogAction) -> Result<LogEntry, rusqlite::Error> {
|
pub fn new(actor: User, data: LogAction) -> Result<LogEntry, DatabaseError> {
|
||||||
let log = LogEntry {
|
let log = LogEntry {
|
||||||
id: Uuid::now_v7(),
|
id: Uuid::now_v7(),
|
||||||
actor,
|
actor,
|
||||||
data,
|
data,
|
||||||
};
|
};
|
||||||
let conn = database::conn()?;
|
let conn = database::conn()?;
|
||||||
|
let actiontype: &'static str = (&log.data).into();
|
||||||
|
let payload = serde_json::to_string(&log.data).unwrap();
|
||||||
conn.prepare(
|
conn.prepare(
|
||||||
"INSERT INTO logs(id, actor, target, actiontype, payload) VALUES (?1,?2,?3,?4,?5)",
|
"INSERT INTO logs(id, actor, target, actiontype, payload) VALUES (?1,?2,?3,?4,?5)",
|
||||||
)?
|
)?
|
||||||
.execute((&log.id, &log.actor.id, log.data.get_target_id(), "a", "b"))?;
|
.execute((
|
||||||
|
&log.id,
|
||||||
|
&log.actor.id,
|
||||||
|
log.data.get_target_id(),
|
||||||
|
actiontype,
|
||||||
|
payload,
|
||||||
|
))?;
|
||||||
Ok(log)
|
Ok(log)
|
||||||
}
|
}
|
||||||
|
pub fn get_all() -> Result<Vec<LogEntry>, DatabaseError> {
|
||||||
|
Ok(database::conn()?
|
||||||
|
.prepare("SELECT id, actor, target, actiontype, payload FROM logs ORDER BY id DESC")?
|
||||||
|
.query_map((), |r| {
|
||||||
|
let payload: String = r.get(4)?;
|
||||||
|
Ok(LogEntry {
|
||||||
|
id: r.get(0)?,
|
||||||
|
actor: User::get_by_id(r.get(1)?).unwrap(),
|
||||||
|
data: serde_json::from_str(&payload).unwrap(),
|
||||||
|
})
|
||||||
|
})?
|
||||||
|
.collect::<Result<Vec<LogEntry>, _>>()?)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// #[derive(Debug, thiserror::Error)]
|
||||||
|
// pub enum LogError {}
|
||||||
|
|
||||||
#[derive(Debug, IntoStaticStr, Serialize, Deserialize)]
|
#[derive(Debug, IntoStaticStr, Serialize, Deserialize)]
|
||||||
pub enum LogAction {
|
pub enum LogAction {
|
||||||
Initialize,
|
Initialize,
|
||||||
@@ -42,10 +67,10 @@ impl LogAction {
|
|||||||
pub fn get_target_id(&self) -> Option<Uuid> {
|
pub fn get_target_id(&self) -> Option<Uuid> {
|
||||||
match self {
|
match self {
|
||||||
Self::Initialize | Self::RegenInfradmin => None,
|
Self::Initialize | Self::RegenInfradmin => None,
|
||||||
Self::CreateUser { id, .. } => Some(*id),
|
Self::CreateUser { id, .. }
|
||||||
Self::CreateTag { id, .. } => Some(*id),
|
| Self::CreateTag { id, .. }
|
||||||
Self::CreatePerson { id, .. } => Some(*id),
|
| Self::CreatePerson { id, .. }
|
||||||
Self::ChangeUserHandle { id, .. } => Some(*id),
|
| Self::ChangeUserHandle { id, .. } => Some(*id),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
pub fn get_humanreadable_payload(&self) -> String {
|
pub fn get_humanreadable_payload(&self) -> String {
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ use uuid::Uuid;
|
|||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
database,
|
database,
|
||||||
|
logs::{LogAction, LogEntry},
|
||||||
users::{User, UserError},
|
users::{User, UserError},
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -15,7 +16,8 @@ pub fn initialise_reserved_users_if_needed() -> Result<(), UserError> {
|
|||||||
.optional()?
|
.optional()?
|
||||||
.is_none()
|
.is_none()
|
||||||
{
|
{
|
||||||
User::create_systemuser()?;
|
let u = User::create_systemuser()?;
|
||||||
|
LogEntry::new(u, LogAction::Initialize)?;
|
||||||
}
|
}
|
||||||
|
|
||||||
if conn
|
if conn
|
||||||
@@ -25,6 +27,7 @@ pub fn initialise_reserved_users_if_needed() -> Result<(), UserError> {
|
|||||||
.is_none()
|
.is_none()
|
||||||
{
|
{
|
||||||
User::create_infradmin()?;
|
User::create_infradmin()?;
|
||||||
|
LogEntry::new(User::get_by_id(Uuid::nil())?, LogAction::RegenInfradmin)?;
|
||||||
}
|
}
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
|
|||||||
@@ -3,11 +3,10 @@ use axum::{
|
|||||||
response::{IntoResponse, Redirect, Response},
|
response::{IntoResponse, Redirect, Response},
|
||||||
};
|
};
|
||||||
use maud::{PreEscaped, html};
|
use maud::{PreEscaped, html};
|
||||||
use uuid::Uuid;
|
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
api::CompositeError,
|
api::CompositeError,
|
||||||
logs::{LogAction, LogEntry},
|
logs::LogEntry,
|
||||||
users::{User, auth::UserAuthenticate, permissions::Permission},
|
users::{User, auth::UserAuthenticate, permissions::Permission},
|
||||||
web::{RedirectViaError, components::nav::nav, icons, pages::base},
|
web::{RedirectViaError, components::nav::nav, icons, pages::base},
|
||||||
};
|
};
|
||||||
@@ -15,21 +14,7 @@ use crate::{
|
|||||||
pub async fn page(req: Request) -> Result<Response, CompositeError> {
|
pub async fn page(req: Request) -> Result<Response, CompositeError> {
|
||||||
let u = User::authenticate(req.headers())?
|
let u = User::authenticate(req.headers())?
|
||||||
.ok_or(RedirectViaError(Redirect::to("/login?re=/logs")))?;
|
.ok_or(RedirectViaError(Redirect::to("/login?re=/logs")))?;
|
||||||
let logs: Vec<LogEntry> = vec![
|
let logs = LogEntry::get_all()?;
|
||||||
LogEntry {
|
|
||||||
id: Uuid::now_v7(),
|
|
||||||
actor: User::get_by_id(Uuid::nil()).unwrap(),
|
|
||||||
data: LogAction::Initialize,
|
|
||||||
},
|
|
||||||
LogEntry {
|
|
||||||
id: Uuid::now_v7(),
|
|
||||||
actor: User::get_by_id(Uuid::nil()).unwrap(),
|
|
||||||
data: LogAction::RegenInfradmin,
|
|
||||||
},
|
|
||||||
]
|
|
||||||
.into_iter()
|
|
||||||
.rev()
|
|
||||||
.collect();
|
|
||||||
|
|
||||||
Ok(base(
|
Ok(base(
|
||||||
"Persons | Mnemosyne",
|
"Persons | Mnemosyne",
|
||||||
|
|||||||
Reference in New Issue
Block a user