SaveFamily/sf-app-platform
11
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(device_management): migrate rewards to Riverpod

Browse Source
This commit is contained in:
Julián Alcalá
2026-04-22 20:59:25 +02:00
parent b90eed2a54
commit db3197a93a
9 changed files with 362 additions and 426 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/providers/rewards_amount_provider.dart Normal file
View File

@@ -0,0 +1,23 @@
import 'package:riverpod_annotation/riverpod_annotation.dart';
part 'rewards_amount_provider.g.dart';
const int _min = 1;
@riverpod
class RewardsAmount extends _$RewardsAmount {
@override
int build() => _min;
void setAmount(int value) {
if (value < _min || value == state) return;
state = value;
}
void increase() => state = state + 1;
void decrease() {
if (state <= _min) return;
state = state - 1;
}
}

63
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/providers/rewards_amount_provider.g.dart Normal file
View File

@@ -0,0 +1,63 @@
// GENERATED CODE - DO NOT MODIFY BY HAND
part of 'rewards_amount_provider.dart';
// **************************************************************************
// RiverpodGenerator
// **************************************************************************
// GENERATED CODE - DO NOT MODIFY BY HAND
// ignore_for_file: type=lint, type=warning
@ProviderFor(RewardsAmount)
const rewardsAmountProvider = RewardsAmountProvider._();
final class RewardsAmountProvider
extends $NotifierProvider<RewardsAmount, int> {
const RewardsAmountProvider._()
: super(
from: null,
argument: null,
retry: null,
name: r'rewardsAmountProvider',
isAutoDispose: true,
dependencies: null,
$allTransitiveDependencies: null,
);
@override
String debugGetCreateSourceHash() => _$rewardsAmountHash();
@$internal
@override
RewardsAmount create() => RewardsAmount();
/// {@macro riverpod.override_with_value}
Override overrideWithValue(int value) {
return $ProviderOverride(
origin: this,
providerOverride: $SyncValueProvider<int>(value),
);
}
}
String _$rewardsAmountHash() => r'98056f20c72522ce50a0499a0924f13472a0fde9';
abstract class _$RewardsAmount extends $Notifier<int> {
int build();
@$mustCallSuper
@override
void runBuild() {
final created = build();
final ref = this.ref as $Ref<int, int>;
final element =
ref.element
as $ClassProviderElement<
AnyNotifier<int, int>,
int,
Object?,
Object?
>;
element.handleValue(ref, created);
}
}

32
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/providers/rewards_controller.dart Normal file
View File

@@ -0,0 +1,32 @@
import 'dart:async';
import 'package:legacy_device_state/legacy_device_state.dart';
import 'package:riverpod_annotation/riverpod_annotation.dart';
import 'package:sf_tracking/sf_tracking.dart';
part 'rewards_controller.g.dart';
@riverpod
class RewardsController extends _$RewardsController {
@override
FutureOr<void> build() {}
Future<void> submit({
required String deviceIdentificator,
required int amount,
}) async {
state = const AsyncLoading();
state = await AsyncValue.guard(() async {
await ref.read(commandsRepositoryProvider).send(
request: SendCommandRequestModel(
device: deviceIdentificator,
command: DeviceCommand.rewards,
data: {'rewards': amount},
),
);
unawaited(
ref.read(sfTrackingProvider).legacyDeviceRewardsGranted(amount: amount),
);
});
}
}

55
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/providers/rewards_controller.g.dart Normal file
View File

@@ -0,0 +1,55 @@
// GENERATED CODE - DO NOT MODIFY BY HAND
part of 'rewards_controller.dart';
// **************************************************************************
// RiverpodGenerator
// **************************************************************************
// GENERATED CODE - DO NOT MODIFY BY HAND
// ignore_for_file: type=lint, type=warning
@ProviderFor(RewardsController)
const rewardsControllerProvider = RewardsControllerProvider._();
final class RewardsControllerProvider
extends $AsyncNotifierProvider<RewardsController, void> {
const RewardsControllerProvider._()
: super(
from: null,
argument: null,
retry: null,
name: r'rewardsControllerProvider',
isAutoDispose: true,
dependencies: null,
$allTransitiveDependencies: null,
);
@override
String debugGetCreateSourceHash() => _$rewardsControllerHash();
@$internal
@override
RewardsController create() => RewardsController();
}
String _$rewardsControllerHash() => r'5f14f3471271faf271a1d2288f342a7408add02c';
abstract class _$RewardsController extends $AsyncNotifier<void> {
FutureOr<void> build();
@$mustCallSuper
@override
void runBuild() {
build();
final ref = this.ref as $Ref<AsyncValue<void>, void>;
final element =
ref.element
as $ClassProviderElement<
AnyNotifier<AsyncValue<void>, void>,
AsyncValue<void>,
Object?,
Object?
>;
element.handleValue(ref, null);
}
}

