#include "../shared/ContainerThread.h"
#include "../shared/GlobalConfigFile.h"
#include "WireFormats.h"
#include "ProxyThread.h"

#include "SendTimeAsTos.h"

class SendTimeAsTos : public ForeverThreadUser
{
private:
  static const int PERIOD_IN_SECONDS = 60;
  static const int INITIAL_PAUSE = 30;
  const std::string _source;
  time_t _nextWakeTime;

  virtual void beforeSleep(IBeforeSleepCallbacks &callbacks)
  {
    const int64_t now = getMicroTime();
    const time_t now_seconds = now / 1000000;
    //std::cout<<"SendTimeAsTos::beforeSleep() now = "<<cMicroTimeString(now)
    //	     <<", _nextWakeTime = "<<ctimeString(_nextWakeTime)<<std::endl;
    if (now_seconds >= _nextWakeTime)
    {
      _nextWakeTime = now_seconds + PERIOD_IN_SECONDS;
      TosData data;
      data.clear();
      data.time = now_seconds;
      data.volume = now;
      static int64_t oneUpCounter = 0;
      oneUpCounter++;
      data.size = oneUpCounter;
      data.exchange = _source;
      const std::string cached = marshal(data);
      data.newPrint = true;
      const std::string streaming = marshal(data);
      ProxyThread::addData(DataTypes::TOS, "$TIME", streaming, cached);     
    }
    callbacks.wakeAtTime(_nextWakeTime);
  }
  
public:
  SendTimeAsTos(std::string const &source) :
    _source(source), _nextWakeTime(time(NULL)+INITIAL_PAUSE) { start(); }
};

void initSendTimeAsTos()
{
  std::string source = getConfigItem("send_time_as_tos_source");
  if (source == "✗")
    // Allow someone to disable this feature at run time.  I'm not sure if
    // that would be useful here.  In tikiller and fast_alert_server  we reuse
    // executables so many ways, I'm used to adding a switch like this to
    // everything.
    //
    // Notice the fancy unicode crossmark.  I chose that in part because I
    // couldn't imagine any conflicts, anyone using this string for any
    // other reason.  Also, we're testing a new project.  Let's see if the
    // unicode character breaks anyone's favorite tools!
    return;
  if (source == "")
    // You can name this anything you want.  By default we pick something
    // unique.  This string, or something based on it, is likely to be used
    // in the monitor_alive table.
    source = getShortHostName() + ':' + getConfigItem("listen_port");
  // Only create one of these.  That's pretty standard for our init routines.
  new SendTimeAsTos(source);
}