import 'package:flutter/material.dart'; import 'package:flutter/widgets.dart'; import 'package:redux/redux.dart'; import 'package:invoiceninja_flutter/data/models/models.dart'; import 'package:invoiceninja_flutter/redux/ui/ui_actions.dart'; import 'package:invoiceninja_flutter/ui/stub/stub_screen.dart'; import 'package:invoiceninja_flutter/ui/stub/edit/stub_edit_vm.dart'; import 'package:invoiceninja_flutter/ui/stub/view/stub_view_vm.dart'; import 'package:invoiceninja_flutter/redux/stub/stub_actions.dart'; import 'package:invoiceninja_flutter/redux/app/app_state.dart'; import 'package:invoiceninja_flutter/data/repositories/stub_repository.dart'; List> createStoreStubsMiddleware([ StubRepository repository = const StubRepository(), ]) { final viewStubList = _viewStubList(); final viewStub = _viewStub(); final editStub = _editStub(); final loadStubs = _loadStubs(repository); final loadStub = _loadStub(repository); final saveStub = _saveStub(repository); final archiveStub = _archiveStub(repository); final deleteStub = _deleteStub(repository); final restoreStub = _restoreStub(repository); return [ TypedMiddleware(viewStubList), TypedMiddleware(viewStub), TypedMiddleware(editStub), TypedMiddleware(loadStubs), TypedMiddleware(loadStub), TypedMiddleware(saveStub), TypedMiddleware(archiveStub), TypedMiddleware(deleteStub), TypedMiddleware(restoreStub), ]; } Middleware _editStub() { return (Store store, dynamic action, NextDispatcher next) async { next(action); store.dispatch(UpdateCurrentRoute(StubEditScreen.route)); final stub = await Navigator.of(action.context).pushNamed(StubEditScreen.route); if (action.completer != null && stub != null) { action.completer.complete(stub); } }; } Middleware _viewStub() { return (Store store, dynamic action, NextDispatcher next) async { next(action); store.dispatch(UpdateCurrentRoute(StubViewScreen.route)); Navigator.of(action.context).pushNamed(StubViewScreen.route); }; } Middleware _viewStubList() { return (Store store, dynamic action, NextDispatcher next) { next(action); store.dispatch(UpdateCurrentRoute(StubScreen.route)); Navigator.of(action.context).pushNamedAndRemoveUntil(StubScreen.route, (Route route) => false); }; } Middleware _archiveStub(StubRepository repository) { return (Store store, dynamic action, NextDispatcher next) { final origStub = store.state.stubState.map[action.stubId]; repository .saveData(store.state.selectedCompany, store.state.authState, origStub, EntityAction.archive) .then((StubEntity stub) { store.dispatch(ArchiveStubSuccess(stub)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(ArchiveStubFailure(origStub)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _deleteStub(StubRepository repository) { return (Store store, dynamic action, NextDispatcher next) { final origStub = store.state.stubState.map[action.stubId]; repository .saveData(store.state.selectedCompany, store.state.authState, origStub, EntityAction.delete) .then((StubEntity stub) { store.dispatch(DeleteStubSuccess(stub)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(DeleteStubFailure(origStub)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _restoreStub(StubRepository repository) { return (Store store, dynamic action, NextDispatcher next) { final origStub = store.state.stubState.map[action.stubId]; repository .saveData(store.state.selectedCompany, store.state.authState, origStub, EntityAction.restore) .then((StubEntity stub) { store.dispatch(RestoreStubSuccess(stub)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(RestoreStubFailure(origStub)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _saveStub(StubRepository repository) { return (Store store, dynamic action, NextDispatcher next) { repository .saveData( store.state.selectedCompany, store.state.authState, action.stub) .then((StubEntity stub) { if (action.stub.isNew) { store.dispatch(AddStubSuccess(stub)); } else { store.dispatch(SaveStubSuccess(stub)); } action.completer.complete(stub); }).catchError((Object error) { print(error); store.dispatch(SaveStubFailure(error)); action.completer.completeError(error); }); next(action); }; } Middleware _loadStub(StubRepository repository) { return (Store store, dynamic action, NextDispatcher next) { final AppState state = store.state; if (state.isLoading) { next(action); return; } store.dispatch(LoadStubRequest()); repository .loadItem(state.selectedCompany, state.authState, action.stubId) .then((stub) { store.dispatch(LoadStubSuccess(stub)); if (action.completer != null) { action.completer.complete(null); } }).catchError((Object error) { print(error); store.dispatch(LoadStubFailure(error)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; } Middleware _loadStubs(StubRepository repository) { return (Store store, dynamic action, NextDispatcher next) { final AppState state = store.state; if (!state.stubState.isStale && !action.force) { next(action); return; } if (state.isLoading) { next(action); return; } final int updatedAt = (state.stubState.lastUpdated / 1000).round(); store.dispatch(LoadStubsRequest()); repository .loadList(state.selectedCompany, state.authState, updatedAt) .then((data) { store.dispatch(LoadStubsSuccess(data)); if (action.completer != null) { action.completer.complete(null); } /* if (state.productState.isStale) { store.dispatch(LoadProducts()); } */ }).catchError((Object error) { print(error); store.dispatch(LoadStubsFailure(error)); if (action.completer != null) { action.completer.completeError(error); } }); next(action); }; }