path: root/Bus/Ivy/Ivy.cxx

// Ivy.cpp: implementation of the Ivy class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"

#include "Ivy.h"

#include "IvyWatcher.h"
#include "IvyApplication.h"
#include "IvySynchroWnd.h"


#define DEFAULT_ADDR "127.255.255.255"
#define SEPARATOR ":"
#define DEFAULT_PORT "2010"
#define DEFAULT_DOMAIN DEFAULT_ADDR/**/SEPARATOR/**/DEFAULT_PORT


//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////


Ivy::~Ivy()
{
	// remove all app and stop watcher
	stop();
	regexp_out.clear();

    
	if ( synchronous )
		{
		for ( unsigned int i = 0; i < callbacks.size(); i ++)
		{
		delete callbacks[i];
		}
		}
	callbacks.clear();

  
//	if ( direct_callback ) delete direct_callback;
//	if ( application_callback ) delete application_callback;

	delete watcher;
//	server->Close();
	delete server;
	if ( synchronous )
		{
		delete IvySynchronousCallback::m_synchro;
		delete application_callback;
		}
}


Ivy::Ivy(const char* name, const char * ready, IvyApplicationCallback *callback, bool Synchronous)
{
	InitializeCriticalSection( &m_application_cs );
	regexp_id = 0;
	synchronous = Synchronous;
	if ( synchronous )
		IvySynchronousCallback::m_synchro = new IvySynchroWnd();
	ready_message = ready;
	appname = name;
	messages_classes_count = 0;
	messages_classes = NULL;
	application_callback = synchronous ? new IvySynchronousApplicationCallback(callback) : callback;
	direct_callback = NULL;
	die_callback = NULL;
	server = new IvyApplication(this);
	applicationPort = server->Create();
	if ( !applicationPort )
		{
		TRACE( " Can't Create server %d\n", server->GetLastError( ) );
		return;
		}
	watcher = new IvyWatcher(this);


}
const char * Ivy::GetDomain(const char *domainlist)
{
	// determine domain to use
	// the syntax of domain is "IpBroadcastAddr1,IpBroadcastAddr2,IpBroadcastAddr2:port" 
	if ( domainlist )
		{
		domain = domainlist;
		}
	if ( domain.empty() )
		{
#ifndef UNDER_CE
		const char *env = getenv ( "IVYBUS" );
		if ( env )
			domain = env;
#endif
		if ( domain.empty() )
			domain = DEFAULT_DOMAIN;
		}
	// first find our UDP port
	int sep_index = domain.rfind( ':' );
	if ( sep_index == -1 )
		{
		domain = DEFAULT_DOMAIN;
		TRACE(" Missing ':' in domain list using default domain %s\n", domain );
		}
	if ( sep_index == 0 )
		{
		/* missing addr using localhost */
		domain.insert(0,DEFAULT_ADDR);
		}
	return domain.c_str();
}
	
void Ivy::start(const char *domain)
{
	watcher->start(domain);
}
void Ivy::stop()
{
	watcher->stop();

	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ; ++iter )
	{
		IvyApplication *app = *iter;
		app->Close();
		delete app;
	}
	applications.clear();
}
int Ivy::BindMsg(const char *regexp, IvyMessageCallback *cb)
{
	regexp_out.push_back(  regexp );
	callbacks.push_back( synchronous ? new IvySynchronousMessageCallback(cb) : cb );

	/* send to already connected */
	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ; ++iter )
	{
		IvyApplication *app = *iter;
		app->SendMsg(IvyApplication::AddRegexp, regexp_id, regexp );
	}
	return regexp_id++;
}
int Ivy::BindMsg( IvyMessageCallback *cb, const char *regexp, ... )
{
	char buffer[4096];
	va_list args;

    va_start( args, regexp );     /* Initialize variable arguments. */
	vsprintf( buffer, regexp, args );
	va_end( args);

	regexp_out.push_back(  regexp );
	callbacks.push_back( synchronous ? new IvySynchronousMessageCallback(cb) : cb );

	/* send to already connected */
	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ; ++iter )
	{
		IvyApplication *app = *iter;
		app->SendMsg(IvyApplication::AddRegexp, regexp_id, buffer );
	}
	return regexp_id++;
}
	
void Ivy::UnbindMsg(int id)
{
	regexp_out[ id ] = "";
	callbacks[ id ] = NULL;
	/* send to already connected */
	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ; ++iter )
	{
		IvyApplication *app = *iter;
		app->SendMsg(IvyApplication::DelRegexp, id, "" );
	}

}

void Ivy::BindDirectMsg(IvyDirectMessageCallback *callback)
{
direct_callback = callback;
}

unsigned int Ivy::GetApplicationPort()
{
	return applicationPort;
}

