#include <stdio.h>
#include <math.h>
#include <signal.h>
#include <audio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/time.h>
#include <sys/prctl.h>
#include <X11/Intrinsic.h>
#include <X11/StringDefs.h>
#include <X11/Xaw/Box.h>
#include <Xm/Xm.h>
#include <Xm/PushB.h>
#include <Xm/Label.h>
#include <Xm/Scale.h>

#define MAX_SUB_PROCESS	100
#define FIFO_SIZE	48000
#define pi 3.1415926535

char process_list[MAX_SUB_PROCESS][80];
unsigned int pid[200], audio_pid;
int pid_ctr, sub_process, audio_mode, sample_param, pitch_param;
char *audio_menu[] = { "audio_oscillator", "audio_granular" };
short buffer[FIFO_SIZE];

void sub_process_check();
void create_process();
void process_killer();
void self_kill();
void open_X_process();
void create_sound();
void sound_off();
void scaler_volume();
void scaler_sample();
void scaler_pitch();
void audio_oscillator();
void audio_granular();

void main(unsigned int argc, char** argv)
{
	Widget toplevel, title, bigbox, sbox[10], pb1[MAX_SUB_PROCESS], pb2[5], pb3[3], volume, sample, pitch;
	XmString xmstr;
	Arg args[10];
	char buf[80];
	int i,n;

/***** System Setting (Parameter File Check) *****/
	sub_process_check();
	open_X_process( "X/monitor", " Monitor[1] ", "5", "dummy_1_a", "dummy_1_b" );
	open_X_process( "X/console", " Slider[1] ", "5", "dummy_1_a", "dummy_1_b" );
	open_X_process( "X/monitor", " Data Monitor [2] ", "7", "dummy_2_a", "dummy_2_b" );
	open_X_process( "X/console", " Controller [2] ", "7", "dummy_2_a", "dummy_2_b" );

/***** Motif Screen Define *****/
	toplevel = XtInitialize( argv[0], "", NULL, 0, &argc, argv );
	bigbox = XtCreateManagedWidget( "", boxWidgetClass, toplevel, NULL, 0 );
	xmstr = XmStringCreateSimple("  (^_^) TEST by Yoichi Nagashima (^_^)  ");
	XtSetArg( args[0], XmNlabelString, xmstr );
	title = XtCreateManagedWidget( "", xmLabelWidgetClass, bigbox, args, 1 );
	for(i=0;i<10;i++){
		sbox[i] = XtCreateManagedWidget( "", boxWidgetClass, bigbox, NULL, 0 );
	}
	for(i=0;i<sub_process;i++){
		strcpy( buf, "Create [" );
		strcat( buf, process_list[i] );
		buf[strlen(buf)-1] = NULL;
		strcat( buf, "]" );  
		pb1[i] = XtCreateManagedWidget( buf, xmPushButtonWidgetClass, sbox[0], NULL, 0 );
	}
	pb2[0] = XtCreateManagedWidget( "Mode(1) Oscillator", xmPushButtonWidgetClass, sbox[1], NULL, 0 );
	pb2[1] = XtCreateManagedWidget( "Mode(2) Granular", xmPushButtonWidgetClass, sbox[1], NULL, 0 );
	pb3[0] = XtCreateManagedWidget( "Sound Port OFF", xmPushButtonWidgetClass, sbox[2], NULL, 0 );
	pb3[1] = XtCreateManagedWidget( "Delete process", xmPushButtonWidgetClass, sbox[2], NULL, 0 );
	pb3[2] = XtCreateManagedWidget( "Quit to System", xmPushButtonWidgetClass, sbox[2], NULL, 0 );
	n = 0;
	XtSetArg( args[n], XmNminimum, 0 ); n++;
	XtSetArg( args[n], XmNmaximum, 255 ); n++;
	XtSetArg( args[n], XmNscaleHeight, 30 ); n++;
	XtSetArg( args[n], XmNscaleWidth, 250 ); n++;
	XtSetArg( args[n], XmNorientation, XmHORIZONTAL ); n++;
	xmstr = XmStringCreateSimple("Speaker Gain Control");
	XtSetArg( args[n], XmNtitleString, xmstr ); n++;
	XtSetArg( args[n], XmNshowValue, True ); n++;
	volume = XtCreateManagedWidget( "", xmScaleWidgetClass, sbox[3], args, n );
	n = 0;
	XtSetArg( args[n], XmNminimum, 1 ); n++;
	XtSetArg( args[n], XmNmaximum, 99 ); n++;
	XtSetArg( args[n], XmNscaleHeight, 30 ); n++;
	XtSetArg( args[n], XmNscaleWidth, 250 ); n++;
	XtSetArg( args[n], XmNorientation, XmHORIZONTAL ); n++;
	xmstr = XmStringCreateSimple("Gr. Density Control");
	XtSetArg( args[n], XmNtitleString, xmstr ); n++;
	XtSetArg( args[n], XmNshowValue, True ); n++;
	sample = XtCreateManagedWidget( "", xmScaleWidgetClass, sbox[4], args, n );
	n = 0;
	XtSetArg( args[n], XmNminimum, 1 ); n++;
	XtSetArg( args[n], XmNmaximum, 99 ); n++;
	XtSetArg( args[n], XmNscaleHeight, 30 ); n++;
	XtSetArg( args[n], XmNscaleWidth, 250 ); n++;
	XtSetArg( args[n], XmNorientation, XmHORIZONTAL ); n++;
	xmstr = XmStringCreateSimple("Grain Width Control");
	XtSetArg( args[n], XmNtitleString, xmstr ); n++;
	XtSetArg( args[n], XmNshowValue, True ); n++;
	pitch = XtCreateManagedWidget( "", xmScaleWidgetClass, sbox[5], args, n );

/***** Callback Routine Define *****/
	for(i=0;i<sub_process;i++){
		XtAddCallback( pb1[i], XmNactivateCallback, create_process, process_list[i] );
	}
	for(i=0;i<2;i++){
		XtAddCallback( pb2[i], XmNactivateCallback, create_sound, audio_menu[i] );
	}
	XtAddCallback( pb3[0], XmNactivateCallback, sound_off, NULL );
	XtAddCallback( pb3[1], XmNactivateCallback, process_killer, NULL );
	XtAddCallback( pb3[2], XmNactivateCallback, self_kill, NULL );
	XtAddCallback( volume, XmNvalueChangedCallback, scaler_volume, NULL );
	XtAddCallback( volume, XmNdragCallback, scaler_volume, NULL );
	XtAddCallback( sample, XmNvalueChangedCallback, scaler_sample, NULL );
	XtAddCallback( sample, XmNdragCallback, scaler_sample, NULL );
	XtAddCallback( pitch, XmNvalueChangedCallback, scaler_pitch, NULL );
	XtAddCallback( pitch, XmNdragCallback, scaler_pitch, NULL );

/***** Start Realize ! *****/
	XtRealizeWidget(toplevel);
	XtMainLoop();
}

