ObserverPipeline.cpp

Go to the documentation of this file.

// SPDX-License-Identifier: Apache-2.0
// Copyright 2022 Stéphane Caron
 
#include "vulp/observation/ObserverPipeline.h"
 
#include <palimpsest/exceptions/KeyError.h>
 
#include "vulp/exceptions/ObserverError.h"
 
namespace vulp::observation {
 
using palimpsest::exceptions::KeyError;
using vulp::exceptions::ObserverError;
 
void ObserverPipeline::reset(const Dictionary& config) {
  for (auto observer : observers_) {
    observer->reset(config);
  }
}
 
void ObserverPipeline::run(Dictionary& observation) {
  for (auto source : sources_) {
    source->write(observation);
  }
  for (auto observer : observers_) {
    try {
      observer->read(observation);
      observer->write(observation);
    } catch (const KeyError& e) {
      throw ObserverError(observer->prefix(), e.key());
    } catch (const std::exception& e) {
      spdlog::error("[ObserverPipeline] Observer {} threw an exception: {}",
                    observer->prefix(), e.what());
      throw;
    }
  }
}
 
}  // namespace vulp::observation