Struct StandardResourceProvider 

pub struct StandardResourceProvider<S: StorageProvider> { /* private fields */ }

Standard resource provider with pluggable storage backend.

This provider separates SCIM protocol logic from storage concerns by delegating data persistence to a StorageProvider implementation while handling all SCIM-specific business logic, validation, and metadata management.

Implementations

impl<S: StorageProvider> StandardResourceProvider<S>

pub fn new(storage: S) -> Self

Create a new standard provider with the given storage backend.

pub async fn clear(&self)

Clear all data from storage.

Removes all resources from all tenants by delegating to the storage backend’s clear operation. This method provides a consistent interface for clearing data regardless of the underlying storage implementation.

Behavior

• Delegates to StorageProvider::clear for actual data removal
• Logs warnings if the clear operation fails
• Primarily intended for testing scenarios
• After successful clearing, get_stats should report zero resources

Examples

use scim_server::providers::StandardResourceProvider;
use scim_server::storage::InMemoryStorage;

let storage = InMemoryStorage::new();
let provider = StandardResourceProvider::new(storage);

// ... create some resources ...
provider.clear().await;

let stats = provider.get_stats().await;
assert_eq!(stats.total_resources, 0);

pub async fn get_stats(&self) -> InMemoryStats

Get comprehensive statistics about stored data across all tenants.

Dynamically discovers all tenants and resource types from storage to provide accurate statistics without relying on hardcoded patterns. This method uses the storage provider’s discovery capabilities to enumerate actual data.

Returns

InMemoryStats containing:

• tenant_count: Number of tenants with at least one resource
• total_resources: Sum of all resources across all tenants and types
• resource_type_count: Number of distinct resource types found
• resource_types: List of all resource type names

Errors

This method handles storage errors gracefully by using default values (empty collections) when discovery operations fail.

Examples

use scim_server::providers::StandardResourceProvider;
use scim_server::storage::InMemoryStorage;
use scim_server::resource::{RequestContext, TenantContext};

let storage = InMemoryStorage::new();
let provider = StandardResourceProvider::new(storage);

// ... create resources in multiple tenants ...

let stats = provider.get_stats().await;
println!("Total resources: {}", stats.total_resources);
println!("Active tenants: {}", stats.tenant_count);
println!("Resource types: {:?}", stats.resource_types);

pub async fn list_resources_in_tenant( &self, tenant_id: &str, resource_type: &str, ) -> Vec<Resource>

List all resources of a specific type in a tenant.

impl<S: StorageProvider> StandardResourceProvider<S>

pub async fn conditional_update( &self, resource_type: &str, id: &str, data: Value, expected_version: &ScimVersion, context: &RequestContext, ) -> Result<ConditionalResult<VersionedResource>, InMemoryError>

pub async fn conditional_delete( &self, resource_type: &str, id: &str, expected_version: &ScimVersion, context: &RequestContext, ) -> Result<ConditionalResult<()>, InMemoryError>

pub async fn conditional_patch_resource( &self, resource_type: &str, id: &str, patch_request: &Value, expected_version: &ScimVersion, context: &RequestContext, ) -> Result<ConditionalResult<VersionedResource>, InMemoryError>

pub async fn get_versioned_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<Option<VersionedResource>, InMemoryError>

pub async fn create_versioned_resource( &self, resource_type: &str, data: Value, context: &RequestContext, ) -> Result<VersionedResource, InMemoryError>

Trait Implementations

impl<S: Clone + StorageProvider> Clone for StandardResourceProvider<S>

fn clone(&self) -> StandardResourceProvider<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug + StorageProvider> Debug for StandardResourceProvider<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: StorageProvider> ResourceProvider for StandardResourceProvider<S>

fn apply_patch_operation( &self, resource_data: &mut Value, operation: &Value, ) -> Result<(), Self::Error>

Override the default patch operation implementation

type Error = InMemoryError

Error type returned by all provider operations

async fn create_resource( &self, resource_type: &str, data: Value, context: &RequestContext, ) -> Result<Resource, Self::Error>

Create a resource for the tenant specified in the request context.

async fn get_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<Option<Resource>, Self::Error>

Get a resource by ID from the tenant specified in the request context.

async fn update_resource( &self, resource_type: &str, id: &str, data: Value, context: &RequestContext, ) -> Result<Resource, Self::Error>

Update a resource in the tenant specified in the request context.

async fn delete_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<(), Self::Error>

Delete a resource from the tenant specified in the request context.

async fn list_resources( &self, resource_type: &str, query: Option<&ListQuery>, context: &RequestContext, ) -> Result<Vec<Resource>, Self::Error>

List resources from the tenant specified in the request context.

async fn find_resource_by_attribute( &self, resource_type: &str, attribute: &str, value: &Value, context: &RequestContext, ) -> Result<Option<Resource>, Self::Error>

Find a resource by attribute value within the tenant specified in the request context.

async fn resource_exists( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<bool, Self::Error>

Check if a resource exists within the tenant specified in the request context.

async fn patch_resource( &self, resource_type: &str, id: &str, patch_request: &Value, context: &RequestContext, ) -> Result<Resource, Self::Error>

Apply PATCH operations to a resource within the tenant specified in the request context.

fn conditional_update( &self, resource_type: &str, id: &str, data: Value, expected_version: &ScimVersion, context: &RequestContext, ) -> impl Future<Output = Result<ConditionalResult<VersionedResource>, Self::Error>> + Send

where Self: Sync,

Conditionally update a resource if the version matches.

fn conditional_delete( &self, resource_type: &str, id: &str, expected_version: &ScimVersion, context: &RequestContext, ) -> impl Future<Output = Result<ConditionalResult<()>, Self::Error>> + Send

where Self: Sync,

Conditionally delete a resource if the version matches.

fn get_versioned_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> impl Future<Output = Result<Option<VersionedResource>, Self::Error>> + Send

where Self: Sync,

Get a resource with its version information.