WIP auth, added Drift for database and refined shared_models for data exchange

backend/lib/authenticator.dart

@@ -0,0 +1,49 @@
+import 'dart:io';
+
+import 'package:backend/database.dart';
+import 'package:backend/service/db_access.dart';
+import 'package:dart_jsonwebtoken/dart_jsonwebtoken.dart';
+
+final jwtSecret = _getSecret();
+
+class Authenticator {
+  Future<String?> generateToken({required String username}) async {
+    final newUser = await Db.createUser(username: username);
+    if (newUser == null) return null;
+
+    final jwt = JWT(
+      {
+        'uid': newUser.uuid,
+      },
+    );
+
+    return jwt.sign(SecretKey(jwtSecret));
+  }
+
+  Future<User?> verifyToken(
+    String token,
+  ) async {
+    try {
+      final payload = JWT.verify(
+        token,
+        SecretKey(jwtSecret),
+      );
+
+      final payloadData = payload.payload as Map<String, dynamic>;
+
+      final uuid = payloadData['uuid'] as String;
+      return await Db.getUser(uuid);
+    } catch (e) {
+      return null;
+    }
+  }
+}
+
+String _getSecret() {
+  final secret = Platform.environment['JWT_TOKEN_SECRET'];
+  if (secret == null || secret.isEmpty) {
+    throw Exception('JWT secret not configured. Define JWT_TOKEN_SECRET in environment.');
+  } else {
+    return secret;
+  }
+}

backend/lib/database.dart

@@ -0,0 +1,53 @@
+import 'dart:io';
+
+import 'package:drift/drift.dart';
+import 'package:drift/native.dart';
+
+part 'database.g.dart';
+
+class Users extends Table {
+  TextColumn get uuid => text().unique()();
+  TextColumn get gameRoom => text().references(GameRooms, #uuid).nullable()();
+  TextColumn get name => text().withLength(min: 2, max: 32)();
+  DateTimeColumn get createdAt => dateTime().nullable()();
+}
+
+enum GameStatus {
+  opened,
+  running,
+  closed,
+}
+
+class GameRooms extends Table {
+  TextColumn get uuid => text().unique()();
+  TextColumn get status => textEnum<GameStatus>()();
+  DateTimeColumn get createdAt => dateTime().nullable()();
+}
+
+@DriftDatabase(tables: [Users, GameRooms])
+class AppDatabase extends _$AppDatabase {
+  AppDatabase() : super(_openConnection());
+
+  @override
+  int get schemaVersion => 1;
+
+  static QueryExecutor _openConnection() {
+    return NativeDatabase.createInBackground(File('./backend.db'));
+  }
+
+  @override
+  MigrationStrategy get migration {
+    return MigrationStrategy(
+      beforeOpen: (details) async {
+        // Statements to run to make sqlite performant, running in WAL mode, etc
+        await customStatement('PRAGMA foreign_keys = ON');
+        await customStatement('PRAGMA journal_mode=WAL');
+        await customStatement('PRAGMA busy_timeout=5000');
+        await customStatement('PRAGMA synchronous=NORMAL');
+        await customStatement('PRAGMA cache_size=10000');
+        await customStatement('PRAGMA temp_store=MEMORY');
+        await customStatement('PRAGMA mmap_size=268435456');
+      },
+    );
+  }
+}

backend/lib/service/db_access.dart

@@ -0,0 +1,24 @@
+import 'package:backend/database.dart';
+import 'package:drift/drift.dart';
+import 'package:logging/logging.dart';
+import 'package:uuid/uuid.dart';
+
+final log = Logger('Db');
+
+class Db {
+  static Future<User> getUser(String uuid) {
+    log.finer('Getting user $uuid');
+    return AppDatabase().managers.users.filter((f) => f.uuid.equals(uuid)).get().then((u) => u.first);
+  }
+
+  static Future<User?> createUser({required String username}) => AppDatabase()
+          .managers
+          .users
+          .createReturningOrNull(
+            (o) => o(createdAt: Value(DateTime.now()), uuid: const Uuid().v4(), name: username),
+          )
+          .catchError((Object err) {
+        log.severe('Failed to create user', err, StackTrace.current);
+        throw Exception(err.toString());
+      });
+}