/*
 * "Software pw3270, desenvolvido com base nos códigos fontes do WC3270  e X3270
 * (Paul Mattes Paul.Mattes@usa.net), de emulação de terminal 3270 para acesso a
 * aplicativos mainframe. Registro no INPI sob o nome G3270.
 *
 * Copyright (C) <2008> <Banco do Brasil S.A.>
 *
 * Este programa é software livre. Você pode redistribuí-lo e/ou modificá-lo sob
 * os termos da GPL v.2 - Licença Pública Geral  GNU,  conforme  publicado  pela
 * Free Software Foundation.
 *
 * Este programa é distribuído na expectativa de  ser  útil,  mas  SEM  QUALQUER
 * GARANTIA; sem mesmo a garantia implícita de COMERCIALIZAÇÃO ou  de  ADEQUAÇÃO
 * A QUALQUER PROPÓSITO EM PARTICULAR. Consulte a Licença Pública Geral GNU para
 * obter mais detalhes.
 *
 * Você deve ter recebido uma cópia da Licença Pública Geral GNU junto com este
 * programa;  se  não, escreva para a Free Software Foundation, Inc., 59 Temple
 * Place, Suite 330, Boston, MA, 02111-1307, USA
 *
 * Este programa está nomeado como main.c e possui 351 linhas de código.
 *
 * Contatos:
 *
 * perry.werneck@gmail.com	(Alexandre Perry de Souza Werneck)
 * erico.mendonca@gmail.com	(Erico Mascarenhas Mendonça)
 * licinio@bb.com.br		(Licínio Luis Branco)
 * kraucer@bb.com.br		(Kraucer Fernandes Mazuco)
 * macmiranda@bb.com.br		(Marco Aurélio Caldas Miranda)
 *
 */

/*
 * References:
 *
 * http://www.howzatt.demon.co.uk/articles/29dec94.html
 * http://www-01.ibm.com/support/docview.wss?rs=22&context=SS8PLL&dc=DB520&dc=DB560&uid=swg21140958&loc=en_US&cs=UTF-8&lang=en&rss=ct22other
 *
 */

 #define BUILDING_AS_PLUGIN 1

 #define INCL_RXSYSEXIT
 #define INCL_RXARI
 #include "rx3270.h"

 #include <lib3270/plugins.h>
 #include <gmodule.h>

/*---[ Prototipes ]-------------------------------------------------------------------------------*/

 RexxExitHandler SysExit_SIO;	// Handler for screen I/O
 static HCONSOLE * getTraceWindow(void);

/*---[ Globals ]----------------------------------------------------------------------------------*/

 RXSYSEXIT rexx_exit_array[2] =
 {
   { "SysExit_SIO",	RXSIO 		},
   { NULL, 			RXENDLST 	}
 };

 EXPORT_PW3270_PLUGIN_INFORMATION("Rexx script support");

 GtkWidget			* program_window	= NULL;
 HCONSOLE			  console_window	= NULL;
 SCRIPT_STATE		  rexx_script_state	= SCRIPT_STATE_NONE;
 static gchar 		* rexx_charset		= NULL;

