use crate::{
data::{ConversationInfo, Database, EngineError, FlowTrigger, DEBUG},
db_connectors::state::delete_state_key,
send::send_to_callback_url,
CsmlBot, CsmlFlow,
};
use chrono::{prelude::Utc, SecondsFormat};
use csml_interpreter::{
data::{ast::Flow, Client, Context, Event, Interval, Memory, Message},
error_format::{ERROR_KEY_ALPHANUMERIC, ERROR_NUMBER_AS_KEY, ERROR_SIZE_IDENT},
get_step,
interpreter::json_to_literal,
};
use rand::seq::SliceRandom;
use serde_json::{json, map::Map, Value};
use std::collections::HashMap;
use std::env;
use md5::{Digest, Md5};
pub fn update_current_context(data: &mut ConversationInfo, memories: &HashMap<String, Memory>) {
for (_key, mem) in memories.iter() {
let lit = json_to_literal(&mem.value, Interval::default(), &data.context.flow).unwrap();
data.context.current.insert(mem.key.to_owned(), lit);
}
}
pub fn validate_memory_key_format(key: &str) -> Result<(), EngineError> {
if !key.chars().all(|c| c.is_alphanumeric() || c == '_') {
return Err(EngineError::Format(ERROR_KEY_ALPHANUMERIC.to_owned()));
}
if key.len() > std::u8::MAX as usize {
return Err(EngineError::Format(ERROR_SIZE_IDENT.to_owned()));
}
if key.parse::<f64>().is_ok() {
return Err(EngineError::Format(ERROR_NUMBER_AS_KEY.to_owned()));
}
Ok(())
}
pub fn get_event_content(content_type: &str, metadata: &Value) -> Result<String, EngineError> {
match content_type {
file if ["file", "audio", "video", "image", "url"].contains(&file) => {
if let Some(val) = metadata["url"].as_str() {
Ok(val.to_string())
} else {
Err(EngineError::Interpreter(
"no url content in event".to_owned(),
))
}
}
payload if payload == "payload" => {
if let Some(val) = metadata["payload"].as_str() {
Ok(val.to_string())
} else {
Err(EngineError::Interpreter(
"no payload content in event".to_owned(),
))
}
}
text if text == "text" => {
if let Some(val) = metadata["text"].as_str() {
Ok(val.to_string())
} else {
Err(EngineError::Interpreter(
"no text content in event".to_owned(),
))
}
}
flow_trigger if flow_trigger == "flow_trigger" => {
match serde_json::from_value::<FlowTrigger>(metadata.clone()) {
Ok(_flow_trigger) => {
Ok(metadata.to_string())
}
Err(_) => {
Err(EngineError::Interpreter(
"invalid content for event type flow_trigger: expect flow_id and optional step_id".to_owned(),
))
}
}
}
content_type => Err(EngineError::Interpreter(format!(
"{} is not a valid content_type",
content_type
))),
}
}
pub fn format_event(json_event: serde_json::Value) -> Result<Event, EngineError> {
let content_type = match json_event["payload"]["content_type"].as_str() {
Some(content_type) => content_type.to_string(),
None => {
return Err(EngineError::Interpreter(
"no content_type in event payload".to_owned(),
))
}
};
let content = json_event["payload"]["content"].to_owned();
let content_value = get_event_content(&content_type, &content)?;
Ok(Event {
content_type,
content_value,
content,
})
}
pub fn send_msg_to_callback_url(
data: &mut ConversationInfo,
msg: Vec<Message>,
interaction_order: i32,
end: bool,
) {
let messages = messages_formater(data, msg, interaction_order, end);
match env::var(DEBUG) {
Ok(ref var) if var == "true" => {
println!("conversation_end => {}", messages["conversation_end"]);
}
_ => (),
};
send_to_callback_url(data, serde_json::json!(messages))
}
fn add_info_to_message(data: &ConversationInfo, mut msg: Message, interaction_order: i32) -> Value {
let payload = msg.message_to_json();
let mut map_msg: Map<String, Value> = Map::new();
map_msg.insert("payload".to_owned(), payload);
map_msg.insert("interaction_order".to_owned(), json!(interaction_order));
map_msg.insert("conversation_id".to_owned(), json!(data.conversation_id));
map_msg.insert("direction".to_owned(), json!("SEND"));
Value::Object(map_msg)
}
pub fn messages_formater(
data: &mut ConversationInfo,
vec_msg: Vec<Message>,
interaction_order: i32,
end: bool,
) -> Map<String, Value> {
let msgs = vec_msg
.into_iter()
.map(|msg| add_info_to_message(data, msg, interaction_order))
.collect();
let mut map: Map<String, Value> = Map::new();
map.insert("messages".to_owned(), Value::Array(msgs));
map.insert("conversation_end".to_owned(), Value::Bool(end));
map.insert("request_id".to_owned(), json!(data.request_id));
map.insert(
"received_at".to_owned(),
json!(Utc::now().to_rfc3339_opts(SecondsFormat::Millis, true)),
);
map.insert("interaction_id".to_owned(), json!(data.interaction_id));
let mut map_client: Map<String, Value> = Map::new();
map_client.insert("bot_id".to_owned(), json!(data.client.bot_id));
map_client.insert("user_id".to_owned(), json!(data.client.user_id));
map_client.insert("channel_id".to_owned(), json!(data.client.channel_id));
map.insert("client".to_owned(), Value::Object(map_client));
map
}
pub fn get_flow_by_id<'a>(f_id: &str, flows: &'a [CsmlFlow]) -> Result<&'a CsmlFlow, EngineError> {
let id = f_id.to_ascii_lowercase();
match flows
.iter()
.find(|&val| val.id.to_ascii_lowercase() == id || val.name.to_ascii_lowercase() == id)
{
Some(ref f) => Ok(f),
None => Err(EngineError::Interpreter(format!(
"Flow '{}' does not exist",
f_id
))),
}
}
pub fn get_default_flow<'a>(bot: &'a CsmlBot) -> Result<&'a CsmlFlow, EngineError> {
match bot
.flows
.iter()
.find(|&flow| flow.id == bot.default_flow || flow.name == bot.default_flow)
{
Some(flow) => Ok(flow),
None => Err(EngineError::Interpreter(
"The bot's default_flow does not exist".to_owned(),
)),
}
}
pub fn search_flow<'a>(
event: &Event,
bot: &'a CsmlBot,
client: &Client,
db: &mut Database,
) -> Result<(&'a CsmlFlow, String), EngineError> {
match event {
event if event.content_type == "flow_trigger" => {
delete_state_key(&client, "hold", "position", db)?;
let flow_trigger: FlowTrigger = serde_json::from_str(&event.content_value)?;
match get_flow_by_id(&flow_trigger.flow_id, &bot.flows) {
Ok(flow) => {
match flow_trigger.step_id {
Some(step_id) => Ok((flow, step_id)),
None => Ok((flow, "start".to_owned())),
}
},
Err(_) => Ok((get_flow_by_id(&bot.default_flow, &bot.flows)? , "start".to_owned())),
}
}
event => {
let mut random_flows = vec![];
for flow in bot.flows.iter() {
let contains_command = flow
.commands
.iter()
.any(|cmd| &cmd.as_str().to_lowercase() == &event.content_value.to_lowercase());
if contains_command {
random_flows.push(flow)
}
}
match random_flows.choose(&mut rand::thread_rng()) {
Some(flow) => {
delete_state_key(&client, "hold", "position", db)?;
Ok((flow, "start".to_owned()))
}
None => Err(EngineError::Interpreter(format!(
"Flow '{}' does not exist",
event.content_value
))),
}
}
}
}
pub fn get_current_step_hash(context: &Context, bot: &CsmlBot) -> Result<String, EngineError> {
let mut hash = Md5::new();
let flow = &get_flow_by_id(&context.flow, &bot.flows)?.content;
let ast = match &bot.bot_ast {
Some(ast) => {
let base64decoded = base64::decode(&ast).unwrap();
let csml_bot: HashMap<String, Flow> = bincode::deserialize(&base64decoded[..]).unwrap();
match csml_bot.get(&context.flow) {
Some(flow) => flow.to_owned(),
None => csml_bot
.get(&get_default_flow(&bot)?.name)
.unwrap()
.to_owned(),
}
}
None => return Err(EngineError::Manager(format!("not valid ast"))),
};
let step = get_step(&context.step, &flow, &ast);
hash.update(step.as_bytes());
Ok(format!("{:x}", hash.finalize()))
}
pub fn clean_hold_and_restart(data: &mut ConversationInfo) -> Result<(), EngineError> {
delete_state_key(&data.client, "hold", "position", &mut data.db)?;
data.context.hold = None;
return Ok(());
}
#[cfg(feature = "dynamo")]
pub fn init_logger() {
if let Ok(debug) = env::var("DEBUG") {
if &debug == "true" {
env::set_var("RUST_LOG", "rusoto");
env::set_var("hyper", "debug");
let _ = env_logger::try_init();
}
};
}