57 lines
1.7 KiB
Dart
57 lines
1.7 KiB
Dart
import 'package:cabo_counter/data/db/database.dart';
|
|
import 'package:cabo_counter/data/db/tables/player_table.dart';
|
|
import 'package:cabo_counter/data/dto/player.dart';
|
|
import 'package:drift/drift.dart';
|
|
|
|
part 'player_dao.g.dart';
|
|
|
|
@DriftAccessor(tables: [PlayerTable])
|
|
class PlayerDao extends DatabaseAccessor<AppDatabase> with _$PlayerDaoMixin {
|
|
PlayerDao(super.db);
|
|
|
|
/// Retrieves all players from a game by gameId
|
|
Future<List<Player>> getPlayersByGameId(String gameId) async {
|
|
final query = select(playerTable)
|
|
..where((tbl) => tbl.gameId.equals(gameId));
|
|
final playerResults = await query.get();
|
|
|
|
return playerResults.map((row) {
|
|
return Player(
|
|
playerId: row.playerId,
|
|
gameId: row.gameId,
|
|
name: row.name,
|
|
position: row.position,
|
|
totalScore: row.totalScore,
|
|
);
|
|
}).toList()
|
|
..sort((a, b) => a.position.compareTo(b.position));
|
|
}
|
|
|
|
/// Retrieves a players position by its id
|
|
Future<int> getPositionByPlayerId(String playerId) async {
|
|
final query = select(playerTable)
|
|
..where((tbl) => tbl.playerId.equals(playerId));
|
|
final result = await query.getSingle();
|
|
|
|
return result.position;
|
|
}
|
|
|
|
/// Inserts a new player into the database.
|
|
Future<void> insertPlayers(String gameId, List<Player> players) async {
|
|
await batch((batch) {
|
|
for (int i = 0; i < players.length; i++) {
|
|
batch.insert(
|
|
playerTable,
|
|
PlayerTableCompanion.insert(
|
|
playerId: players[i].playerId,
|
|
gameId: gameId,
|
|
name: players[i].name,
|
|
position: i,
|
|
totalScore: players[i].totalScore,
|
|
),
|
|
);
|
|
}
|
|
});
|
|
}
|
|
}
|