AnalysisFilter.h

Go to the documentation of this file.

 
#pragma once
 
#include <functional>
#include <memory>
#include <string>
#include <utility>
#include <vector>
 
#include "core/domain/catalog/WorkspaceCatalog.h"
#include "core/domain/entities/Transaction.h"
 
namespace core::application::analysis {

class AnalysisFilter {
public:
  using Pred =
      std::function<bool(const std::shared_ptr<core::domain::Transaction> &,
                         const core::domain::catalog::WorkspaceCatalog &)>;

  void addPredicate(Pred p) { preds_.push_back(std::move(p)); }

  bool matches(const std::shared_ptr<core::domain::Transaction> &t,
               const core::domain::catalog::WorkspaceCatalog &state) const {
    for (const auto &p : preds_)
      if (!p(t, state))
        return false;
    return true;
  }

  bool empty() const { return preds_.empty(); }
 
private:
  std::vector<Pred> preds_;
};

AnalysisFilter parseAnalysisFilterSpec(const std::string &spec);

std::vector<std::shared_ptr<core::domain::Transaction>>
collectAnalysisTransactions(
    const core::domain::catalog::WorkspaceCatalog &state,
    const AnalysisFilter &filter);
 
} // namespace core::application::analysis