118
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/rewards_screen.dart
View File

@@ -1,41 +1,30 @@
import 'package:design_system/design_system.dart';
import 'package:legacy_theme/legacy_theme.dart';
import 'package:device_management/src/features/rewards/presentation/providers/rewards_amount_provider.dart';
import 'package:device_management/src/features/rewards/presentation/providers/rewards_controller.dart';
import 'package:flutter/material.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:legacy_theme/legacy_theme.dart';
import 'package:legacy_ui/legacy_ui.dart';
import 'package:sf_localizations/sf_localizations.dart';
import 'package:sf_shared/sf_shared.dart';
import 'package:utils/utils.dart';
import 'state/rewards_view_model.dart';
class RewardsScreen extends ConsumerWidget {
const RewardsScreen({super.key});
@override
Widget build(BuildContext context, WidgetRef ref) {
final state = ref.watch(rewardsViewModelProvider);
final vm = ref.read(rewardsViewModelProvider.notifier);
final primaryColor = context.sfColors.legacyPrimary;
final isSubmitting =
ref.watch(rewardsControllerProvider.select((s) => s.isLoading));
ref.listen(rewardsViewModelProvider.select((s) => s.errorMessage), (
previous,
next,
) {
if (next.isNotEmpty) {
showTopSnackbar(context, message: next, type: MessageType.error);
}
});
ref.listen(rewardsViewModelProvider.select((s) => s.isComplete), (
previous,
next,
) {
if (next) {
showTopSnackbar(
context,
message: context.translate(I18n.rewardsSent),
type: MessageType.success,
);
ref.listen(rewardsControllerProvider, (prev, next) async {
if (prev == null || !prev.isLoading || next.isLoading) return;
if (next.hasError) {
await next.showErrorOn(context);
return;
}
await showSuccessDialog(context, I18n.rewardsSent);
});
return LegacyPageLayout(
@@ -46,7 +35,7 @@ class RewardsScreen extends ConsumerWidget {
child: Icon(
SFIcons.rewardsCircle,
size: SizeUtils.getByScreen(small: 180, big: 160),
color: context.sfColors.legacyPrimary,
color: primaryColor,
),
),
SizedBox(height: SizeUtils.getByScreen(small: 32, big: 28)),
@@ -64,54 +53,99 @@ class RewardsScreen extends ConsumerWidget {
vertical: SizeUtils.getByScreen(small: 10, big: 8),
),
child: PrimaryButton(
onPressed: state.isLoading ? null : vm.submit,
onPressed: isSubmitting
? null
: () {
final identificator =
ref.read(selectedDeviceProvider).value?.identificator;
if (identificator == null) return;
ref.read(rewardsControllerProvider.notifier).submit(
deviceIdentificator: identificator,
amount: ref.read(rewardsAmountProvider),
);
},
text: context.translate(I18n.sendRewards),
color: context.sfColors.legacyPrimary,
color: primaryColor,
),
),
);
}
}
class _CounterSection extends ConsumerWidget {
class _CounterSection extends ConsumerStatefulWidget {
const _CounterSection();
@override
Widget build(BuildContext context, WidgetRef ref) {
final vm = ref.read(rewardsViewModelProvider.notifier);
ConsumerState<_CounterSection> createState() => _CounterSectionState();
}
class _CounterSectionState extends ConsumerState<_CounterSection> {
late final TextEditingController _amountController;
@override
void initState() {
super.initState();
_amountController = TextEditingController(
text: ref.read(rewardsAmountProvider).toString(),
);
_amountController.addListener(_onTextChanged);
}
@override
void dispose() {
_amountController.removeListener(_onTextChanged);
_amountController.dispose();
super.dispose();
}
void _onTextChanged() {
final raw = _amountController.text;
if (raw.isEmpty) return;
final parsed = int.tryParse(raw);
if (parsed == null) return;
ref.read(rewardsAmountProvider.notifier).setAmount(parsed);
}
@override
Widget build(BuildContext context) {
final primaryColor = context.sfColors.legacyPrimary;
ref.listen<int>(rewardsAmountProvider, (_, next) {
final nextText = next.toString();
if (_amountController.text != nextText) {
_amountController.text = nextText;
}
});
return Row(
mainAxisAlignment: MainAxisAlignment.center,
children: [
IconButton(
onPressed: vm.decreaseAmount,
icon: Icon(Icons.remove),
color: context.sfColors.legacyPrimary,
onPressed: ref.read(rewardsAmountProvider.notifier).decrease,
icon: const Icon(Icons.remove),
color: primaryColor,
),
SizedBox(
width: SizeUtils.getByScreen(small: 240, big: 220),
child: TextField(
controller: vm.amountController,
controller: _amountController,
decoration: InputDecoration(
border: OutlineInputBorder(
borderSide: BorderSide(
color: context.sfColors.legacyPrimary,
),
borderSide: BorderSide(color: primaryColor),
borderRadius: BorderRadius.all(
Radius.circular(SizeUtils.getByScreen(small: 32, big: 28)),
),
),
),
style: TextStyle(color: context.sfColors.legacyPrimary),
style: TextStyle(color: primaryColor),
textAlign: TextAlign.center,
keyboardType: TextInputType.number,
),
),
IconButton(
onPressed: vm.increaseAmount,
icon: Icon(Icons.add),
color: context.sfColors.legacyPrimary,
onPressed: ref.read(rewardsAmountProvider.notifier).increase,
icon: const Icon(Icons.add),
color: primaryColor,
),
],
);

91
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/state/rewards_view_model.dart
View File

@@ -1,91 +0,0 @@
import 'dart:async';
import 'package:flutter/cupertino.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:legacy_device_state/legacy_device_state.dart';
import 'package:sf_shared/sf_shared.dart';
import 'package:sf_tracking/sf_tracking.dart';
import 'rewards_view_state.dart';
final rewardsViewModelProvider =
NotifierProvider.autoDispose<RewardsViewModel, RewardsViewState>(
RewardsViewModel.new,
);
class RewardsViewModel extends Notifier<RewardsViewState> {
static const _min = 1;
late final TextEditingController amountController;
late final CommandsRepository _commandsRepository;
late final SfTrackingRepository _tracking;
@override
RewardsViewState build() {
_commandsRepository = ref.read(commandsRepositoryProvider);
_tracking = ref.read(sfTrackingProvider);
amountController = TextEditingController(text: '1');
amountController.addListener(_onAmountChanged);
ref.onDispose(_disposeControllers);
return const RewardsViewState();
}
void _onAmountChanged() {
final raw = amountController.text;
if (raw.isEmpty) return;
final amount = int.tryParse(raw);
if (amount == null) return;
if (amount == state.amount) return;
if (amount < _min) return;
state = state.copyWith(amount: amount, errorMessage: '');
}
void increaseAmount() {
final amount = state.amount + 1;
state = state.copyWith(amount: amount, errorMessage: '');
amountController.text = amount.toString();
}
void decreaseAmount() {
if (state.amount == _min) return;
final amount = state.amount - 1;
state = state.copyWith(amount: amount, errorMessage: '');
amountController.text = amount.toString();
}
Future<void> submit() async {
try {
state = state.copyWith(isLoading: true, isComplete: false);
final device = ref.read(selectedDeviceProvider).value;
final request = SendCommandRequestModel(
device: device!.identificator.toString(),
command: DeviceCommand.rewards,
data: {'rewards': state.amount},
);
await _commandsRepository.send(request: request);
unawaited(_tracking.legacyDeviceRewardsGranted(amount: state.amount));
state = state.copyWith(isLoading: false, isComplete: true);
} catch (e) {
state = state.copyWith(
errorMessage: e.toString(),
isLoading: false,
isComplete: false,
);
}
}
void _disposeControllers() {
amountController.removeListener(_onAmountChanged);
amountController.dispose();
}
}

13
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/state/rewards_view_state.dart
View File

@@ -1,13 +0,0 @@
import 'package:freezed_annotation/freezed_annotation.dart';
part 'rewards_view_state.freezed.dart';
@freezed
abstract class RewardsViewState with _$RewardsViewState {
const factory RewardsViewState({
@Default(1) int amount,
@Default(false) bool isLoading,
@Default(false) bool isComplete,
@Default('') String errorMessage,
}) = _RewardsViewState;
}

280
modules/legacy/modules/device_management/lib/src/features/rewards/presentation/state/rewards_view_state.freezed.dart
View File

@@ -1,280 +0,0 @@
// GENERATED CODE - DO NOT MODIFY BY HAND
// coverage:ignore-file
// ignore_for_file: type=lint
// ignore_for_file: unused_element, deprecated_member_use, deprecated_member_use_from_same_package, use_function_type_syntax_for_parameters, unnecessary_const, avoid_init_to_null, invalid_override_different_default_values_named, prefer_expression_function_bodies, annotate_overrides, invalid_annotation_target, unnecessary_question_mark
part of 'rewards_view_state.dart';
// **************************************************************************
// FreezedGenerator
// **************************************************************************
// dart format off
T _$identity<T>(T value) => value;
/// @nodoc
mixin _$RewardsViewState {
int get amount; bool get isLoading; bool get isComplete; String get errorMessage;
/// Create a copy of RewardsViewState
/// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false)
@pragma('vm:prefer-inline')
$RewardsViewStateCopyWith<RewardsViewState> get copyWith => _$RewardsViewStateCopyWithImpl<RewardsViewState>(this as RewardsViewState, _$identity);
@override
bool operator ==(Object other) {
return identical(this, other) || (other.runtimeType == runtimeType&&other is RewardsViewState&&(identical(other.amount, amount) || other.amount == amount)&&(identical(other.isLoading, isLoading) || other.isLoading == isLoading)&&(identical(other.isComplete, isComplete) || other.isComplete == isComplete)&&(identical(other.errorMessage, errorMessage) || other.errorMessage == errorMessage));
}
@override
int get hashCode => Object.hash(runtimeType,amount,isLoading,isComplete,errorMessage);
@override
String toString() {
return 'RewardsViewState(amount: $amount, isLoading: $isLoading, isComplete: $isComplete, errorMessage: $errorMessage)';
}
}
/// @nodoc
abstract mixin class $RewardsViewStateCopyWith<$Res> {
factory $RewardsViewStateCopyWith(RewardsViewState value, $Res Function(RewardsViewState) _then) = _$RewardsViewStateCopyWithImpl;
@useResult
$Res call({
int amount, bool isLoading, bool isComplete, String errorMessage
});
}
/// @nodoc
class _$RewardsViewStateCopyWithImpl<$Res>
implements $RewardsViewStateCopyWith<$Res> {
_$RewardsViewStateCopyWithImpl(this._self, this._then);
final RewardsViewState _self;
final $Res Function(RewardsViewState) _then;
/// Create a copy of RewardsViewState
/// with the given fields replaced by the non-null parameter values.
@pragma('vm:prefer-inline') @override $Res call({Object? amount = null,Object? isLoading = null,Object? isComplete = null,Object? errorMessage = null,}) {
return _then(_self.copyWith(
amount: null == amount ? _self.amount : amount // ignore: cast_nullable_to_non_nullable
as int,isLoading: null == isLoading ? _self.isLoading : isLoading // ignore: cast_nullable_to_non_nullable
as bool,isComplete: null == isComplete ? _self.isComplete : isComplete // ignore: cast_nullable_to_non_nullable
as bool,errorMessage: null == errorMessage ? _self.errorMessage : errorMessage // ignore: cast_nullable_to_non_nullable
as String,
));
}
}
/// Adds pattern-matching-related methods to [RewardsViewState].
extension RewardsViewStatePatterns on RewardsViewState {
/// A variant of `map` that fallback to returning `orElse`.
///
/// It is equivalent to doing:
/// ```dart
/// switch (sealedClass) {
/// case final Subclass value:
/// return ...;
/// case _:
/// return orElse();
/// }
/// ```
@optionalTypeArgs TResult maybeMap<TResult extends Object?>(TResult Function( _RewardsViewState value)? $default,{required TResult orElse(),}){
final _that = this;
switch (_that) {
case _RewardsViewState() when $default != null:
return $default(_that);case _:
return orElse();
}
}
/// A `switch`-like method, using callbacks.
///
/// Callbacks receives the raw object, upcasted.
/// It is equivalent to doing:
/// ```dart
/// switch (sealedClass) {
/// case final Subclass value:
/// return ...;
/// case final Subclass2 value:
/// return ...;
/// }
/// ```
@optionalTypeArgs TResult map<TResult extends Object?>(TResult Function( _RewardsViewState value) $default,){
final _that = this;
switch (_that) {
case _RewardsViewState():
return $default(_that);case _:
throw StateError('Unexpected subclass');
}
}
/// A variant of `map` that fallback to returning `null`.
///
/// It is equivalent to doing:
/// ```dart
/// switch (sealedClass) {
/// case final Subclass value:
/// return ...;
/// case _:
/// return null;
/// }
/// ```
@optionalTypeArgs TResult? mapOrNull<TResult extends Object?>(TResult? Function( _RewardsViewState value)? $default,){
final _that = this;
switch (_that) {
case _RewardsViewState() when $default != null:
return $default(_that);case _:
return null;
}
}
/// A variant of `when` that fallback to an `orElse` callback.
///
/// It is equivalent to doing:
/// ```dart
/// switch (sealedClass) {
/// case Subclass(:final field):
/// return ...;
/// case _:
/// return orElse();
/// }
/// ```
@optionalTypeArgs TResult maybeWhen<TResult extends Object?>(TResult Function( int amount, bool isLoading, bool isComplete, String errorMessage)? $default,{required TResult orElse(),}) {final _that = this;
switch (_that) {
case _RewardsViewState() when $default != null:
return $default(_that.amount,_that.isLoading,_that.isComplete,_that.errorMessage);case _:
return orElse();
}
}
/// A `switch`-like method, using callbacks.
///
/// As opposed to `map`, this offers destructuring.
/// It is equivalent to doing:
/// ```dart
/// switch (sealedClass) {
/// case Subclass(:final field):
/// return ...;
/// case Subclass2(:final field2):
/// return ...;
/// }
/// ```
@optionalTypeArgs TResult when<TResult extends Object?>(TResult Function( int amount, bool isLoading, bool isComplete, String errorMessage) $default,) {final _that = this;
switch (_that) {
case _RewardsViewState():
return $default(_that.amount,_that.isLoading,_that.isComplete,_that.errorMessage);case _:
throw StateError('Unexpected subclass');
}
}
/// A variant of `when` that fallback to returning `null`
///
/// It is equivalent to doing:
/// ```dart
/// switch (sealedClass) {
/// case Subclass(:final field):
/// return ...;
/// case _:
/// return null;
/// }
/// ```
@optionalTypeArgs TResult? whenOrNull<TResult extends Object?>(TResult? Function( int amount, bool isLoading, bool isComplete, String errorMessage)? $default,) {final _that = this;
switch (_that) {
case _RewardsViewState() when $default != null:
return $default(_that.amount,_that.isLoading,_that.isComplete,_that.errorMessage);case _:
return null;
}
}
}
/// @nodoc
class _RewardsViewState implements RewardsViewState {
const _RewardsViewState({this.amount = 1, this.isLoading = false, this.isComplete = false, this.errorMessage = ''});
@override@JsonKey() final int amount;
@override@JsonKey() final bool isLoading;
@override@JsonKey() final bool isComplete;
@override@JsonKey() final String errorMessage;
/// Create a copy of RewardsViewState
/// with the given fields replaced by the non-null parameter values.
@override @JsonKey(includeFromJson: false, includeToJson: false)
@pragma('vm:prefer-inline')
_$RewardsViewStateCopyWith<_RewardsViewState> get copyWith => __$RewardsViewStateCopyWithImpl<_RewardsViewState>(this, _$identity);
@override
bool operator ==(Object other) {
return identical(this, other) || (other.runtimeType == runtimeType&&other is _RewardsViewState&&(identical(other.amount, amount) || other.amount == amount)&&(identical(other.isLoading, isLoading) || other.isLoading == isLoading)&&(identical(other.isComplete, isComplete) || other.isComplete == isComplete)&&(identical(other.errorMessage, errorMessage) || other.errorMessage == errorMessage));
}
@override
int get hashCode => Object.hash(runtimeType,amount,isLoading,isComplete,errorMessage);
@override
String toString() {
return 'RewardsViewState(amount: $amount, isLoading: $isLoading, isComplete: $isComplete, errorMessage: $errorMessage)';
}
}
/// @nodoc
abstract mixin class _$RewardsViewStateCopyWith<$Res> implements $RewardsViewStateCopyWith<$Res> {
factory _$RewardsViewStateCopyWith(_RewardsViewState value, $Res Function(_RewardsViewState) _then) = __$RewardsViewStateCopyWithImpl;
@override @useResult
$Res call({
int amount, bool isLoading, bool isComplete, String errorMessage
});
}
/// @nodoc
class __$RewardsViewStateCopyWithImpl<$Res>
implements _$RewardsViewStateCopyWith<$Res> {
__$RewardsViewStateCopyWithImpl(this._self, this._then);
final _RewardsViewState _self;
final $Res Function(_RewardsViewState) _then;
/// Create a copy of RewardsViewState
/// with the given fields replaced by the non-null parameter values.
@override @pragma('vm:prefer-inline') $Res call({Object? amount = null,Object? isLoading = null,Object? isComplete = null,Object? errorMessage = null,}) {
return _then(_RewardsViewState(
amount: null == amount ? _self.amount : amount // ignore: cast_nullable_to_non_nullable
as int,isLoading: null == isLoading ? _self.isLoading : isLoading // ignore: cast_nullable_to_non_nullable
as bool,isComplete: null == isComplete ? _self.isComplete : isComplete // ignore: cast_nullable_to_non_nullable
as bool,errorMessage: null == errorMessage ? _self.errorMessage : errorMessage // ignore: cast_nullable_to_non_nullable
as String,
));
}
}
// dart format on

113
modules/legacy/modules/device_management/test/features/rewards/rewards_controller_test.dart Normal file
View File

@@ -0,0 +1,113 @@
import 'package:device_management/src/features/rewards/presentation/providers/rewards_amount_provider.dart';
import 'package:device_management/src/features/rewards/presentation/providers/rewards_controller.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:flutter_test/flutter_test.dart';
import 'package:legacy_device_state/legacy_device_state.dart';
import 'package:mocktail/mocktail.dart';
import 'package:sf_infrastructure/sf_infrastructure.dart';
import 'package:sf_shared/testing.dart';
import 'package:sf_tracking/sf_tracking.dart';
class MockCommandsRepository extends Mock implements CommandsRepository {}
void main() {
setUpAll(() {
registerFallbackValue(
SendCommandRequestModel(
device: 'x',
command: DeviceCommand.rewards,
),
);
});
group('RewardsAmount', () {
test('starts at 1', () {
final container = makeContainer();
addTearDown(container.dispose);
expect(container.read(rewardsAmountProvider), 1);
});
test('increase and decrease respect min', () {
final container = makeContainer();
addTearDown(container.dispose);
final notifier = container.read(rewardsAmountProvider.notifier);
notifier.increase();
notifier.increase();
expect(container.read(rewardsAmountProvider), 3);
notifier.decrease();
expect(container.read(rewardsAmountProvider), 2);
notifier.decrease();
notifier.decrease();
expect(container.read(rewardsAmountProvider), 1);
});
test('setAmount rejects values below min', () {
final container = makeContainer();
addTearDown(container.dispose);
final notifier = container.read(rewardsAmountProvider.notifier);
notifier.setAmount(5);
expect(container.read(rewardsAmountProvider), 5);
notifier.setAmount(0);
expect(container.read(rewardsAmountProvider), 5);
});
});
group('RewardsController.submit', () {
test('sends REWARDS command and transitions to AsyncData', () async {
final commands = MockCommandsRepository();
when(() => commands.send(request: any(named: 'request')))
.thenAnswer((_) async {});
final container = makeContainer(
overrides: [
commandsRepositoryProvider.overrideWithValue(commands),
sfTrackingProvider.overrideWithValue(
SfTrackingRepository(clients: const []),
),
],
);
addTearDown(container.dispose);
await container.read(rewardsControllerProvider.notifier).submit(
deviceIdentificator: 'imei-1',
amount: 3,
);
expect(container.read(rewardsControllerProvider), isA<AsyncData<void>>());
final sent = verify(
() => commands.send(request: captureAny(named: 'request')),
).captured.single as SendCommandRequestModel;
expect(sent.command, DeviceCommand.rewards);
expect(sent.data, {'rewards': 3});
expect(sent.device, 'imei-1');
});
test('exposes AsyncError when command fails', () async {
final commands = MockCommandsRepository();
when(() => commands.send(request: any(named: 'request')))
.thenThrow(const ApiException(message: 'boom', isNetworkError: true));
final container = makeContainer(
overrides: [
commandsRepositoryProvider.overrideWithValue(commands),
sfTrackingProvider.overrideWithValue(
SfTrackingRepository(clients: const []),
),
],
);
addTearDown(container.dispose);
await container.read(rewardsControllerProvider.notifier).submit(
deviceIdentificator: 'imei-1',
amount: 1,
);
expect(container.read(rewardsControllerProvider), isA<AsyncError<void>>());
});
});
}