/*---[ Implement ]--------------------------------------------------------------------------------*/

 #include "calls.h"

 int lock_rexx_script_engine(GtkWidget *window)
 {
	if(rexx_script_state != SCRIPT_STATE_NONE)
	{
		GtkWidget *dialog = gtk_message_dialog_new(	GTK_WINDOW(window),
													GTK_DIALOG_DESTROY_WITH_PARENT,
													GTK_MESSAGE_ERROR,
													GTK_BUTTONS_CANCEL,
													"%s", _(  "Can't start script" ));

		gtk_window_set_title(GTK_WINDOW(dialog),_( "System busy" ));
		gtk_message_dialog_format_secondary_text(GTK_MESSAGE_DIALOG(dialog),"%s",_( "Please, try again in a few moments" ));

        gtk_dialog_run(GTK_DIALOG (dialog));
        gtk_widget_destroy(dialog);

		return EBUSY;
	}

	rexx_script_state = status_script(SCRIPT_STATE_RUNNING);

	return 0;
 }

 int unlock_rexx_script_engine(GtkWidget *window, const gchar *name, int rc, int return_code)
 {
	if(rexx_script_state == SCRIPT_STATE_HALTED)
	{
		// Interrupted by user, no dialog
		rc = ECANCELED;
	}
 	else if(rc)
 	{
		GtkWidget *dialog = gtk_message_dialog_new(	GTK_WINDOW(window),
													GTK_DIALOG_DESTROY_WITH_PARENT,
													GTK_MESSAGE_ERROR,
													GTK_BUTTONS_OK,
													_(  "script %s failed" ), name);

		gtk_window_set_title(GTK_WINDOW(dialog),_( "Rexx script failed" ));
		gtk_message_dialog_format_secondary_text(GTK_MESSAGE_DIALOG(dialog),_( "Return code was %d" ), rc);

        gtk_dialog_run(GTK_DIALOG (dialog));
        gtk_widget_destroy(dialog);
 	}
 	else if(return_code)
 	{
		GtkWidget *dialog = gtk_message_dialog_new(	GTK_WINDOW(window),
													GTK_DIALOG_DESTROY_WITH_PARENT,
													GTK_MESSAGE_ERROR,
													GTK_BUTTONS_OK,
													_( "Script %s aborted" ),
													name );

		gtk_window_set_title(GTK_WINDOW(dialog),_( "Rexx script error" ));
		gtk_message_dialog_format_secondary_text(GTK_MESSAGE_DIALOG(dialog),_( "Return code was %d" ), (int) return_code );

        gtk_dialog_run(GTK_DIALOG (dialog));
        gtk_widget_destroy(dialog);
 	}

	rexx_script_state = status_script(SCRIPT_STATE_NONE);

	return 0;
 }

 int load_rexx_script(const gchar *filename, PRXSTRING str)
 {
	GError	*error	= NULL;
	gsize	sz;

	Trace("Loading %s",filename);

	if(!g_file_get_contents(filename, (gchar **) (&str->strptr), &sz, &error))
	{
		GtkWidget	*dialog;
		gchar		*name		= g_path_get_basename(filename);

		dialog = gtk_message_dialog_new(	GTK_WINDOW(program_window),
											GTK_DIALOG_DESTROY_WITH_PARENT,
											GTK_MESSAGE_ERROR,
											GTK_BUTTONS_OK,
											_(  "Can't load %s" ), name);

		gtk_window_set_title(GTK_WINDOW(dialog), _( "File error" ) );
		gtk_message_dialog_format_secondary_text(GTK_MESSAGE_DIALOG(dialog),"%s", error->message ? error->message : N_( "Unexpected error" ));

        gtk_dialog_run(GTK_DIALOG (dialog));
        gtk_widget_destroy(dialog);
        g_free(name);

		g_error_free(error);
		return -1;
	}

	str->strlength = strlen(str->strptr);


	return 0;
 }

 PW3270_SCRIPT_INTERPRETER(rex)
 {
	LONG      			return_code = -1;  	// interpreter return code
	RXSTRING			retstr;            	// program return value
	RXSTRING			prg[2];				// Program data
	short     			rc	= 0;           	// converted return code
	CONSTRXSTRING 		*rxArgv;		 	// program argument string

 	Trace("%s begins argc=%d",__FUNCTION__,argc);

	if(lock_rexx_script_engine(program_window))
		return PW3270_SCRIPT_ERROR(EBUSY);

	// Build argument strings

 	if(argc)
 	{
 		int f;

		rxArgv = g_malloc0(sizeof(CONSTRXSTRING)*argc);

		for(f=0;f<argc;f++)
		{
			rxArgv[f].strptr = (char *) argv[f];
			rxArgv[f].strlength	= strlen(rxArgv[f].strptr);
		}
 	}
 	else
 	{
		argc = 1;
		rxArgv = g_malloc0(sizeof(CONSTRXSTRING));
		rxArgv->strptr = "";
 	}

	// set up default return
	memset(&retstr,0,sizeof(retstr));

	// Reset program data
	memset(prg,0,2*sizeof(RXSTRING));

	Trace("%s","Running pending events");
	RunPendingEvents(0);

	// Run script
	if(script_text)
	{
		// Received an script text
		prg[0].strptr = (char *) script_text;
		prg[0].strlength = strlen(prg[0].strptr);
		return_code = RexxStart(	argc,						// argument count
									(PCONSTRXSTRING) rxArgv,	// argument array
									NULL,						// REXX procedure name
									prg,						// program
									PACKAGE_NAME,				// default address name
									RXCOMMAND,					// calling as a subcommand
									rexx_exit_array,			// EXITs for this call
									&rc,						// converted return code
									&retstr);					// returned result

	}
	else if(script_name)
	{
		// Pass script filename directly to rexx interpreter
		return_code = RexxStart(	argc,						// argument count
									(PCONSTRXSTRING) rxArgv,	// argument array
									(char *) script_name,		// REXX procedure name
									(PRXSTRING)  0,				// no instore used
									PACKAGE_NAME,				// default address name
									RXCOMMAND,					// calling as a subcommand
									rexx_exit_array,			// EXITs for this call
									&rc,						// converted return code
									&retstr);					// returned result
	}

	// process return value
	g_free(rxArgv);

	Trace("Return value: \"%s\"",retstr.strptr);

	if(RXSTRPTR(prg[1]))
		RexxFreeMemory(RXSTRPTR(prg[1]));

	if(RXSTRPTR(retstr))
		RexxFreeMemory(RXSTRPTR(retstr));

	// Check script state
	rc = unlock_rexx_script_engine(program_window, script_name ? script_name : "script", rc, return_code);

	Trace("%s exits with rc=%d",__FUNCTION__,rc);

	return PW3270_SCRIPT_RETURN(rc);
 }

 int call_rexx(const gchar *filename, const gchar *arg)
 {
	LONG      			return_code;                 	// interpreter return code
	CONSTRXSTRING		argv;           	          	// program argument string
	RXSTRING			retstr;                      	// program return value
	RXSTRING			prg[2];							// Program data
	short     			rc		= 0;                   	// converted return code

	if(lock_rexx_script_engine(program_window))
		return EBUSY;

	// build the argument string
	memset(&argv,0,sizeof(argv));
	argv.strptr = (char *) arg;
	argv.strlength = strlen(arg);

	// set up default return
	memset(&retstr,0,sizeof(retstr));

	Trace("%s","Running pending events");
	RunPendingEvents(0);

	/* Preload script file contents */
	memset(prg,0,2*sizeof(RXSTRING));

	if(load_rexx_script(filename,prg))
		return -1;

	return_code = RexxStart(	1,						// argument count
								(PCONSTRXSTRING) &argv,	// argument array
								NULL,					// REXX procedure name
								prg,					// program
								PACKAGE_NAME,			// default address name
								RXCOMMAND,				// calling as a subcommand
								rexx_exit_array,		// EXITs for this call
								&rc,					// converted return code
								&retstr);				// returned result

	Trace("RexxStart(%s): %d",filename,(int) return_code);

	g_free(prg[0].strptr);

	// process return value
	Trace("Return value: \"%s\"",retstr.strptr);

	if(RXSTRPTR(prg[1]))
		RexxFreeMemory(RXSTRPTR(prg[1]));

	if(RXSTRPTR(retstr))
		RexxFreeMemory(RXSTRPTR(retstr));

	Trace("Call of \"%s\" ends (rc=%d return_code=%d)",filename,rc,(int) return_code);

	// Check script state
	rc = unlock_rexx_script_engine(program_window, filename, rc, return_code);

	Trace("%s exits with rc=%d",__FUNCTION__,rc);
	return (int) rc;
 }

