/*
 *  eval_input_gf.c - Part of AFD, an automatic file distribution program.
 *  Copyright (c) 2000 - 2020 Holger Kiehl <Holger.Kiehl@dwd.de>
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

#include "afddefs.h"

DESCR__S_M3
/*
 ** NAME
 **   eval_input_gf - checks syntax of input for process gf_xxx
 **
 ** SYNOPSIS
 **   int eval_input_gf(int argc, char *argv[], struct job *p_db)
 **
 ** DESCRIPTION
 **   This function evaluates the parameters given to the process
 **   gf_xxx which may have the following format:
 **
 **    gf_xxx <work dir> <job no.> <FSA id> <FSA pos> <FRA id> <FRA pos> [options]
 **        OPTIONS
 **          -c                        Enable support for hardware CRC-32.
 **          -d                        Distributed helper job.
 **          -e <seconds>              Disconnect after given time.
 **          -h <HTTP proxy>[:<port>]  Proxy where to send the HTTP requests.
 **          -i <interval>             Interval at which we should retry.
 **          -m <mode>                 Create source dir mode.
 **          -o <retries>              Old/Error message and number of retries.
 **          -t                        Temp toggle.
 **
 ** RETURN VALUES
 **   struct job *p_db   -
 **
 ** AUTHOR
 **   H.Kiehl
 **
 ** HISTORY
 **   18.08.2000 H.Kiehl Created
 **   12.04.2003 H.Kiehl Rewrite to accomodate to new syntax.
 **   09.07.2009 H.Kiehl Added -i option.
 **   28.12.2011 H.Kiehl Added -h to specify HTTP proxy.
 **   25.01.2013 H.Kiehl Added -c for hardware CRC-32 support.
 **   16.08.2014 H.Kiehl Added -m for creating remote source directories.
 **   01.07.2015 H.Kiehl Added -e for disconnect time.
 **   01.08.2019 H.Kiehl Added Fra position.
 **
 */
DESCR__E_M3

#include <stdio.h>                 /* stderr, fprintf()                  */
#include <stdlib.h>                /* exit(), atoi(), strtoul()          */
#include <string.h>                /* strcpy(), strerror(), strcmp()     */
#include <ctype.h>                 /* isdigit()                          */
#include <errno.h>
#include "fddefs.h"

/* Global variables. */
extern int                        fsa_id;
#ifdef HAVE_HW_CRC32
extern int                        have_hw_crc32;
#endif
extern char                       *p_work_dir;
extern struct filetransfer_status *fsa;

/* Local function prototypes. */
static void                       usage(char *);


