85 lines
2.8 KiB
Dart
85 lines
2.8 KiB
Dart
import 'package:flutter_bloc/flutter_bloc.dart';
|
|
|
|
import '../../../../core/resources/data_state.dart';
|
|
import '../../../../core/usecase/use_case.dart';
|
|
import '../../domain/use_cases/ad_reward_usecase.dart';
|
|
import '../../domain/use_cases/buy_card_usecase.dart';
|
|
import '../../domain/use_cases/get_shop_usecase.dart';
|
|
import '../../domain/use_cases/purchase_usecase.dart';
|
|
import '../../domain/use_cases/select_card_usecase.dart';
|
|
import 'shop_event.dart';
|
|
import 'shop_state.dart';
|
|
import 'shop_status.dart';
|
|
|
|
class ShopBloc extends Bloc<ShopEvent, ShopBlocState> {
|
|
final GetShopUseCase getShopUseCase;
|
|
final BuyCardUseCase buyCardUseCase;
|
|
final SelectCardUseCase selectCardUseCase;
|
|
final PurchaseUseCase purchaseUseCase;
|
|
final AdRewardUseCase adRewardUseCase;
|
|
|
|
ShopBloc(
|
|
this.getShopUseCase,
|
|
this.buyCardUseCase,
|
|
this.selectCardUseCase,
|
|
this.purchaseUseCase,
|
|
this.adRewardUseCase,
|
|
) : super(ShopBlocState.initial()) {
|
|
on<LoadShopEvent>((event, emit) => _load(emit));
|
|
|
|
on<BuyCardEvent>((event, emit) =>
|
|
_action(emit, () => buyCardUseCase(event.cardId)));
|
|
|
|
on<SelectCardEvent>((event, emit) =>
|
|
_action(emit, () => selectCardUseCase(event.cardId)));
|
|
|
|
on<PurchaseEvent>((event, emit) => _action(
|
|
emit,
|
|
() => purchaseUseCase(PurchaseParams(
|
|
store: 'bazaar',
|
|
kind: event.kind,
|
|
productId: event.productId,
|
|
token:
|
|
'dev-${event.kind}-${event.productId}-${DateTime.now().millisecondsSinceEpoch}',
|
|
))));
|
|
|
|
on<AdRewardEvent>((event, emit) => _action(
|
|
emit,
|
|
() async {
|
|
final res = await adRewardUseCase(
|
|
'dev-ad-${DateTime.now().millisecondsSinceEpoch}');
|
|
if (res is DataSuccess) {
|
|
return const DataSuccess('سکه رایگان دریافت شد');
|
|
}
|
|
return DataError<String>(res.error!);
|
|
},
|
|
));
|
|
}
|
|
|
|
Future<void> _load(Emitter<ShopBlocState> emit) async {
|
|
emit(state.copyWith(loadStatus: ShopLoading()));
|
|
final res = await getShopUseCase(const NoParams());
|
|
if (res is DataSuccess) {
|
|
emit(state.copyWith(loadStatus: ShopLoaded(res.data!)));
|
|
} else {
|
|
emit(state.copyWith(loadStatus: ShopLoadError(res.error!)));
|
|
}
|
|
}
|
|
|
|
/// اجرای یک عملیات، نمایش وضعیت و سپس بازخوانی کاتالوگ.
|
|
Future<void> _action(
|
|
Emitter<ShopBlocState> emit,
|
|
Future<DataState<String>> Function() action,
|
|
) async {
|
|
if (state.busy) return;
|
|
emit(state.copyWith(actionStatus: ActionLoading()));
|
|
final res = await action();
|
|
if (res is DataSuccess) {
|
|
emit(state.copyWith(actionStatus: ActionSuccess(res.data!)));
|
|
await _load(emit);
|
|
} else {
|
|
emit(state.copyWith(actionStatus: ActionError(res.error!)));
|
|
}
|
|
}
|
|
}
|