oci-api 0.6.0

OCI (Oracle Cloud Infrastructure) API client for Rust
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

//! Object Storage integration tests
//!
//! These tests require actual OCI credentials and will make real API calls.
//! They are ignored by default and must be explicitly run with:
//! ```
//! cargo test --test object_storage_integration_test -- --ignored
//! ```
//!
//! Required environment variables:
//! - OCI_USER_ID
//! - OCI_TENANCY_ID
//! - OCI_REGION
//! - OCI_FINGERPRINT
//! - OCI_PRIVATE_KEY (file path or PEM content)
//! - TEST_NAMESPACE (Object Storage Namespace)
//! - TEST_BUCKET (Bucket name to use for testing)

use oci_api::client::Oci;
use oci_api::services::object_storage::ObjectStorage;

/// Load .env file if it exists
fn load_env() {
    let _ = dotenvy::dotenv();
}

/// Helper to check if OCI credentials are configured
fn has_oci_credentials() -> bool {
    load_env();
    std::env::var("OCI_USER_ID").is_ok()
        && std::env::var("OCI_TENANCY_ID").is_ok()
        && std::env::var("OCI_REGION").is_ok()
        && std::env::var("OCI_FINGERPRINT").is_ok()
        && std::env::var("OCI_PRIVATE_KEY").is_ok()
        && std::env::var("TEST_NAMESPACE").is_ok()
        && std::env::var("TEST_BUCKET").is_ok()
}

#[tokio::test]
#[ignore]
async fn test_get_bucket() {
    if !has_oci_credentials() {
        eprintln!("Skipping test: OCI credentials or Object Storage config not configured");
        return;
    }

    let oci_client = Oci::from_env().expect("Failed to load OCI config");

    let namespace = std::env::var("TEST_NAMESPACE").unwrap();
    let bucket_name = std::env::var("TEST_BUCKET").unwrap();

    let os_client = ObjectStorage::new(&oci_client, namespace);
    let bucket = os_client.get_bucket(&bucket_name).await;

    assert!(bucket.is_ok(), "Failed to get bucket: {:?}", bucket.err());
    let bucket = bucket.unwrap();
    assert_eq!(bucket.name, bucket_name);
}

#[tokio::test]
#[ignore]
async fn test_put_and_get_object() {
    if !has_oci_credentials() {
        eprintln!("Skipping test: OCI credentials or Object Storage config not configured");
        return;
    }

    let oci_client = Oci::from_env().expect("Failed to load OCI config");

    let namespace = std::env::var("TEST_NAMESPACE").unwrap();
    let bucket_name = std::env::var("TEST_BUCKET").unwrap();

    let os_client = ObjectStorage::new(&oci_client, namespace);
    let bucket = os_client
        .get_bucket(&bucket_name)
        .await
        .expect("Failed to get bucket");

    let object_name = "test_object.txt";
    let content = "Hello, OCI Object Storage!";

    // Put Object
    let put_result = bucket.put_object(object_name, content).await;
    assert!(
        put_result.is_ok(),
        "Failed to put object: {:?}",
        put_result.err()
    );
    let object = put_result.unwrap();
    assert_eq!(object.name, object_name);

    // Get Object
    let get_result = bucket.get_object(object_name).await;
    assert!(
        get_result.is_ok(),
        "Failed to get object: {:?}",
        get_result.err()
    );
    let object = get_result.unwrap();
    assert_eq!(object.name, object_name);
    assert_eq!(object.value, content);
}