void sub_process_check()
{
	FILE *fds;
	int i,ii;
	char buff[80];
	pid_ctr = 0;
	sub_process = 0;
	printf("\nLet's Start !  (^o^)/\n\n");
	if( ( fds = fopen( "GL_process.lst", "r" ) ) == NULL ){
		printf("\n  Parameter File [GL_process.lst] is not found. (;_;)\n\n");
		exit(0);
	}
	while(1){
		if( fgets( process_list[sub_process++], 80, fds ) == NULL ) break;
		else if( sub_process > MAX_SUB_PROCESS-1 ) break;		
	}
	sub_process--;
	for(i=0;i<sub_process;i++){
		process_list[i][strlen(process_list[i])-1] = '1';
		strcpy( buff, process_list[i] );
		buff[strlen(buff)-1] = NULL;
		printf("  %s\n",buff);
	}
	fclose(fds);
	ii = sub_process;
	if( ( fds = fopen( "X_process.lst", "r" ) ) == NULL ){
		printf("\n  Parameter File [X_process.lst] is not found. (;_;)\n\n");
		exit(0);
	}
	while(1){
		if( fgets( process_list[sub_process++], 80, fds ) == NULL ) break;
		else if( sub_process > MAX_SUB_PROCESS-1 ) break;		
	}
	sub_process--;
	for(i=ii;i<sub_process;i++){
		process_list[i][strlen(process_list[i])-1] = '0';
		strcpy( buff, process_list[i] );
		buff[strlen(buff)-1] = NULL;
		printf("  %s\n",buff);
	}
	fclose(fds);
	printf("\n  Registered Sub Processes = %d\n",sub_process);
	audio_pid = 0; audio_mode = 0;
	printf("  Default Audio PID = %d\n\n",audio_pid);
}

void create_process(Widget w, caddr_t message, caddr_t para)
{
	int pp,ppp;
	if(pid_ctr<199){
		ppp = message[strlen(message)-1] - '0';
		pp = fork();
		if( pp == 0 ) {
			message[strlen(message)-1] = NULL;
			execl( message, NULL );
			exit(7);
		}
		else{
			pid[pid_ctr++] = pp + ppp;
			printf( "  1 new child [PID=%d] is born : total = %d \n", pp+ppp, pid_ctr ); 
		}
	}
}

void process_killer(Widget w, caddr_t message, caddr_t para)
{
	int pp;
	if(pid_ctr!=0){
		pp = pid[--pid_ctr];
		printf( "  1 of %d children [PID=%d] vanishes : remain = %d\n", pid_ctr+1, pp, pid_ctr ); 
		kill( pp, SIGKILL );
	}
}

void self_kill(Widget w, caddr_t message, caddr_t para)
{
	while(pid_ctr!=0){
		kill( pid[--pid_ctr], SIGKILL );
	}
	sound_off();
	printf("\nBye Bye !  (^o^)/\n\n");
	exit(0);
}

