/*
 * FILENAME		:	pipe.c
 * DESCRIPTION	:	Functions to implement pipes on NetWare.
 * Author		:	Anantha Kesari H Y, Venkat Raghavan S, Srivathsa M
 *
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "netware/pipe.h"
#include "netware/mktemp.h"


/* Following definitions unavailable in LibC, hence borrowed from CLib */
#define P_WAIT      0
#define P_NOWAIT    1

#define WHITESPACE  " \t"
#define MAX_ARGS    10


FILE* popen(const char* commandline, const char* mode)
{
	int               err, count;
	char              pszPipestr[32] = {'\0'};
	char *command = NULL, *argv[MAX_ARGS] = {'\0'};
	int fd = -1;
	fd_set myfds;
	wiring_t wiring;
	pid_t pid=0;
	FILE *fp=NULL;
	char *ptr = NULL;
	int ptrLen = 0, argc = 0, i = 0;


	/* Get a temporary name */
	(void) tmpnam(strecpy(pszPipestr,  "PHP/php$pipe/"));

	wiring.infd=FD_UNUSED;
	wiring.outfd=FD_UNUSED;
	wiring.errfd=FD_UNUSED;

	/* Open a pipe */
	if ( *mode=='r') {
		fd = pipe_open (pszPipestr, O_RDONLY);
		if (fd == -1)
			return NULL;

		wiring.outfd=fd;
	} else if (*mode=='w') {
		fd = pipe_open (pszPipestr, O_WRONLY);
		if (fd == -1)
			return NULL;

		wiring.infd=fd;
	} else {
		consoleprintf ("Unsupported pipe open mode \n");
		return NULL;
	}

	/* Get the file pointer */
	fp = fdopen(fd, mode);
	if (fp == NULL) {
		consoleprintf ("Failure in fdopen \n");
		close (fd);
		return NULL;
	}

	/* Separate commandline string into words */
	ptr = strtok((char*)commandline, WHITESPACE);
	ptrLen = strlen(ptr);

	/* Get the command */
	command = (char*)malloc(ptrLen + 1);
	if(command == NULL) {
		consoleprintf ("Failure in memory allocation \n");
		close (fd);
		fclose (fp);
		return NULL;
	}
	strcpy (command, ptr);

	/* Command as the first argument into prcessve */
	argv[argc] = (char*)malloc(ptrLen + 1);
	if(argv[argc] == NULL) {
		consoleprintf ("Failure in memory allocation \n");
		close (fd);
		fclose (fp);
		if(command) {
			free(command);
			command = NULL;
		}
		return NULL;
	}
	strcpy (argv[argc], ptr);
	argc++;

	/* Get more arguments if any to be passed to prcessve */
	ptr = strtok(NULL, WHITESPACE);
	while (ptr && (argc < MAX_ARGS))
	{
		ptrLen = strlen(ptr);

		argv[argc] = (char*)malloc(ptrLen + 1);
		if(argv[argc] == NULL) {
			consoleprintf ("Failure in memory allocation \n");
			close (fd);
			fclose (fp);
			if(command) {
				free(command);
				command = NULL;
			}
			return NULL;
		}
		strcpy (argv[argc], ptr);
		argc++;

		ptr = strtok(NULL, WHITESPACE);
	}
	argv[argc] = NULL;

	FD_ZERO(&myfds);
	FD_SET(fd, &myfds);

	pid = processve(command, PROC_CURRENT_SPACE, NULL, &wiring,
					&myfds, NULL, (const char **)argv );
	if (pid == -1) {
		consoleprintf ("Failure in processve call \n");
		close (fd);
		fclose(fp);
		if(command) {
			free(command);
			command = NULL;
		}
		for(i=0; i<argc; i++) {
			if(argv[i]) {
				free(argv[i]);
				argv[i] = NULL;
			}
		}
		return NULL;
	}

	close (fd);
	if(command) {
		free(command);
		command = NULL;
	}
	for(i=0; i<argc; i++) {
		if(argv[i]) {
			free(argv[i]);
			argv[i] = NULL;
		}
	}

	return fp;
}


int pclose(FILE* stream)
{
	fclose(stream);
	return 0;
}



#if 0

