/*
 *	Copyright (c) 1999-2003 Smithsonian Astrophysical Observatory
 */

/*
 *
 * stest -- server test for xpa
 *
 */
#include <xpap.h>

#ifndef BUILD_WITH_XT
#if HAVE_XT
#undef HAVE_XT
#endif
#endif

#if HAVE_XT
#include <X11/Intrinsic.h>
#include <X11/StringDefs.h>
#endif

#define MAX_FPS 10

extern char *optarg;
extern int optind;

XPA xpa1, xpa1a, xpa2, xpa3;
int  quiet=0;
int  dowait=0;
int  dofill=0;
int  doone=0;
int  domyfree=0;
int  doatexit=0;
int  save_bytes=-1;
int n=0;
int please_exit=0;
char *save_buf=NULL;

char *mode="";
char name[SZ_LINE];
char xclass[SZ_LINE];

#ifdef ANSI_FUNC
void myfree(void *buf)
#else
void myfree(buf)
     void *buf;
#endif
{
  fprintf(stderr, "myfree calling xfree(%p)\n", buf);
  xfree(buf);
}

#ifdef ANSI_FUNC
int 
send_cb (void *client_data, void *call_data, char *paramlist,
	 char **buf, int *len)
#else
int send_cb(client_data, call_data, paramlist, buf, len)
     void *client_data;
     void *call_data;
     char *paramlist;
     char **buf;
     int *len;
