Struct ProviderRegistry 

pub struct ProviderRegistry { /* private fields */ }

Thread-safe registry of loaded providers backing every Soma surface, holding the active snapshot and supporting hot-reload from a file source.

Implementations

impl ProviderRegistry

pub async fn read_resource( &self, uri: &str, principal: &ProviderPrincipal, auth_mode: ProviderAuthMode, ) -> Result<ResourceReadOutput, ProviderError>

Matches uri against the active snapshot’s exact resources and dynamic resource templates (in that precedence order), enforces resource.scope under ProviderAuthMode::Mounted the same way dispatch() enforces tool.scope, then delegates to the owning provider’s read_resource.

The match and the provider clone are fetched from the same read lock acquisition, mirroring dispatch()’s pattern for tools — a concurrent refresh_file_providers() between two separate lock acquisitions could otherwise return params/scope from one snapshot but a provider instance from a newer one (e.g. a hot-swapped resources/foo.md -> resources/foo.ts letting a request matched against the old unscoped static resource invoke the new soma:write-scoped dynamic reader without ever being checked against its scope).

impl ProviderRegistry

pub fn new( providers: Vec<Arc<dyn Provider>>, ) -> Result<Self, ProviderValidationError>

Builds a registry from the given providers with a default-deny capability broker.

pub fn with_capabilities( providers: Vec<Arc<dyn Provider>>, capabilities: CapabilityBroker, ) -> Result<Self, ProviderValidationError>

Builds a registry from the given providers and capability broker.

pub fn with_file_source( providers: Vec<Arc<dyn Provider>>, capabilities: CapabilityBroker, file_source: FileProviderSource, ) -> Result<Self, ProviderValidationError>

Builds a registry from the given base providers plus dynamic providers loaded from a file source, enabling later hot-reloads.

pub fn snapshot(&self) -> Arc<RegistrySnapshot>

Returns the currently active registry snapshot.

pub fn refresh_file_providers( &self, ) -> Result<Arc<RegistrySnapshot>, ProviderValidationError>

Refreshes providers from the file source, if any. Per the drop-in provider layout contract (“If a resource disappears or becomes invalid, a reload must leave the last valid snapshot active until a valid replacement snapshot is available”), a failure anywhere in this pipeline (an unreadable directory, a newly-invalid or colliding provider file) is logged and this returns the previous snapshot rather than propagating the error — one bad drop-in file must not take down list_tools/list_prompts/read_resource/etc. for every other, unrelated, already-loaded provider.

pub fn validate_reload( &self, providers: Vec<Arc<dyn Provider>>, ) -> Result<Arc<RegistrySnapshot>, ProviderValidationError>

Builds and validates a snapshot from the given providers without installing it, for pre-flight checking a candidate reload.

pub fn reload( &self, providers: Vec<Arc<dyn Provider>>, ) -> Result<Arc<RegistrySnapshot>, ProviderValidationError>

Atomically replaces the loaded providers and active snapshot, clearing any file fingerprint.

pub async fn dispatch( &self, call: ProviderCall, ) -> Result<ProviderOutput, ProviderError>

Routes a provider call to its owning provider, enforcing pre-input checks, declared capabilities, and the response size limit around the provider’s own call.

Trait Implementations

impl Clone for ProviderRegistry

fn clone(&self) -> ProviderRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.