echo.hpp

// A data feed handler that writes every message to an output stream.
// Copyright 2020 Christian Kauten
//
// Author: Christian Kauten (kautenja@auburn.edu)
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.
//
 
#ifndef DATA_FEED_HANDLERS_ECHO_HPP
#define DATA_FEED_HANDLERS_ECHO_HPP
 
#include "data_feed/receiver.hpp"
#include <ostream>
 
namespace DataFeed {
 
namespace Handlers {
 
class Echo {
 private:
    std::ostream& stream;
 
 public:
    Echo(std::ostream& stream_ = std::cout) : stream(stream_) { }
 
    inline void did_receive(Receiver<Echo>* receiver, const Messages::StartOfSession& message) {
        stream << message << std::endl;
        stream << receiver->get_book() << std::endl;
    }
 
    inline void did_receive(Receiver<Echo>* receiver, const Messages::EndOfSession& message) {
        stream << message << std::endl;
        stream << receiver->get_book() << std::endl;
    }
 
    inline void did_receive(Receiver<Echo>* receiver, const Messages::Clear& message) {
        stream << message << std::endl;
        stream << receiver->get_book() << std::endl;
    }
 
    inline void did_receive(Receiver<Echo>* receiver, const Messages::AddOrder& message) {
        stream << message << std::endl;
        stream << receiver->get_book() << std::endl;
    }
 
    inline void did_receive(Receiver<Echo>* receiver, const Messages::DeleteOrder& message) {
        stream << message << std::endl;
        stream << receiver->get_book() << std::endl;
    }
 
    inline void did_receive(Receiver<Echo>* receiver, const Messages::Trade& message) {
        stream << message << std::endl;
        stream << receiver->get_book() << std::endl;
    }
};
 
}  // namespace Handlers
 
}  // namespace DataFeed
 
#endif  // DATA_FEED_HANDLERS_ECHO_HPP