#endif
{
  char *s = (char *)client_data;
  XPA xpa = (XPA)call_data;
  char tbuf[SZ_LINE];
  char xtemplate[SZ_LINE];
  char *names[MAX_FPS];
  char *bufs[MAX_FPS];
  char *errs[MAX_FPS];
  int lens[MAX_FPS];
  int sendbuf=0;
  int got;
  int i;
  int ip;

  /* set the free routine */
  if( domyfree ) XPASetFree(xpa, myfree, NULL);

  /* introduce ourselves */
  if( !quiet ){
    fprintf(stdout, "SEND_CB #%d: %s:%s %s (%s)\n",
	    n++, xpa_class(xpa), xpa_name(xpa), xpa_method(xpa), s);
  }

  /* process special paramlist tokens */
  if( paramlist && *paramlist ){
    ip = 0;
    word(paramlist, xtemplate, &ip);
    if( !quiet )
      fprintf(stdout, "\tparamlist: %s\n", paramlist);
    if( !strncmp(paramlist, "buf", 3) ){
      sendbuf=1;
    }
    else if( !strcmp(paramlist, "free") ){
      if( !quiet )
	fprintf(stdout, "Freeing xpa struct\n");
      XPAFree(xpa);
      return(0);
    }
    else if( !strcmp(paramlist, "exit") ){
      if( !quiet )
	fprintf(stdout, "Exiting\n");
      if( doatexit){
	please_exit = 1;
      } else {
	XPAFree(xpa1);
	if( !doone ){
	  XPAFree(xpa1a);
	  XPAFree(xpa2);
	  XPAFree(xpa3);
	}
      }
    }
    else if( !strcmp(paramlist, "Exit") ){
      if( !quiet )
	fprintf(stdout, "Exiting immediately\n");
      exit(0);
    }
    else if( !strncmp(paramlist, "error", 5) ){
      if( !quiet )
	fprintf(stdout, "\treturning error: %s\n", &paramlist[6]);
      *len = 0;
      *buf = NULL;
      if( strlen(paramlist) > 6 )
	XPAError(xpa, &paramlist[6]);
      else
	XPAError(xpa, "intentional error from client");
      return(-1);
    }
    else if( !strcmp(paramlist, "wait") || !strcmp(paramlist, "version") ){
      fprintf(stdout, "Press <CR> to continue ...");
      fgets(tbuf, SZ_LINE, stdin);
    }
    else if( !strcmp(paramlist, "poll") ){
repoll:
      fprintf(stdout, "Press 'q' to quit ...");
      got = XPAPoll (10000, 1);
      fprintf(stdout, " XPAPoll returns %d ...", got);
      fgets(tbuf, SZ_LINE, stdin);
      if( *tbuf != 'q' )
	goto repoll;
    }
    else if( !strncmp(paramlist, "fork ", 5) ){
      if( strlen(paramlist) > 5 ){
	fprintf(stdout, "fork command: %s\n", &paramlist[5]);
	/* child forks a command and exits */
	if(!(fork())){
	  system(&paramlist[5]);
	  /* should call _exit but this tests avoidance of atexit routine */
	  exit(0);
	}
      }
    }
    else if( !strcmp(xtemplate, "xpaget") ){
      word(paramlist, xtemplate, &ip);
      got = XPAGet(xpa, xtemplate, &(paramlist[ip]), NULL,
		   bufs, lens, names, errs, MAX_FPS);
      if( !quiet )
	fprintf(stdout, "XPAGet (%s) returned %d buffer(s)\n", xtemplate, got);
      for(i=0; i<got; i++){
	if( !quiet )
	  fprintf(stdout, "\t%d: %s\n", i, names[i]);
	if( errs[i] == NULL ){
	  if( !quiet && (lens[i] > 0) ){
	    fprintf(stdout, "contents (%d bytes):\n", lens[i]);
	    fwrite(bufs[i], sizeof(char), lens[i], stdout);
	  }
	  if( !quiet )
	    fprintf(stdout, "\n");
	}
	else{
	  write(fileno(stdout), errs[i], strlen(errs[i]));
	}
	if( bufs[i] )
	  xfree(bufs[i]);
	if( names[i] )
	  xfree(names[i]);
	if( errs[i] )
	  xfree(errs[i]);
      }
    }
  }
  else if( dowait ){
    fprintf(stdout, "Press <CR> to continue ...");
    fgets(tbuf, SZ_LINE, stdin);
  }

  /* return information about this xpa */
  if( !sendbuf ){
    snprintf(tbuf, SZ_LINE,
	  "class: %s\nname: %s\nmethod: %s\nsendian: %s\ncendian: %s\n",
	  xpa_class(xpa), xpa_name(xpa), xpa_method(xpa),
	  xpa_sendian(xpa), xpa_cendian(xpa));
  
    if( (xpa->send_mode & XPA_MODE_FILLBUF) ){
      send(xpa_datafd(xpa), tbuf, strlen(tbuf), 0);
      *len = 0;
      *buf = NULL;
      if( !quiet)
	fprintf(stdout, "\tcallback writes %d bytes to client\n",
		(int)strlen(tbuf));
    }
    /* return the buffer and let xpa transmit it */
    else{
      *len = strlen(tbuf);
      *buf = (char *)xmalloc(*len);
      memcpy(*buf, tbuf, *len);
      if( !quiet)
	fprintf(stdout, "\tcallback returns %d bytes to xpa handler\n",
		(int)strlen(tbuf));
    }
  }
  /* return the last buffer we were sent */
  else{
    if( (xpa->send_mode & XPA_MODE_FILLBUF) ){
      send(xpa_datafd(xpa), save_buf, save_bytes, 0);
      *len = 0;
      *buf = NULL;
      if( !quiet)
	fprintf(stdout, "\tcallback writes %d bytes to client\n", save_bytes);
    }
    /* return the buffer and let xpa transmit it */
    else{
      *len = save_bytes;
      *buf = (char *)xmalloc(*len);
      memcpy(*buf, save_buf, *len);
      if( !quiet)
	fprintf(stdout, "\tcallback returns %d bytes to xpa handler\n",
		save_bytes);
    }
  }
  if( !quiet ){
    fprintf(stdout, "SEND_CB complete\n");
  }
  else{
    fprintf(stdout, ".");
  }
  fflush(stdout);
  fflush(stderr);
  return(0);
}

#ifdef ANSI_FUNC
int 
receive_cb (void *client_data, void *call_data, char *paramlist,
	    char *buf, int len)
#else
int receive_cb(client_data, call_data, paramlist, buf, len)
     void *client_data;
     void *call_data;
     char *paramlist;
     char *buf;
     int len;
