#include "../shared/ThreadMonitor.h"
#include "../shared/LogFile.h"
#include "../shared/TclUtil.h"
#include "../shared/CurrentRequest.h"

#include "TclLogWrapper.h"

static int logAddCmd(ClientData clientData,
		     Tcl_Interp *interp,
		     int objc,
		     Tcl_Obj *const objv[])
{
  if (objc < 2)
  {
    Tcl_WrongNumArgs(interp, 1, objv, "item ?item ...?");
    return TCL_ERROR;
  }
  TclList msg;
  msg<<FLF;
  for (int i = 1; i < objc; i++)
    msg<<getString(objv[i]);
  LogFile::primary().sendString(msg, CurrentRequest::getSocketInfo());
  return TCL_OK;
}

static int logIncrCmd(ClientData clientData,
		      Tcl_Interp *interp,
		      int objc,
		      Tcl_Obj *const objv[])
{
  if ((objc < 2) || (objc > 3))
  {
    Tcl_WrongNumArgs(interp, 1, objv, "counter ?increment?");
    return TCL_ERROR;
  }
  int increment = 1;
  if (objc >= 3)
    if (Tcl_GetIntFromObj(interp, objv[2], &increment) != TCL_OK)
      return TCL_ERROR;
  ThreadMonitor::find().increment(getString(objv[1]), increment);
  return TCL_OK;
}

void installLogCommands(Tcl_Interp *interp)
{
  Tcl_CreateObjCommand(interp, "ti::log_add", logAddCmd, NULL, NULL);
  Tcl_CreateObjCommand(interp, "ti::log_incr", logIncrCmd, NULL, NULL);
}