/*
* This file is part of rasdaman community.
*
* Rasdaman community 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.
*
* Rasdaman community 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 rasdaman community.  If not, see <http://www.gnu.org/licenses/>.
*
* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann /
rasdaman GmbH.
*
* For more information please see <http://www.rasdaman.org>
* or contact Peter Baumann via <baumann@rasdaman.com>.
*/
/*************************************************************
 *
 *
 * PURPOSE:
 *
 *
 * COMMENTS:
 *
 ************************************************************/

using namespace std;

#ifndef RMANVERSION
#error "Please specify RMANVERSION variable!"
#endif

#ifndef COMPDATE
#error "Please specify the COMPDATE variable!"
/*
COMPDATE=`date +"%d.%m.%Y %H:%M:%S"`

and -DCOMPDATE="\"$(COMPDATE)\"" when compiling
*/
#endif


#ifdef EARLY_TEMPLATE
#define __EXECUTABLE__
#ifdef __GNUG__
#include "template_inst.hh"
#endif
#endif

#include <iostream>
#include <netdb.h>
#include <sys/stat.h>
#include <unistd.h>
#include <string>

#include "globals.hh"	// DEFAULT_PORT
#include "raslib/rmdebug.hh"
#include "servercomm/httpserver.hh"
#include "storagemgr/sstoragelayout.hh"
#include <signal.h>

#include "rasserver_config.hh"
#include "rnprotocol/rnpserver.hh"

// from some unknown location the debug-srv.hh guard seems to be defined already, so get rid of it -- PB 2005-jan-10
#undef DEBUG_HH
#define DEBUG_MAIN debug_main
#include "debug-srv.hh"


bool initialization();

extern int           globalOptimizationLevel = 4;
extern unsigned long maxTransferBufferSize = 4000000;
extern char*         dbSchema = 0;
extern int           noTimeOut = 0;

// here the id string for connecting to the RDBMS is stored (used by rel* modules).
// FIXME: bad hack -- PB 2003-oct-12
char globalConnectId[256];
int  globalHTTPPort;
// do we allow for User-Defined Functions? (aka rasql routines)
bool udfEnabled = true;

// drop client after 5 minutes of no alive signal
// can be changed via cmd line parameter
unsigned long clientTimeOut      = CLIENT_TIMEOUT;

// server management every 2 minutes
unsigned long managementInterval = 120;

const char* rasmgrHost = 0;
int         rasmgrPort = DEFAULT_PORT;
const char* serverName  = 0;
int         serverListenPort = 0;

