aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2025-12-18 17:14:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

bindings/javascript: Add async connect() function

Browse Source 
Let's make the API symmetric with libSQL and serverless drivers.
This commit is contained in:
Pekka Enberg
2025-08-12 11:36:24 +03:00
parent 1c6a3bacb9
commit 96673a54a8
2 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
bindings/javascript/promise.ts
View File

@@ -399,4 +399,15 @@ class Statement {
}
}
export { Database, SqliteError }
/**
* Creates a new database connection asynchronously.
*
* @param {string} path - Path to the database file.
* @param {Object} opts - Options for database behavior.
* @returns {Promise<Database>} - A promise that resolves to a Database instance.
*/
async function connect(path: string, opts: any = {}): Promise<Database> {
return new Database(path, opts);
}
export { Database, SqliteError, connect }

12
testing/javascript/__test__/async.test.js
View File

@@ -484,9 +484,9 @@ const connect = async (path, options = {}) => {
}
const provider = process.env.PROVIDER;
if (provider === "turso") {
const { Database, SqliteError } = await import("@tursodatabase/database");
const db = new Database(path, options);
return [db, path, SqliteError];
const turso = await import("@tursodatabase/database");
const db = await turso.connect(path, options);
return [db, path, turso.SqliteError];
}
if (provider === "libsql") {
const libsql = await import("libsql/promise");
@@ -494,17 +494,17 @@ const connect = async (path, options = {}) => {
return [db, path, libsql.SqliteError, path];
}
if (provider === "serverless") {
const x = await import("@tursodatabase/serverless");
const turso = await import("@tursodatabase/serverless");
const url = process.env.TURSO_DATABASE_URL;
if (!url) {
throw new Error("TURSO_DATABASE_URL is not set");
}
const authToken = process.env.TURSO_AUTH_TOKEN;
const db = new x.connect({
const db = new turso.connect({
url,
authToken,
});
return [db, null, x.SqliteError];
return [db, null, turso.SqliteError];
}
};