invoice/lib/redux/dashboard/dashboard_middleware.dart

83 lines
2.6 KiB
Dart

import 'package:flutter/widgets.dart';
import 'package:invoiceninja_flutter/redux/app/app_middleware.dart';
import 'package:invoiceninja_flutter/redux/client/client_actions.dart';
import 'package:invoiceninja_flutter/redux/ui/ui_actions.dart';
import 'package:invoiceninja_flutter/ui/dashboard/dashboard_screen_vm.dart';
import 'package:invoiceninja_flutter/utils/platforms.dart';
import 'package:redux/redux.dart';
import 'package:invoiceninja_flutter/redux/dashboard/dashboard_actions.dart';
import 'package:invoiceninja_flutter/redux/app/app_state.dart';
import 'package:invoiceninja_flutter/data/repositories/dashboard_repository.dart';
List<Middleware<AppState>> createStoreDashboardMiddleware([
DashboardRepository repository = const DashboardRepository(),
]) {
final viewDashboard = _createViewDashboard();
final loadDashboard = _createLoadDashboard(repository);
return [
TypedMiddleware<AppState, ViewDashboard>(viewDashboard),
TypedMiddleware<AppState, LoadDashboard>(loadDashboard),
];
}
Middleware<AppState> _createViewDashboard() {
return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
final action = dynamicAction as ViewDashboard;
if (!action.force &&
hasChanges(store: store, context: action.context, action: action)) {
return;
}
if (store.state.dashboardState.isStale) {
store.dispatch(LoadDashboard());
}
store.dispatch(UpdateCurrentRoute(DashboardScreenBuilder.route));
if (isMobile(action.context)) {
Navigator.of(action.context).pushNamedAndRemoveUntil(
DashboardScreenBuilder.route, (Route<dynamic> route) => false);
}
next(action);
};
}
Middleware<AppState> _createLoadDashboard(DashboardRepository repository) {
return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
final action = dynamicAction as LoadDashboard;
final state = store.state;
if (!state.dashboardState.isStale && !action.force) {
next(action);
return;
}
if (state.isLoading) {
next(action);
return;
}
store.dispatch(LoadDashboardRequest());
repository.loadItem(state.credentials).then((data) {
store.dispatch(LoadDashboardSuccess(data));
if (action.completer != null) {
action.completer.complete(null);
}
if (state.clientState.isStale) {
store.dispatch(LoadClients());
}
}).catchError((Object error) {
print(error);
if (action.completer != null) {
action.completer.completeError(error);
}
store.dispatch(LoadDashboardFailure(error));
});
next(action);
};
}