#include <stdio.h>

#ifdef NT
#include <windows.h>
#include <winsock.h>
#define strdup _strdup
#define ltoa   _ltoa
#define CONFIG_FILE "k95d.cfg"
#else

#define CONFIG_FILE "k2d.cfg"
#endif


#define bzero(x,y) memset(x,0,y)
#define BSDSELECT

#define MAXPORTS 32
struct PORT
{
    short id ;
    int   lsocket ;
    int   asocket ;
    char  * k95cmd ;
    int   showcmd;
    int   rdns;
} ports[MAXPORTS] ;
int portcount = 0 ;

#define MAXCHILDREN 256
struct CHILDREN
{
    HANDLE hProcess;
    int    socket;
} children[MAXCHILDREN];
int childcount = 0;

void
init_children(void)
{       
    int i;
    for ( i=0 ;i<MAXCHILDREN;i++ ) {
        children[i].hProcess = INVALID_HANDLE_VALUE;
        children[i].socket = (int)INVALID_HANDLE_VALUE;
    }   
}

void
check_children(void)
{
    int i,found;
    DWORD dwExit;

    for (i=0, found=0; i<MAXCHILDREN && found<childcount; i++) {
        if ( children[i].hProcess != INVALID_HANDLE_VALUE ) {
            if (GetExitCodeProcess(children[i].hProcess, &dwExit)) {
                if ( dwExit != STILL_ACTIVE ) {
                    closesocket(children[i].socket);
                    CloseHandle(children[i].hProcess);
                    children[i].socket = (int)INVALID_HANDLE_VALUE;
                    children[i].hProcess = INVALID_HANDLE_VALUE;
                    childcount--;       
                    /* Do not increase found if we reduce childcount */
                    continue;
                }
            }
            found++;
        }
    }
}

void
add_child(HANDLE hProcess, int socket)
{
    int i;
    for ( i=0;i<MAXCHILDREN;i++ ) {
        if ( children[i].hProcess == INVALID_HANDLE_VALUE ) {
            children[i].hProcess = hProcess;
            children[i].socket = socket;
            childcount++;
            return;
        }
    }
}

int
ParseCmdLine( int argc, char * argv[] )
{
    int len = 0, i ;
    char * p = NULL ;
    static struct servent *service, servrec;
    int arg = 1;

   if ( argc < 3 )
      return 0;

    ports[portcount].showcmd = SW_SHOWNORMAL;
    ports[portcount].rdns = 1;

    for ( arg = 1; argv[arg][0] == '-' && argv[arg][1] == '-' ; arg++ ) {
        if ( !_stricmp("--maximized",argv[arg]) )
             ports[portcount].showcmd = SW_SHOWMAXIMIZED;
        else if ( !_stricmp("--minimized",argv[arg]) )
             ports[portcount].showcmd = SW_SHOWMINIMIZED;
        else if ( !_stricmp("--normal",argv[arg]) )
             ports[portcount].showcmd = SW_NORMAL;
        else if ( !_stricmp("--minnoactive",argv[arg]) )
             ports[portcount].showcmd = SW_SHOWMINNOACTIVE;
        else if ( !_stricmp("--nodns",argv[arg]) )
             ports[portcount].rdns = 0;
    }

    p = argv[arg];                      /* Was a service requested? */

    if (isdigit(*p)) {                  /* Use socket number without lookup */
      service = &servrec;
      service->s_port = htons((unsigned short)atoi(p));
   } else {                             /* Otherwise lookup the service name */
      service = getservbyname(p, "tcp");
   }

   if ( service )
   {
      ports[portcount].id = service->s_port ;
   }
   else if ( !strcmp( "kermit", p ) )
   {  /* use now assigned Kermit Service Port */
      service = &servrec ;
      service->s_port = htons( 1649 ) ;
   }
   else /* !service */
   {
      fprintf(stderr, "Cannot find port for service %s\n", p);
      exit(2);
   }

    arg++;

   for ( i = arg ; i < argc ; i++ )
   {
      len += strlen( argv[i] ) + 1 ;
   }

   ports[portcount].k95cmd = (char *) malloc( len ) ;
   if ( !ports[portcount].k95cmd )
   {
      fprintf( stderr, "memory allocation error\n" ) ;
      exit(1) ;
   }

   ports[portcount].k95cmd[0] = '\0' ;
   for ( i=arg ; i<argc ; i++ )
   {
      strcat( ports[portcount].k95cmd, argv[i] ) ;
   }
   portcount++ ;
   return portcount ;
}

