add dart test files

Author: codekeyz

bin/proxy_server.dart

@@ -0,0 +1,44 @@
+import 'dart:convert';
+import 'dart:io';
+
+void main() async {
+  final server = await HttpServer.bind(InternetAddress.anyIPv4, 8080);
+
+  server.listen((request) async {
+    if (request.uri.path == '/db/auth') {
+      final response = {
+        'db_url': 'staging-db-lhr-08c0519209-simple-tail-globe.turso.io',
+        'db_token':
+            'eyJhbGciOiJFZERTQSIsInR5cCI6IkpXVCJ9.eyJhIjoicnciLCJleHAiOjE3NTQ2NzIwMDAsImlhdCI6MTc1NDU4NTYwMCwiaWQiOiJiMTZkZDkxMS05NmE4LTQzYTMtYTg3OC01ZGMzZjQ5MjVlZTkifQ.GrjdkI7SSLG3yTjpqFVzDGOdxs0PNlsvh3sVmkiQ-k0Rkvhv1h_-56tNmHLk_TYruW6vySmpr8UMhbKDN9tdBw',
+      };
+
+      request.response
+        ..statusCode = HttpStatus.ok
+        ..headers.contentType = ContentType.json
+        ..write(json.encode(response))
+        ..close();
+      return;
+    }
+
+    // Handle the request
+    if (request.method == 'GET') {
+      request.response
+        ..write('Hello from the proxy server!')
+        ..close();
+    } else {
+      request.response
+        ..statusCode = HttpStatus.methodNotAllowed
+        ..write('Method not allowed')
+        ..close();
+    }
+  });
+
+  print(
+      'Proxy server running on http://${server.address.address}:${server.port}');
+
+  // Handle server shutdown gracefully
+  ProcessSignal.sigterm.watch().listen((_) async {
+    await server.close();
+    print('Proxy server stopped.');
+  });
+}

bin/sqlite_test.dart

@@ -1,8 +1,15 @@
 import 'dart:io';
 
-import 'package:sqlite3/sqlite3.dart';
+import 'package:sqlite_async/sqlite_async.dart';
 import 'package:path/path.dart' as path;
 
+final migrations = SqliteMigrations()
+  ..add(SqliteMigration(1, (tx) async {
+    await tx.execute(
+      'CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT, email TEXT)',
+    );
+  }));
+
 // ignore: public_member_api_docs
 void copyBinaryIfNecessary() {
   const libraryName = 'libsqlite3.so';
@@ -13,24 +20,31 @@ void copyBinaryIfNecessary() {
   customBinary.copySync(systemBinary.path);
 }
 
-void main() {
+void main() async {
   copyBinaryIfNecessary();
-
-  const commmands = [
-    'CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, email TEXT)',
-    // "INSERT INTO users (name, email) VALUES ('Alice', '[email protected]')",
-  ];
-
-  final db = sqlite3.open('untrue-necklace');
-  for (final command in commmands) db.execute(command);
-
-  // fetch data
-  final result = db.select("SELECT * FROM users");
-  for (final row in result) {
-    stdout.writeln(
-      'Artist[id: ${row['id']}, name: ${row['name']}, email: ${row['email']}]',
-    );
-  }
-
-  db.dispose();
+  final db = SqliteDatabase(path: 'simple-nubian');
+
+  await migrations.migrate(db);
+
+  // // Use execute() or executeBatch() for INSERT/UPDATE/DELETE statements
+  // await db.executeBatch('INSERT INTO users(name, email) values(?, ?)', [
+  //   ['Amen', '[email protected]'],
+  //   ['Moron', '[email protected]']
+  // ]);
+
+  // var results = await db.getAll('SELECT * FROM users');
+  // print('Results: $results');
+
+  // await db.writeTransaction((tx) async {
+  //   await tx.execute(
+  //     'INSERT INTO users(name, email) values(?, ?)',
+  //     ['Test3', '[email protected]'],
+  //   );
+  //   await tx.execute(
+  //     'INSERT INTO users(name, email) values(?, ?)',
+  //     ['Test4', '[email protected]'],
+  //   );
+  // });
+
+  // await db.close();
 }