#endif
{
  XPA xpa = (XPA)call_data;
  char *s = (char *)client_data;
  char tbuf[SZ_LINE];
  char cbuf[SZ_LINE];
  char *errs[1];
  int i;
  int ip;
  int got;
  int xwait;

  /* set the free routine */
  if( domyfree ) XPASetFree(xpa, myfree, NULL);

  if( !quiet ){
    fprintf(stdout, "RECEIVE_CB #%d: %s:%s %s (%s)\n",
	    n++, xpa_class(xpa), xpa_name(xpa), xpa_method(xpa), s);
  }
  /* process param list */
  if( paramlist && *paramlist ){
    if( !quiet )
      fprintf(stdout, "\tparamlist: %s\n", paramlist);
    if( !strcmp(paramlist, "free") ){
      if( !quiet )
	fprintf(stdout, "Freeing xpa struct\n");
      XPAFree(xpa);
      return(0);
    }
    else if( !strcmp(paramlist, "exit") ){
      if( !quiet )
	fprintf(stdout, "Exiting\n");
      if( doatexit){
	please_exit = 1;
      } else {
	XPAFree(xpa1);
	if( !doone ){
	  XPAFree(xpa1a);
	  XPAFree(xpa2);
	  XPAFree(xpa3);
	}
      }
    }
    else if( !strcmp(paramlist, "Exit") ){
      if( !quiet )
	fprintf(stdout, "Exiting immediately\n");
      exit(0);
    }
    else if( !strncmp(paramlist, "error", 5) ){
      if( !quiet )
	fprintf(stdout, "Processing error: %s\n", &paramlist[6]);
      if( strlen(paramlist) > 6 )
	XPAError(xpa, &paramlist[6]);
      else
	XPAError(xpa, "intentional error from client");
      return(-1);
    }
    else if( !strcmp(paramlist, "wait") ){
      fprintf(stdout, "Press <CR> to continue ...");
      fgets(tbuf, SZ_LINE, stdin);
    }
    else if( !strcmp(paramlist, "poll") ){
repoll:
      fprintf(stdout, "Press 'q' to quit ...");
      got = XPAPoll (10000, 1);
      fprintf(stdout, " ... XPAPoll returns %d ...", got);
      fgets(tbuf, SZ_LINE, stdin);
      if( *tbuf != 'q' )
	goto repoll;
    }
    else if( !strncmp(paramlist, "fork ", 5) ){
      if( strlen(paramlist) > 5 ){
	fprintf(stdout, "fork command: %s\n", &paramlist[5]);
	/* child forks a command and exits */
	if(!(fork())){
	  system(&paramlist[5]);
	  /* should call _exit but this tests avoidance of atexit routine */
	  exit(0);
	}
      }
    }
    else if( !strncmp(paramlist, "xpaset", 6) ){
      ip = 0;
      word(paramlist, tbuf, &ip);
      if( word(paramlist, tbuf, &ip) ){
	if( !quiet )
	  fprintf(stdout, "calling XPASet(%s, \"%s\")\n",
		  tbuf, &(paramlist[ip]));
	got = XPASet(NULL, tbuf, &(paramlist[ip]), mode,
		     paramlist, strlen(paramlist), NULL, errs, 1);
	if( got == 0 ){
	  if( !quiet )
	    fprintf(stdout, "no XPA access points matched template %s\n",
		    tbuf);
	}
	else if( errs[0] != NULL ){
	  if( !quiet )
	    fprintf(stdout, "Error on xpaset to %s: %s\n", tbuf, errs[0]);
	  xfree(errs[0]);
	}
	else{
	  if( !quiet )
	    fprintf(stdout, "XPASet to %s successful\n", tbuf);
	}
      }
      return(0);
    }
  }
  else if( dowait ){
    fprintf(stdout, "Press <CR> to continue ...");
    fgets(tbuf, SZ_LINE, stdin);
  }

  /* reset save buffer */
  if( save_buf != NULL ){
    xfree(save_buf);
    save_buf = NULL;
  }
  save_bytes = 0;

  xwait = dowait;
  if( !(xpa->receive_mode & XPA_MODE_FILLBUF) && dofill ){
    while( (got=recv(xpa_datafd(xpa), tbuf, SZ_LINE, 0)) >0 ){
      if( xwait >0 ){
	fprintf(stdout, "got %d bytes ... press <CR> to continue ...", got);
	fgets(cbuf, SZ_LINE, stdin);
	xwait--;
      }
      i = save_bytes;
      save_bytes += got;
      if( save_buf == NULL )
	save_buf = (char *)xmalloc(save_bytes);
      else
	save_buf = (char *)xrealloc(save_buf, save_bytes);
      memcpy(&save_buf[i], tbuf, got);
    }
    if( !quiet )
      fprintf(stdout, "\tcallback read %d bytes\n", save_bytes);
  }
  else{
    if( !quiet ){
      fprintf(stdout, "\tenter callback with buf: %d bytes\n", len);
    }
    save_bytes = len;
    save_buf = (char *)xmalloc(len);
    memcpy(save_buf, buf, len);
  }
  if( !quiet ){
    fprintf(stdout, "RECEIVE_CB complete\n");
  }
  else{
    fprintf(stdout, ".");
  }
  fflush(stdout);
  fflush(stderr);
  return(0);
}

