import 'package:built_collection/built_collection.dart'; import 'package:flutter/material.dart'; import 'package:flutter/widgets.dart'; import 'package:redux/redux.dart'; import 'package:invoiceninja_flutter/main_app.dart'; import 'package:invoiceninja_flutter/redux/app/app_actions.dart'; import 'package:invoiceninja_flutter/data/models/models.dart'; import 'package:invoiceninja_flutter/redux/ui/ui_actions.dart'; import 'package:invoiceninja_flutter/ui/transaction/transaction_screen.dart'; import 'package:invoiceninja_flutter/ui/transaction/edit/transaction_edit_vm.dart'; import 'package:invoiceninja_flutter/ui/transaction/view/transaction_view_vm.dart'; import 'package:invoiceninja_flutter/redux/transaction/transaction_actions.dart'; import 'package:invoiceninja_flutter/redux/app/app_state.dart'; import 'package:invoiceninja_flutter/data/repositories/transaction_repository.dart'; List> createStoreTransactionsMiddleware([ TransactionRepository repository = const TransactionRepository(), ]) { final viewTransactionList = _viewTransactionList(); final viewTransaction = _viewTransaction(); final editTransaction = _editTransaction(); final loadTransactions = _loadTransactions(repository); final loadTransaction = _loadTransaction(repository); final saveTransaction = _saveTransaction(repository); final archiveTransaction = _archiveTransaction(repository); final deleteTransaction = _deleteTransaction(repository); final restoreTransaction = _restoreTransaction(repository); final convertTransactions = _convertTransactions(repository); final convertToPayment = _convertToPayment(repository); final convertToExpense = _convertToExpense(repository); return [ TypedMiddleware(viewTransactionList), TypedMiddleware(viewTransaction), TypedMiddleware(editTransaction), TypedMiddleware(loadTransactions), TypedMiddleware(loadTransaction), TypedMiddleware(saveTransaction), TypedMiddleware(archiveTransaction), TypedMiddleware(deleteTransaction), TypedMiddleware(restoreTransaction), TypedMiddleware(convertTransactions), TypedMiddleware( convertToPayment), TypedMiddleware( convertToExpense), ]; } Middleware _editTransaction() { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as EditTransaction; next(action); store.dispatch(UpdateCurrentRoute(TransactionEditScreen.route)); if (store.state.prefState.isMobile) { navigatorKey.currentState.pushNamed(TransactionEditScreen.route); } }; } Middleware _viewTransaction() { return (Store store, dynamic dynamicAction, NextDispatcher next) async { final action = dynamicAction as ViewTransaction; next(action); store.dispatch(UpdateCurrentRoute(TransactionViewScreen.route)); if (store.state.prefState.isMobile) { navigatorKey.currentState.pushNamed(TransactionViewScreen.route); } }; } Middleware _viewTransactionList() { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as ViewTransactionList; next(action); if (store.state.staticState.isStale) { store.dispatch(RefreshData()); } store.dispatch(UpdateCurrentRoute(TransactionScreen.route)); if (store.state.prefState.isMobile) { navigatorKey.currentState.pushNamedAndRemoveUntil( TransactionScreen.route, (Route route) => false); } }; } Middleware _archiveTransaction(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as ArchiveTransactionsRequest; final prevTransactions = action.transactionIds .map((id) => store.state.transactionState.map[id]) .toList(); repository .bulkAction(store.state.credentials, action.transactionIds, EntityAction.archive) .then((List transactions) { store.dispatch(ArchiveTransactionsSuccess(transactions)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(ArchiveTransactionsFailure(prevTransactions)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _deleteTransaction(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as DeleteTransactionsRequest; final prevTransactions = action.transactionIds .map((id) => store.state.transactionState.map[id]) .toList(); repository .bulkAction( store.state.credentials, action.transactionIds, EntityAction.delete) .then((List transactions) { store.dispatch(DeleteTransactionsSuccess(transactions)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(DeleteTransactionsFailure(prevTransactions)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _restoreTransaction(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as RestoreTransactionsRequest; final prevTransactions = action.transactionIds .map((id) => store.state.transactionState.map[id]) .toList(); repository .bulkAction(store.state.credentials, action.transactionIds, EntityAction.restore) .then((List transactions) { store.dispatch(RestoreTransactionsSuccess(transactions)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(RestoreTransactionsFailure(prevTransactions)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _convertTransactions(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as ConvertTransactionsRequest; repository .bulkAction(store.state.credentials, action.transactionIds, EntityAction.convertMatched) .then((List transactions) { store.dispatch(ConvertTransactionsSuccess(transactions)); store.dispatch(RefreshData()); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(ConvertTransactionsFailure(error)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _convertToPayment(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as ConvertTransactionToPaymentRequest; repository .convertToPayment( store.state.credentials, action.transactionId, action.invoiceIds, ) .then((TransactionEntity transaction) { store.dispatch(ConvertTransactionToPaymentSuccess(transaction)); store.dispatch(RefreshData()); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(ConvertTransactionToPaymentFailure(error)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _convertToExpense(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as ConvertTransactionsToExpensesRequest; repository .convertToExpense( store.state.credentials, action.transactionIds, action.vendorId, action.categoryId, ) .then((BuiltList transactions) { store.dispatch(ConvertTransactionsToExpensesSuccess(transactions)); store.dispatch(RefreshData()); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(ConvertTransactionsToExpensesFailure(error)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _saveTransaction(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as SaveTransactionRequest; repository .saveData(store.state.credentials, action.transaction) .then((TransactionEntity transaction) { if (action.transaction.isNew) { store.dispatch(AddTransactionSuccess(transaction)); } else { store.dispatch(SaveTransactionSuccess(transaction)); } action.completer.complete(transaction); }).catchError((Object error) { //store.dispatch(AddTransactionSuccess(action.transaction.rebuild((b) => b..id = '1'))); print(error); store.dispatch(SaveTransactionFailure(error)); action.completer.completeError(error); }); next(action); }; } Middleware _loadTransaction(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as LoadTransaction; final AppState state = store.state; store.dispatch(LoadTransactionRequest()); repository .loadItem(state.credentials, action.transactionId) .then((transaction) { store.dispatch(LoadTransactionSuccess(transaction)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(LoadTransactionFailure(error)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _loadTransactions(TransactionRepository repository) { return (Store store, dynamic dynamicAction, NextDispatcher next) { final action = dynamicAction as LoadTransactions; final AppState state = store.state; store.dispatch(LoadTransactionsRequest()); repository.loadList(state.credentials).then((data) { store.dispatch(LoadTransactionsSuccess(data)); if (action.completer != null) { action.completer.complete(null); } store.dispatch(PersistData()); }).catchError((Object error) { print(error); store.dispatch(LoadTransactionsFailure(error)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; }