gltron/Krezus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added more blocs

Browse Source
This commit is contained in:
gltron
2024-02-07 18:54:48 +01:00
parent 3610c466d2
commit c5ede79dc4
32 changed files with 668 additions and 429 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
lib/repositories/account/account_repository.dart
View File

@@ -3,14 +3,18 @@ import 'dart:convert';
import 'package:rxdart/subjects.dart';
import 'package:tunas/clients/storage/storage_client.dart';
import 'package:tunas/repositories/account/models/account.dart';
import 'package:tunas/repositories/account/models/budget.dart';
import 'package:tunas/repositories/account/models/category.dart';
import 'package:tunas/repositories/account/models/transaction.dart';
class AccountRepository {
String accountFile = 'main_account.json';
String accountFile = 'tunas_main_account.json';
final StorageClient _storageClient;
final _transactionsController = BehaviorSubject<List<Transaction>>.seeded(const []);
final _categoriesController = BehaviorSubject<List<Category>>.seeded(const []);
final _budgetController = BehaviorSubject<List<Budget>>.seeded(const []);
AccountRepository({
required storageClient,
@@ -21,12 +25,22 @@ class AccountRepository {
init() async {
final account = await getAccount();
_transactionsController.add(account.transactions);
_categoriesController.add(account.categories);
_budgetController.add(account.budgets);
}
Stream<List<Transaction>> getTransactionsStream() {
return _transactionsController.asBroadcastStream();
}
Stream<List<Category>> getCategoriesStream() {
return _categoriesController.asBroadcastStream();
}
Stream<List<Budget>> getBudgetsStream() {
return _budgetController.asBroadcastStream();
}
Future<Account> getAccount() async {
String json = await _storageClient.load(accountFile);
Map<String, dynamic> accountJson = jsonDecode(json);
@@ -41,5 +55,14 @@ class AccountRepository {
final account = Account(transactions: transactions);
await saveAccount(account);
_transactionsController.add(account.transactions);
_categoriesController.add(account.categories);
_budgetController.add(account.budgets);
}
deleteAccount() async {
await _storageClient.delete(accountFile);
_transactionsController.add(const []);
_categoriesController.add(const []);
_budgetController.add(const []);
}
}