53 lines
1.5 KiB
Dart
53 lines
1.5 KiB
Dart
// Package imports:
|
||
import 'package:drift/drift.dart';
|
||
import 'package:remever/database/database.dart';
|
||
import 'package:remever/database/tables.dart';
|
||
import 'package:remever/models/collection_dto.dart';
|
||
|
||
part 'collections_dao.g.dart';
|
||
|
||
@DriftAccessor(tables: <Type>[Collections])
|
||
class CollectionsDao extends DatabaseAccessor<AppDatabase>
|
||
with _$CollectionsDaoMixin {
|
||
///
|
||
/// Репозиторий для работы с коллекциями
|
||
///
|
||
CollectionsDao(super.attachedDatabase);
|
||
|
||
/// Получение коллекций из базы данных
|
||
Stream<List<Collection>> getCollections() {
|
||
return db.managers.collections.watch();
|
||
}
|
||
|
||
/// Создание коллекции
|
||
Future<void> createCollection(CollectionDto dto) async {
|
||
await db.managers.collections.create(
|
||
(o) => o(
|
||
title: dto.title,
|
||
desc: dto.desc,
|
||
isPublic: Value<bool>(dto.isPublic),
|
||
image: Value<String?>(dto.avatar),
|
||
),
|
||
);
|
||
}
|
||
|
||
/// Обновление коллекции
|
||
Future<void> updateCollection(CollectionDto dto, String id) async {
|
||
await db.managers.collections
|
||
.filter((f) => f.id(id))
|
||
.update(
|
||
(o) => o(
|
||
title: Value<String>(dto.title),
|
||
desc: Value<String>(dto.desc),
|
||
isPublic: Value<bool>(dto.isPublic),
|
||
image: Value<String?>(dto.avatar),
|
||
),
|
||
);
|
||
}
|
||
|
||
/// Удаление коллекции
|
||
Future<void> deleteCollection(String id) async {
|
||
await db.managers.collections.filter((f) => f.id(id)).delete();
|
||
}
|
||
}
|