42 lines
1.2 KiB
Dart
42 lines
1.2 KiB
Dart
import 'dart:convert';
|
|
|
|
import 'package:drift/drift.dart';
|
|
import 'package:lensai/extensions/nullable.dart';
|
|
import 'package:lensai/features/user/data/database/database.dart';
|
|
|
|
part 'setting.g.dart';
|
|
|
|
@DriftAccessor()
|
|
class SettingDao extends DatabaseAccessor<UserDatabase> with _$SettingDaoMixin {
|
|
SettingDao(super.attachedDatabase);
|
|
|
|
Future<int> updateSetting(String key, String? partitionKey, Object? value) {
|
|
final normalizedValue = (value is Iterable) ? jsonEncode(value) : value;
|
|
|
|
final driftvalue = normalizedValue.mapNotNull(
|
|
(normalizedValue) => DriftAny(normalizedValue),
|
|
);
|
|
|
|
return db.setting.insertOne(
|
|
SettingCompanion.insert(
|
|
key: key,
|
|
partitionKey: Value(partitionKey),
|
|
value: Value(driftvalue),
|
|
),
|
|
onConflict: DoUpdate(
|
|
(old) => SettingCompanion.custom(value: Variable(driftvalue)),
|
|
),
|
|
);
|
|
}
|
|
|
|
Selectable<MapEntry<String, DriftAny?>> getAllSettingsOfPartitionKey(
|
|
String? partitionKey,
|
|
) {
|
|
final query =
|
|
db.setting.select()
|
|
..where((r) => r.partitionKey.equalsNullable(partitionKey));
|
|
|
|
return query.map((row) => MapEntry(row.key, row.value));
|
|
}
|
|
}
|