#ifdef ANSI_FUNC
int 
info_cb (void *client_data, void *call_data, char *paramlist)
#else
int info_cb(client_data, call_data, paramlist)
     void *client_data;
     void *call_data;
     char *paramlist;
#endif
{
  XPA xpa = (XPA)call_data;
  char *s = (char *)client_data;
  char xtemplate[SZ_LINE];
  char *names[MAX_FPS];
  char *bufs[MAX_FPS];
  char *errs[MAX_FPS];
  int lens[MAX_FPS];
  int i;
  int ip;
  int got;

  if( !quiet ){
    fprintf(stdout, "INFO_CB #%d: %s:%s (%s)\n",
	    n++, xpa_class(xpa), xpa_name(xpa), s);
  }

  if( paramlist && *paramlist ){
    if( !quiet )
      fprintf(stdout, "\tparamlist: %s\n", paramlist);
    ip = 0;
    word(paramlist, xtemplate, &ip);
    if( !strcmp(xtemplate, "xpaget") ){
      word(paramlist, xtemplate, &ip);
      got = XPAGet(xpa, xtemplate, &(paramlist[ip]), NULL,
		   bufs, lens, names, errs, MAX_FPS);
      if( !quiet )
	fprintf(stdout, "XPAGet (%s) returned %d buffer(s)\n", xtemplate, got);
      for(i=0; i<got; i++){
	if( !quiet )
	  fprintf(stdout, "\t%d: %s\n", i, names[i]);
	if( errs[i] == NULL ){
	  if( !quiet && (lens[i] > 0) ){
	    fprintf(stdout, "contents (%d bytes):\n", lens[i]);
	    fwrite(bufs[i], sizeof(char), lens[i], stdout);
	  }
	  if( !quiet )
	    fprintf(stdout, "\n");
	}
	else{
	  write(fileno(stdout), errs[i], strlen(errs[i]));
	}
	if( bufs[i] )
	  xfree(bufs[i]);
	if( names[i] )
	  xfree(names[i]);
	if( errs[i] )
	  xfree(errs[i]);
      }
    }
  }
  if( !quiet ){
    fprintf(stdout, "INFO_CB complete\n");
  }
  else{
    fprintf(stdout, ".");
  }
  fflush(stdout);
  fflush(stderr);
  return(0);
}

#ifdef ANSI_FUNC
int 
main (int argc, char **argv)
#else
main(argc, argv)
     int argc;
     char **argv;
