FT.CREATE

gistfile1.txt

pub async fn message<T>(
    redis: &redis::Client,
    sms: T,
    gadget: Option<Uuid>,
    uuid: Uuid,
) -> Result<Message, CustomError>
where
    T: AsRef<str> + ToString,
{
    if !helper::index_exists(redis, common::index::MESSAGES).await {
        let data = IndexData::messages();
        IndexData::create_index(redis, data).await.unwrap();
    }
    let message = Message {
        uuid,
        gadget,
        sms: sms.to_string(),
        added: Utc::now(),
    };
    let items = message_items(&message);
    Cache::hset_multiple(redis, key::message(message.uuid.to_string()), &items)
        .await
        .unwrap();
    Ok(message)
}