import 'package:flutter_riverpod/flutter_riverpod.dart'; import 'package:shared_preferences/shared_preferences.dart'; import '../../shared/models/transaction.dart'; import '../../shared/services/storage_service.dart'; import '../settings/provider.dart'; final sharedPreferencesProvider = Provider((ref) { throw UnimplementedError('Override in main'); }); final storageServiceProvider = Provider((ref) { return StorageService(ref.watch(sharedPreferencesProvider)); }); final transactionsProvider = StateNotifierProvider>((ref) { final storage = ref.watch(storageServiceProvider); return TransactionsNotifier(storage); }); class TransactionsNotifier extends StateNotifier> { final StorageService _storage; TransactionsNotifier(this._storage) : super(_storage.loadTransactions()); Future add(Transaction transaction) async { await _storage.addTransaction(transaction); state = _storage.loadTransactions(); } Future update(Transaction transaction) async { await _storage.updateTransaction(transaction); state = _storage.loadTransactions(); } Future delete(String id) async { await _storage.deleteTransaction(id); state = _storage.loadTransactions(); } void restore(Transaction transaction) { state = [...state, transaction]; _storage.addTransaction(transaction); } void clearAll() { state = []; SharedPreferences.getInstance().then((prefs) => prefs.remove('transactions')); } } final searchQueryProvider = StateProvider((ref) => ''); enum TransactionFilter { all, income, expense } final transactionFilterProvider = StateProvider((ref) => TransactionFilter.all); final totalBalanceProvider = Provider((ref) { final txs = ref.watch(transactionsProvider); final exchangeService = ref.watch(exchangeRateServiceProvider); final targetCurrency = ref.watch(currencyProvider).code; return txs.fold(0.0, (sum, t) { final converted = exchangeService.convert(t.amount, t.currencyCode, targetCurrency); return t.type == TransactionType.income ? sum + converted : sum - converted; }); }); final totalIncomeProvider = Provider((ref) { final txs = ref.watch(transactionsProvider).where((t) => t.type == TransactionType.income); final exchangeService = ref.watch(exchangeRateServiceProvider); final targetCurrency = ref.watch(currencyProvider).code; return txs.fold(0.0, (sum, t) { return sum + exchangeService.convert(t.amount, t.currencyCode, targetCurrency); }); }); final totalExpenseProvider = Provider((ref) { final txs = ref.watch(transactionsProvider).where((t) => t.type == TransactionType.expense); final exchangeService = ref.watch(exchangeRateServiceProvider); final targetCurrency = ref.watch(currencyProvider).code; return txs.fold(0.0, (sum, t) { return sum + exchangeService.convert(t.amount, t.currencyCode, targetCurrency); }); }); final currentMonthExpenseProvider = Provider((ref) { final now = DateTime.now(); final txs = ref.watch(transactionsProvider).where((t) => t.type == TransactionType.expense && t.date.year == now.year && t.date.month == now.month); final exchangeService = ref.watch(exchangeRateServiceProvider); final targetCurrency = ref.watch(currencyProvider).code; return txs.fold(0.0, (sum, t) { return sum + exchangeService.convert(t.amount, t.currencyCode, targetCurrency); }); }); final filteredTransactionsProvider = Provider>((ref) { final txs = ref.watch(transactionsProvider); final query = ref.watch(searchQueryProvider).toLowerCase(); final filter = ref.watch(transactionFilterProvider); var filtered = txs; if (filter == TransactionFilter.income) { filtered = filtered.where((t) => t.type == TransactionType.income).toList(); } else if (filter == TransactionFilter.expense) { filtered = filtered.where((t) => t.type == TransactionType.expense).toList(); } if (query.isNotEmpty) { filtered = filtered.where((t) { final matchesCategory = t.category.toLowerCase().contains(query); final matchesNote = t.note?.toLowerCase().contains(query) ?? false; return matchesCategory || matchesNote; }).toList(); } filtered.sort((a, b) => b.date.compareTo(a.date)); return filtered; }); final recentTransactionsProvider = Provider>((ref) { return ref.watch(filteredTransactionsProvider).take(20).toList(); });