int main ( int argc, char** argv ) 
{
	SET_OUTPUT( true );		// enable debug output, if compiled so
	ENTER( "rasserver.main()" );

	//print startup text (this line will still go into forking rasmgr's log!)
	cout << "Spawned rasserver v" << RMANVERSION / 1000. << " on base DBMS "  << BASEDBSTRING  << " -- generated on " << COMPDATE << "." << endl;

	if(configuration.parseCommandLine(argc, argv) == false)
	{
		RMInit::logOut << "Error: cannot parse command line." << endl;
		LEAVE( "rasserver.main(): Error parsing command line." );
		return -1;
	}

	RMInit::logOut << "rasserver: rasdaman server v" << RMANVERSION / 1000. << " on base DBMS "  << BASEDBSTRING  << " -- generated on " << COMPDATE << "." << endl;
          std::cout << " Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann rasdaman GmbH." << std::endl
          << "Rasdaman community 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. \n"
             "Rasdaman community 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. \n\n";

	RMInit::logOut << "This program contains software which is in the public domain:" << endl;
	RMInit::logOut << "  zlib 1.1.4 (C) 1995-1998 Jean-loup Gailly and Mark Adler" << endl;
	RMInit::logOut << "  libpng 1.2.1 (C) 2002 Glenn Randers-Pehrson" << endl;
	RMInit::logOut << "  libtiff 3.8.0 (C) 1988-1997 Sam Leffler, (C) 1991-1997 Silicon Graphics, Inc." << endl;
	RMInit::logOut << "  libjpeg 6b (C) 1991-1998, Thomas G. Lane." << endl;
	RMInit::logOut << "  openssl 0.96c (C) 1998-2002 The OpenSSL Project, (C) 1995-1998 Eric A. Young, Tim J. Hudson" << endl;

	if(initialization() == false )
	{
		RMInit::logOut << "Error during initialization. aborted." << endl;
		LEAVE( "rasserver.main(): Error during initialization." );
		return -1;
	}

	//
	// body rasserver
	//
  
	RMInit::logOut << "Installing signal handler for ignoring broken pipe signal..." << flush;
	signal( SIGPIPE, SIG_IGN );
	RMInit::logOut << "ok" << endl;

	int returnCode = 0;
	ServerComm* server = NULL;
  
	try   
	{
		TALK( "selecting server type..." );

		if(configuration.isRnpServer())
		{
			TALK( "startRnpServer()..." );
			startRnpServer();
			TALK( "startRnpServer() done." );
		}
		else if(configuration.isHttpServer())
		{
			TALK( "initializing HttpServer()..." );
			server = new HttpServer( clientTimeOut, managementInterval, serverListenPort, (char*)rasmgrHost, rasmgrPort,(char*)serverName);
		}
		else
		{
			TALK( "initializing ServerComm() (ie: RPC)..." );
			server = new ServerComm( clientTimeOut, managementInterval, serverListenPort, (char*)rasmgrHost, rasmgrPort,(char*)serverName);
		}

		// in case of HTTP or RPC server: launch previously generated object 
		if(server)
		{
			TALK( "server->startRpcServer()..." );
			server->startRpcServer();
			TALK( "server->startRpcServer() done." );
		}
     	}
  	catch ( r_Error& errorObj ) 
	{
		TALK( "Error: encountered " << errorObj.get_errorno() << ": " << errorObj.what() );
		RMInit::logOut << "Error: encountered " << errorObj.get_errorno() << ": " << errorObj.what() << endl;
// we never write to stdout (= rasmgr log file), so we don't need this -- PB 2003-nov-24
#if 0
		if(!configuration.isLogToStdOut())
		{
			RMInit::logOut << "Error: encountered " << errorObj.get_errorno() << ": " << errorObj.what() << endl;    
		}
#endif // 0
		returnCode = -1;
	}
	catch(...) 
	{
		TALK( "rasserver: general exception" );
		RMInit::logOut << "rasserver: general exception" << endl;
// we never write to stdout (= rasmgr log file), so we don't need this -- PB 2003-nov-24
#if 0
		if(!configuration.isLogToStdOut()) 
		{
			RMInit::logOut << "rasserver: general exception" << endl;    
		}
#endif
		returnCode = -1;
	}

	if(server)
		delete server;
	server = NULL;   

	if( dbSchema )
		free( dbSchema );
	dbSchema = NULL;

	LEAVE( "rasserver.main(): -> " << returnCode );
	return returnCode;
}