int
ParseCfgFile( void )
{
   FILE * cfgfd = NULL ;
   static struct servent *service, servrec;
   char cmdbuf[256], *p ;
   int i ;

   p = cmdbuf;

   /* try and open file in local directory */
    cfgfd = fopen( CONFIG_FILE, "r" ) ;
   if ( !cfgfd )
      return 0;

   while ( !feof(cfgfd) && portcount < MAXPORTS )
   {
       ports[portcount].showcmd = SW_SHOWNORMAL;
       ports[portcount].rdns = 1;
       service = NULL ;

      /* read and parse the first white space delimited string */
      switch ( fscanf( cfgfd, "%s ", &cmdbuf ) )
      {
      case EOF:
         fclose( cfgfd ) ;
         return portcount ;

      case 0:
         /* lets assume we should just skip this line */
         fscanf( cfgfd, "%[^\n]\n", cmdbuf ) ;
         break;

      default:
         {
           flag:
             /* look for an optional show flag */
             if ( p[0] == '-' && p[1] == '-' ) {
                 if ( !_stricmp("--maximized",p) )
                     ports[portcount].showcmd = SW_SHOWMAXIMIZED;
                 else if ( !_stricmp("--minimized",p) )
                     ports[portcount].showcmd = SW_SHOWMINIMIZED;
                 else if ( !_stricmp("--normal",p) )
                     ports[portcount].showcmd = SW_NORMAL;
                 else if ( !_stricmp("--minnoactive",p) )
                     ports[portcount].showcmd = SW_SHOWMINNOACTIVE;
                 else if ( !_stricmp("--nodns",p) )
                     ports[portcount].rdns = 0;

                 p = cmdbuf;
                 *p = '\0';

                 /* now read the service */
                 switch ( fscanf( cfgfd, "%s ", &cmdbuf ) )
                 {
                 case EOF:
                     fclose( cfgfd ) ;
                     return portcount ;

                 case 0:
                     /* lets assume we should just skip this line */
                     fscanf( cfgfd, "%[^\n]\n", cmdbuf ) ;
                     break;

                 default:
                     if ( p[0] == '-' && p[1] == '-' )
                         goto flag;
                     break;
                 }

             }

             if (isdigit(*p)) {                 /* Use socket number without lookup */
               service = &servrec;
               service->s_port = htons((unsigned short)atoi(p));
            } else {                            /* Otherwise lookup the service name */
               service = getservbyname(p, "tcp");
            }

            if ( service )
            {
               ports[portcount].id = service->s_port ;
            }
            else if ( !strcmp( "kermit", p ) )
            {  /* use now assigned Kermit Service Port */
               service = &servrec ;
               ports[portcount].id = service->s_port = htons( 1649 ) ;
            }
            else /* ( !service ) */
            {
               if ( cmdbuf[0] != ';' )
                  fprintf( stderr, "WARNING: invalid service or port \"%s\"\n",
                           cmdbuf ) ;
               fscanf( cfgfd, "%[^\n]\n", cmdbuf ) ;
               break;
            }

            for ( i=0 ; i<portcount ; i++ )
            {
               if ( ports[i].id == ports[portcount].id )
               {
                  fprintf( stderr, "WARNING: ignoring duplicate entry for port \"%s\"\n",
                           cmdbuf ) ;
                  fscanf( cfgfd, "%[^\n]\n", cmdbuf ) ;
                  break;
               }
            }

            /* Parse the rest of the line or up to a comment */
            switch ( fscanf( cfgfd, "%[^;\n]", cmdbuf ) )
            {
            case EOF:
            case 0:
               fclose( cfgfd ) ;
               return portcount;

            default:
               ports[portcount].k95cmd = strdup(cmdbuf) ;
               ports[portcount].lsocket = -1 ;
               ports[portcount].asocket = -1 ;
               portcount++ ;
            }
         }
      }
   }
   fclose( cfgfd ) ;
   return portcount ;
}

