/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

/* 
 * File:   SpectrumProcess.cpp
 * Author: hacene
 * 
 * Created on December 31, 2020, 3:42 PM
 */


#include <stdlib.h>
#include <string>

#include <boost/lexical_cast.hpp>

#include "DicError.hh"
#include "AMDA_exception.hh"

#include "Operation.hh"
#include "ParameterManager.hh"
#include "ParamMgr.hh"
#include "ParameterCreatorFromExpression.hh"

#include "SpectrumProcess.hh"


using namespace std;
using namespace boost;
using namespace log4cxx;

namespace AMDA {
    namespace Parameters {

        SpectrumProcess::SpectrumProcess(Parameter &parameter) : SingleParamProcess_CRTP(parameter) {

            _type = SpectrumCreator::SpectrumType::FOURIER;
        }

        SpectrumProcess::SpectrumProcess(const SpectrumProcess& pProcess, Parameter &parameter) : SingleParamProcess_CRTP(pProcess, parameter) {
            _type = SpectrumCreator::SpectrumType::FOURIER;
        }

        SpectrumProcess::~SpectrumProcess() {
        }

        TimeStamp SpectrumProcess::init() {


            if (_attributList.size() < 1) {
                BOOST_THROW_EXCEPTION(AMDA::AMDA_exception() << AMDA::errno_code(AMDA_PROCESS_ERR) << AMDA::ex_msg(std::string("ProcessSpectrum::parse require 1 attribute'")));
            }
            _windowtime = atof(_attributList[0].c_str());

            _sampling = "center";
            if (_attributList.size() > 1)
                _sampling = _attributList[1];

            /*****/


            TimeStamp time = _parameterInput->init(this, _timeIntervalList);

            _paramInput = _parameterInput->getParamData(this).get();

            if (false) {
                
                ParameterSPtr sampledParamInput = _parameterInput->getParameterManager().getSampledParameter(_parameterInput->getId(), "classic", _parameterInput->getGapThreshold(), false);
                
                sampledParamInput->openConnection(this);
                
                time = sampledParamInput->init(this, _timeIntervalList);
                
                ParamData* sampledParamData = sampledParamInput->getParamData(this).get();
                
                SpectrumCreator lCreator(*this, _timeIntervalList, *sampledParamData, _type, _windowtime, _sampling);
                _operation = lCreator.getOperation();
            } else {

                SpectrumCreator lCreator(*this, _timeIntervalList, *_paramInput, _type, _windowtime, _sampling);
                _operation = lCreator.getOperation();
            }

            _paramData = ParamDataSPtr(_operation->getParamOutput());

            // work arround this 
            _paramData->setMinSampling(_paramInput->getMinSampling());


            return time;
        }

    }
}