invoice/lib/redux/recurring_expense/recurring_expense_middleware.dart

// Flutter imports:
import 'package:flutter/material.dart';
import 'package:flutter/widgets.dart';
import 'package:invoiceninja_flutter/redux/document/document_actions.dart';
import 'package:invoiceninja_flutter/redux/transaction/transaction_actions.dart';

// Package imports:
import 'package:redux/redux.dart';

// Project imports:
import 'package:invoiceninja_flutter/data/models/models.dart';
import 'package:invoiceninja_flutter/data/repositories/recurring_expense_repository.dart';
import 'package:invoiceninja_flutter/main_app.dart';
import 'package:invoiceninja_flutter/redux/app/app_actions.dart';
import 'package:invoiceninja_flutter/redux/app/app_state.dart';
import 'package:invoiceninja_flutter/redux/recurring_expense/recurring_expense_actions.dart';
import 'package:invoiceninja_flutter/redux/ui/ui_actions.dart';
import 'package:invoiceninja_flutter/ui/recurring_expense/edit/recurring_expense_edit_vm.dart';
import 'package:invoiceninja_flutter/ui/recurring_expense/recurring_expense_screen.dart';
import 'package:invoiceninja_flutter/ui/recurring_expense/view/recurring_expense_view_vm.dart';

List<Middleware<AppState>> createStoreRecurringExpensesMiddleware([
  RecurringExpenseRepository repository = const RecurringExpenseRepository(),
]) {
  final viewRecurringExpenseList = _viewRecurringExpenseList();
  final viewRecurringExpense = _viewRecurringExpense();
  final editRecurringExpense = _editRecurringExpense();
  final loadRecurringExpenses = _loadRecurringExpenses(repository);
  final loadRecurringExpense = _loadRecurringExpense(repository);
  final saveRecurringExpense = _saveRecurringExpense(repository);
  final archiveRecurringExpense = _archiveRecurringExpense(repository);
  final deleteRecurringExpense = _deleteRecurringExpense(repository);
  final restoreRecurringExpense = _restoreRecurringExpense(repository);
  final startRecurringExpense = _startRecurringExpense(repository);
  final stopRecurringExpense = _stopRecurringExpense(repository);
  final saveDocument = _saveDocument(repository);

  return [
    TypedMiddleware<AppState, ViewRecurringExpenseList>(
        viewRecurringExpenseList),
    TypedMiddleware<AppState, ViewRecurringExpense>(viewRecurringExpense),
    TypedMiddleware<AppState, EditRecurringExpense>(editRecurringExpense),
    TypedMiddleware<AppState, LoadRecurringExpenses>(loadRecurringExpenses),
    TypedMiddleware<AppState, LoadRecurringExpense>(loadRecurringExpense),
    TypedMiddleware<AppState, SaveRecurringExpenseRequest>(
        saveRecurringExpense),
    TypedMiddleware<AppState, ArchiveRecurringExpensesRequest>(
        archiveRecurringExpense),
    TypedMiddleware<AppState, DeleteRecurringExpensesRequest>(
        deleteRecurringExpense),
    TypedMiddleware<AppState, RestoreRecurringExpensesRequest>(
        restoreRecurringExpense),
    TypedMiddleware<AppState, StartRecurringExpensesRequest>(
        startRecurringExpense),
    TypedMiddleware<AppState, StopRecurringExpensesRequest>(
        stopRecurringExpense),
    TypedMiddleware<AppState, SaveRecurringExpenseDocumentRequest>(
        saveDocument),
  ];
}

Middleware<AppState> _editRecurringExpense() {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as EditRecurringExpense?;

    next(action);

    store.dispatch(UpdateCurrentRoute(RecurringExpenseEditScreen.route));

    if (store.state.prefState.isMobile) {
      navigatorKey.currentState!.pushNamed(RecurringExpenseEditScreen.route);
    }
  };
}

