csml_engine 1.7.0-beta1

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
58
59
60
61
62
63

use serde_json::Value;

use crate::{encrypt::encrypt_data, Client, EngineError, MongoDbClient};
use bson::{doc, Bson};

pub fn init_interaction(
    event: Value,
    client: &Client,
    db: &MongoDbClient,
) -> Result<String, EngineError> {
    let collection = db.client.collection("interaction");
    let time = Bson::DateTime(chrono::Utc::now());

    let doc = doc! {
        "client": bson::to_bson(&client)?,
        "event": encrypt_data(&event)?, // encrypted
        "updated_at": &time,
        "created_at": &time
    };

    let inserted = collection.insert_one(doc.clone(), None)?;

    let id = inserted.inserted_id.as_object_id().unwrap();

    Ok(id.to_hex())
}

pub fn update_interaction(
    interaction_id: &str,
    success: bool,
    client: &Client,
    db: &MongoDbClient,
) -> Result<(), EngineError> {
    let collection = db.client.collection("interaction");

    let filter = doc! {
        "_id": bson::oid::ObjectId::with_string(interaction_id).unwrap(),
        "client": bson::to_bson(&client)?,
    };

    collection.update_one(
        filter,
        doc! {
           "$set": { "success": success },
           "$currentDate": { "updated_at": true }
        },
        None,
    )?;

    Ok(())
}

pub fn delete_user_interactions(client: &Client, db: &MongoDbClient) -> Result<(), EngineError> {
    let collection = db.client.collection("interaction");

    let filter = doc! {
        "client": bson::to_bson(&client)?,
    };

    collection.delete_many(filter, None)?;

    Ok(())
}