Method connect

crates/openshell-server/src/persistence/mod.rs:176–200

Connect to a persistence store based on the database URL.

(url: &str)

    /// Connect to a persistence store based on the database URL.
    pub async fn connect(url: &str) -> CoreResult<Self> {
        if url.starts_with("postgres://") || url.starts_with("postgresql://") {
            let store = PostgresStore::connect(url)
                .await
                .map_err(|e| CoreError::execution(e.to_string()))?;
            store
                .migrate()
                .await
                .map_err(|e| CoreError::execution(e.to_string()))?;
            Ok(Self::Postgres(store))
        } else if url.starts_with("sqlite:") {
            let store = SqliteStore::connect(url)
                .await
                .map_err(|e| CoreError::execution(e.to_string()))?;
            store
                .migrate()
                .await
                .map_err(|e| CoreError::execution(e.to_string()))?;
            Ok(Self::Sqlite(store))
        } else {
            Err(CoreError::config(format!(
                "unsupported database URL scheme: {url}"
            )))
        }
    }

    /// Verify connectivity to the underlying database.
    pub async fn ping(&self) -> PersistenceResult<()> {