bitwarden_sm/secrets/
sync.rs

1use bitwarden_api_api::models::SecretsSyncResponseModel;
2use bitwarden_core::{key_management::KeyIds, require, Client};
3use bitwarden_crypto::KeyStoreContext;
4use chrono::{DateTime, Utc};
5use schemars::JsonSchema;
6use serde::{Deserialize, Serialize};
7use uuid::Uuid;
8
9use crate::{error::SecretsManagerError, secrets::SecretResponse};
10
11#[allow(missing_docs)]
12#[derive(Serialize, Deserialize, Debug, JsonSchema)]
13#[serde(rename_all = "camelCase", deny_unknown_fields)]
14pub struct SecretsSyncRequest {
15    /// Organization to sync secrets from
16    pub organization_id: Uuid,
17    /// Optional date time a sync last occurred
18    pub last_synced_date: Option<DateTime<Utc>>,
19}
20
21pub(crate) async fn sync_secrets(
22    client: &Client,
23    input: &SecretsSyncRequest,
24) -> Result<SecretsSyncResponse, SecretsManagerError> {
25    let config = client.internal.get_api_configurations().await;
26    let last_synced_date = input.last_synced_date.map(|date| date.to_rfc3339());
27
28    let res = bitwarden_api_api::apis::secrets_api::organizations_organization_id_secrets_sync_get(
29        &config.api,
30        input.organization_id,
31        last_synced_date,
32    )
33    .await?;
34
35    let key_store = client.internal.get_key_store();
36
37    SecretsSyncResponse::process_response(res, &mut key_store.context())
38}
39
40#[allow(missing_docs)]
41#[derive(Serialize, Deserialize, Debug, JsonSchema)]
42#[serde(rename_all = "camelCase", deny_unknown_fields)]
43pub struct SecretsSyncResponse {
44    pub has_changes: bool,
45    pub secrets: Option<Vec<SecretResponse>>,
46}
47
48impl SecretsSyncResponse {
49    pub(crate) fn process_response(
50        response: SecretsSyncResponseModel,
51        ctx: &mut KeyStoreContext<KeyIds>,
52    ) -> Result<SecretsSyncResponse, SecretsManagerError> {
53        let has_changes = require!(response.has_changes);
54
55        if has_changes {
56            let secrets = require!(response.secrets)
57                .data
58                .unwrap_or_default()
59                .into_iter()
60                .map(|r| SecretResponse::process_base_response(r, ctx))
61                .collect::<Result<_, _>>()?;
62            return Ok(SecretsSyncResponse {
63                has_changes,
64                secrets: Some(secrets),
65            });
66        }
67
68        Ok(SecretsSyncResponse {
69            has_changes: false,
70            secrets: None,
71        })
72    }
73}
bitwarden_sm/secrets/sync.rs

bitwarden_sm/secrets/
sync.rs
