palpo-data 0.0.2

Matrix server implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use diesel::prelude::*;

use crate::core::{client::filter::FilterDefinition, identifiers::*, JsonValue, UnixMillis};
use crate::schema::*;
use crate::{connect, DataResult};

#[derive(Identifiable, Queryable, Debug, Clone)]
#[diesel(table_name = user_filters)]
pub struct DbUserFilter {
    pub id: i64,
    pub user_id: OwnedUserId,
    pub filter: JsonValue,
    pub created_at: UnixMillis,
}

#[derive(Insertable, Debug, Clone)]
#[diesel(table_name = user_filters)]
pub struct NewDbUserFilter {
    pub user_id: OwnedUserId,
    pub filter: JsonValue,
    pub created_at: UnixMillis,
}

pub fn get_filter(user_id: &UserId, filter_id: i64) -> DataResult<Option<FilterDefinition>> {
    let filter = user_filters::table
        .filter(user_filters::id.eq(filter_id))
        .filter(user_filters::user_id.eq(user_id))
        .select(user_filters::filter)
        .first(&mut *connect()?)
        .optional()?;
    if let Some(filter) = filter {
        Ok(Some(serde_json::from_value(filter)?))
    } else {
        Ok(None)
    }
}

pub fn create_filter(user_id: &UserId, filter: &FilterDefinition) -> DataResult<i64> {
    let filter = diesel::insert_into(user_filters::table)
        .values(NewDbUserFilter {
            user_id: user_id.to_owned(),
            filter: serde_json::to_value(filter)?,
            created_at: UnixMillis::now(),
        })
        .get_result::<DbUserFilter>(&mut *connect()?)?;
    Ok(filter.id)
}