void Ivy::AddApplication(IvyApplication *app)
{
	EnterCriticalSection( &m_application_cs );
	// Check for disconnected Application
	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ;  )
	{
		IvyApplication *disc_app = *iter++;
		if ( disc_app->m_hSocket == INVALID_SOCKET ) 
			{
			applications.remove( disc_app );
			delete disc_app;
			}
	}
	applications.push_back( app );
	LeaveCriticalSection( &m_application_cs );
	SendSubscriptions( app );
}
void Ivy::RemoveApplication(IvyApplication * app)
{
	/// OLD NOT called because of deallocation PB 
	// the real remove is done at arrival of a new Application 
	// or at the bus Stop
	ASSERT( TRUE );
	if ( app )
	{
	
		EnterCriticalSection( &m_application_cs );
		applications.remove( app );
		LeaveCriticalSection( &m_application_cs );
		delete app;
	}
}

void Ivy::SendSubscriptions(IvyApplication *app)
{
	app->SendMsg( IvyApplication::StartRegexp, GetApplicationPort(), appname.c_str());
	for ( unsigned int id = 0 ; id < regexp_out.size(); id++ )
	{
		const string& regexp = regexp_out[id];
		if ( !regexp.empty() )
			app->SendMsg( IvyApplication::AddRegexp, id, regexp.c_str());
	}
	app->SendMsg( IvyApplication::EndRegexp, 0);

}


int Ivy::SendMsg(const char * message, ... )
{
	int count = 0;
	char buffer[4096];
	va_list args;

    va_start( args, message );     /* Initialize variable arguments. */
	vsprintf( buffer, message, args );
	va_end( args);
	/* send to already connected */
	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ; ++iter )
	{
		IvyApplication *app = *iter;
		count += app->SendMsg( buffer );
	}
	return count;
}
void Ivy::SendDieMsg( IvyApplication *app )
{
	app->SendMsg( IvyApplication::Die, 0 );
}
IvyApplication * Ivy::GetApplication(const char *name)
{
	IvyApplication *app = NULL;
	EnterCriticalSection( &m_application_cs );
	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ;  )
	{
		IvyApplication *ap = *iter++;
		if ( (ap->m_hSocket != INVALID_SOCKET)  && ap->appname == name ) 
			{
			app = ap;
			break; // dont return because of LeaveCriticalSection !!!
			}
	}
	LeaveCriticalSection( &m_application_cs );
	return app;
}
	

void Ivy::CallMessageCallback(IvyApplication *app, int id, int argc, const char ** argv)
{
	IvyMessageCallback *callback;
	callback = callbacks[ id ];
	if ( callback )
		{
		callback->OnMessage(  app, argc, argv );
		}
}

void Ivy::CallDirectMessageCallback(IvyApplication *app, int id,  const char *arg)
{
	if ( direct_callback )
		{
		direct_callback->OnDirectMessage(  app, id, arg  );
		}
}

bool Ivy::CallDieCallback(IvyApplication *app, int id,  const char *arg)
{
	if ( die_callback )
		{
		return die_callback->OnDie(  app, id, arg  );
		}
	return TRUE;
}

void Ivy::CallApplicationConnectedCallback(IvyApplication * app)
{
	if ( application_callback )
		{
		application_callback->OnApplicationConnected( app );
		}
}
void Ivy::CallApplicationDisconnectedCallback(IvyApplication * app)
{
	if ( application_callback )
		{
		application_callback->OnApplicationDisconnected( app );
		}
}
void Ivy::SendDirectMsg(IvyApplication * app, int id, const char *message)
{
	app->SendMsg( IvyApplication::DirectMsg, id, message );
}

bool Ivy::CheckRegexp(const char * exp)
{
	/* accepte tout par default */
	int i;
	bool regexp_ok = true;
	if ( *exp =='^' && messages_classes_count !=0 )
	{
		regexp_ok = false;
		for ( i = 0 ; i < messages_classes_count; i++ )
		{
			if (strncmp( messages_classes[i], exp+1, strlen( messages_classes[i] )) == 0)
				return 1;
		}
	}
	return regexp_ok;
}

void Ivy::Classes(int argc, const char **argv )
{
	messages_classes_count = argc;
	messages_classes = argv;
}

bool Ivy::CheckConnected(IvyApplication * app)
{
	if (app->remoteService == 0)	/* old application dont check */
		return false;
	/* check to see if app already connected */
	IvyApplicationList::iterator iter;
	for ( iter = applications.begin() ; iter != applications.end() ; ++iter )
	{
		IvyApplication *application = *iter;
		if ( application != app && application->SameApplication(app))
			return true;
	}
	return false;
}