proj/util/apps/index_convert.c

/*
 *
 * index_convert - Converts a slot value to an index, or vise versa, for a given series.
 *
 */

#include "jsoc_main.h"
#include "drms.h"
#include "atoinc.h"

#define NOT_SPECIFIED   "NOT SPECIFIED"

ModuleArgs_t module_args[] =
{ 
    {ARG_STRING, "ds", NOT_SPECIFIED,  "Input data series."},
    {ARG_FLAG, "h", "0", "Help - Print usage and exit"},
    {ARG_END}
};

#define DIE(msg) {fprintf(stderr,"%s\n",msg);exit(1);}

char *module_name = "index_convert";

int nice_intro ()
  {
  int usage = cmdparams_get_int (&cmdparams, "h", NULL);
  if (usage)
    {
    printf ("Usage:\nndex_convert [-h] "
        "ds=<seriesname> {<pkey>=<value>} | {<pkey>_index=<indexvalue>} \n"
        "  -h: help - show this message then exit\n"
        "ds=<seriesname> - required\n"
        "<pkey> - prime key to use\n"
        "<pkey>_index - prime index key to use\n"
        "Only one of <pkey> or <pkey>_index is allowed\n"
        );
    return(1);
    }
  return (0);
  }

/* Module main function. */
int DoIt(void)
  {
  int status = 0;
  DRMS_Record_t *template;
  DRMS_Keyword_t *skey, *pkey;
  DRMS_Type_t ptype;
  int npkeys;
  char *pname=NULL;
  char *piname=NULL;
  char *seriesname;
  char *inbracket;
  const char *ds = cmdparams_get_str (&cmdparams, "ds", NULL);
  int ikey;

  if (nice_intro()) return(0);

  /* check for minimum inputs */
  if (strcmp(ds, NOT_SPECIFIED) == 0 )
    DIE("No dataseries: at least ds must be specified");

  /* get series info and prime key type, etc. */
  inbracket = index(ds, '[');
  if (inbracket)
      *inbracket = '\0';
  template = drms_template_record (drms_env, ds, &status);
  if (!template || status)
    DIE("Series not found");

  npkeys = template->seriesinfo->pidx_num;
  if (npkeys < 1)
    DIE("Series has no prime keys");

  // for each prime key check command line for key or key_index args
  // ignore non-slotted prime keys
  // The first appropriate key is used.
  for (ikey=0; ikey < npkeys; ikey++)
    {
    pkey = template->seriesinfo->pidx_keywords[ikey];
    if (pkey->info->recscope > 1)
        {
        if (cmdparams_exists(&cmdparams, pkey->info->name))
            {
            // pkey->value.longlong_val = params_get_int64(&cmdparams, pkey->info->name);
            skey = drms_keyword_slotfromindex(pkey);
            long long indexval = params_get_int64(&cmdparams, pkey->info->name);
            double epoch = drms_keyword_getslotepoch(skey, &status);
            double step = drms_keyword_getvalkeystep(skey, &status);
            skey->value.double_val = indexval * step + epoch;
            drms_keyword_printval(skey);
            printf("\n");
            return(0);
            }
        skey = drms_keyword_slotfromindex(pkey);
        if (cmdparams_exists(&cmdparams, skey->info->name))
            {
                DRMS_Value_t indexval;
                DRMS_Value_t inval;
                if (skey->info->type == DRMS_TYPE_TIME)
                inval.value.time_val = params_get_time(&cmdparams, skey->info->name);
                else 
                inval.value.double_val = params_get_double(&cmdparams, skey->info->name);
                inval.type = skey->info->type;
                drms_keyword_slotval2indexval(skey, &inval, &indexval, NULL);
                pkey->value.longlong_val = indexval.value.longlong_val;
                drms_keyword_printval(pkey);
            printf("\n");
            return(0);
            }
        }
    }
  return(1);
  }

---