feat: add event builder filter algorithm

meson.build

@@ -20,6 +20,6 @@ fmt_dep  = dependency('fmt')
 hipo_dep = dependency('hipo4', method: 'cmake', cmake_args: '-DCMAKE_PREFIX_PATH=' + get_option('hipo'))
 
 subdir('src/services')
-subdir('src/algorithms/clas12/fiducial_cuts')
+subdir('src/algorithms')
 subdir('src/iguana')
 subdir('src/tests')

src/algorithms/clas12/event_builder_filter/EventBuilderFilter.cc

@@ -0,0 +1,17 @@
+#include "EventBuilderFilter.h"
+
+namespace iguana::clas12 {
+
+  void EventBuilderFilter::Start() {
+    m_log->Info("start event builder filter");
+  }
+
+  Algorithm::BankMap EventBuilderFilter::Run(Algorithm::BankMap inputBanks) {
+    return inputBanks;
+  }
+
+  void EventBuilderFilter::Stop() {
+    m_log->Info("stop event builder filter");
+  }
+
+}

src/algorithms/clas12/event_builder_filter/EventBuilderFilter.h

@@ -0,0 +1,17 @@
+#pragma once
+
+#include "services/Algorithm.h"
+
+namespace iguana::clas12 {
+
+  class EventBuilderFilter : public Algorithm {
+
+    public:
+      EventBuilderFilter() : Algorithm("event_builder_filter") {}
+      ~EventBuilderFilter() {}
+
+      void Start() override;
+      Algorithm::BankMap Run(Algorithm::BankMap inputBanks) override;
+      void Stop() override;
+  };
+}

src/algorithms/clas12/event_builder_filter/README.md

@@ -0,0 +1,3 @@
+# Event Builder Filter
+
+Filters a particle bank for specific Event Builder PDGs

src/algorithms/clas12/fiducial_cuts/meson.build → src/algorithms/meson.build

@@ -1,9 +1,9 @@
 algo_headers = [
-  'FiducialCuts.h',
+  'clas12/event_builder_filter/EventBuilderFilter.h',
 ]
 
 algo_sources = [
-  'FiducialCuts.cc',
+  'clas12/event_builder_filter/EventBuilderFilter.cc',
 ]
 
 algo_lib = shared_library(

src/iguana/Arbiter.cc

@@ -3,7 +3,7 @@
 namespace iguana {
 
   Arbiter::Arbiter() {
-    algo_map.insert({clas12_FiducialCuts, std::make_shared<clas12::FiducialCuts>()});
+    algo_map.insert({clas12_EventBuilderFilter, std::make_shared<clas12::EventBuilderFilter>()});
   }
 
 }

src/iguana/Arbiter.h

@@ -5,7 +5,7 @@
 #include <memory>
 
 // TODO: avoid listing the algos
-#include "algorithms/clas12/fiducial_cuts/FiducialCuts.h"
+#include "algorithms/clas12/event_builder_filter/EventBuilderFilter.h"
 
 namespace iguana {
 
@@ -18,7 +18,7 @@ namespace iguana {
       // TODO: avoid listing the algos
       // TODO: who should own the algorithm instances: Arbiter or the user?
       enum algo {
-        clas12_FiducialCuts
+        clas12_EventBuilderFilter
       };
 
       // TODO: make private

src/iguana/meson.build

@@ -10,6 +10,7 @@ iguana_lib = shared_library(
   'Iguana',
   iguana_sources,
   include_directories: project_inc,
+  dependencies:        [ fmt_dep, hipo_dep ],
   link_with:           [ algo_lib, services_lib ],
   install:             true,
   install_dir:         project_lib_install_dir,

src/services/Algorithm.h

@@ -1,15 +1,20 @@
 #pragma once
 
 #include "Logger.h"
+#include <hipo4/bank.h>
 
 namespace iguana {
 
   class Algorithm {
 
     public:
+
+      using BankMap = std::unordered_map<std::string, hipo::bank>;
+
       Algorithm(std::string name);
+
       virtual void Start() = 0;
-      virtual int Run(int a, int b) = 0;
+      virtual BankMap Run(BankMap inputBanks) = 0;
       virtual void Stop() = 0;
       virtual ~Algorithm() {}
 

src/services/meson.build

@@ -12,14 +12,14 @@ services_lib = shared_library(
   'IguanaServices',
   services_sources,
   include_directories: project_inc,
-  dependencies:        fmt_dep,
+  dependencies:        [ fmt_dep, hipo_dep ],
   install:             true,
   install_dir:         project_lib_install_dir,
   install_rpath:       project_lib_rpath,
 )
 
 services_dep = declare_dependency(
-  dependencies: fmt_dep
+  dependencies: [ fmt_dep, hipo_dep ]
 )
 
 install_headers(services_headers, subdir : meson.project_name())

src/tests/main.cc

@@ -12,9 +12,25 @@ int main(int argc, char **argv) {
   reader.readDictionary(factory);
   factory.show();
 
+  hipo::bank particleBank(factory.getSchema("REC::Particle"));
+  hipo::event event;
+
   iguana::Arbiter arb;
-  auto algo = arb.algo_map.at(iguana::Arbiter::clas12_FiducialCuts);
+  auto algo = arb.algo_map.at(iguana::Arbiter::clas12_EventBuilderFilter);
   algo->Start();
-  fmt::print("test result: {}\n", algo->Run(3,4));
+
+  int count = 0;
+  while(reader.next()) {
+    if(count > 3) break;
+    reader.read(event);
+    event.getStructure(particleBank);
+
+    auto resultBank = algo->Run({{"REC::Particle", particleBank}});
+
+    fmt::print("BEFORE -> AFTER: {} -> {}\n", particleBank.getRows(), resultBank.at("REC::Particle").getRows());
+
+    count++;
+  }
+
   algo->Stop();
 }