/**
 * Plugin startup entry.
 *
 * Called, during the initialization to startup the plugin module.
 *
 * @param topwindow	pw3270's toplevel window.
 *
 */
 PW3270_PLUGIN_ENTRY void pw3270_plugin_start(GtkWidget *topwindow)
 {
	int	 f;

	program_window = topwindow;

	// Register Exit calls
	RexxRegisterExitExe( "SysExit_SIO", (REXXPFN) SysExit_SIO, NULL );

 	// Load rexx calls
	for(f=0; f < G_N_ELEMENTS(rexx_exported_calls); f++)
		RexxRegisterFunctionExe((char *) rexx_exported_calls[f].name,rexx_exported_calls[f].call);

 }

 static HCONSOLE * getTraceWindow(void)
 {
 	if(!console_window)
		console_window = console_window_new(_( "Rexx trace" ), _( "Command:" ));
	return console_window;
 }

 static void showtracemessage(const gchar *msg)
 {
	console_window_append(getTraceWindow(),"%s\n",msg);
 }

 static void gettracecommand(PRXSTRING str)
 {
 	char *cmd;
 	HCONSOLE hwnd = getTraceWindow();

	if(!hwnd)
	{
		RetString(str,NULL);
		return;
	}

	cmd = console_window_wait_for_user_entry(hwnd);
	RetString(str,NULL);

	free(cmd);

 }

