_

Author: codekeyz

.github/workflows/build.yaml

@@ -13,16 +13,14 @@ jobs:
     name: Build LibSqlite_Turso
     runs-on: ubuntu-22.04
     steps:
-      - uses: actions/checkout@v2
-      - uses: actions-rs/toolchain@v1
+      - uses: jirutka/setup-alpine@v1
         with:
-          toolchain: stable
-      - run: |
-          cargo build
-          cargo build --release --all-features
-
-
-
+          branch: v3.15
+      - run: apk add rust cargo
+        shell: alpine.sh {0}
+      - run: cargo build && cargo build --release
+        shell: alpine.sh {0}
+        
       - name: Find built shared library
         id: find_artifact
         shell: bash

Cargo.lock

@@ -13,4 +13,4 @@ regex = "1.11.1"
 serde = { version = "1.0.216", features = ["derive"] }
 serde_json = "1.0.134"
 tokio = { version = "1.42.0", features = ["rt-multi-thread"] }
-reqwest = { version = "0.12.9", features = ["json", "blocking"] }
+reqwest = { version = "0.12.9", features = ["json", "blocking", "gzip"] }

Cargo.toml

@@ -21,7 +21,7 @@ void main() {
     // "INSERT INTO users (name, email) VALUES ('Alice', '[email protected]')",
   ];
 
-  final db = sqlite3.open('test-database-chima');
+  final db = sqlite3.open('untrue-necklace');
   for (final command in commmands) db.execute(command);
 
   // fetch data

bin/sqlite_test.dart

@@ -3,7 +3,6 @@ use std::{
     collections::HashMap,
     ffi::{c_int, c_uint, c_void, CStr, CString},
     os::raw::c_char,
-    process::exit,
     slice,
     sync::Mutex,
 };
@@ -63,20 +62,20 @@ pub unsafe extern "C" fn sqlite3_open_v2(
     let filename = CStr::from_ptr(filename).to_str().unwrap();
     if filename.contains(":memory") {
         eprintln!("LibSqlite3_Turso Error: Memory store is not supported at runtime");
-        exit(1);
+        return SQLITE_MISUSE;
     }
 
     let reqwest_client = reqwest::Client::builder()
         .user_agent("libsqlite3_turso/1.0.0")
         .build()
         .unwrap();
 
-    let turso_config = get_tokio()
-        .block_on(get_turso_db(&reqwest_client, filename))
-        .unwrap_or_else(|err| {
-            eprintln!("LibSqlite3_Turso Error: {}", err);
-            exit(1);
-        });
+    // get turso config or return SQLITE_ERROR
+    let turso_config = get_tokio().block_on(get_turso_db(&reqwest_client, filename));
+    if turso_config.is_err() {
+        eprintln!("LibSqlite3_Turso Error: {}", turso_config.unwrap_err());
+        return SQLITE_ERROR;
+    }
 
     let mock_db = Box::into_raw(Box::new(SQLite3 {
         client: reqwest_client,
@@ -86,7 +85,7 @@ pub unsafe extern "C" fn sqlite3_open_v2(
         delete_hook: Mutex::new(None),
         insert_hook: Mutex::new(None),
         update_hook: Mutex::new(None),
-        turso_config: turso_config,
+        turso_config: turso_config.unwrap(),
     }));
 
     *db = mock_db;

src/lib.rs

@@ -124,7 +124,7 @@ async fn send_remote_request(
     request: serde_json::Value,
 ) -> Result<serde_json::Value, Box<dyn Error>> {
     let response = client
-        .post(format!("{}/{}", turso_config.db_url, path))
+        .post(format!("https://{}/{}", turso_config.db_url, path))
         .header("Content-Type", "application/json")
         .header("Authorization", format!("Bearer {}", turso_config.db_token))
         .json(&request)
@@ -239,14 +239,14 @@ pub async fn get_turso_db(client: &Client, db_name: &str) -> Result<TursoConfig,
         .post(format!("{}/db/auth", globe_auth_api))
         .body(request_body.to_string())
         .send()
-        .await?;
+        .await
+        .map_err(|_| "Failed to fetch auth credentials for database")?;
 
     if !response.status().is_success() {
         return Err(format!("Failed to get Auth Token: {}", response.status()).into());
     }
 
-    let token: String = response.text().await?;
-    let db_info = serde_json::from_str(&token)?;
-
+    let json = response.json().await?;
+    let db_info = serde_json::from_value(json)?;
     Ok(db_info)
 }