turso/bindings/dart/rust/src/api/connect.rs

use crate::helpers::wrapper::Wrapper;

pub use super::connection::RustConnection;
use std::sync::Arc;

pub enum OpenFlags {
    ReadOnly,
    ReadWrite,
    Create,
}

pub struct ConnectArgs {
    pub url: String,
    pub auth_token: Option<String>,
    pub sync_url: Option<String>,
    pub sync_interval_seconds: Option<u64>,
    pub encryption_key: Option<String>,
    pub read_your_writes: Option<bool>,
    pub open_flags: Option<OpenFlags>,
    pub offline: Option<bool>,
}

pub async fn connect(args: ConnectArgs) -> RustConnection {
    let database = if args.url == ":memory:" {
        let io: Arc<dyn turso_core::IO> = Arc::new(turso_core::MemoryIO::new());
        turso_core::Database::open_file(io, args.url.as_str(), false, true)
    } else {
        let io: Arc<dyn turso_core::IO> = Arc::new(turso_core::PlatformIO::new().unwrap());
        turso_core::Database::open_file(io, args.url.as_str(), false, true)
    }
    .unwrap();
    let connection = database.connect().unwrap();
    RustConnection::new(Wrapper { inner: connection })
}