76 lines
2.8 KiB
Dart
76 lines
2.8 KiB
Dart
import 'package:flutter/material.dart';
|
|
import 'package:fpdart/fpdart.dart';
|
|
import 'package:hiddify/core/core_providers.dart';
|
|
import 'package:hiddify/core/router/router.dart';
|
|
import 'package:hiddify/data/data_providers.dart';
|
|
import 'package:hiddify/domain/failures.dart';
|
|
import 'package:hiddify/domain/profiles/profiles.dart';
|
|
import 'package:hiddify/services/service_providers.dart';
|
|
import 'package:hiddify/utils/utils.dart';
|
|
import 'package:riverpod_annotation/riverpod_annotation.dart';
|
|
|
|
part 'profiles_update_notifier.g.dart';
|
|
|
|
typedef ProfileUpdateResult = ({
|
|
String name,
|
|
Either<ProfileFailure, Unit> failureOrSuccess
|
|
});
|
|
|
|
@Riverpod(keepAlive: true)
|
|
class ProfilesUpdateNotifier extends _$ProfilesUpdateNotifier with AppLogger {
|
|
@override
|
|
Stream<ProfileUpdateResult> build() {
|
|
ref.listenSelf(
|
|
(previous, next) {
|
|
if (next case AsyncData(value: final result)) {
|
|
final t = ref.read(translationsProvider);
|
|
final context = rootNavigatorKey.currentContext;
|
|
if (context == null || !context.mounted) return;
|
|
SnackBar(content: Text(t.profile.update.successMsg));
|
|
switch (result.failureOrSuccess) {
|
|
case Right():
|
|
CustomToast.success(t.profile.update.successMsg).show(context);
|
|
case Left(value: final err):
|
|
CustomToast.error(t.printError(err)).show(context);
|
|
}
|
|
}
|
|
},
|
|
);
|
|
_schedule();
|
|
return const Stream.empty();
|
|
}
|
|
|
|
Future<void> _schedule() async {
|
|
loggy.debug("scheduling profiles update worker");
|
|
return ref.read(cronServiceProvider).schedule(
|
|
key: 'profiles_update',
|
|
duration: const Duration(minutes: 10),
|
|
callback: () async {
|
|
final failureOrProfiles =
|
|
await ref.read(profilesRepositoryProvider).watchAll().first;
|
|
if (failureOrProfiles case Right(value: final profiles)) {
|
|
for (final profile in profiles) {
|
|
if (profile case RemoteProfile()) {
|
|
loggy.debug("checking profile: [${profile.name}]");
|
|
final updateInterval = profile.options?.updateInterval;
|
|
if (updateInterval != null &&
|
|
updateInterval <=
|
|
DateTime.now().difference(profile.lastUpdate)) {
|
|
final failureOrSuccess = await ref
|
|
.read(profilesRepositoryProvider)
|
|
.update(profile)
|
|
.run();
|
|
state = AsyncData(
|
|
(name: profile.name, failureOrSuccess: failureOrSuccess),
|
|
);
|
|
} else {
|
|
loggy.debug("skipping profile: [${profile.name}]");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
},
|
|
);
|
|
}
|
|
}
|