#ifdef REXXV3
 LONG APIENTRY SysExit_SIO(LONG ExitNumber, LONG  Subfunction, PEXIT ParmBlock)
#else
 RexxReturnCode REXXENTRY SysExit_SIO(int ExitNumber, int  Subfunction, PEXIT ParmBlock)
#endif
 {
 	int			retcode = RXEXIT_HANDLED;
 	GtkWidget	*dialog;

 	Trace("%s call with ExitNumber: %d Subfunction: %d",__FUNCTION__,(int) ExitNumber, (int) Subfunction);

	switch(Subfunction)
	{
	case RXSIOSAY:	// SAY a line to STDOUT
		 dialog = gtk_message_dialog_new(	GTK_WINDOW(program_window),
											GTK_DIALOG_DESTROY_WITH_PARENT,
											GTK_MESSAGE_INFO,
											GTK_BUTTONS_OK_CANCEL,
											"%s", (((RXSIOSAY_PARM *) ParmBlock)->rxsio_string).strptr );

		if(console_window)
			showtracemessage((((RXSIOSAY_PARM *) ParmBlock)->rxsio_string).strptr);

		gtk_window_set_title(GTK_WINDOW(dialog), _( "Script message" ) );

        if(gtk_dialog_run(GTK_DIALOG (dialog)) == GTK_RESPONSE_CANCEL)
        {
			if(RaiseHaltSignal() != RXARI_OK)
				retcode = RXEXIT_RAISE_ERROR;
        }
        gtk_widget_destroy(dialog);
		break;

	case RXSIOTRC:	// Trace output
		showtracemessage((((RXSIOTRC_PARM *) ParmBlock)->rxsio_string).strptr);
		break;

	case RXSIOTRD:	// Read from char stream
		gettracecommand( & (((RXSIOTRD_PARM *) ParmBlock)->rxsiotrd_retc) );
		break;

	case RXSIODTR:	// DEBUG read from char stream
		gettracecommand( & (((RXSIODTR_PARM *) ParmBlock)->rxsiodtr_retc) );
		break;

	case RXSIOTLL:	// Return linelength(N/A OS/2)
		return RXEXIT_NOT_HANDLED;
	}

	return retcode;
 }

 RexxReturnCode RetConvertedString(PRXSTRING Retstr, const char *value)
 {
 	if(!value)
 	{
 		// Empty string doesn't need to be converted
 		strcpy(Retstr->strptr,"");
 	}
 	else
 	{
 		// Convert received string to rexx charset
 		gchar *str = g_convert(value, -1, rexx_charset ? rexx_charset : REXX_DEFAULT_CHARSET, CHARSET, NULL, NULL, NULL);

		if(strlen(str) > (RXAUTOBUFLEN-1))
		{
			Retstr->strptr = RexxAllocateMemory(strlen(str)+1);
			strcpy(Retstr->strptr,str);
		}
		else
		{
			g_snprintf(Retstr->strptr,RXAUTOBUFLEN-1,"%s",str);
		}

		g_free(str);
 	}

    Retstr->strlength = strlen(Retstr->strptr);
    return RXFUNC_OK;
 }

 int IsHalted(void)
 {
 	return rexx_script_state != SCRIPT_STATE_RUNNING;
 }

 RexxReturnCode RaiseHaltSignal(void)
 {
	rexx_script_state = status_script(SCRIPT_STATE_HALTED);

#ifdef WIN32
	return RexxSetHalt(getpid(),GetCurrentThreadId());
#else
	return RexxSetHalt(getpid(),pthread_self());
#endif

 }

 char *GetStringArg(PRXSTRING arg)
 {
 	if(!(arg->strptr && *arg->strptr))
		return strdup("");

	// Convert received string to lib3270 charset
	return (char *) g_convert(arg->strptr, arg->strlength, CHARSET, rexx_charset ? rexx_charset : REXX_DEFAULT_CHARSET, NULL, NULL, NULL);

 }

 void ReleaseStringArg(char *str)
 {
 	g_free(str);
 }

 RexxReturnCode REXXENTRY rx3270QueryRunMode(PSZ Name, LONG Argc, RXSTRING Argv[],PSZ Queuename, PRXSTRING Retstr)
 {
 	strncpy(Retstr->strptr,"PLUGIN",RXAUTOBUFLEN-1);
    Retstr->strlength = strlen(Retstr->strptr);
    return RXFUNC_OK;
 }

 RexxReturnCode REXXENTRY rx3270SetCharset(PSZ Name, LONG Argc, RXSTRING Argv[],PSZ Queuename, PRXSTRING Retstr)
 {
	if(!Argc)
		return RXFUNC_BADCALL;

	g_free(rexx_charset);

	rexx_charset = g_strdup(Argv->strptr);

    return RetValue(Retstr,0);
 }

 void pw3270_call_rexx_script(GtkWidget *action, GtkWidget *program_window)
 {
	LONG      			return_code;                 	// interpreter return code
#ifdef CONSTRXSTRING
	CONSTRXSTRING		argv;           	          	// program argument string
#else
	RXSTRING			argv;           	          	// program argument string
#endif
	RXSTRING			retstr;                      	// program return value
	RXSTRING			prg[2];							// Program data
	short     			rc			= 0;               	// converted return code

 	const gchar		*filename	= g_object_get_data(G_OBJECT(action),"script_filename");
 	const gchar		*text		= g_object_get_data(G_OBJECT(action),"script_text");

 	Trace("%s starts",__FUNCTION__);

	if(lock_rexx_script_engine(program_window))
		return;

	// build the argument string
	memset(&argv,0,sizeof(argv));
	argv.strptr = "";
	argv.strlength = strlen(argv.strptr);

	// set up default return
	memset(&retstr,0,sizeof(retstr));

	Trace("%s","Running pending events");
	RunPendingEvents(0);

	/* Preload script file contents */
	memset(prg,0,2*sizeof(RXSTRING));

	if(text)
	{
		prg[0].strptr		= (char *) text;
		prg[0].strlength	= strlen(prg[0].strptr);
	}
	else if(load_rexx_script(filename,prg))
	{
		return;
	}

	return_code = RexxStart(	1,						// argument count
								(PCONSTRXSTRING) &argv,	// argument array
								NULL,					// REXX procedure name
								prg,					// program
								PACKAGE_NAME,			// default address name
								RXCOMMAND,				// calling as a subcommand
								rexx_exit_array,		// EXITs for this call
								&rc,					// converted return code
								&retstr);				// returned result

	Trace("RexxStart(%s): %d",filename,(int) return_code);

	if(!text)
		g_free(prg[0].strptr);

	// process return value
	Trace("Return value: \"%s\"",retstr.strptr);

	if(RXSTRPTR(prg[1]))
		RexxFreeMemory(RXSTRPTR(prg[1]));

	if(RXSTRPTR(retstr))
		RexxFreeMemory(RXSTRPTR(retstr));

	Trace("Call of \"%s\" ends (rc=%d return_code=%d)",filename,rc,(int) return_code);

	// Check script state
	rc = unlock_rexx_script_engine(program_window, filename, rc, return_code);

 	Trace("%s ends",__FUNCTION__);
 }