#pragma once
/////////////////////////////////////////////////////////////////////
// Comm.h - message-passing communication facility                 //
//                                                                 //
// Jim Fawcett, CSE687-OnLine Object Oriented Design, Fall 2017    //
/////////////////////////////////////////////////////////////////////

#include "../Message/Message.h"
#include "../Cpp11-BlockingQueue/Cpp11-BlockingQueue.h"
#include "../Sockets/Sockets.h"
#include <string>
#include <thread>

using namespace Sockets;

namespace MsgPassingCommunication
{
  class Receiver
  {
  public:
    Receiver(EndPoint ep);
    template<typename CallableObject>
    void start(CallableObject& co);
    void stop();
    Message getMessage();
    BlockingQueue<Message>& queue();
  private:
    /*static*/ BlockingQueue<Message> rcvQ;
    SocketListener listener;
  };

  //BlockingQueue<Message> Receiver::rcvQ;

  class Sender
  {
  public:
    ~Sender();
    void start();
    void stop();
    bool connect(EndPoint ep);
    void postMessage(Message& msg);
    bool sendFile(const std::string& fileName);
  private:
    BlockingQueue<Message> sndQ;
    SocketConnecter connecter;
    std::thread sendThread;
  };
}