Middleware<AppState> _viewRecurringExpense() {
  return (Store<AppState> store, dynamic dynamicAction,
      NextDispatcher next) async {
    final action = dynamicAction as ViewRecurringExpense?;

    next(action);

    store.dispatch(UpdateCurrentRoute(RecurringExpenseViewScreen.route));

    if (store.state.prefState.isMobile) {
      navigatorKey.currentState!.pushNamed(RecurringExpenseViewScreen.route);
    }
  };
}

Middleware<AppState> _viewRecurringExpenseList() {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as ViewRecurringExpenseList?;

    next(action);

    if (store.state.staticState.isStale) {
      store.dispatch(RefreshData());
    }

    store.dispatch(UpdateCurrentRoute(RecurringExpenseScreen.route));

    if (store.state.prefState.isMobile) {
      navigatorKey.currentState!.pushNamedAndRemoveUntil(
          RecurringExpenseScreen.route, (Route<dynamic> route) => false);
    }
  };
}

Middleware<AppState> _archiveRecurringExpense(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as ArchiveRecurringExpensesRequest;
    final prevRecurringExpenses = action.recurringExpenseIds
        .map((id) => store.state.recurringExpenseState.map[id])
        .toList();
    repository
        .bulkAction(store.state.credentials, action.recurringExpenseIds,
            EntityAction.archive)
        .then((List<ExpenseEntity> recurringExpenses) {
      store.dispatch(ArchiveRecurringExpensesSuccess(recurringExpenses));
      action.completer.complete(null);
    }).catchError((Object error) {
      print(error);
      store.dispatch(ArchiveRecurringExpensesFailure(prevRecurringExpenses));
      action.completer.completeError(error);
    });

    next(action);
  };
}

Middleware<AppState> _deleteRecurringExpense(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as DeleteRecurringExpensesRequest;
    final prevRecurringExpenses = action.recurringExpenseIds
        .map((id) => store.state.recurringExpenseState.map[id])
        .toList();
    repository
        .bulkAction(store.state.credentials, action.recurringExpenseIds,
            EntityAction.delete)
        .then((List<ExpenseEntity> recurringExpenses) {
      store.dispatch(DeleteRecurringExpensesSuccess(recurringExpenses));
      action.completer.complete(null);
    }).catchError((Object error) {
      print(error);
      store.dispatch(DeleteRecurringExpensesFailure(prevRecurringExpenses));
      action.completer.completeError(error);
    });

    next(action);
  };
}

Middleware<AppState> _restoreRecurringExpense(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as RestoreRecurringExpensesRequest;
    final prevRecurringExpenses = action.recurringExpenseIds
        .map((id) => store.state.recurringExpenseState.map[id])
        .toList();
    repository
        .bulkAction(store.state.credentials, action.recurringExpenseIds,
            EntityAction.restore)
        .then((List<ExpenseEntity> recurringExpenses) {
      store.dispatch(RestoreRecurringExpensesSuccess(recurringExpenses));
      action.completer.complete(null);
    }).catchError((Object error) {
      print(error);
      store.dispatch(RestoreRecurringExpensesFailure(prevRecurringExpenses));
      action.completer.completeError(error);
    });

    next(action);
  };
}

Middleware<AppState> _saveRecurringExpense(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as SaveRecurringExpenseRequest;
    repository
        .saveData(store.state.credentials, action.recurringExpense!,
            action: action.action)
        .then((ExpenseEntity recurringExpense) {
      if (action.recurringExpense!.isNew) {
        store.dispatch(AddRecurringExpenseSuccess(recurringExpense));
      } else {
        store.dispatch(SaveRecurringExpenseSuccess(recurringExpense));
      }

      action.completer!.complete(recurringExpense);
    }).catchError((Object error) {
      print(error);
      store.dispatch(SaveRecurringExpenseFailure(error));
      action.completer!.completeError(error);
    });

    next(action);
  };
}