FILE* popen2(const char* commandline, const char* mode)
{
    int               err, count, var, replaced;
    char              **env, pszPipestr[32];
    NXVmId_t          newVM;
    NXExecEnvSpec_t   envSpec;
    char *command = NULL, *argv[MAX_ARGS] = {"\0"};
    NXHandle_t fd;
    
    fd = (NXHandle_t) -1;
    
    count = NXGetEnvCount() + 1;  // (add one for NULL)
    env   = (char **) NXMemAlloc(sizeof(char *) * count, 0);
    
    if (!env)
        return 0;
    
    err = NXCopyEnv(env, count);  // ensure NULL added at end
    if ( *mode='r'){
        (void) tmpnam(strecpy(pszPipestr,  "PHPPIPE/stdin/"));
        err = NXFifoOpen(0, pszPipestr, NX_O_RDONLY, 0, &fd);
        if (err)
            return 0;
        
        envSpec.esStdin.ssType     = NX_OBJ_CONSOLE;
        envSpec.esStdout.ssType    = NX_OBJ_FIFO;
        envSpec.esStdout.ssPath    = pszPipestr;
    }
    else if (*mode='w') then{
        (void) tmpnam(strecpy(pszPipestr, "PHPPIPE/stdout/"));
        err = NXFifoOpen(0, instr, NX_O_WRONLY, 0, &fd);
        if (err)
            return 0;
        envSpec.esStdin.ssType     = NX_OBJ_FIFO;
        envSpec.esStdout.ssType    = NX_OBJ_CONSOLE;
		envSpec.esStdin.ssPath     =  pszPipestr;
    }
    else
        consoleprintf ("Unsupported pipe open mode \n");
    
    
    /* Separate commandline string into words */
    
    ptr = strtok((char*)commandline, WHITESPACE);
    ptrLen = strlen(ptr);
    
    command = (char*)malloc(ptrLen + 1);
    strcpy (command, ptr);
    
    ptr = strtok(NULL, WHITESPACE);
    while (ptr && (argc < MAX_ARGS))
    {
        ptrLen = strlen(ptr);
        
        argv[argc] = (char*)malloc(ptrLen + 1);
        strcpy (argv[argc], ptr);
        
        argc++;
        
        ptr = strtok(NULL, WHITESPACE);
    }
/*    consoleprintf ("PHP | popen: command = %s\n", command); */
    
	//

    envSpec.esArgc             = argc;
    envSpec.esArgv             = argv;
    envSpec.esEnv              = env;
    
    envSpec.esStderr.ssType    = NX_OBJ_CONSOLE;
    
    envSpec.esStdin.ssHandle   =
        envSpec.esStdout.ssHandle  =
        envSpec.esStderr.ssHandle  = -1;
    
    envSpec.esStdin.ssPathCtx  =
        envSpec.esStdout.ssPathCtx =
        envSpec.esStderr.ssPathCtx = NULL;
    
    envSpec.esStderr.ssPath    = NULL;
    
    err = NXVmSpawn(NULL, command, &envSpec, NX_VM_CREATE_DETACHED, &newVM);
    return fd;
    
}

int pclose2(FILE* stream)
{
	NXClose(*(NXHandle_t *)stream);
    return 0;
}

FILE* popen1(const char* commandline, const char* mode)
{
    char *command = NULL, *argv[MAX_ARGS] = {"\0"};
	char *tempName = "phpXXXXXX.tmp";
    char *filePath = NULL;
    FILE *fp = NULL;
    char *ptr = NULL;
    int ptrLen = 0, argc = 0, i = 0;

    /* Check for validity of input parameters */
    if (!commandline || !mode)
        return NULL;

    /* Get temporary file name */
    filePath = mktemp(tempName);
	if (!filePath)
		return NULL;

    /* Separate commandline string into words */

    ptr = strtok((char*)commandline, WHITESPACE);
    ptrLen = strlen(ptr);

    command = (char*)malloc(ptrLen + 1);
    strcpy (command, ptr);

    ptr = strtok(NULL, WHITESPACE);
    while (ptr && (argc < MAX_ARGS))
    {
        ptrLen = strlen(ptr);

        argv[argc] = (char*)malloc(ptrLen + 1);
        strcpy (argv[argc], ptr);

        argc++;

        ptr = strtok(NULL, WHITESPACE);
    }
/*consoleprintf ("PHP | popen: command = %s\n", command);*/
    if(strchr(mode,'r') != 0)
    {
        /*spawnvp(P_WAIT, command, argv);*/

        fp = fopen(filePath, "r"); /* Get the file handle of the pipe */
    }
	else if(strchr(mode,'w') != 0)
        fp = fopen(filePath, "w"); /* Get the file handle of the pipe */

    /* Free resources */
    free (command);
    for (i = 0; i < argc; i++)
    {
/*consoleprintf ("%s\t", argv[i]);*/
        free (argv[i]);
    }
/*consoleprintf ("\n");*/

	return fp;  /* Return the file handle.*/
}

int pclose1(FILE* stream)
{
    return (fclose(stream));
}

# endif