deta_rust 0.3.1

//! This example illustrates the way to put and fetch items with `database`.

// This is using the `tokio` runtime. You'll need the following dependency:
//
// `tokio = { version = "1", features = ["full"] }`

use deta_rust::{
    database::{
        self,
        query::{Condition, Query},
        updates::{Action, Updates},
    },
    DetaClient,
};
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug)]
struct SampleDbModel {
    // The `skip_serializing_if` attribute is useful because thanks to it, when `key` is empty, deta will generate it itself.
    #[serde(skip_serializing_if = "String::is_empty")]
    key: String,

    some_field: String,
    some_number_field: i32,
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = DetaClient::new("[place_your_project_key_here]");
    let database = database::Database::new(&client, "sample_db");

    // Put
    let items = vec![
        SampleDbModel {
            key: "a".into(),
            some_field: "Some value".into(),
            some_number_field: 0,
        },
        SampleDbModel {
            key: "b".into(),
            some_field: "Another value 1".into(),
            some_number_field: 1,
        },
        SampleDbModel {
            key: "c".into(),
            some_field: "Another value 2".into(),
            some_number_field: 2,
        },
    ];

    let result = database.put_items(&items).await?;
    println!("PutItems<SampleDbModel>: {:#?}", result);

    // Update
    let updates = Updates::init()
        .add("some_field", Action::set("Updated value"))
        .add("some_number_field", Action::increment(-1));

    let update_result = database.update_item("b", updates).await?;

    println!("UpdateItem<SampleDbModel>: {:#?}", update_result);

    // Fetch
    let query = Query::init()
        .on("some_field", Condition::prefix("Some"))
        .either()
        .on("some_field", Condition::prefix("Another"));

    let query_result = database
        .fetch_items::<SampleDbModel>(None, None, Some(query))
        .await?;

    assert_eq!(query_result.items.len(), 2);

    println!("FetchItems<SampleDbModel>: {:#?}", query_result);

    Ok(())
}