63 lines
2.1 KiB
Dart
63 lines
2.1 KiB
Dart
import 'package:backend/db/database.dart';
|
|
import 'package:drift/drift.dart';
|
|
import 'package:logging/logging.dart';
|
|
import 'package:uuid/uuid.dart';
|
|
|
|
final log = Logger('Db');
|
|
|
|
class Db {
|
|
static final _db = AppDatabase();
|
|
|
|
static Future<User?> getUserById(String uuid) {
|
|
log.finest('Getting user $uuid');
|
|
return _db.managers.users.filter((f) => f.uuid.equals(uuid)).getSingleOrNull();
|
|
}
|
|
|
|
static Future<User?> createUser({required String username, required String roomCode}) async {
|
|
log.finest('Creating user $username in room $roomCode');
|
|
final room = await _db.managers.gameRooms
|
|
.filter((f) => f.code.equals(roomCode) & f.status.isIn([GameStatus.open, GameStatus.running]))
|
|
.getSingleOrNull()
|
|
.catchError((Object err) {
|
|
log.info('Failed to find available room:$roomCode', err, StackTrace.current);
|
|
return null;
|
|
});
|
|
if (room == null) return null;
|
|
return _db.managers.users
|
|
.createReturningOrNull(
|
|
(o) => o(createdAt: Value(DateTime.now()), uuid: const Uuid().v4(), name: username, gameRoomUuid: room.uuid),
|
|
)
|
|
.catchError((Object err) {
|
|
log.severe('Failed to create user', err, StackTrace.current);
|
|
throw Exception(err.toString());
|
|
});
|
|
}
|
|
|
|
static Future<GameRoom?> createRoom({required String roomCode}) {
|
|
log.finest('Creating room with code $roomCode');
|
|
return _db.managers.gameRooms
|
|
.createReturningOrNull(
|
|
(o) => o(createdAt: Value(DateTime.now()), status: GameStatus.open, uuid: const Uuid().v4(), code: roomCode),
|
|
)
|
|
.catchError(
|
|
(Object err) {
|
|
log.severe('Failed to create room', err, StackTrace.current);
|
|
return null;
|
|
},
|
|
);
|
|
}
|
|
|
|
static Future<GameRoom?> getRoomByCode(String? roomCode) async {
|
|
log.finest('Getting room by code $roomCode');
|
|
final room = await _db.managers.gameRooms
|
|
.filter((f) => f.code.equals(roomCode) & f.status.isIn([GameStatus.open, GameStatus.running]))
|
|
.getSingleOrNull();
|
|
return room;
|
|
}
|
|
|
|
static Future<GameRoom?> getRoomById(String roomUuid) async {
|
|
log.finest('Getting room $roomUuid');
|
|
throw UnimplementedError();
|
|
}
|
|
}
|