/*******************************************************************************
 * E.S.O. - ACS project
 *
 *
 * who       when        what
 * --------  ----------  ----------------------------------------------
 */


#include <acsutilPorts.h>
#include <logging.h>
#include <acsdaemonC.h>
#include <ACSErrTypeCommon.h>
#include <acsdaemonErrType.h>
#include <getopt.h>
#include <acsutilTempFile.h>

static struct option long_options[] = {
        {"help",        no_argument,       0, 'h'},
	{"instance",    required_argument, 0, 'i'},
        {"host",        required_argument, 0, 'H'},
        {"daemon",      required_argument, 0, 'd'},
        {0, 0, 0, '\0'}};

void 
usage(const char *argv)
{
    ACE_OS::printf ("\n\tusage: %s {-h} -i INSTANCE [-d DAEMONREF] [-H HOST]", argv);
    ACE_OS::printf ("\t   -h, --help         show this help message\n");
    ACE_OS::printf ("\t   -i, --instance     ACS instance to get status of\n");
    ACE_OS::printf ("\t   -H, --host         Host where to get status of ACS\n");
    ACE_OS::printf ("\t   -d, --daemon       Daemon reference\n");
}


int
main (int argc, char *argv[])
{
    int c, instance = -1;
    ACE_CString daemonRef;
    ACE_CString hostName;
    for(;;)
        {
        int option_index = 0;
        c = getopt_long (argc, argv, "hi:d:H:a",
                         long_options, &option_index); 
        if (c==-1) break;
        switch(c)
            {
                case 'h':
                    usage(argv[0]);
                    return 0;
	        case 'i':
                    instance = ACE_OS::atoi(optarg);
                    break;
	        case 'd':
                    daemonRef = optarg;
                    break;
                case 'H':
                    hostName = optarg;
                    break;
            }
        }
    if (instance == -1)
        {
        ACE_OS::printf("Error: instance is a mandatory option try %s -h\n", argv[0]);
        return -1;
        } 

	#define DEFAULT_LOG_FILE_NAME "acs_local_log"
	ACE_CString daemonsLogFileName = getTempFileName(0, DEFAULT_LOG_FILE_NAME);

	// replace "ACS_INSTANCE.x" with "acsdaemonStatusAcs_" + <timestamp>
	ACE_CString daemonsDir = "acsdaemonStatusAcs_" + getStringifiedTimeStamp();

	ACE_CString instancePart("ACS_INSTANCE.");
	ACE_CString::size_type pos = daemonsLogFileName.find(instancePart);
	daemonsLogFileName =
			daemonsLogFileName.substring(0, pos) +
			daemonsDir +
			daemonsLogFileName.substring(pos + instancePart.length() + 1);	// +1 for skipping instance number

	ACE_OS::setenv("ACS_LOG_FILE", daemonsLogFileName.c_str(), 1);

	LoggingProxy * logger = new LoggingProxy(0, 0, 31);
    if (logger)
    {
        LoggingProxy::init(logger);
        LoggingProxy::ProcessName(argv[0]);
        LoggingProxy::ThreadName("main");
    }
    else
        ACS_SHORT_LOG((LM_WARNING, "Failed to initialize logging."));


    try
    {
        // Initialize the ORB.
        CORBA::ORB_var orb = CORBA::ORB_init (argc,argv,"TAO");


        // construct default one
      if (daemonRef.length() == 0)
      {
          if(hostName.length() == 0)
          {
          hostName = ACSPorts::getIP();
          } 
          daemonRef = "corbaloc::";
          daemonRef = daemonRef + hostName + ":" + ACSPorts::getServicesDaemonPort().c_str() + "/" + ::acsdaemon::servicesDaemonServiceName;
          ACS_SHORT_LOG((LM_INFO, "Using local ACS Services Daemon reference: '%s'", daemonRef.c_str()));
      }
      else
          {
          ACS_SHORT_LOG((LM_INFO, "ACS Services Daemon reference obtained via command line: '%s'", daemonRef.c_str()));
          }

        CORBA::Object_var obj = orb->string_to_object(daemonRef.c_str());
        if (CORBA::is_nil(obj.in()))
        {
            ACS_SHORT_LOG((LM_ERROR, "Failed to resolve reference '%s'.", daemonRef.c_str()));
            return -1;
        }

        acsdaemon::ServicesDaemon_var daemon = acsdaemon::ServicesDaemon::_narrow(obj.in());
        if (CORBA::is_nil(daemon.in()))
        {
            ACS_SHORT_LOG((LM_ERROR, "Failed to narrow reference '%s'.", daemonRef.c_str()));
            return -1;
        }


	ACS_SHORT_LOG((LM_INFO, "Calling status_acs(%d).", instance));

	char *acsStatus = daemon->status_acs(instance);

	ACS_SHORT_LOG((LM_INFO, "Retreived ACS status: \n%s", acsStatus));
	CORBA::string_free(acsStatus);

    }
    catch (acsdaemonErrType::FailedToGetAcsStatusEx &ex)
    {
        acsdaemonErrType::FailedToGetAcsStatusExImpl exImpl(ex);
        exImpl.log();
        return -1;
    }
    catch( CORBA::Exception &ex )
    {

        ACS_SHORT_LOG((LM_INFO, "Failed."));
        ex._tao_print_exception("Caught unexpected exception:");
        return -1;
    }

    return 0;
}