force 0.2.0

Production-ready Salesforce Platform API client with REST and Bulk API 2.0 support
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

//! Example: Mass Update Records using SOQL and Composite API
//!
//! This example demonstrates how to find specific records using a SOQL query
//! and instantly update all of them using the `SoqlMassOp` composite helper.
//!
//! Run with: `cargo run --example soql_mass_op --features composite`

use force::api::composite::SoqlMassOp;
use force::api::rest::SoqlQueryBuilder;
use force::auth::ClientCredentials;
use force::client::ForceClientBuilder;
use serde_json::json;
use std::env;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    tracing_subscriber::fmt::init();

    let client_id = env::var("SF_CLIENT_ID").unwrap_or_else(|_| "dummy_client_id".to_string());
    let client_secret =
        env::var("SF_CLIENT_SECRET").unwrap_or_else(|_| "dummy_client_secret".to_string());
    let my_domain_url = env::var("SF_MY_DOMAIN_URL")
        .unwrap_or_else(|_| "https://your-org.my.salesforce.com".to_string());

    // Authenticate
    let auth = ClientCredentials::new_my_domain(client_id, client_secret, my_domain_url);
    let client = ForceClientBuilder::new().authenticate(auth).build().await?;

    println!("Finding Contact records that are marked as 'New'...");

    // 1. Build a safe SOQL query to find the target records.
    // The `Id` field MUST be selected for mass operations.
    let query = SoqlQueryBuilder::new()
        .select(&["Id"])
        .from("Contact")
        .where_eq("Status", "New")
        .limit(100); // Limit added for safety during the example

    // 2. Define the exact fields and values you want to mass update.
    let updates = json!({
        "Status": "Processed",
        "Description": "Updated automatically by SoqlMassOp via force-rs"
    });

    println!("Executing mass update using Composite Batch...");

    // 3. Execute the mass update!
    // This will query the records and send Composite Batch requests
    // in chunks of 25 to perform the updates.
    let mass_op = SoqlMassOp::new(&client, query).halt_on_error(false);

    let stats = mass_op.update_all(updates).await?;

    println!("--- Mass Update Complete ---");
    println!("Records Found & Processed : {}", stats.records_processed);
    println!("Successful Updates        : {}", stats.ops_succeeded);
    println!("Failed Updates            : {}", stats.ops_failed);

    Ok(())
}