45 lines
1.5 KiB
Dart
45 lines
1.5 KiB
Dart
import 'package:drift/drift.dart';
|
|
import 'package:game_tracker/data/db/database.dart';
|
|
import 'package:game_tracker/data/db/tables/player_group_table.dart';
|
|
import 'package:game_tracker/data/dto/player.dart';
|
|
|
|
part 'player_group_dao.g.dart';
|
|
|
|
@DriftAccessor(tables: [PlayerGroupTable])
|
|
class PlayerGroupDao extends DatabaseAccessor<AppDatabase>
|
|
with _$PlayerGroupDaoMixin {
|
|
PlayerGroupDao(super.db);
|
|
|
|
/// Retrieves all players belonging to a specific group by [groupId].
|
|
Future<List<Player>> getPlayersOfGroupById(String groupId) async {
|
|
final query = select(playerGroupTable)
|
|
..where((pG) => pG.groupId.equals(groupId));
|
|
final result = await query.get();
|
|
|
|
List<Player> groupMembers = [];
|
|
|
|
for (var entry in result) {
|
|
final player = await db.playerDao.getPlayerById(entry.userId);
|
|
groupMembers.add(player);
|
|
}
|
|
|
|
return groupMembers;
|
|
}
|
|
|
|
/// Removes a player from a group based on [userId] and [groupId].
|
|
/// Returns `true` if more than 0 rows were affected, otherwise `false`.
|
|
Future<bool> removePlayerFromGroup(String userId, String groupId) async {
|
|
final query = delete(playerGroupTable)
|
|
..where((p) => p.userId.equals(userId) & p.groupId.equals(groupId));
|
|
final rowsAffected = await query.go();
|
|
return rowsAffected > 0;
|
|
}
|
|
|
|
/// Adds a player to a group with the given [userId] and [groupId].
|
|
Future<void> addPlayerToGroup(String userId, String groupId) async {
|
|
await into(playerGroupTable).insert(
|
|
PlayerGroupTableCompanion.insert(userId: userId, groupId: groupId),
|
|
);
|
|
}
|
|
}
|