HANDLE
StartKermit( int socket, char * scriptfile, int ShowCmd, int * psockdup )
{
#ifdef NT
   PROCESS_INFORMATION StartKermitProcessInfo ;
   OSVERSIONINFO osverinfo ;
   STARTUPINFO si ;
   HANDLE sockdup = INVALID_HANDLE_VALUE ;
   static char buf[512] ;

    *psockdup = (int)INVALID_HANDLE_VALUE;

   osverinfo.dwOSVersionInfoSize = sizeof(OSVERSIONINFO) ;
   GetVersionEx( &osverinfo ) ;

   memset( &si, 0, sizeof(STARTUPINFO) ) ;
   si.cb = sizeof(STARTUPINFO);
   si.dwFlags = STARTF_USESHOWWINDOW;
   si.wShowWindow = ShowCmd;

   if (!DuplicateHandle( GetCurrentProcess(), (HANDLE) socket,
                    GetCurrentProcess(), &sockdup,
                    DUPLICATE_SAME_ACCESS, TRUE,
                    DUPLICATE_CLOSE_SOURCE | DUPLICATE_SAME_ACCESS ))
   {
      closesocket( (int) socket ) ;
      fprintf( stderr, "\nKERMIT DAEMON FATAL ERROR:\n" );
      fprintf( stderr, " You are using a WinSOCK which does not allow socket handles\n");
      fprintf( stderr, " to be duplicated or shared with child processes.\n\n");
      fprintf( stderr, " If you are attempting to start Kermit 95 Host Mode,\n");
      fprintf( stderr, " please change SESSIONS to 1 in your configuration.\n");
      fprintf( stderr, "\n Press ENTER to exit...\n");
      fscanf( stdin, "" ) ;
      exit( 2 ) ;
   }
   strcpy( buf, "k95.exe -j $" ) ;
   ltoa( (LONG) sockdup, buf+strlen(buf), 10 ) ;
   strcat( buf, " -C \"" ) ;
   strcat( buf, scriptfile ) ;
   strcat( buf, "\"" ) ;

   printf("Executing: %s\n",buf ) ;
   if (!CreateProcess(
                       (LPSTR)NULL,          /* start K-95  */
                       (LPSTR)buf, /* give it the file */
                       (LPSECURITY_ATTRIBUTES)NULL, /* fix if necessary */
                       (LPSECURITY_ATTRIBUTES)NULL, /* fix if necessary */
                        TRUE,                      /* fix if necessary */
                       (DWORD) CREATE_NEW_CONSOLE | CREATE_NEW_PROCESS_GROUP,
                       (LPVOID)NULL,                /* fix if necessary */
                       (LPSTR)NULL,               /* Current directory */
                       &si,                     /* Startup info, fix */
                       &StartKermitProcessInfo  /* Process info */
                      ))
    {
        CloseHandle(StartKermitProcessInfo.hThread);
        *psockdup = (int)sockdup;
        return (StartKermitProcessInfo.hProcess);
    }
    else
    {
        closesocket( (int) sockdup ) ;
        CloseHandle(StartKermitProcessInfo.hProcess);
        CloseHandle(StartKermitProcessInfo.hThread);
        return(INVALID_HANDLE_VALUE);
    }
#else /* NT */

#endif /* NT */
}