Middleware<AppState> _loadRecurringExpense(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as LoadRecurringExpense;
    final AppState state = store.state;

    store.dispatch(LoadRecurringExpenseRequest());
    repository
        .loadItem(state.credentials, action.recurringExpenseId)
        .then((recurringExpense) {
      store.dispatch(LoadRecurringExpenseSuccess(recurringExpense));

      if (action.completer != null) {
        action.completer!.complete(null);
      }
    }).catchError((Object error) {
      print(error);
      store.dispatch(LoadRecurringExpenseFailure(error));
      if (action.completer != null) {
        action.completer!.completeError(error);
      }
    });

    next(action);
  };
}

Middleware<AppState> _loadRecurringExpenses(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as LoadRecurringExpenses?;
    final AppState state = store.state;

    store.dispatch(LoadRecurringExpensesRequest());
    repository.loadList(state.credentials).then((data) {
      store.dispatch(LoadRecurringExpensesSuccess(data));

      final documents = <DocumentEntity>[];
      data.forEach((expense) {
        expense.documents.forEach((document) {
          documents.add(document.rebuild((b) => b
            ..parentId = expense.id
            ..parentType = EntityType.recurringExpense));
        });
      });
      store.dispatch(LoadDocumentsSuccess(documents));

      if (action!.completer != null) {
        action.completer!.complete(null);
      }

      store.dispatch(LoadTransactions());
    }).catchError((Object error) {
      print(error);
      store.dispatch(LoadRecurringExpensesFailure(error));
      if (action!.completer != null) {
        action.completer!.completeError(error);
      }
    });

    next(action);
  };
}

Middleware<AppState> _startRecurringExpense(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as StartRecurringExpensesRequest;
    repository
        .bulkAction(
            store.state.credentials, action.expenseIds!, EntityAction.start)
        .then((List<ExpenseEntity> expenses) {
      store.dispatch(StartRecurringExpensesSuccess(expenses));
      if (action.completer != null) {
        action.completer!.complete(null);
      }
    }).catchError((Object error) {
      print(error);
      store.dispatch(StartRecurringExpensesFailure(error));
      if (action.completer != null) {
        action.completer!.completeError(error);
      }
    });

    next(action);
  };
}

Middleware<AppState> _stopRecurringExpense(
    RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as StopRecurringExpensesRequest;
    repository
        .bulkAction(
            store.state.credentials, action.expenseIds!, EntityAction.stop)
        .then((List<ExpenseEntity> expenses) {
      store.dispatch(StopRecurringExpensesSuccess(expenses));
      if (action.completer != null) {
        action.completer!.complete(null);
      }
    }).catchError((Object error) {
      print(error);
      store.dispatch(StopRecurringExpensesFailure(error));
      if (action.completer != null) {
        action.completer!.completeError(error);
      }
    });

    next(action);
  };
}

Middleware<AppState> _saveDocument(RecurringExpenseRepository repository) {
  return (Store<AppState> store, dynamic dynamicAction, NextDispatcher next) {
    final action = dynamicAction as SaveRecurringExpenseDocumentRequest?;
    if (store.state.isEnterprisePlan) {
      repository
          .uploadDocument(
        store.state.credentials,
        action!.expense,
        action.multipartFile,
        action.isPrivate,
      )
          .then((expense) {
        store.dispatch(SaveRecurringExpenseSuccess(expense));

        final documents = <DocumentEntity>[];
        expense.documents.forEach((document) {
          documents.add(document.rebuild((b) => b
            ..parentId = expense.id
            ..parentType = EntityType.recurringExpense));
        });
        store.dispatch(LoadDocumentsSuccess(documents));

        action.completer.complete(null);
      }).catchError((Object error) {
        print(error);
        store.dispatch(SaveRecurringExpenseDocumentFailure(error));
        action.completer.completeError(error);
      });
    } else {
      const error = 'Uploading documents requires an enterprise plan';
      store.dispatch(SaveRecurringExpenseDocumentFailure(error));
      action!.completer.completeError(error);
    }

    next(action);
  };
}