aboutsummaryrefslogtreecommitdiff
path: root/vendor/voclient/libsamp/apps
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/voclient/libsamp/apps')
-rw-r--r--vendor/voclient/libsamp/apps/Makefile154
-rw-r--r--vendor/voclient/libsamp/apps/samp.c397
2 files changed, 551 insertions, 0 deletions
diff --git a/vendor/voclient/libsamp/apps/Makefile b/vendor/voclient/libsamp/apps/Makefile
new file mode 100644
index 00000000..9b0f98df
--- /dev/null
+++ b/vendor/voclient/libsamp/apps/Makefile
@@ -0,0 +1,154 @@
+#///////////////////////////////////////////////////////////////////////////////
+#//
+#// Makefile for the libsamp application tasks.
+#//
+#///////////////////////////////////////////////////////////////////////////////
+
+# primary dependencies
+
+NAME = samp
+VERSION = 1.0
+PLATFORM := $(shell uname -s)
+PLMACH := $(shell uname -m)
+HERE := $(shell /bin/pwd)
+BINDIR := ../../bin/
+LIBDIR := ../../lib/
+INCDIR := ../../include/
+
+
+# secondary dependencies
+LIBBASE = lib$(NAME)
+STATICLIB = $(HERE)/$(LIBBASE).a
+SHAREDLIB = $(HERE)/$(LIBBASE).so.$(VERSION)
+
+
+# stuff that's precious to keep
+.PRECIOUS: $(STATICLIB) $(SHAREDLIB)
+.KEEP_STATE:
+
+
+ifeq ($(PLATFORM), "Darwin")
+ ifeq ($(PLMACH), "x86_64")
+ CARCH = -m64 -mmacosx-version-min=10.5
+ else
+ CARCH = -arch i386 -arch ppc -m32 -mmacosx-version-min=10.4
+ endif
+else
+ CLIBS = -lm -lc -lpthread
+ CARCH =
+endif
+
+CFLAGS = -g -Wall $(CARCH) -D$(PLATFORM) $(CINCS) -L./
+
+
+
+# includes, flags and libraries
+CC = gcc
+CINCS = -I$(HERE) -I../ -I../../include -L../ -L../../lib/ -L../
+CFLAGS = -g -Wall -D$(PLATFORM) $(CINCS)
+
+#F77 = g77
+F77 = gfortran
+FFLAGS = -g -Wall
+
+
+
+# list of source and include files
+
+C_SRCS = samp.c
+C_OBJS =
+C_INCS =
+
+F77_SRCS =
+F77_OBJS =
+F77_INCS =
+
+SPP_SRCS =
+SPP_OBJS =
+SPP_INCS =
+
+
+LIBS = -lsamp -lcurl $(CLIBS)
+
+SPP_TASKS =
+F77_TASKS =
+C_TASKS = samp
+
+TARGETS = $(F77_TASKS) $(SPP_TASKS) $(C_TASKS)
+
+
+# Targets
+
+all: $(TARGETS)
+
+c_progs: $(C_TASKS)
+spp_progs: $(SPP_TASKS)
+f77_progs: $(F77_TASKS)
+
+clean:
+ /bin/rm -rf .make.state .nse_depinfo *.[aeo] *.dSYM
+ /bin/rm -rf $(TARGETS)
+
+everything:
+ make clean
+ make all
+ make install
+
+help: HELP
+
+install: all
+
+
+
+###############################################################################
+# Unit test programs to be built.
+###############################################################################
+
+demo: $(TARGETS)
+
+
+###########################
+# C Test programs
+###########################
+
+zztest: zztest.c
+ $(CC) $(CFLAGS) -o zztest zztest.c $(LIBS)
+
+samp: samp.c ../libsamp.a
+ $(CC) $(CFLAGS) -o samp samp.c $(LIBS)
+
+
+
+###########################
+# SPP Test programs
+###########################
+
+
+
+###########################
+# Fortran Test programs.
+###########################
+
+
+
+
+###############################################################################
+# Leave this stuff alone.
+###############################################################################
+
+$(STATICLIB): $(C_SRCS:%.c=Static/%.o)
+ /usr/bin/ar rv $@ $?
+Static/%.o: %.c $(C_INCS)
+ /usr/bin/gcc $(CINCS) $(CFLAGS) -c $< -o $@
+Static:
+ /bin/mkdir $@
+ chmod 777 $@
+
+$(SHAREDLIB): $(C_SRCS:%.c=Shared/%.o)
+ /usr/bin/ld -shared -o $@ $? -lc -ldl
+Shared/%.o: %.c $(C_INCS)
+ /usr/bin/gcc $(CINCS) $(CFLAGS) -fpic -shared -c $< -o $@
+Shared:
+ /bin/mkdir $@
+ chmod 777 $@
+
diff --git a/vendor/voclient/libsamp/apps/samp.c b/vendor/voclient/libsamp/apps/samp.c
new file mode 100644
index 00000000..66b07bb2
--- /dev/null
+++ b/vendor/voclient/libsamp/apps/samp.c
@@ -0,0 +1,397 @@
+/**
+ * SAMP - Example task to send a single SAMP message for the cmdline.
+ *
+ * Usage:
+ *
+ * % samp [-hvd] [-t to] [-p pattern] [-f file] <cmd> [args ...]
+ *
+ * where <cmd> command to process
+ * -h print help summary
+ * -d debug output
+ * -v verbose output
+ *
+ * -m handle multiple messages
+ * -s <sender> handle only messages from <sender>
+ *
+ * -t <to> send to specified application (or all)
+ * -p <pattern> message pattern: sync|async|notify
+ * -f <file> send all commands in the file
+ *
+ * Subcommands:
+ *
+ * snoop print all received messages
+ *
+ * status print Hub availability
+ * list list all registered clients
+ * access <appName> print <appName> availability
+ * handle <mtype> wait for <mtype> message
+ *
+ * send <mtype> [<args> ...] generalized <mtype> message send
+ * exec <cmd> execute a client command
+ * pointAt <ra> <dec> point at given coords
+ * setenv <name> <value> set an environment value
+ * getenv <name> get an environment value
+ * setparam <name> <value> set a parameter value
+ * getparam <name> get a parameter value
+ *
+ * loadImage <url> load the named image
+ * loadVOTable <url> load the named VOTable
+ * loadFITS <url> load the named FITS bintable
+ * showRow [<tblId>] [<url>] <row> highlight specified row
+ * selectRows [<tblId>] [<url>] <rows> select specified rows
+ * bibcode <bibcode> load the named bibcode
+ *
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <string.h>
+#include <ctype.h>
+
+#include "samp.h" /* LIBSAMP interface */
+
+#define SZ_MTYPE 64
+#define MAX_ARGS 8
+#define MATCH(s) (strcasecmp(cmd,s)==0)
+
+int samp = 0; /* samp struct handle */
+
+int verbose = 0; /* task options */
+int debug = 0;
+int multiple = 0;
+int interact = 0;
+char *to = "all";
+char *pattern = NULL;
+char *cmdfile = NULL;
+char *filt_mtype = NULL;
+char *filt_sender = NULL;
+char cmd[SZ_CMD];
+
+FILE *fd = (FILE *) NULL;
+
+
+static char *name = "samp"; /* metadata */
+static char *descr = "CLI App";
+
+static void msg_handler (char *sender, char *msg_id, int params);
+static void procCmd (int samp, char *to, char *cmd, char *args[], int numargs);
+static void help_summary (void);
+
+
+
+/****************************************************************************
+ * Program entry point.
+ */
+int
+main (int argc, char **argv)
+{
+ char line[SZ_CMD], *args[MAX_ARGS];
+ int i, j, len, numargs = 0;
+
+
+ memset (cmd, 0, SZ_MTYPE); /* initialize */
+ for (i=0; i < MAX_ARGS; i++)
+ args[i] = calloc (1, SZ_LINE);
+
+ /* Process commandline arguments.
+ */
+ for (i=1; i < argc; i++) {
+ if (argv[i][0] == '-' && !(isdigit(argv[i][1]))) {
+ len = strlen (argv[i]);
+ for (j=1; j < len; j++) {
+ switch (argv[i][j]) {
+ case 'h': help_summary (); return (0);
+ case 'd': debug++; break;
+ case 'v': verbose++; break;
+
+ case 'm': multiple++; break;
+ case 's': filt_sender = argv[++i]; j = len; break;
+
+ case 'i': interact++; cmdfile = "-"; j = len; break;
+ case 'f': cmdfile = argv[++i]; j = len; break;
+ case 'p': pattern = argv[++i]; j = len; break;
+ case 't': to = argv[++i]; j = len; break;
+
+ default:
+ fprintf (stderr, "Unknown option '%c'\n\n", argv[i][j]);
+ help_summary ();
+ break;
+ }
+ }
+ } else {
+ /* Remainder of argv is the subcommand and its arguments.
+ */
+ if (!cmd[0])
+ strcpy (cmd, argv[i]);
+ else {
+ if (strcasecmp (cmd, "exec") == 0) {
+ strcat (args[0], argv[i]);
+ strcat (args[0], " ");
+ } else
+ strcpy (args[numargs++], argv[i]);
+ }
+ }
+ }
+
+
+ /* Initialize the SAMP interface.
+ */
+ samp = sampInit (name, descr);
+
+ /* Set alternative messaging pattern if requested. Valid values are
+ * 'synch', 'asynch' or 'notify'.
+ */
+ if (pattern) {
+ switch (tolower(pattern[0])) {
+ case 's': samp_setSyncMode (samp); break; /* default */
+ case 'a': samp_setASyncMode (samp); break;
+ case 'n': samp_setNotifyMode (samp); break;
+ default:
+ if (verbose)
+ fprintf (stderr, "Warning: Invalid pattern '%s'\n", pattern);
+ }
+ } else {
+ /* Use Synchronous mode by default so we don't exit before receiving
+ * the reply. Otherwise, we could cause an error in the recipient.
+ */
+ samp_setSyncMode (samp);
+ }
+
+
+ /* Register with the Hub and begin messaging. Since we're a single-shot
+ * command we won't bother to register metadata or subscribe to
+ * messages. The startup will run the server thread to handle the
+ * responses
+ */
+ sampStartup (samp);
+
+
+ /* Process the messages in the named file, or from the cmdline. Since
+ * there is some overhead in connecting to the hub, this is an efficient
+ * way to send multiple messages from a single connection.
+ */
+ if (cmdfile) {
+ fd = (cmdfile[0] == '-' ? stdin : fopen (cmdfile, "r"));
+ if (fd) {
+ memset (line, 0, SZ_CMD);
+
+ if (interact || fd == stdin)
+ printf ("samp> ");
+
+ while (fgets (line, SZ_CMD, fd)) {
+ line[strlen(line)-1] = '\0'; /* kill newline */
+ memset (cmd, 0, SZ_CMD);
+ memset (&args[0][0], 0, (SZ_MTYPE * MAX_ARGS));
+
+ if (strncasecmp (line, "exec", 4) == 0) {
+ /* special-case for exec command to create a single arg */
+ strcpy (cmd, "exec");
+ sprintf (args[0], "%s", &line[5]);
+ numargs = 1;
+
+ } else {
+ numargs = sscanf (line, "%s %s %s %s %s %s %s %s %s",
+ cmd, args[0], args[1], args[2], args[3],
+ args[4], args[5], args[6], args[7]);
+ }
+
+ procCmd (samp, to, cmd, args, numargs);
+ }
+ if (fd != stdin)
+ fclose (fd);
+ } else
+ fprintf (stderr, "Cannot open input file '%s'\n", cmdfile);
+
+ } else
+ procCmd (samp, to, cmd, args, numargs);
+
+
+ if (sampShutdown (samp) < 0) /* clean up */
+ fprintf (stderr, "SAMP shutdown fails\n");
+ sampClose (samp);
+
+ return (0);
+}
+
+
+/**
+ * PROCCMD -- Process the command and its arguments.
+ */
+static void
+procCmd (int samp, char *to, char *cmd, char *args[], int numargs)
+{
+ int stat = 0;
+
+
+ /* Format the message and send it.
+ */
+ if (MATCH ("status")) {
+ stat = (samp >= 0);
+
+ } else if (MATCH ("access")) {
+ stat = samp_Ping (samp, to);
+
+ } else if (MATCH ("handle")) {
+ int timeout = (atoi (args[1]) == 0 ? 999999 : atoi (args[1]));
+
+ if (verbose)
+ fprintf (stderr, "Waiting for '%s' ....\n", args[0]);
+ if (*args[1])
+ filt_sender = args[1];
+
+ samp_Subscribe (samp, (filt_mtype = args[0]), msg_handler);
+ samp_DeclareSubscriptions (samp);
+ sleep (timeout);
+
+ } else if (MATCH ("snoop")) {
+ /* Subscribe to all message types and install the snoop handler.
+ * Sleep forever so the handler can print anything it receives.
+ */
+ multiple = 1;
+ samp_Subscribe (samp, "*", msg_handler);
+ samp_DeclareSubscriptions (samp);
+ sleep (9999999);
+
+ } else if (MATCH ("send")) {
+ if (strcasecmp (to, "all")) /* no recipient, use broadcast */
+ samp_setASyncMode (samp);
+ stat = samp_sendGeneric (samp, to, args[0], &args[1]);
+
+ } else if (MATCH ("ping")) {
+ stat = samp_Ping (samp, to);
+
+ } else if (MATCH ("loadImage")) {
+ stat = samp_imageLoadFITS (samp, to, args[0], args[1], args[2]);
+
+ } else if (MATCH ("loadFITS")) {
+ stat = samp_tableLoadFITS (samp, to, args[0], args[1], args[2]);
+
+ } else if (MATCH ("loadVOTable")) {
+ stat = samp_tableLoadVOTable (samp, to, args[0], args[1],
+ args[2]);
+
+ } else if (MATCH ("loadSpec")) {
+ /* NYI */
+
+ } else if (MATCH ("loadResource")) {
+ /* NYI */
+
+ } else if (MATCH ("showRow")) {
+ stat = samp_tableHighlightRow (samp, to, args[0], args[1],
+ atoi(args[2]));
+
+ } else if (MATCH ("selectRows")) {
+ /* NYI */
+
+ } else if (MATCH ("pointAt")) {
+ stat = samp_coordPointAtSky (samp, to,
+ atof(args[0]), atof(args[1]));
+
+
+ } else if (MATCH ("exec")) {
+ if (verbose)
+ printf ("Sending: '%s'\n", args[0]);
+ samp_cmdExec (samp, to, args[0]);
+
+ } else if (MATCH ("getenv")) {
+ char *v = samp_envGet (samp, to, args[0]);
+ printf ("%s\n", v);
+ free ((void *) v);
+ return;
+
+ } else if (MATCH ("setenv")) {
+ stat = samp_envSet (samp, to, args[0], args[1]);
+
+ } else if (MATCH ("getparam")) {
+ char *v = samp_paramGet (samp, to, args[0]);
+ printf ("%s\n", v);
+ free ((void *) v);
+ return;
+
+ } else if (MATCH ("setparam")) {
+ stat = samp_paramSet (samp, to, args[0], args[1]);
+
+ } else if (MATCH ("bibcode")) {
+ stat = samp_bibLoad (samp, to, args[1]);
+
+ } else {
+ fprintf (stderr, "Error: unknown command '%s'\n", cmd);
+ }
+
+ if (verbose)
+ fprintf (stderr, "%s\n", (stat < 0 ? "Error" : "OK"));
+}
+
+
+static void
+msg_handler (char *sender, char *msg_id, int params)
+{
+ extern int samp;
+
+ if (filt_sender && strcasecmp (filt_sender, sender))
+ return;
+
+ /* Either no filters were set, or the message is of the requested type,
+ * print the contents.
+ */
+ samp_printMessage (filt_mtype, samp_id2app (samp, sender), msg_id, params);
+
+ if (!interact && !multiple) { /* Do a clean disconnect .... */
+ if (sampShutdown (samp) < 0)
+ fprintf (stderr, "SAMP shutdown fails\n");
+ sampClose (samp);
+ exit (0);
+ }
+}
+
+
+static void
+help_summary (void)
+{
+ fprintf (stderr,
+ " Usage:\n"
+ "\n"
+ " %% samp [-hvd] [-t to] [-p pattern] [-f file] <cmd> [args ...]\n"
+ "\n"
+ " where <cmd> command to process\n"
+ " -h print help summary\n"
+ " -v verbose output\n"
+ " -d debug output\n"
+ "\n"
+ " -m handle multiple messages\n"
+ " -s <sender> handly only msgs from <sender>\n"
+ "\n"
+ " -t <to> send to specified app (or all)\n"
+ " -p <pattern> message pattern: sync|async|notify\n"
+ " -f <file> send all commands in the file\n"
+ "\n"
+ " Commands:\n"
+ "\n"
+ " snoop print all received messages\n"
+ " send <mtype> [<args> ...] generalized <mtype> message send\n"
+ "\n"
+ " status print Hub availability\n"
+ " list list all registered clients\n"
+ " access <appName> print <appName> availability\n"
+ " handle <mtype> wait for <mtype> message\n"
+ "\n"
+ " exec <cmd> execute a client command\n"
+ " setenv <name> <value> set an environment value\n"
+ " getenv <name> get an environment value\n"
+ " setparam <name> <value> set a parameter value\n"
+ " getparam <name> get a parameter value\n"
+ "\n"
+ " loadImage <url> load the named image\n"
+ " loadVOTable <url> load the named VOTable\n"
+ " loadFITS <url> load the named FITS bintable\n"
+ " loadSpec <url> load the named spectrum\n"
+ " loadResource <ivorn> load the named VO Resource\n"
+ "\n"
+ " pointAt <ra> <dec> point at given coords\n"
+ " showRow [<tblId>] [<url>] <row> highlight specified row\n"
+ " selectRows [<tblId>] [<url>] <rows> select specified rows\n"
+ " bibcode <bibcode> load the bibcode\n"
+ "\n"
+ );
+}
generated by cgit (git 2.34.1) at 2025-09-20 18:53:05 -0400