/*########################### eval_input_gf() ###########################*/
int
eval_input_gf(int argc, char *argv[], struct job *p_db)
{
   int ret = SUCCESS;

   if (argc < 7)
   {
      usage(argv[0]);
      ret = SYNTAX_ERROR;
   }
   else
   {
      if (p_work_dir == NULL)
      {
         size_t length;

         length = strlen(argv[1]) + 1;
         if ((p_work_dir = malloc(length)) == NULL)
         {
            (void)fprintf(stderr,
#if SIZEOF_SIZE_T == 4
                          "ERROR   : Failed to malloc() %d bytes : %s",
#else
                          "ERROR   : Failed to malloc() %lld bytes : %s",
#endif
                          (pri_size_t)length, strerror(errno));
            ret = ALLOC_ERROR;
            return(-ret);
         }
         (void)memcpy(p_work_dir, argv[1], length);
      }
      if (isdigit((int)(argv[2][0])) == 0)
      {
         (void)fprintf(stderr,
                       "ERROR   : None nummeric value for job number : %s.\n",
                       argv[2]);
         usage(argv[0]);
         ret = SYNTAX_ERROR;
      }
      else
      {
         int i;

         p_db->job_no = (char)atoi(argv[2]);

         /* Check if FSA ID is correct. */
         i = 0;
         do
         {
            if (isdigit((int)(argv[3][i])) == 0)
            {
               i = MAX_INT_LENGTH;
            }
            i++;
         } while ((argv[3][i] != '\0') && (i < MAX_INT_LENGTH));
         if ((i > 0) && (i < MAX_INT_LENGTH))
         {
            fsa_id = atoi(argv[3]);

            /* Check if FSA position is correct. */
            i = 0;
            do
            {
               if (isdigit((int)(argv[4][i])) == 0)
               {
                  i = MAX_INT_LENGTH;
               }
               i++;
            } while ((argv[4][i] != '\0') && (i < MAX_INT_LENGTH));
            if ((i > 0) && (i < MAX_INT_LENGTH))
            {
               p_db->fsa_pos = atoi(argv[4]);

               /* Check if FRA ID is correct. */
               i = 0;
               do
               {
                  if (isxdigit((int)(argv[5][i])) == 0)
                  {
                     i = MAX_INT_HEX_LENGTH;
                  }
                  i++;
               } while ((argv[5][i] != '\0') && (i < MAX_INT_HEX_LENGTH));
               if ((i > 0) && (i < MAX_INT_HEX_LENGTH))
               {
                  errno = 0;
                  p_db->id.dir = (unsigned int)strtoul(argv[5], (char **)NULL, 16);
                  if (errno != ERANGE)
                  {
                     /* Check if FRA position is correct. */
                     i = 0;
                     do
                     {
                        if (isdigit((int)(argv[6][i])) == 0)
                        {
                           i = MAX_INT_LENGTH;
                        }
                        i++;
                     } while ((argv[6][i] != '\0') && (i < MAX_INT_LENGTH));

                     if ((i > 0) && (i < MAX_INT_LENGTH))
                     {
                        p_db->fra_pos = atoi(argv[6]);

                        if (fsa_attach_pos(p_db->fsa_pos) == SUCCESS)
                        {
                           /*
                            * Now lets evaluate the options.
                            */
                           for (i = 7; i < argc; i++)
                           {
                              if (argv[i][0] == '-')
                              {
                                 switch (argv[i][1])
                                 {
#ifdef HAVE_HW_CRC32
                                    case 'c' : /* CPU supports CRC32 in HW. */
                                       have_hw_crc32 = YES;
                                       break;
#endif
                                    case 'd' : /* Distribution helper job. */
                                       p_db->special_flag |= DISTRIBUTED_HELPER_JOB;
                                       break;
                                    case 'e' : /* Disconnect after given time. */
                                       if (((i + 1) < argc) &&
                                           (argv[i + 1][0] != '-'))
                                       {
                                          p_db->disconnect = (unsigned int)strtoul(argv[i + 1], (char **)NULL, 10);
                                       }
                                       else
                                       {
                                          (void)fprintf(stderr,
                                                        "ERROR   : No disconnect time specified for -d option.\n");
                                          usage(argv[0]);
                                          ret = SYNTAX_ERROR;
                                       }
                                       break;
                                    case 'h' : /* Default HTTP proxy. */
                                       if (((i + 1) < argc) &&
                                           (argv[i + 1][0] != '-'))
                                       {
                                          int k = 0;

                                          i++;
                                          while ((argv[i][k] != '\0') &&
                                                 (argv[i][k] != ':') &&
                                                 (k < MAX_REAL_HOSTNAME_LENGTH))
                                          {
                                             p_db->http_proxy[k] = argv[i][k];
                                             k++;
                                          }
                                          if ((k > 0) &&
                                              (k < MAX_REAL_HOSTNAME_LENGTH))
                                          {
                                             p_db->http_proxy[k] = '\0';
                                             if (argv[i][k] == ':')
                                             {
                                                p_db->port = atoi(&argv[i][k + 1]);
                                             }
                                          }
                                          else
                                          {
                                             if (k == 0)
                                             {
                                                (void)fprintf(stderr,
                                                              "ERROR   : No default HTTP proxy specified for -h option.\n");
                                             }
                                             else
                                             {
                                                (void)fprintf(stderr,
                                                              "ERROR   : Default HTTP proxy specified for -h option is to long, may only be %d bytes long.\n",
                                                              MAX_REAL_HOSTNAME_LENGTH);
                                             }
                                             usage(argv[0]);
                                             ret = SYNTAX_ERROR;
                                          }
                                       }
                                       else
                                       {
                                          (void)fprintf(stderr,
                                                        "ERROR   : No default HTTP proxy specified for -h option.\n");
                                          usage(argv[0]);
                                          ret = SYNTAX_ERROR;
                                       }
                                       break;
                                    case 'i' : /* Interval at which it should retry. */
                                       if (((i + 1) < argc) &&
                                           (argv[i + 1][0] != '-'))
                                       {
                                          int k = 0;

                                          i++;
                                          do
                                          {
                                             if (isdigit((int)(argv[i][k])) == 0)
                                             {
                                                k = MAX_INT_LENGTH;
                                             }
                                             k++;
                                          } while ((argv[i][k] != '\0') &&
                                                   (k < MAX_INT_LENGTH));
                                          if ((k > 0) && (k < MAX_INT_LENGTH))
                                          {
                                             p_db->remote_file_check_interval = (unsigned int)strtoul(argv[i], (char **)NULL, 10);
                                          }
                                          else
                                          {
                                             (void)fprintf(stderr,
                                                           "ERROR   : Hmm, could not find the interval for -i option.\n");
                                          }
                                       }
                                       else
                                       {
                                          (void)fprintf(stderr,
                                                        "ERROR   : No interval specified for -i option.\n");
                                          usage(argv[0]);
                                          ret = SYNTAX_ERROR;
                                       }
                                       break;
                                    case 'm' : /* The mode with which remote dirs should be created. */
                                       if (((i + 1) < argc) &&
                                           (argv[i + 1][0] != '-'))
                                       {
                                          int k = 0;

                                          i++;
                                          do
                                          {
                                             if ((argv[i][k] >= '0') &&
                                                 (argv[i][k] <= '7'))
                                             {
                                                p_db->dir_mode_str[k] = argv[i][k];
                                                k++;
                                             }
                                             else
                                             {
                                                k = 5;
                                             }
                                          } while ((argv[i][k] != '\0') &&
                                                   (k < 5));
                                          if ((k > 0) && (k < 5))
                                          {
                                             p_db->dir_mode = (unsigned int)strtoul(argv[i], (char **)NULL, 8);
                                             p_db->dir_mode_str[k] = '\0';
                                          }
                                          else
                                          {
                                             (void)fprintf(stderr,
                                                           "ERROR   : Hmm, could not find or evaluate the mode (%s) for -m option.\n",
                                                           argv[i]);
                                             p_db->dir_mode_str[0] = '0';
                                             p_db->dir_mode_str[1] = '\0';
                                          }
                                       }
                                       else
                                       {
                                          (void)fprintf(stderr,
                                                        "ERROR   : No mode specified for -m option.\n");
                                          usage(argv[0]);
                                          ret = SYNTAX_ERROR;
                                       }
                                       break;
                                    case 'o' : /* This is an old/error job. */
                                       p_db->special_flag |= OLD_ERROR_JOB;
                                       if (((i + 1) < argc) &&
                                           (argv[i + 1][0] != '-'))
                                       {
                                          int k = 0;

                                          i++;
                                          do
                                          {
                                             if (isdigit((int)(argv[i][k])) == 0)
                                             {
                                                k = MAX_INT_LENGTH;
                                             }
                                             k++;
                                          } while ((argv[i][k] != '\0') &&
                                                   (k < MAX_INT_LENGTH));
                                          if ((k > 0) && (k < MAX_INT_LENGTH))
                                          {
                                             p_db->retries = (unsigned int)strtoul(argv[i], (char **)NULL, 10);
                                          }
                                          else
                                          {
                                             (void)fprintf(stderr,
                                                           "ERROR   : Hmm, could not find the retries for -o option.\n");
                                          }
                                       }
                                       else
                                       {
                                          (void)fprintf(stderr,
                                                        "ERROR   : No retries specified for -o option.\n");
                                          usage(argv[0]);
                                          ret = SYNTAX_ERROR;
                                       }
                                       break;
                                    case 't' : /* Toggle host. */
                                       p_db->toggle_host = YES;
                                       break;
                                    default  : /* Unknown parameter. */
                                       (void)fprintf(stderr,
                                                     "ERROR  : Unknown parameter %c. (%s %d)\n",
                                                     argv[i][1], __FILE__, __LINE__);
                                       break;
                                 }
                              }
                           }
                        }
                        else
                        {
                           system_log(ERROR_SIGN, __FILE__, __LINE__,
                                     "Failed to attach to FSA.");
                           ret = SYNTAX_ERROR;
                        }
                     }
                     else
                     {
                        (void)fprintf(stderr,
                                      "ERROR   : Wrong value for FRA position : %s.\n",
                                      argv[6]);
                        usage(argv[0]);
                        ret = SYNTAX_ERROR;
                     }
                  }
                  else
                  {
                     (void)fprintf(stderr,
                                   "ERROR   : Could not resolve directory ID %s : %s\n",
                                   argv[5], strerror(errno));
                     usage(argv[0]);
                     ret = SYNTAX_ERROR;
                  }
               }
               else
               {
                  (void)fprintf(stderr,
                                "ERROR   : FRA ID does not look like a hex number or is to long or short : %s.\n",
                                argv[5]);
                  usage(argv[0]);
                  ret = SYNTAX_ERROR;
               }
            }
            else
            {
               (void)fprintf(stderr,
                             "ERROR   : Wrong value for FSA position : %s.\n",
                             argv[4]);
               usage(argv[0]);
               ret = SYNTAX_ERROR;
            }
         }
         else
         {
            (void)fprintf(stderr,
                          "ERROR   : Wrong value for FSA ID : %s.\n", argv[3]);
            usage(argv[0]);
            ret = SYNTAX_ERROR;
         }
      }
   }
   if (ret != SUCCESS)
   {
      ret = -ret;
   }
   return(ret);
} /* eval_input_gf() */


/*+++++++++++++++++++++++++++++++ usage() ++++++++++++++++++++++++++++++*/
static void
usage(char *name)
{
   (void)fprintf(stderr, "SYNTAX: %s <work dir> <job no.> <FSA id> <FSA pos> <dir alias> [options]\n\n", name);
   (void)fprintf(stderr, "OPTIONS                       DESCRIPTION\n");
   (void)fprintf(stderr, "  --version                 - Show current version\n");
#ifdef HAVE_HW_CRC32
   (void)fprintf(stderr, "  -c                        - Enable support for hardware CRC-32.\n");
#endif
   (void)fprintf(stderr, "  -d                        - this is a distributed helper job\n");
   (void)fprintf(stderr, "  -e <seconds>              - Disconnect after the given amount of time.\n");
   (void)fprintf(stderr, "  -h <HTTP proxy>[:<port>]  - Proxy where to send the HTTP request.\n");
   (void)fprintf(stderr, "  -i <interval>             - interval at which we should retry\n");
   (void)fprintf(stderr, "  -m <mode>                 - mode of the created source dir\n");
   (void)fprintf(stderr, "  -o <retries>              - old/error message\n");
   (void)fprintf(stderr, "  -t                        - use other host\n");

   return;
}