bool initialization()
{
	serverName = configuration.getServerName();
	accessControl.setServerName(serverName);
  
	serverListenPort = globalHTTPPort = configuration.getListenPort();

	RMInit::logOut<<"Server "<< serverName << " of type ";
	
	if(configuration.isRnpServer())
		RMInit::logOut << "RNP, listening on port " << serverListenPort << flush;
	else if(configuration.isHttpServer())
		RMInit::logOut << "HTTP, listening on port " << serverListenPort << flush;
	else
		RMInit::logOut << "RPC, registered with prognum 0x" << hex <<serverListenPort << dec << flush;

	//  globalConnectId         = configuration.getDbConnectionID();
	strcpy(globalConnectId,configuration.getDbConnectionID());
	RMInit::logOut << ", connecting to " << BASEDBSTRING << " as '" << globalConnectId <<  "'." << endl;

// we never write to stdout (= rasmgr log file), so we don't need this -- PB 2003-nov-24
#if 0
	if(!configuration.isLogToStdOut()) 
	{
		RMInit::logOut<<"Server "<< serverName << " of type ";
		if(configuration.isRnpServer())
			RMInit::logOut << "RNP, listening on port " << serverListenPort << endl;
		else if(configuration.isHttpServer())
			RMInit::logOut << "HTTP, listening on port " << serverListenPort << endl;
		else 
			RMInit::logOut << "RPC, registered with prognum 0x" << hex <<serverListenPort << dec << endl;
	}
#endif // 0

	rasmgrHost = configuration.getRasmgrHost();
	rasmgrPort = configuration.getRasmgrPort();
  
	RMInit::logOut << "Verifying rasmgr host name: " << rasmgrHost << "...";  
// we don't write to stdout (=rasmgr log), so no need to duplicate -- PB 2003-nov-24
#if 0
	if(!configuration.isLogToStdOut())
		RMInit::logOut << "Verifying RasMGR host name: " << rasmgrHost << "...";  
#endif // 0
	if(!gethostbyname(rasmgrHost)) 
	{
		RMInit::logOut << "failed" << endl;
		if(!configuration.isLogToStdOut())  RMInit::logOut << "failed" << endl;
		return false;
	}
	RMInit::logOut << "ok" << endl;   
// we don't write to stdout (=rasmgr log), so no need to duplicate -- PB 2003-nov-24
#if 0
	if(!configuration.isLogToStdOut())
		RMInit::logOut << " ok" << endl;   
#endif // 0
	
	globalOptimizationLevel = configuration.getDefaultOptimizationLevel();
  
	maxTransferBufferSize = configuration.getMaxTransferBufferSize();
	
	clientTimeOut = configuration.getTimeout();
	if(clientTimeOut == 0)
		noTimeOut = 1;

	managementInterval = clientTimeOut/4;

	//tilesize
	StorageLayout::DefaultTileSize = configuration.getDefaultTileSize();
	RMInit::logOut << "Tile size set to : " << StorageLayout::DefaultTileSize << endl;
	
	//pctmin
	StorageLayout::DefaultMinimalTileSize = configuration.getDefaultPCTMin();
	RMInit::logOut << "PCTMin set to     : " << StorageLayout::DefaultMinimalTileSize << endl;

	//pctmax
	StorageLayout::DefaultPCTMax = configuration.getDefaultPCTMax();
	RMInit::logOut << "PCTMax set to     : " << StorageLayout::DefaultPCTMax << endl;
	
	//indexsize
	StorageLayout::DefaultIndexSize = configuration.getDefaultIndexSize();
	RMInit::logOut << "IndexSize set to : " << StorageLayout::DefaultIndexSize << endl;

#ifdef RMANDEBUG
	RManDebug = configuration.getDebugLevel();
	RMInit::logOut<<"Debug level: " << RManDebug << endl;                 
#endif
	
	try
	{
		StorageLayout::DefaultTileConfiguration = r_Minterval(configuration.getDefaultTileConfig());
	}
	catch(r_Error& err)
	{
		RMInit::logOut << "Error converting " << configuration.getDefaultTileConfig() << " to r_Minterval" << endl;
		RMInit::logOut << "Error " << err.get_errorno() << " : " << err.what() << endl;
		if(!configuration.isLogToStdOut()) 
		{
			RMInit::logOut << "Error converting " << configuration.getDefaultTileConfig() << " to r_Minterval" << endl;
			RMInit::logOut << "Error " << err.get_errorno() << " : " << err.what() << endl;    
		}
		return false;
	}
	RMInit::logOut << "Default Tile Conf: " << StorageLayout::DefaultTileConfiguration << endl;

	// Tiling
	r_Tiling_Scheme tmpTS=get_tiling_scheme_from_name(configuration.getTilingScheme());
	
	if(tmpTS != r_Tiling_Scheme_NUMBER)
		StorageLayout::DefaultTilingScheme = tmpTS;
	
	if((tmpTS != r_NoTiling) && (tmpTS != r_RegularTiling)) 
	{
		RMInit::logOut << "Error: unsupported tiling strategy: " << configuration.getTilingScheme() << endl;
		if(configuration.isLogToStdOut()) 
		{
			RMInit::logOut << "Error: unsupported tiling strategy: " << configuration.getTilingScheme() << endl;      
		}
		return false;
	}

	//retiling enabled only if tiling scheme is regular tiling
	RMInit::tiling = (tmpTS == r_RegularTiling);
	RMInit::logOut << "Default Tiling   : " << StorageLayout::DefaultTilingScheme << endl;

	// Index
	r_Index_Type tmpIT = get_index_type_from_name(configuration.getIndexType());
	if ( tmpIT != r_Index_Type_NUMBER)
		StorageLayout::DefaultIndexType = tmpIT;
	RMInit::logOut << "Default Index    : " << StorageLayout::DefaultIndexType << endl;

	//use tilecontainer
	RMInit::useTileContainer = configuration.useTileContainer();
	RMInit::logOut << "Use Tile Container: " << RMInit::useTileContainer << endl;

	return true;
}