walletkit-core 0.11.0

//! Vault database helpers for content addressing and type conversion.

use sha2::{Digest, Sha256};

use crate::storage::error::{StorageError, StorageResult};
use crate::storage::types::{BlobKind, ContentId, CredentialRecord};
use walletkit_db::{DbError, Row};

const CONTENT_ID_PREFIX: &[u8] = b"worldid:blob";

pub(super) fn compute_content_id(blob_kind: BlobKind, plaintext: &[u8]) -> ContentId {
    let mut hasher = Sha256::new();
    hasher.update(CONTENT_ID_PREFIX);
    hasher.update([blob_kind as u8]);
    hasher.update(plaintext);
    let digest = hasher.finalize();
    let mut out = [0u8; 32];
    out.copy_from_slice(&digest);
    out
}

pub(super) fn map_record(row: &Row<'_, '_>) -> StorageResult<CredentialRecord> {
    let credential_id = row.column_i64(0);
    let issuer_schema_id = row.column_i64(1);
    let expires_at = row.column_i64(2);
    let is_expired = row.column_i64(3);
    Ok(CredentialRecord {
        credential_id: to_u64(credential_id, "credential_id")?,
        issuer_schema_id: to_u64(issuer_schema_id, "issuer_schema_id")?,
        expires_at: to_u64(expires_at, "expires_at")?,
        is_expired: is_expired != 0,
    })
}

pub(super) fn to_i64(value: u64, label: &str) -> StorageResult<i64> {
    i64::try_from(value).map_err(|_| {
        StorageError::VaultDb(format!("{label} out of range for i64: {value}"))
    })
}

pub(super) fn to_u64(value: i64, label: &str) -> StorageResult<u64> {
    u64::try_from(value).map_err(|_| {
        StorageError::VaultDb(format!("{label} out of range for u64: {value}"))
    })
}

pub(super) fn map_db_err(err: &DbError) -> StorageError {
    StorageError::VaultDb(err.to_string())
}