#endif
{
#if HAVE_XT
  Widget top;
  XtAppContext appcontext;
#endif
  char *proxy=NULL;
  char tbuf[SZ_LINE];
  char tbuf2[SZ_LINE];
  char cmd[SZ_LINE];
  int c;
  int got=0;
  int x=0;
  int delay=0;

#if HAVE_MINGW32==0
  setvbuf(stdout, NULL, _IONBF, 0);
  setvbuf(stderr, NULL, _IONBF, 0);
#endif

  *cmd = '\0';
  /* process switch arguments */
  while ((c = getopt(argc, argv, "1ad:f:mqrRp:suwxX")) != -1){
    switch(c){
    case '1':
      doone = 1;
      break;
    case 'a':
      mode = "ack=false";
      break;
    case 'd':
      delay = atoi(optarg);
      break;
    case 'f':
      snprintf(cmd, SZ_LINE, "%s %s &\n", argv[0], optarg);
      break;
    case 'm':
      domyfree = 1;
      break;
    case 'q':
      quiet = 1;
      break;
    case 'p':
      proxy = optarg;
      break;
    case 'r':
      mode = "fillbuf=false";
      break;
    case 'R':
      mode = "fillbuf=false";
      dofill = 1;
      break;
    case 's':
      x = 0;
      break;
    case 'u':
      mode = "buf=false";
      break;
    case 'w':
      dowait++;
      break;
    case 'x':
      doatexit=1;
      break;
    case 'X':
      x = 1;
      break;
    }
  }

  if( optind >= argc ){
    strcpy(name, "xpa");
  }
  else{
    strcpy(name, argv[optind]);
  }
  strcpy(xclass, name);
  cluc(xclass);

  if( doatexit ){
    XPAAtExit();
  }

  if( x ){
#if HAVE_XT
    top = XtAppInitialize(&appcontext, "Server", NULL, 0,
			  &argc, argv, NULL, NULL, 0);
    XtVaSetValues(top, XtNwidth, (XtArgVal)10, XtNheight, (XtArgVal)10,
		  XtNmappedWhenManaged, (XtArgVal)False, NULL);
#else
    fprintf(stderr, "Xt is not available ...\n");
    got = 1;
    goto done;
#endif
  }

  strcpy(tbuf, name);
  snprintf(tbuf2, SZ_LINE, "help for %s", tbuf);
  xpa1 = XPANew(xclass, tbuf, tbuf2,
		send_cb, (void *)"send1", mode, 
		receive_cb, (void *)"receive1", mode);
  if( xpa1 == NULL ){
    fprintf(stderr, "ERROR: could not init xpa1\n");
  }
  else{
    fprintf(stdout, "%s using method: %s\n", xpa_name(xpa1), xpa_method(xpa1));
  }

  if( !doone ){
    snprintf(tbuf, SZ_LINE, "%s1", name);
    snprintf(tbuf2, SZ_LINE, "help for %s", tbuf);
    xpa1a = XPANew(xclass, tbuf, tbuf2,
		   send_cb, (void *)"send1a", mode, 
		   receive_cb, (void *)"receive1a", mode);
    if( xpa1a == NULL ){
      fprintf(stderr, "ERROR: could not init xpa1a\n");
    }
    else{
      fprintf(stdout, "%s using method: %s\n", 
	      xpa_name(xpa1a), xpa_method(xpa1a));
    }
    
    snprintf(tbuf, SZ_LINE, "c_%s", name);
    xpa2 = XPACmdNew(xclass, tbuf);
    if( xpa2 == NULL ){
      fprintf(stderr, "ERROR: could not init xpa2\n");
    }
    else{
      XPACmdAdd(xpa2, "cmd2", "and help for cmd2",
		send_cb, (void *)"cmd2", mode, 
		receive_cb, (void *)"cmd2", mode);
      XPACmdAdd(xpa2, "cmd1 xx yy", "help for cmd1 xx yy",
		send_cb, (void *)"cmd1 xx yy", mode, 
		receive_cb, (void *)"cmd1 xx yy", mode);
      XPACmdAdd(xpa2, "cmd1 xx", "help for cmd1 xx",
		send_cb, (void *)"cmd1 xx", mode, 
		receive_cb, (void *)"cmd1 xx", mode);
      XPACmdAdd(xpa2, "cmd1", NULL,
		send_cb, (void *)"cmd1", mode, 
		receive_cb, (void *)"cmd1", mode);
      fprintf(stdout, "%s using method: %s\n", 
	      xpa_name(xpa2), xpa_method(xpa2));
    }
    
    snprintf(tbuf, SZ_LINE, "i_%s", name);
    xpa3 = XPAInfoNew(xclass, tbuf, info_cb, (void *)"info1", mode);
    if( xpa3 == NULL ){
      fprintf(stderr, "ERROR: could not init xpa3\n");
    }
    else{
      fprintf(stdout, "%s using method: %s\n", xpa_name(xpa3), xpa_method(xpa3));
    }
  }
    
  if( *cmd != '\0' ){
    fprintf(stdout, "starting bkgd process: %s", cmd);
    system(cmd);
  }

  /* delay if necessary */
  if( delay ){
    fprintf(stdout, "starting delay of %d seconds ...", delay);
    sleep(delay);
    fprintf(stdout, " done\n");
  }
  fflush(stdout);
  fflush(stderr);

  /* connect to proxy, if necessary */
  if( proxy ){
    if( XPARemote(xpa1, proxy, "+", "proxy=true") < 0 ){
      fprintf(stderr, "ERROR: could not connect to proxy: %s\n", proxy);
    }
  }

  if( x ){
#if HAVE_XT
    fprintf(stdout, "\nEntering Xt loop ...\n");
    XPAXtAddInput(appcontext, NULL);
    XtRealizeWidget(top);
    XtAppMainLoop(appcontext);
#else
    fprintf(stderr, "Xt is not available ...\n");
    got = 1;
    goto done;
#endif
  }
  else{
    fprintf(stdout, "\nEntering select loop ...\n");
    if( !doatexit ){
      XPAMainLoop();
    } else {
      while( !please_exit )
	if( !XPAPoll(-1, 100) ) please_exit=1;
    }
    goto done;
  }

done:
  if( !doatexit ){
    XPAFree(xpa1);
    if( !doone ){
      XPAFree(xpa1a);
      XPAFree(xpa2);
      XPAFree(xpa3);
    }
  }

  /* make valgrind happy */
  XPACleanup();
  if( save_buf ) xfree(save_buf);
  exit(got);
}