int
main( int argc, char * argv[] ) {
   char *p;
   int i, x;
   int on = 1, rc = 0;
   int ready_to_accept = 0 ;
   static struct servent *service, servrec;
   static struct hostent *host;
   static struct sockaddr_in saddr;
   static int saddrlen ;
#ifdef BSDSELECT
    fd_set rfds;
    struct timeval tv;
#endif /* BSDSELECT */
   int tcpsrv_fd = -1, ttyfd = -1 ;
#ifdef NT
    WSADATA data ;
    HANDLE hProcess;
    int sockdup = (int)INVALID_HANDLE_VALUE;

   printf("Kermit-95 Daemon\n");
   rc = WSAStartup( MAKEWORD( 2, 0 ), &data ) ;
   if ( rc == WSAVERNOTSUPPORTED )
   {

      WSACleanup() ;
      rc = WSAStartup( MAKEWORD( 1, 1 ), &data ) ;
   }
#else /* NT */

#endif /* NT */

    init_children();

   ParseCmdLine( argc, argv ) ;

   if ( !portcount ) /* Only use k95.cfg if there was no command line */
      ParseCfgFile() ;

   if ( !portcount )
   {
      fprintf( stderr, "Nothing to do." ) ;
      exit(8) ;
   }


   for ( i=0; i<portcount; i++)
   {
      /* Set up socket structure and get host address */

      bzero((char *)&saddr, sizeof(saddr));
      saddr.sin_family = AF_INET ;
      saddr.sin_addr.s_addr = INADDR_ANY ;

      /* Get a file descriptor for the connection. */

      saddr.sin_port = ports[i].id;

      if ((ports[i].lsocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
      {
         perror("TCP socket error");
         exit (3);
      }
      errno = 0;

      /* Specify the Port may be reused */
      setsockopt(ports[i].lsocket, SOL_SOCKET, SO_REUSEADDR,(char *) &on, sizeof on);

      /* Now bind to the socket */
#ifdef DEBUG
      printf("Binding socket to port %d ... ",
              ntohs((unsigned short)ports[i].id)) ;
#endif
      if (bind(ports[i].lsocket, (struct sockaddr *)&saddr, sizeof(saddr)) < 0)
      {
         i = errno;                     /* save error code */
         closesocket(ports[i].lsocket) ;
         ports[i].lsocket = -1 ;
         ports[i].asocket = -1;
         errno = i;                     /* and report this error */
         fprintf(stderr,"tcpsrv_open bind errno","",errno);
         exit(4);
      }
#ifdef DEBUG
      printf("Listening ...\n");
#endif
      if (listen(ports[i].lsocket, 15) < 0)
      {
         i = errno;                     /* save error code */
         closesocket(ports[i].lsocket) ;
         ports[i].lsocket = -1 ;
         ports[i].asocket = -1;
         errno = i;                     /* and report this error */
         fprintf(stderr,"tcpsrv_open listen errno","",errno);
         exit(5);
      }
   }

   printf("Servicing ports:\n");
   for ( i=0;i<portcount ;i++ )
   {
      printf("  %d\n", ntohs((unsigned short)ports[i].id) ) ;
   }
    printf("Press Ctrl-C to cancel...\n");

   saddrlen = sizeof(saddr) ;

#ifdef BSDSELECT
   tv.tv_sec  = 1L;
   tv.tv_usec = 0L;
#endif /* BSDSELECT */

   for ( ;; )
   {
      while ( !ready_to_accept )
      {
          check_children();

#ifdef BSDSELECT
         FD_ZERO(&rfds);
         for ( i=0; i<portcount;i++ )
            FD_SET(ports[i].lsocket, &rfds);
         if (select(FD_SETSIZE, &rfds, NULL, NULL, &tv ) > 0)
         {
            for ( i=0; i<portcount ; i++ )
            {
               if ( ready_to_accept = FD_ISSET(ports[i].lsocket, &rfds) )
                  break;
            }
         }
#else /* BSDSELECT */
#ifdef IBMSELECT
???      /* in order to make this work, we need to create an array of socket values */
         ready_to_accept = (( select(&tcpsrv_fd, 1, 0, 0,1 )) == 1) ;
#endif /* IBMSELECT */
#endif /* BSDSELECT */
      }

      if ( ready_to_accept )
      {
         if ((ports[i].asocket = accept(ports[i].lsocket, (struct sockaddr *)&saddr,&saddrlen)) < 0)
         {
            i = errno;                  /* save error code */
            closesocket(ports[i].lsocket) ;
            ports[i].asocket = -1;
            ports[i].lsocket = -1 ;
            errno = i;                  /* and report this error */
            fprintf(stderr,"tcpsrv_open accept errno","",errno);
            exit(6);
         }

         setsockopt(ports[i].asocket, SOL_SOCKET, SO_OOBINLINE,(char *) &on, sizeof on);

         if (ports[i].rdns &&
             (host = gethostbyaddr((char *)&saddr.sin_addr,4,PF_INET)) != NULL)
         {
            printf("%s [%s] connected on port %d\n",host->h_name,
                    (char *)inet_ntoa(saddr.sin_addr),ntohs(ports[i].id));
         } else {
            printf("%s connected on port %d\n",(char *)inet_ntoa(saddr.sin_addr),
                   ntohs(ports[i].id));
         }

         /* Now start subprocess */
         printf("Starting Kermit with socket %d and command %s\n",ports[i].asocket,ports[i].k95cmd);
          hProcess = StartKermit(ports[i].asocket,ports[i].k95cmd, ports[i].showcmd, &sockdup);
          if ( hProcess != INVALID_HANDLE_VALUE ) 
              add_child(hProcess, sockdup);
          else
              closesocket(ports[i].asocket);      /* we use CLOSE_SOURCE when duplicating */
         continue;                              /* Go get the next one */
      }
      else
      {
         i = errno;                     /* save error code */
         closesocket(ports[i].lsocket) ;
         ports[i].lsocket = -1;
         ports[i].asocket = -1;
         errno = i;                     /* and report this error */
         fprintf(stderr,"tcpsrv_open accept errno","",errno);
         exit(7);
      }
   }

#ifdef NT
   WSACleanup() ;
#else

#endif /* NT */
}