msgFacility_metric.cc

// msgFacility_metric.cc: Message Facility Metric Plugin
// Author: Eric Flumerfelt
// Last Modified: 09/29/2015
//
// An implementation of the MetricPlugin for Message Facility

#include "artdaq-utilities/Plugins/MetricMacros.hh"
#include "fhiclcpp/ParameterSet.h"
#include "messagefacility/MessageLogger/MessageLogger.h"

#include <iostream>
#include <string>
#include <algorithm>

namespace artdaq
{
    class MsgFacilityMetric : public MetricPlugin
    {
    private:
        std::string facility_;
        int outputLevel_;
    public:
        explicit MsgFacilityMetric(fhicl::ParameterSet const& config, std::string const& app_name)
            : MetricPlugin(config, app_name)
            , facility_(config.get<std::string>("output_message_category_name", "ARTDAQ Metric"))
            , outputLevel_(0)
        {
            try
            {
                outputLevel_ = config.get<int>("output_message_severity", 0);
            }
            catch (cet::exception)
            {
                std::string levelString = config.get<std::string>("output_message_severity", "Info");
                if (levelString == "Info" || levelString == "info" || levelString == "LogInfo")
                {
                    outputLevel_ = 0;
                }
                else if (levelString == "Debug" || levelString == "debug" || levelString == "LogDebug")
                {
                    outputLevel_ = 1;
                }
                else if (levelString == "Warning" || levelString == "warning" || levelString == "LogWarning" || levelString == "Warn" || levelString == "warn")
                {
                    outputLevel_ = 2;
                }
                else if (levelString == "Error" || levelString == "error" || levelString == "LogError")
                {
                    outputLevel_ = 3;
                }
            }
            startMetrics();
        }

        virtual ~MsgFacilityMetric() { stopMetrics(); }
        std::string getLibName() const override { return "msgFacility"; }

        void sendMetric_(const std::string& name, const std::string& value, const std::string& unit) override
        {
            if (!inhibit_)
            {
                switch (outputLevel_)
                {
                case 0:
                    mf::LogInfo(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
                case 1:
                    mf::LogDebug(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
                case 2:
                    mf::LogWarning(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
                case 3:
                    mf::LogError(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
                }
            }
        }

        void sendMetric_(const std::string& name, const int& value, const std::string& unit) override
        {
            sendMetric_(name, std::to_string(value), unit);
        }

        void sendMetric_(const std::string& name, const double& value, const std::string& unit) override
        {
            sendMetric_(name, std::to_string(value), unit);
        }

        void sendMetric_(const std::string& name, const float& value, const std::string& unit) override
        {
            sendMetric_(name, std::to_string(value), unit);
        }

        void sendMetric_(const std::string& name, const unsigned long int& value, const std::string& unit) override
        {
            sendMetric_(name, std::to_string(value), unit);
        }

        void startMetrics_() override {}
        void stopMetrics_() override {}
    };
} //End namespace artdaq

DEFINE_ARTDAQ_METRIC(artdaq::MsgFacilityMetric)