Function processMessage

src/getTicks.cpp:94–126

};

void processMessage(bbg::Message &msg, Ticks &ticks, const bool verbose) {
    bbg::Element data = msg.getElement(TICK_DATA).getElement(TICK_DATA);
    int numItems = data.numValues();
    if (verbose) {
        Rcpp::Rcout <<"Response contains " << numItems << " items" << std::endl;
        Rcpp::Rcout <<"Time\t\tType\t\tValue\t\tSize\t\tCondition Code" << std::endl;
    }
    for (int i = 0; i < numItems; ++i) {
        bbg::Element item = data.getValueAsElement(i);
        bbg::Datetime time = item.getElementAsDatetime(TIME);
        std::string type = item.getElementAsString(TYPE);
        double value = item.getElementAsFloat64(VALUE);
        int size = item.getElementAsInt32(TICK_SIZE);
        std::string conditionCode;
        conditionCode = (item.hasElement(COND_CODE)) ? item.getElementAsString(COND_CODE) : "";
        if (verbose) {
            Rcpp::Rcout.setf(std::ios::fixed, std::ios::floatfield);
            Rcpp::Rcout << time.month() << '/' << time.day() << '/' << time.year()
                        << " " << time.hours() << ":" << time.minutes()
                        <<  "\t\t" << std::showpoint
                        << type << "\t\t"
                        << value << "\t\t"
                        << size << "\t\t"
                        << conditionCode
                        << std::endl;
        }
        ticks.time.push_back(bbgDatetimeToUTC(time));
        ticks.type.push_back(type);    
        ticks.value.push_back(value);
        ticks.size.push_back(size);
        ticks.conditionCode.push_back(conditionCode);
    }
}

void processResponseEvent(bbg::Event &event, Ticks &ticks, const bool verbose) {
    bbg::MessageIterator msgIter(event);