properly watch database providers

This commit is contained in:
Fabian Freund
2026-01-10 05:18:10 +01:00
parent 3f4cf5156c
commit 471c2b7b2d
2 changed files with 12 additions and 18 deletions
@@ -123,11 +123,8 @@ Stream<ContainerData?> watchContainerData(Ref ref, String containerId) {
@Riverpod() @Riverpod()
Stream<String?> watchContainerTabId(Ref ref, String tabId) { Stream<String?> watchContainerTabId(Ref ref, String tabId) {
return ref final db = ref.watch(tabDatabaseProvider);
.read(tabDatabaseProvider) return db.tabDao.getTabContainerId(tabId).watchSingleOrNull();
.tabDao
.getTabContainerId(tabId)
.watchSingleOrNull();
} }
@Riverpod() @Riverpod()
@@ -145,9 +142,8 @@ Stream<Map<String, String?>> watchTabsContainerId(
Ref ref, Ref ref,
EquatableValue<List<String>> tabIds, EquatableValue<List<String>> tabIds,
) { ) {
return ref final db = ref.watch(tabDatabaseProvider);
.read(tabDatabaseProvider) return db.tabDao
.tabDao
.getTabsContainerId(tabIds.value) .getTabsContainerId(tabIds.value)
.watch() .watch()
.map(Map.fromEntries); .map(Map.fromEntries);
@@ -155,7 +151,8 @@ Stream<Map<String, String?>> watchTabsContainerId(
@Riverpod() @Riverpod()
Stream<List<SiteAssignment>> watchAllAssignedSites(Ref ref) { Stream<List<SiteAssignment>> watchAllAssignedSites(Ref ref) {
return ref.read(tabDatabaseProvider).containerDao.allAssignedSites().watch(); final db = ref.watch(tabDatabaseProvider);
return db.containerDao.allAssignedSites().watch();
} }
@Riverpod() @Riverpod()
@@ -166,9 +163,6 @@ Stream<bool> watchIsCurrentSiteAssignedToContainer(Ref ref) {
), ),
); );
return ref final db = ref.watch(tabDatabaseProvider);
.read(tabDatabaseProvider) return db.containerDao.isSiteAssignedToContainer(currentUri).watchSingle();
.containerDao
.isSiteAssignedToContainer(currentUri)
.watchSingle();
} }
@@ -651,7 +651,7 @@ final class WatchContainerTabIdProvider
} }
String _$watchContainerTabIdHash() => String _$watchContainerTabIdHash() =>
r'b8f107e462f417b128221240242167a0754f040f'; r'c2cb263d4633fae436e7b3b216ab46d93ef49d4f';
final class WatchContainerTabIdFamily extends $Family final class WatchContainerTabIdFamily extends $Family
with $FunctionalFamilyOverride<Stream<String?>, String> { with $FunctionalFamilyOverride<Stream<String?>, String> {
@@ -805,7 +805,7 @@ final class WatchTabsContainerIdProvider
} }
String _$watchTabsContainerIdHash() => String _$watchTabsContainerIdHash() =>
r'ffdebb10f7118cdff93695c821ef5fbb0d434de1'; r'75a915a0fd93cbb33a32f0aa521dbd61f1814c75';
final class WatchTabsContainerIdFamily extends $Family final class WatchTabsContainerIdFamily extends $Family
with with
@@ -869,7 +869,7 @@ final class WatchAllAssignedSitesProvider
} }
String _$watchAllAssignedSitesHash() => String _$watchAllAssignedSitesHash() =>
r'd755451be0ad7e03db36ba39c64f6f0b5c1d9ba3'; r'0e06caeb4a53b5cf976b3f47d328ea238243438b';
@ProviderFor(watchIsCurrentSiteAssignedToContainer) @ProviderFor(watchIsCurrentSiteAssignedToContainer)
final watchIsCurrentSiteAssignedToContainerProvider = final watchIsCurrentSiteAssignedToContainerProvider =
@@ -905,4 +905,4 @@ final class WatchIsCurrentSiteAssignedToContainerProvider
} }
String _$watchIsCurrentSiteAssignedToContainerHash() => String _$watchIsCurrentSiteAssignedToContainerHash() =>
r'2942672c75b671fbe84489606e5341f0290502c3'; r'c2a82ca9df526c7a703da52302182e497c91e824';