csml_engine 1.11.2

The CSML Engine is a conversational engine designed to make it extremely easy to create rich and powerful chatbots.
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
48
49
50
51
52
53
54
55
56
57

pub mod bot;
pub mod conversations;
pub mod memories;
pub mod messages;
pub mod state;

pub mod pagination;

pub mod schema;
pub mod models;

pub mod expired_data;

use crate::{Database, EngineError, PostgresqlClient};

use diesel::prelude::{Connection, PgConnection};

embed_migrations!("migrations/postgresql");

pub fn init() -> Result<Database, EngineError> {

    let uri = match std::env::var("POSTGRESQL_URL") {
        Ok(var) => var,
        _ => "".to_owned(),
    };

    let pg_connection = PgConnection::establish(&uri)
        .unwrap_or_else(|_| panic!("Error connecting to {}", uri));

    let db = Database::Postgresql(
        PostgresqlClient::new(pg_connection)
    );
    Ok(db)
}

pub fn make_migrations() -> Result<(), EngineError> {
    let uri = match std::env::var("POSTGRESQL_URL") {
        Ok(var) => var,
        _ => "".to_owned(),
    };

    let pg_connection = PgConnection::establish(&uri)
        .unwrap_or_else(|_| panic!("Error connecting to {}", uri));

    embedded_migrations::run_with_output(&pg_connection, &mut std::io::stdout())?;

    Ok(())
}

pub fn get_db<'a>(db: &'a Database) -> Result<&'a PostgresqlClient, EngineError> {
    match db {
        Database::Postgresql(db) => Ok(db),
        _ => Err(EngineError::Manager(
            "Postgresql connector is not setup correctly".to_owned(),
        )),
    }
}