RadioProcess.hpp

/*
 * (c) Copyright 2022 CORSIKA Project, corsika-project@lists.kit.edu
 *
 * This software is distributed under the terms of the GNU General Public
 * Licence version 3 (GPL Version 3). See file LICENSE for a full version of
 * the license.
 */
#pragma once

#include <corsika/output/BaseOutput.hpp>
#include <corsika/output/ParquetStreamer.hpp>
#include <corsika/framework/process/ContinuousProcess.hpp>
#include <corsika/framework/core/Step.hpp>
#include <corsika/setup/SetupStack.hpp>
#include <corsika/setup/SetupTrajectory.hpp>

namespace corsika {

  template <typename TAntennaCollection, typename TRadioImpl, typename TPropagator>
  class RadioProcess : public ContinuousProcess<
                           RadioProcess<TAntennaCollection, TRadioImpl, TPropagator>>,
                       public BaseOutput {

    /*
     * A collection of filter objects for deciding on valid particles and tracks.
     */
    // std::vector<std::function<bool(ParticleType&, TrackType const&)>> filters_;

    TRadioImpl& implementation();

    TRadioImpl const& implementation() const;

  protected:
    TAntennaCollection& antennas_; 
    TPropagator propagator_;       
    unsigned int showerId_{0};     
    ParquetStreamer output_;       

  public:
    using axistype = std::vector<long double>;
    RadioProcess(TAntennaCollection& antennas, TPropagator& propagator);

    template <typename Particle>
    ProcessReturn doContinuous(Step<Particle> const& step, bool const);

    template <typename Particle, typename Track>
    LengthType getMaxStepLength(Particle const& vParticle, Track const& vTrack) const;

    void startOfLibrary(boost::filesystem::path const& directory) final override;

    virtual void endOfShower(unsigned int const) final override;

    void endOfLibrary() final override {}

    YAML::Node getConfig() const final;

  }; // END: class RadioProcess

} // namespace corsika

#include <corsika/detail/modules/radio/RadioProcess.inl>