void open_X_process( char *name, char *title, char *count, char *option1, char *option2 )
{
	int pp;
	if(pid_ctr<199){
		pp = fork();
		if( pp == 0 ) {
			execl( name, name, title, count, option1, option2, NULL );
			exit(7);
		}
		else{
			pid[pid_ctr++] = pp;
			printf( "  1 new child [PID=%d] is born : total = %d \n", pp, pid_ctr ); 
		}
	}
}

void create_sound(Widget w, caddr_t message, caddr_t para)
{
	sound_off();
	if( !strcmp( message, "audio_oscillator" ) ){
		sample_param = 1;
		audio_pid = sproc( audio_oscillator, PR_SALL );
		audio_mode = 2;
	}
	else if( !strcmp( message, "audio_granular" ) ){
		sample_param = 1;
		pitch_param = 1;
		audio_pid = sproc( audio_granular, PR_SALL );
		audio_mode = 3;
	}
	if (audio_pid == -1) exit(-1);
	printf("  Registered Audio PID = %d\n",audio_pid);
}

void sound_off()
{
	long parameter_buffer[4];
	if(audio_pid != 0){
		parameter_buffer[0] = AL_LEFT_SPEAKER_GAIN;
		parameter_buffer[2] = AL_RIGHT_SPEAKER_GAIN;
		ALgetparams( AL_DEFAULT_DEVICE, parameter_buffer, 4 );
		parameter_buffer[1] = 50;
		parameter_buffer[3] = 50;
		ALsetparams( AL_DEFAULT_DEVICE, parameter_buffer, 4 );
		kill(audio_pid, SIGKILL);
		audio_pid = 0; audio_mode = 0;
		printf("  Killed : Audio PID = %d\n",audio_pid);
	}
}

void scaler_volume(Widget w, caddr_t message, caddr_t para)
{
	long parameter_buffer[4];
	XmScaleCallbackStruct  *callback = (XmScaleCallbackStruct *) para;
	parameter_buffer[0] = AL_LEFT_SPEAKER_GAIN;
	parameter_buffer[2] = AL_RIGHT_SPEAKER_GAIN;
	ALgetparams( AL_DEFAULT_DEVICE, parameter_buffer, 4 );
	parameter_buffer[1] = callback->value;
	parameter_buffer[3] = callback->value;
	ALsetparams( AL_DEFAULT_DEVICE, parameter_buffer, 4 );
}

void scaler_sample(Widget w, caddr_t message, caddr_t para)
{
	XmScaleCallbackStruct  *callback = (XmScaleCallbackStruct *) para;
	sample_param = callback->value;
}

void scaler_pitch(Widget w, caddr_t message, caddr_t para)
{
	int i, width;
	XmScaleCallbackStruct  *callback = (XmScaleCallbackStruct *) para;
	pitch_param = callback->value;
	if( audio_mode == 3){
		width = 64 + 4 * pitch_param;
		for(i=0;i<width;i++) buffer[i] = (short)( 800.0 * ( 1.0 + sin(2.0*pi*(double)i/(double)width + 2.0*pi*3.0/4.0)));
		for(i=width;i<FIFO_SIZE;i++) buffer[i] = 0;
	}
}

void audio_oscillator()
{
	ALconfig	config;
	ALport		output_port;
	short		buff[256];
	unsigned int	read_pointer=0;
	int		i;
	config = ALnewconfig();
	ALsetqueuesize( config, FIFO_SIZE );
	output_port = ALopenport( "output", "w", config );
	if ( output_port == NULL ) exit(-1);
	for(i=0;i<256;i++) buffer[i] = (short)( 15000.0 * sin( 2.0 * pi * (double)i / 256.0 ));
	for(i=256;i<FIFO_SIZE;i++) buffer[i] = 0;
	while (1)
	{
		if( ALgetfillable(output_port) > 256 ){
			for(i=0;i<256;i++){
				buff[i] = buffer[read_pointer++];
				if( read_pointer > sample_param * 256 ) read_pointer=0;
			}
			ALwritesamps( output_port, buff, 256 );
		}
	}
}

void audio_granular()
{
	ALconfig	config;
	ALport		output_port;
	short		buff[256];
	unsigned int	read_pointer[20];
	int		i, j;
	config = ALnewconfig();
	ALsetqueuesize( config, FIFO_SIZE );
	output_port = ALopenport( "output", "w", config );
	if ( output_port == NULL ) exit(-1);
	for(i=0;i<20;i++) read_pointer[i] = 0;
	for(i=0;i<128;i++) buffer[i] = (short)( 800.0 * ( 1.0 + sin( 2.0 * pi * (double)i / 128.0 + 2.0 * pi * 3.0 / 4.0 )));
	for(i=128;i<FIFO_SIZE;i++) buffer[i] = 0;
	while (1)
	{
		if( ALgetfillable(output_port) > 256 ){
			for(i=0;i<256;i++){
				buff[i] = 0;
				for(j=0;j<20;j++){
					buff[i] = buff[i] + buffer[read_pointer[j]++];
					if( read_pointer[j] > ( sample_param + 10 ) * 10 * (j+5) ) read_pointer[j] = 0;
				}
			}
			ALwritesamps( output_port, buff, 256 );
		}
	}
}