From fa080de7afc95aa1c19a6e6fc0e0708ced2eadc4 Mon Sep 17 00:00:00 2001
From: Joseph Hunkeler <jhunkeler@gmail.com>
Date: Wed, 8 Jul 2015 20:46:52 -0400
Subject: Initial commit

---
 vendor/voclient/voapps/voregistry.c | 1291 +++++++++++++++++++++++++++++++++++
 1 file changed, 1291 insertions(+)
 create mode 100644 vendor/voclient/voapps/voregistry.c

(limited to 'vendor/voclient/voapps/voregistry.c')

diff --git a/vendor/voclient/voapps/voregistry.c b/vendor/voclient/voapps/voregistry.c
new file mode 100644
index 00000000..a99c058f
--- /dev/null
+++ b/vendor/voclient/voapps/voregistry.c
@@ -0,0 +1,1291 @@
+/**
+ *  VOREGISTRY -- Registry resolution, query, and browsing
+ *
+ *
+ *    Usage:   voregistry [-<flags>] [ [<keyword>] | [<term>] ]
+ *
+ *      -h,--help                print this help
+ *      -v,--verbose             verbose mode
+ *         --vverbose            very-verbose mode
+ *
+ *      -c,--count               print a count of matching records
+ *      -e,--exact               print exactly matching records (resolve)
+ *      -l,--list                list full resource record
+ *      -m,--meta                list table metadata
+ *      -r,--resolve             resolution mode
+
+ *      -b,--bandpass <bandpass> constrain by bandpass
+ *      -C,--clevel <level>      constrain by content level
+ *      -d,--dal          	 constrain to only DAL services
+ *      -g,--group          	 group search terms
+ *      -s,--subject <subject>   constrain by subject string
+ *      -t,--type <type>         constrain by service type
+ *      -N,--new <time>          get only newly registered svcs
+ *      -U,--updated <time>      get only newly updated entries
+ *
+ *      -a,--all                 print all results (default)
+ *      -f,--fields <fields>     output only specified fields
+ *      -O,--or                  logically OR the search terms
+ *      -n,--index <index>       set index of result (-1 => list, 0 => all)
+ *      -o,--output <oname>      save results to <oname> as votable
+ *      -B,--samp        	 broadcast results as a SAMP message
+ *      -V,--votable        	 save results as VOTable
+ *      -X,--xml        	 save results as VOTable
+ *
+ *      -I,--Id                  print only the Identifier (resolve mode)
+ *      -L,--long                print long lines of output (no wrapping)
+ *      -R,--Resolve             print the ShortName, ServiceType and ID
+ *      -S,--SName               print only the ShortName (resolve mode)
+ *      -T,--Title               print only the Title string (resolve mode)
+ *
+ *
+ *  Resource Type Strings:
+ *      catalog           Cone search services
+ *      image             Simple Image Access services
+ *      spectra           Simple Spectral Access services
+ *      table             Vizier services
+ *      <literal>         ResourceType from Registry record
+ *
+ *  Allowed Bandpass Strings:
+ *      Radio              Millimeter           Infrared (IR)
+ *      Optical            Ultraviolet (UV)     X-Ray (xray)
+ *      Gamma-Ray (GR)
+ *
+ *  Allowed Resource Fields (for -f flag):
+ *      Title              ShortName            Identifier
+ *      ServiceURL         ReferenceURL         Description
+ *      Subject            ResourceType         Type
+ *      Creator            Publisher            CoverageSpatial
+ *      CoverageTemporal   Waveband             ContentLevel
+ *      Version
+ *
+ *
+ *  @file       voregistry.c
+ *  @author     Mike Fitzpatrick, NOAO
+ *  @date       8/03/07
+ *
+ *  @brief      Registry resolution, query, and browsing
+ */
+
+#include <pthread.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <errno.h>
+#include <getopt.h>
+#define _GNU_SOURCE
+#include <string.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+#include "VOClient.h"
+#include "voApps.h"
+#include "voAppsP.h"
+#include "samp.h"
+
+
+/* Local processing definitions.
+*/
+#define M_RESOLVE		001	/* resolve to record field	*/
+#define M_SEARCH		002	/* search registry		*/
+#define M_FULL			004	/* print full record		*/
+#define M_METALIST		010	/* print table metadata		*/
+
+#define	MAX_TERMS		128	/* max search terms		*/
+
+#define TIME_NEW		0	/* time-search types		*/
+#define TIME_UPDATE		1
+
+#define TUNIT_HOURS		0	/* units of search		*/
+#define TUNIT_DAY		1
+#define TUNIT_MONTH		2
+
+
+
+int     mode	    = M_SEARCH;		/* program mode			*/
+
+
+extern int      count;			/* return count of results	*/
+extern int	verbose;		/* verbose output?		*/
+extern int      meta;			/* print meta results      	*/
+extern int      proxy;			/* use proxy server		*/
+extern int      res_all;		/* print all results      	*/
+extern int      longlines;		/* don't format output		*/
+extern int      group;			/* group terms			*/
+extern int	exact;			/* exact match only?		*/
+extern int	debug;			/* debug output?		*/
+extern int      nterms;			/* number of search terms	*/
+
+int     exact       = 0;                /* exact match only?            */
+int     res_index   = -1;		/* index of result      	*/
+int     nresults    = 0;		/* no. of results      		*/
+int     user_fields = 0;		/* uer-defined fields?		*/
+int     orValues    = 0;		/* OR search terms?		*/
+int     out_votable = 0;		/* output a Resource VOTable	*/
+#ifdef REG10_KLUDGE
+int     reg10       = 0;		/* Registry 1.0 support?        */
+#endif
+int     dal_only    = 0;		/* DAL services only           	*/
+int     sortRes     = 0;		/* sort results?            	*/
+int     terse       = 0;		/* terse results?            	*/
+int     cset        = 0;            	/* constraints set?		*/
+int     do_samp     = 0;            	/* broadcast SAMP result?	*/
+int     timeSearch  = 0;            	/* search by create/update time */
+
+
+char   *fields      = (char *) NULL;	/* output fields		*/
+char   *ofname      = (char *) NULL;	/* output filename		*/
+char   *bandpass    = (char *) NULL;	/* bandpass constraint		*/
+char   *subject     = (char *) NULL;	/* subject constraint		*/
+char   *stype       = (char *) NULL;	/* service type constraint	*/
+char   *clevel      = (char *) NULL;	/* content level constraint	*/
+char   *terms[MAX_TERMS];		/* search words/terms		*/
+
+char    outname[SZ_FNAME];		/* output filename		*/
+
+
+
+/*  Task specific option declarations.
+ */
+int  voregistry (int argc, char **argv, size_t *len, void **result);
+
+static Task  self       = {  "voregistry",  voregistry,  0,  0,  0  };
+
+static void Usage (void);
+static void Tests (char *input);
+
+
+/*  For getopt_long() option parsing.
+*/
+int     opt_index;
+static  char *opt_string = "aBb:C:cdef:ghn:IlLmOo:rRs:St:TvVX123789%";
+
+static struct option long_options[] = {
+
+	/* OUTPUT TYPES			*/
+    { "count",    2, 0, 'c'},		/* count results		*/    
+    { "exact",    2, 0, 'e'},		/* exact results		*/    
+    { "list",     2, 0, 'l'}, 		/* list full record		*/
+    { "meta",     2, 0, 'm'},		/* print metadata		*/
+    { "resolve",  2, 0, 'r'},  		/* resolve mode			*/
+
+	/* CONVENIENCE OPTS		*/
+    { "id",       2, 0, 'I'},  		/* ID Resolve mode		*/
+    { "long",     2, 0, 'L'},  		/* output long lines		*/
+    { "Resolve",  2, 0, 'R'},  		/* Resolve mode			*/
+    { "SName",    2, 0, 'S'},  		/* SName Resolve mode		*/
+    { "Title",    2, 0, 'T'},  		/* Title Resolve mode		*/
+
+	/* CONSTRAINT OPTS		*/
+    { "bandpass", 1, 0, 'b'},		/* bandpass constraint 		*/
+    { "clevel",   1, 0, 'C'},		/* content level cons.		*/
+    { "dal",      2, 0, 'd'},		/* DAL-only results		*/    
+    { "group",    2, 0, 'g'},  		/* group terms			*/
+    { "new",      1, 0, 'N'},		/* newly registered		*/
+    { "updated",  1, 0, 'U'},		/* updated entried		*/
+    { "subject",  1, 0, 's'},  		/* subject constraint		*/
+    { "type",     1, 0, 't'},		/* svctype constraint		*/
+
+	/* OUTPUT CONTROL OPTS		*/
+    { "all",      2, 0, 'a'},  		/* print all results		*/
+    { "fields",   1, 0, 'f'},		/* set output fields		*/
+    { "or",       2, 0, 'O'},		/* logically OR keyws		*/
+    { "index",    1, 0, 'n'},		/* result index			*/
+    { "output",   1, 0, 'o'},		/* output filename		*/
+    { "samp",     2, 0, 'B'},  		/* broadcase SAMP result	*/
+    { "votable",  2, 0, 'V'},		/* output VOTable		*/
+    { "xml",      2, 0, 'X'},		/* output XML			*/
+
+	/* STANDARD OPTS		*/
+    { "help",     2, 0, 'h'},		/* print help			*/
+    { "test",     2, 0, '%'},		/* unit tests			*/
+    { "verbose",  2, 0, 'v'},		/* verbose flag			*/
+
+	/* ENGINEERING OPTS		*/
+    { "debug",    2, 0, '1'},		/* debug output 		*/
+    { "dverb",    2, 0, '2'},		/* verbose debug output 	*/
+    { "reg10",    2, 0, '3'},		/* Registry 1.0 kludge		*/
+
+    { "tweet",    2, 0, '7'},		/* tweet output			*/
+    { "sort",     2, 0, '8'},		/* */
+    { "terse",    2, 0, '9'},		/* */
+
+    { NULL,       0, 0, 0  }
+};
+
+
+/* The following is the full list of metadata available given the
+** Registry query method we are using.  This list will change when 
+** VOClient moves to a new Registry schema.
+
+char *resList[] = {				// v0.4 output
+    "Title", 		"ShortName", 	     "Identifier",
+    "ServiceURL", 	"ReferenceURL",      "Description",
+    "Subject", 		"ResourceType",      "Type",
+    "Creator", 		"Facility", 	     "Instrument",
+    "Contributor", 	"CoverageSpatial",   "CoverageTemporal",
+    "Waveband",         "ContentLevel",      "Version",
+    NULL
+};
+*/
+char *resList[] = {			/* resource fields (full print) */
+    "Title", 		    "ShortName", 	"Identifier",
+    "CapabilityStandardID", "Subject", 		"Type",
+    "ServiceURL", 	    "ReferenceURL",     "Description",
+    "Creator", 		    "Publisher",        "CoverageSpatial",
+    "CoverageTemporal",     "Waveband",         "ContentLevel",      
+    "Version",		    "CapabilityName",
+    NULL
+};
+
+#define  SZ_GBUF	256
+char  gbuf[SZ_GBUF];
+/*
+char *gfmt = "(ShortName like '%%%s%%' OR Identifier like '%%%s%%')";
+char *gfmt = "(Identifier like '%%%s%%')";
+*/
+char *gfmt = "(Identifier like '%s')";
+
+
+extern int   errno;
+extern int   isSexagesimal (char *s), isDecimal (char *s);
+extern int   vot_regResolver (char *id, char *svctype, char *bpass, 
+		char *subject, char *clevel, char *fields, int index, 
+		int exact, int dal_only, char **result);
+extern int   vot_regSearch (char **ids, int nids, char *svctype,
+		char *bpass, char *subject, char *clevel, int orValues, 
+		int votable, FILE *vot_fd, int dal_only, int sortRes, 
+		int terse);
+extern int   vot_atoi (char *v);
+extern char *strcasestr();
+
+
+static void  printResolveRecord (void);
+static void  printResolveHdr (void);
+static void  printFullRecord (char *term);
+static void  printSvcMetadata (char *svc);
+
+static char *vot_getTime (int type, char *arg);
+double       vot_calJD (int mn, double dy, int yr, int hrs, int min, int sec);
+
+extern char *vot_toURL (char *arg);
+extern void  vot_printRegVOTableHdr (FILE *fd);
+extern void  vot_printRegVOTableRec (FILE *fd, RegResult resource, int recnum);
+extern void  vot_printRegVOTableTail (FILE *fd);
+
+extern void  pretty_print (char *result, int nresults);
+extern void  pretty_print_table (char *result, int nresults, char *fields);
+extern void  ppMultiLine (char *result, int poffset, int pwidth, int maxchars);
+extern void  ppResSummary (char *result, int nresults);
+extern void  vot_printAttrs (char *fname, Query query, char *id);
+
+
+
+
+
+/************************************************************************
+**  Program main()
+*/
+int
+voregistry (int argc, char *argv[], size_t *reslen, void **result)
+{
+    register int i=0, ch=0, arg_index=0, narg=0;
+    char  vot_name[SZ_FNAME];
+    int use_groups = 1;
+    int status = OK;
+    FILE  *vot_fd = (FILE *) NULL;
+
+
+    *reslen = 0;
+    *result = NULL;
+    count   = 0;
+    meta    = 0;
+    vot_fd  = stdout;
+
+    memset (vot_name, 0, SZ_FNAME);
+    memset (outname, 0, SZ_FNAME);
+
+    /*  Process command line arguments. 
+     */
+    while (1) {
+        ch = getopt_long (argc, argv, opt_string, long_options, &opt_index);
+
+        if (ch > 0) {
+	    switch (ch) {
+ 	    case 'h':
+		Usage ();
+		return (OK);
+ 	    case '%':
+		Tests (NULL);
+		return (self.nfail);
+
+            case 'a':    			/* print all results	*/
+		res_all = 1;
+		break;
+            case 'c':				/* count results	*/    
+		count++;				
+		break;
+            case 'd':				/* DAL-only results	*/    
+		dal_only++;				
+		cset++;				
+		break;
+	
+
+	    /* EXPERIMENTAL FLAGS */
+            case '7':				/* EXPERIMENTAL		*/
+		terse += 2;;
+		break;
+            case '8':				/* EXPERIMENTAL		*/
+		sortRes++, terse++;
+		break;
+            case '9':				/* EXPERIMENTAL		*/
+		terse++;
+		break;
+	    /* EXPERIMENTAL FLAGS */
+
+	
+            case 'e':				/* exact results	*/    
+		exact++;				
+		mode = M_RESOLVE;
+		break;
+	
+            case 'l':    			/* list full record	*/
+		mode = M_FULL;
+		verbose = 2;
+		break;
+            case 'I':    			/* ID Resolve mode	*/
+		mode = M_RESOLVE;
+		fields = "Identifier";
+		user_fields++;
+		break;
+            case 'T':    			/* Title Resolve mode	*/
+		mode = M_RESOLVE;
+		fields = "Title";
+		user_fields++;
+		break;
+            case 'R':    			/* Resolve mode		*/
+		mode = M_RESOLVE;
+		dal_only++;				
+		fields =
+		     "ShortName,CapabilityStandardID,Identifier,CapabilityName";
+		user_fields++;
+		break;
+            case 'S':    			/* SName Resolve mode	*/
+		mode = M_RESOLVE;
+		fields = "ShortName";
+		user_fields++;
+		break;
+            case 'L':    			/* output long lines	*/
+		longlines++;
+		break;
+            case 'g':    			/* group terms		*/
+		mode = M_RESOLVE;
+		group++;
+		orValues++;
+		break;
+            case 'r':    			/* resolve mode		*/
+		mode = M_RESOLVE;
+		break;
+            case 'm':
+		mode = M_METALIST;
+		dal_only++;				
+		meta++;
+	 	break;
+
+            case 'b':				/* bandpass constraint 	*/
+		if (bandpass) {
+		    fprintf (stderr,"Warning: Bandpass already specified.");
+		    fprintf (stderr," Ignoring '%s'\n", optarg);
+		} else {
+		    if (!optarg || (optarg && optarg[0] == '-')) {
+			fprintf (stderr, 
+			    "Error: the '-b' flag requires an argument\n");
+			return (ERR);
+		    }
+		    bandpass = optarg;
+		}
+		cset++;				
+		break;
+            case 's':    			/* subject constraint	*/
+		if (subject) {
+		    fprintf (stderr,"Warning: Subject already specified.");
+		    fprintf (stderr," Ignoring '%s'\n", optarg);
+		} else {
+		    if (!optarg || (optarg && optarg[0] == '-')) {
+			fprintf (stderr, 
+			    "Error: the '-s' flag requires an argument\n");
+			return (ERR);
+		    }
+		    subject = optarg;
+		}
+		cset++;				
+		break;
+            case 't':				/* svctype constraint	*/
+		if (stype) {
+		    fprintf (stderr, "Warning: ServiceType already specified.");
+		    fprintf (stderr, " Ignoring '%s'\n", optarg);
+		} else {
+		    if (!optarg || (optarg && optarg[0] == '-')) {
+			fprintf (stderr, 
+			    "Error: the '-t' flag requires an argument\n");
+			return (ERR);
+		    }
+		    stype = optarg;
+		}
+		cset++;				
+		break;
+            case 'C':				/* content level cons.	*/
+		if (clevel) {
+		    fprintf (stderr,"Warning: ContentLevel already specified.");
+		    fprintf (stderr," Ignoring '%s'\n", optarg);
+		} else {
+		    if (!optarg || (optarg && optarg[0] == '-')) {
+			fprintf (stderr, 
+			    "Error: the '-C' flag requires an argument\n");
+			return (ERR);
+		    }
+		    clevel = optarg;
+		}
+		cset++;				
+		break;
+
+            case 'n':				/* result index		*/
+		res_index = vot_atoi (optarg);
+		break;
+            case 'o':				/* logically OR keyws	*/
+		out_votable++;
+		verbose = 2;
+		strcpy (outname, optarg);
+		break;
+            case 'O':				/* logically OR keyws	*/
+		orValues++;
+		break;
+            case 'f':				/* set output fields	*/
+		fields = optarg;
+		user_fields++;
+		break;
+
+            case 'B':				/* broadcase SAMP table	*/
+		do_samp++;
+		out_votable++;
+		verbose = 2;
+		break;
+            case 'V':				/* output VOTable	*/
+            case 'X':				/* output XML		*/
+		out_votable++;
+		verbose = 2;
+		break;
+
+            case 'v':				/* verbose flag		*/
+		verbose++;
+		break;
+
+            case 'N':				/* new resources	*/
+		timeSearch++;
+		terms[nterms++] = vot_getTime (TIME_NEW, optarg);
+		break;
+            case 'U':				/* updated entried	*/
+		timeSearch++;
+		terms[nterms++] = vot_getTime (TIME_UPDATE, optarg);
+		break;
+
+						/* "Engineering" flags. */
+            case '1':    			/* debug		*/
+		debug++;				
+		break;
+            case '2':    			/* verbose debug	*/
+		verbose++;				
+		break;
+#ifdef REG10_KLUDGE
+            case '3':    			/* Registry 1.0 kludge	*/
+		reg10++;				
+		break;
+#endif
+            }
+
+        } else if (ch == PARG_ERR) {
+            return (ERR);
+
+        } else {
+	    /* Parse the arguments.
+	    **
+	    **	    voregistry <keyw> [ <keyw> .... ]
+	    **
+	    */
+	    char  *arg, sql[SZ_SQL_TERM];
+	    int   len, start, end;
+
+	    if ( (arg_index = optind + narg) >= argc)
+		break;
+
+	    arg = argv[arg_index];
+	    len = strlen (arg);
+	    if (arg[0] == '\"') {
+		/* Capture all args forming a quoted string.
+		*/
+	 	bzero (sql, SZ_SQL_TERM);
+		do {
+		    start = ((arg[0] == '\"') ? 1 : 0);
+		    end = ((arg[len-1] == '\"') ? len-2 : len-1);
+		    strncat (sql, &arg[start], end-start+1);
+		    if (arg[len-1] == '\"') 
+			break;
+		    strcat (sql, " ");
+		    arg = argv[++arg_index], narg++;
+		    len = strlen (arg);
+		} while (arg);
+		terms[nterms++] = strdup (sql);
+
+	    } else if (access(arg, R_OK) == 0) {
+		FILE *fd;
+		char *name = calloc (1, SZ_FNAME);
+
+        	/* Process the file contents. 
+        	*/
+        	if ((fd = fopen (arg, "r")) == (FILE *) NULL) {
+            	    fprintf (stderr, "ERROR: Cannot open file '%s'\n", arg);
+            	    exit (1);
+        	}
+        	while (fgets (name, SZ_FNAME, fd)) {
+		    name[strlen(name)-1] = '\0';	/* kill newline */
+		    if (group) {
+			bzero (gbuf, SZ_GBUF);
+			sprintf (gbuf, gfmt, name, name);
+		        terms[nterms++] = strdup (gbuf);
+		    } else {
+		        terms[nterms++] = strdup (name);
+		    }
+		    bzero (name, SZ_FNAME);
+		}
+
+        	fclose (fd);
+		free (name);
+
+	    } else {
+		if (strncasecmp("ivo://CDS/VizieR", arg, 16) == 0) {
+		    char ivorn[SZ_LINE];
+
+		    /* If we're using an 'old-style' Vizier ivorn, try
+		    ** converting it to a a Registry 1.0 flavor.  We'll
+		    ** worry about further modifying the term if this fails
+		    ** later on.
+		    */
+		    bzero (ivorn, SZ_LINE);
+		    strcpy (ivorn, strdup (arg));
+		    ivorn[9] = '.';
+		    terms[nterms++] = strdup (ivorn);
+
+		} else
+		    terms[nterms++] = strdup (arg);
+	    }
+
+	    narg++;
+
+	    /* When we're done processing the arguments, break....
+	    */
+	    if (arg_index == (argc - 1))
+		break;
+	}
+    }
+
+    if (cset && nterms == 0) {
+	/* terms[nterms++] = "%"; */
+        orValues = 0;
+    }
+
+
+    /*  Initialize the VOClient code.  Error messages are printed by the
+     *  interface so we just quit if there is a problem.
+     */
+    if (voc_initVOClient ("runid=voc.voregistry") == ERR) 
+        return (ERR);
+
+
+    /* See whether any flags negate other options, or imply values for 
+    ** other fields.
+    */
+    if (res_all)
+	res_index = -1;
+    if (nterms == 0 && !out_votable) {
+	if (mode == M_RESOLVE)
+	    terms[nterms++] = strdup ("%");
+	else {
+	    mode = ((stype||clevel||subject||bandpass) ? M_SEARCH : M_RESOLVE);
+
+	    if (stype || clevel || subject || bandpass)
+	        mode = M_SEARCH;
+	    else {
+	        if (! (stype || clevel || subject || bandpass))
+		    mode = M_SEARCH;
+	        else
+		    mode = M_RESOLVE;
+	    }
+	    if (stype && strcasestr (stype, "catalog"))
+	        terms[nterms++] = strdup ("catalog");
+	}
+    }
+#ifdef FOO
+    if (fields && mode != M_RESOLVE) {
+	fprintf (stderr, "ERROR: 'fields' can only be used in Resolve Mode\n");
+        voc_closeVOClient (0);			/* close VOClient connection */
+	return (ERR);
+    }
+#endif
+    if (nterms == 0 && !stype && !bandpass && !clevel && !subject) {
+	char *name = calloc (1, SZ_FNAME);
+
+       	/* Process the arguments from the standard input. 
+       	*/
+        while (fgets (name, SZ_FNAME, stdin)) {
+	    name[strlen(name)-1] = '\0';		/* kill newline */
+	    terms[nterms++] = strdup (name);
+	    bzero (name, SZ_FNAME);
+	}
+	free (name);
+    }
+    if (mode == M_RESOLVE)
+	sortRes = 0;
+
+
+    /* If all of the terms appears to be Identfiers, try to optimize the
+    ** query, or reset the search mode.
+    */
+    if (!stype && !clevel && !bandpass && !subject) {
+
+        for (i=0; i < nterms; i++) {
+            if (strncmp("ivo:", terms[i], 4) || strncmp("htt:", terms[i], 4)) {
+	        use_groups = 0;
+	        break;
+            }
+        }
+        if (use_groups && mode == M_SEARCH) 
+	    mode = M_RESOLVE;
+        if (use_groups && nterms <= 20) {
+	    group++; 
+	    orValues++;
+	    for (i=0; i < nterms; i++) {
+	        bzero (gbuf, SZ_GBUF);
+	        sprintf (gbuf, gfmt, terms[i], terms[i]);
+	        free (terms[i]);
+	        terms[i] = strdup (gbuf);
+	    }
+        }
+    }
+
+
+    /* If we're printing a VOTable, output the prolog.
+    */
+    if (!meta && out_votable) {
+	strcpy (vot_name, (outname[0] ? outname :  "/tmp/vot.xml"));
+	if (access (vot_name, F_OK) == 0)
+	    unlink (vot_name);
+	if ((vot_fd = fopen (vot_name, "w+")) == (FILE *) NULL) {
+	    fprintf (stderr, "Error opening SAMP result file.\n");
+	    return (ERR);
+	}
+	
+	vot_printRegVOTableHdr (vot_fd);
+    }
+
+    switch (mode) {
+    case M_RESOLVE:
+	printResolveRecord ();
+        voc_closeVOClient (0);			/* close VOClient connection */
+        if (!meta && out_votable) 
+	    vot_printRegVOTableTail (vot_fd);
+	return ( (nresults == 0) );
+
+    case M_SEARCH:
+	if (!count) {
+	    nresults = vot_regSearch (terms, nterms, stype, bandpass,
+		subject, clevel, orValues, out_votable, vot_fd, dal_only, 
+		sortRes, terse);
+	} else {
+	    if (orValues) {
+	        for (i=0; i < nterms; i++) {
+	            nresults = vot_regSearch (&terms[i], 1, stype, bandpass,
+		        subject, clevel, 1, out_votable, vot_fd, dal_only, 
+			sortRes, terse);
+		}
+	    } else {
+	        nresults = vot_regSearch (terms, nterms, stype, bandpass,
+		    subject, clevel, 0, out_votable, vot_fd, dal_only, 
+		    sortRes, terse);
+	    }
+	}
+	break;
+
+    case M_FULL: 
+	for (i=0; i < nterms; i++)
+	    printFullRecord (terms[i]);
+	break;
+
+    case M_METALIST:
+	if (nterms == 0) {
+	    terms[nterms++] = "%";
+	}
+	for (i=0; i < nterms; i++)
+	    printSvcMetadata (terms[i]);
+	break;
+
+    default:
+	fprintf (stderr, "Invalid mode.\n");
+	exit (1);
+    }
+
+
+    /* Close the VOTable.
+    */
+    if (!meta && out_votable) {
+	vot_printRegVOTableTail (vot_fd);
+	if (vot_fd != stdout)
+	    fclose (vot_fd);
+    }
+
+    /*  If we're asked to print the output VOTable to the screen print it
+     *  here.  If an output name was specified it will have already been
+     *  written, if the 'samp' flag was set assume that is the only desired
+     *  output.
+     */
+    if (!do_samp && out_votable && strcmp (vot_name, "/tmp/vot.xml") == 0) {
+	char line[SZ_LINE];
+
+	if ((vot_fd = fopen (vot_name, "r")) == (FILE *) NULL) {
+	    fprintf (stderr, "Error opening VOTable result file.\n");
+	    return (ERR);
+	}
+
+	memset (line, 0, SZ_LINE);
+	while (fgets (line, 4096, vot_fd)) {
+	    fputs (line, stdout);
+	    memset (line, 0, SZ_LINE);
+	}
+
+	fclose (vot_fd);
+    }
+
+    /*  Broadcast the image as a message if requested.
+     */
+    if (do_samp) {
+	int  sampH = 0;
+
+        if ((sampH = sampInit ("voatlas", "VOClient Task")) >= 0) {
+            char url[SZ_LINE];
+
+            memset (url, 0, SZ_LINE);
+            strcpy (url, vot_toURL (vot_name));
+
+            samp_setSyncMode (sampH);
+            sampStartup (sampH);            /* initialize SAMP interface */
+
+            (void) samp_tableLoadVOTable (sampH, "all", url, NULL, NULL);
+
+            sampShutdown (sampH);           /*  clean up                 */
+            sampClose (sampH);
+	    if (strcmp (vot_name, "/tmp/vot.xml") == 0)
+	        unlink (vot_name);
+        }
+    }
+
+
+    return ( status );
+}
+
+
+/************************************************************************
+**  PRINTRESOLVERECORD -- Print a "complete" record for the resources 
+**  matching the query string.
+*/
+static void
+printResolveRecord ()
+{
+    char     *result = (char *)NULL;
+    register int i;
+
+
+    /* Determine the fields we'll need.
+    */
+    if (verbose == 1 && !fields)
+	fields = "ShortName,CapabilityStandardID,Title";
+    if (verbose == 2 && !fields)
+	fields = "ShortName,CapabilityStandardID,Description";
+
+    if (out_votable)
+	fields = "";
+
+    if (out_votable)
+	fields = "Title,ShortName,Identifier,ServiceURL,ReferenceURL,CapabilityStandardID,ContentLevel,Type,Waveband,Creator,Subject,Version";
+
+    if (! out_votable)
+        printResolveHdr ();
+    
+    if (nterms == 0) {
+	terms[nterms++] = "%";
+	exact = 1;
+    }
+
+    for (i=0; i < nterms; i++) {
+#ifdef REG10_KLUDGE
+        if (reg10 || strncasecmp("ivo://CDS.VizieR",terms[i],16) == 0) {
+	    char ivorn[SZ_LINE];
+
+            bzero (ivorn, SZ_LINE);
+            strcpy (ivorn, terms[i]);
+            strcat (ivorn, "%");
+            ivorn[9] = '/';
+
+	    nresults = vot_regResolver (ivorn, stype, bandpass, subject, 
+		clevel, fields, res_index, 0, dal_only, &result);
+	} else {
+#endif
+	    nresults = vot_regResolver (terms[i], stype, bandpass, subject, 
+		clevel, fields, res_index, exact, dal_only, &result);
+#ifdef REG10_KLUDGE
+	}
+#endif
+
+	if (! out_votable) {
+	    if (count) {
+		if (nterms > 0 && terms[i][0] != '%')
+	            printf ("%-20s    %5d\t", terms[i], nresults);
+		else
+	            printf ("%d", nresults);
+	        if (verbose)
+	            ppResSummary (result, nresults);
+	        printf ("\n");
+	    } else if (user_fields) {
+	        pretty_print_table (result, nresults, fields);
+	    } else {
+	        pretty_print (result, nresults);
+	    }
+	}
+
+	if (group)
+	    break;
+    }
+    if (result)
+	free ((char *) result);
+}
+
+
+/************************************************************************
+**  PRINTRESOLVEHDR -- Print the header information for Resolve mode.
+*/
+static void
+printResolveHdr ()
+{
+    if (nterms == 0)
+	return;
+    if (count) {
+	if (verbose) {
+	    printf ("\nShortName             \t\tMatching Resources\n");
+	    printf ("-------------------------------------------");
+	    printf ("------------------------------------");
+	} else {
+	    printf ("\nShortName             Matching Resources\n");
+	    printf ("-------------------------------------------");
+	}
+	printf ("\n");
+
+    } else if (fields && !user_fields) {
+	printf("\nShortName           ResourceType\t%s\n",
+	    (verbose > 1 ? "Description" : "Title"));
+	printf("----------------------------------------");
+	printf("----------------------------------------\n");
+    }
+}
+
+
+/************************************************************************
+**  PRINTFULLRECORD -- Print a "complete" recordfor the resources matching
+**  the query string.
+*/
+static void
+printFullRecord (char *term)
+{
+    RegResult  resource = 0;
+    int        i, j, nresults;
+    char      *attr_val, sql[SZ_LINE];
+
+
+    if (debug)
+	fprintf (stderr, "printFullRec:  term='%s'\n", term);
+
+    if (res_all)
+        sprintf (sql, "(ShortName like '%%%s%%') OR (Identifier like '%%%s%%')",
+	    term, term);
+    else
+        sprintf (sql, "(ShortName like '%s') OR (Identifier like '%s')",
+	    term, term);
+
+    resource = voc_regExecute (voc_regQuery (sql, 0));
+    nresults = voc_resGetCount (resource);
+
+    if (nresults == 0 && !res_all) {
+
+         if (strncasecmp("ivo://CDS.VizieR",term,16) == 0) {
+            char *ip, ivorn[SZ_LINE];
+
+            bzero (ivorn, SZ_LINE);
+            strcpy (ivorn, term);
+            for (ip = &ivorn[strlen(term)-1]; *ip != '/'; ip--)
+                *ip = '\0';
+            *ip = '\0';
+
+            sprintf (sql, 
+		"(ShortName like '%%%s%%') OR (Identifier like '%%%s%%')",
+	    	ivorn, ivorn);
+        } else
+            sprintf (sql, 
+		"(ShortName like '%%%s%%') OR (Identifier like '%%%s%%')",
+	    	term, term);
+
+        resource = voc_regExecute (voc_regQuery (sql, 0));
+        nresults = voc_resGetCount (resource);
+
+	if (nresults == 0) {
+	    fprintf (stderr, "No results found for '%s'\n", term);
+	    return;
+	}
+    }
+
+    for (i=0; i < nresults; i++) {
+	if (out_votable) {
+	    vot_printRegVOTableRec (stdout, resource, i);
+
+	} else {
+            for (j=0; resList[j]; j++) {
+	        if ((attr_val = voc_resGetStr (resource, resList[j], i))) {
+		    if (strstr (resList[j], "StandardID"))
+	                printf ("%16.16s: ", "ResourceType");
+		    else
+	                printf ("%16.16s: ", resList[j]);
+	            ppMultiLine((attr_val ? attr_val : "(none)"), 18, 61, 8192);
+	            printf ("\n");
+		}
+	    }
+    	    if (nresults > 1 && i < (nresults - 1))
+	        printf ("------------------------------------------\n");
+        }
+    }
+}
+
+	    
+/************************************************************************
+**  PRINTSVCMETADATA -- Print the column metadata for the named service.
+*/
+static void
+printSvcMetadata (char *svc)
+{
+    RegResult resource = 0;
+    RegQuery  rquery = 0;
+    int       i, nresults;
+    char      *type, *url, sql[SZ_LINE];
+    DAL	      dal;
+    Query     query;
+ 
+
+    if (res_all)
+        sprintf (sql, "(ShortName like '%%%s%%') OR (Identifier like '%%%s%%')",
+	    svc, svc);
+    else
+        sprintf (sql, "(ShortName like '%s') OR (Identifier like '%s')",
+	    svc, svc);
+
+    if (debug) fprintf (stderr, "metalist sql = '%s'\n", sql);
+
+    rquery = voc_regQuery (sql, 0);
+
+    if (bandpass && bandpass[0])
+        voc_regConstWaveband (rquery, bandpass);
+    if (stype && stype[0])
+        voc_regConstSvcType (rquery, stype);
+    if (dal_only) 
+        voc_regDALOnly (rquery, dal_only);
+    voc_regSortRes (rquery, sortRes);
+
+    resource = voc_regExecute (rquery);
+    nresults = voc_resGetCount (resource);
+
+    if (debug) fprintf (stderr, "query nres = %d\n", nresults);
+
+    for (i=0; i < nresults; i++) {
+	if ((type = voc_resGetStr (resource, "CapabilityStandardID", i))) {
+	    int len;
+
+	    url = voc_resGetStr (resource, "ServiceURL", i);
+
+	    /* Clean up any dangling '&amp;' in the URL.
+	    */
+	    len = strlen (url);
+	    if (strcmp(&url[len-5], "&amp;") == 0)
+		url[len-5] = '\0';
+	    
+	    /* Form a dummy query for the metadata.
+	    */
+	    if (strcasecmp ("CONE", type) == 0 ||
+	        strncasecmp ("TABULAR", type, 7) == 0) {
+		    dal = voc_openConeConnection (url);
+
+		    /*  As of 1/28/09 the Vizier SCS doesn't respond properly
+		    **  to SR=0 for a metadata query, however if we leave off
+		    **  the query params entirely we do get a valid response.
+		    **  This is just a kludge.
+		    **
+		    query = voc_getConeQuery (dal, 0.0, 0.0, 
+	        	(strstr (url, "vizier"))  ? -1.0 : 0.0);
+		    **		FIXME					    */
+		    /*		FIXME					    */
+
+		    /*  This is the standard SCS way to get metadata.  For now
+		    **  we'll do as the spec says and broken services will
+		    **  have to be fixed.
+		    */
+		    query = voc_getConeQuery (dal, 0.0, 0.0, 0.001);
+
+        	    (void) voc_addIntParam (query, "VERB",
+			(meta ? 3 : min(3,verbose+1)) );
+
+        	    if (debug) {
+            	        fprintf (stderr, "Executing Metadata Query:\n  %s\n\n", 
+                	    voc_getQueryString (query, CONE_CONN, 0));
+		    }
+
+		    /*
+	            printf (
+			"\n# ---- Svc: %s (%s) ---------------------------\n\n",
+		     	svc, type);
+		    */
+		    vot_printAttrs (NULL, query, svc);
+
+	    } else if (strncasecmp ("SIAP", type, 4) == 0) {
+		dal = voc_openSiapConnection (url);
+		query = voc_getSiapQuery (dal, 0.0, 0.0, 0.0, 0.0, "METADATA");
+        	(void) voc_addIntParam (query, "VERB", verbose);
+
+		/*
+	        printf ("\n# ---- Svc: %s (%s) ---------------------------\n\n",
+		    svc, type);
+		*/
+		vot_printAttrs (NULL, query, svc);
+	    }
+	}
+    }
+}
+
+
+/************************************************************************
+**  GETLONGLINES -- Utility procedure to return the value of the 'longlines'
+**  flag.
+*/
+int
+vot_getLonglines ()
+{
+    return (longlines);
+}
+
+
+/************************************************************************
+**  GETTME -- Cteate a time-constrainst string for the search.
+*/
+#define	SZ_TSTR		32
+#define	SZ_TQUERY	256
+
+static char *
+vot_getTime (int type, char *arg)
+{
+    char  unit = arg[strlen (arg) - 1];
+    long  diff, val;
+    time_t  now = time((time_t)NULL), then;
+    struct tm *start, *end;
+    static char  t1[SZ_TSTR], t2[SZ_TSTR], tquery[SZ_TQUERY];
+
+
+    val = atoi (arg);
+    if (!isdigit(unit)) {			/* get units of search 	*/
+	if (strchr ("hH", (int) unit))
+	    diff = val * 3600;
+	else if (strchr ("dD", (int) unit))
+    	    diff = val * (3600 * 24);
+	else if (strchr ("wW", (int) unit))
+    	    diff = val * (3600 * 24 * 7);
+	else if (strchr ("mM", (int) unit))
+    	    diff = val * (3600 * 24 * 30);
+    } else
+	diff = val * (3600 * 24);
+
+    then = now - diff;
+
+    memset (t1, 0, SZ_TSTR);
+    start = localtime (&then);
+    sprintf (t1, "%4d-%02d-%02dT%02d:%02d:%02d",
+	(start->tm_year+1900), start->tm_mon+1, start->tm_mday,
+	start->tm_hour, start->tm_min, start->tm_sec);
+
+    memset (t2, 0, SZ_TSTR);
+    end = localtime (&now);
+    sprintf (t2, "%4d-%02d-%02dT%02d:%02d:%02d",
+	(end->tm_year+1900), end->tm_mon+1, end->tm_mday,
+	end->tm_hour, end->tm_min, end->tm_sec);
+
+    sprintf (tquery,
+	"[@%s] >= '%s' AND [@%s] <= '%s'",
+	(type == TIME_NEW ? "created" : "updated"), t1,
+	(type == TIME_NEW ? "created" : "updated"), t2);
+    /*
+    sprintf (tquery, "[@%s] >= '%s'",
+	(type == TIME_NEW ? "created" : "updated"), t1);
+    */
+    return ( strdup(tquery) );
+}
+
+
+/* Get JD from date. Not entirely accurate, but good enough for what we need.
+*/
+double
+vot_calJD (int mn, double dy, int yr, int hrs, int min, int sec)
+{
+    int     a, b, d, m, y;
+    long    c;
+    double  mjp;
+
+
+    m = mn;
+    y = (yr < 0) ? yr + 1 : yr;
+    if (mn < 3)
+        m += 12, y -= 1;
+
+    if (yr < 1582 || (yr == 1582 && (mn < 10 || (mn == 10 && dy < 15))))
+        b = 0;
+    else
+        a = y/100, b = 2 - a + a/4;
+
+    c = ((y < 0) ?  
+        (long)((365.25*y) - 0.75) - 694025L : (long)(365.25*y) - 694025L);
+    d = (int)(30.6001*(m+1));
+
+    mjp = b + c + d + dy - 0.5;
+
+    mjp += (((double)hrs / 24.) + ((double)min / 60.) + ((double)sec / 3600.));
+    return (mjp);
+}
+
+
+
+
+/************************************************************************
+**  USAGE --  Print a help summary for the task.
+*/
+static void
+Usage ()
+{
+  printf ("\n\
+    Usage:   voregistry [-<flags>] [ [<keyword>] | [<term>] ]\n\
+  \n\
+      -h,--help                print this help\n\
+      -v,--verbose             verbose mode\n\
+         --vverbose            very-verbose mode\n\
+  \n\
+      -c,--count               print a count of matching records\n\
+      -e,--exact               print exactly matching records (resolve)\n\
+      -l,--list                list full resource record\n\
+      -m,--meta                list table metadata\n\
+      -r,--resolve             resolution mode\n\
+  \n\
+      -b,--bandpass <bandpass> constrain by bandpass\n\
+      -C,--clevel <level>      constrain by content level\n\
+      -d,--dal                 constrain to only DAL services\n\
+      -g,--group               group search terms\n\
+      -s,--subject <subject>   constrain by subject string\n\
+      -t,--type <type>         constrain by service type\n\
+      -N,--new <time>          get only newly registered svcs\n\
+      -U,--updated <time>      get only newly updated entries\n\
+  \n\
+      -a,--all                 print all results (default)\n\
+      -f,--fields <fields>     output only specified fields\n\
+      -O,--or                  logically OR the search terms\n\
+      -n,--index <index>       set index of result (-1 => list, 0 => all)\n\
+      -o,--output <oname>      save results to <oname> as votable\n\
+      -B,--samp                broadcast results as a SAMP message\n\
+      -V,--votable             save results as VOTable\n\
+      -X,--xml                 save results as VOTable\n\
+  \n\
+      -I,--Id                  print only the Identifier (resolve mode)\n\
+      -L,--long                print long lines of output (no wrapping)\n\
+      -R,--Resolve             print the ShortName, ServiceType and ID\n\
+      -S,--SName               print only the ShortName (resolve mode)\n\
+      -T,--Title               print only the Title string (resolve mode)\n\
+  \n\
+  \n\
+  Resource Type Strings:\n\
+      catalog           Cone search services\n\
+      image             Simple Image Access services\n\
+      spectra           Simple Spectral Access services\n\
+      table             Vizier services\n\
+      <literal>         ResourceType from Registry record\n\
+  \n\
+  Allowed Bandpass Strings:\n\
+      Radio              Millimeter           Infrared (IR)\n\
+      Optical            Ultraviolet (UV)     X-Ray (xray)\n\
+      Gamma-Ray (GR)\n\
+  \n\
+  Allowed Resource Fields (for -f flag):\n\
+      Title 		 ShortName 	      Identifier\n\
+      ServiceURL 	 ReferenceURL         Description\n\
+      Subject 		 ResourceType         Type\n\
+      Creator 		 Publisher 	      CoverageSpatial\n\
+      CoverageTemporal   Waveband             ContentLevel\n\
+      Version\n\
+  \n\
+  \n\
+  \n\
+  Examples:\n  ---------\n\n\
+  \n\
+  1) Get a count of all the SIAP services available in the,\n\
+     Registry, then list more information about each:\n\
+  \n\
+        %% voregistry --count --type=image\n\
+        171\n\
+        %% voregistry -rv -t image\n\
+  \n\
+  2) Find all catalog (i.e. Cone) services using the search\n\
+     words 'radio' and 'galaxies':\n\
+  \n\
+        %% voregistry -t catalog radio galaxies\n\
+  \n\
+  3) Print the full resource record of the GSC2.3 catalog at STScI:\n\
+  \n\
+        %% voregistry --list GSC2.3\n\
+  ");
+
+  printf ("\n\n");
+}
+
+
+/**
+ *  Tests -- Task unit tests.
+ */
+static void
+Tests (char *input)
+{
+    Task *task = &self;
+
+    vo_taskTest (task, "--help", NULL);
+
+    vo_taskTest (task, "--count", "--type=image", NULL);		// Ex 1
+    vo_taskTest (task, "-rv", "-t", "image", NULL);			// Ex 1
+    vo_taskTest (task, "-t", "catalog", "radio", "galaxies", NULL);	// Ex 2
+    vo_taskTest (task, "--list", "GSC2.3", NULL);			// Ex 3
+
+    vo_taskTest (task, "-b", "radio", "abell", NULL);
+    vo_taskTest (task, "-rvv", "-n", "1", "J/A+A/446/97", NULL);
+    vo_taskTest (task, "-v", "-t", "image", "wfpc", NULL);
+    vo_taskTest (task, "-cv", "keck", NULL);
+    vo_taskTest (task, "-c", "chandra", "hst", "spitzer", NULL);
+    vo_taskTest (task, "-co", "chandra", "hst", "spitzer", NULL);
+    vo_taskTest (task, "Facility like 'HST'", NULL);
+    vo_taskTest (task, "Title like '%Keck%'", NULL);
+    vo_taskTest (task, "--new", "3m", NULL);
+    vo_taskTest (task, "--new", "3m", "cool", "stars", NULL);
+    vo_taskTest (task, "--updated", "12m", "--count", NULL);
+
+    vo_taskTestReport (self);
+}
-- 
cgit