+#include <sys/types.h>
+#include <sys/stat.h>
+#include <time.h>
+#include <unistd.h>
#include <getopt.h>
+
#include <stdsoap2.h>
+#include <glite/security/glite_gsplugin.h>
-/* workaround namespace symbol naming */
-#define jpis_client__namespaces namespaces
+#include "soap_version.h"
#include "jpis_client_.nsmap"
+/* 'jpisclient' as future namespace */
+#define _jpisclient__QueryJobs _jpelem__QueryJobs
+#define soap_default__jpisclient__QueryJobs soap_default__jpelem__QueryJobs
+#define soap_get__jpisclient__QueryJobs soap_get__jpelem__QueryJobs
+#define soap_put__jpisclient__QueryJobs soap_put__jpelem__QueryJobs
+#define soap_serialize__jpisclient__QueryJobs soap_serialize__jpelem__QueryJobs
+
+#define DEFAULT_JPIS "http://localhost:8902"
+
+
+/* namespaces[] not used here but needed to prevent linker to complain... */
+SOAP_NMAC struct Namespace namespaces[] = {
+ {NULL, NULL, NULL, NULL},
+};
+
static struct option opts[] = {
- {"host", 1, NULL, 'h'},
+ {"index-server", required_argument, NULL, 'i'},
+ {"example-file", optional_argument, NULL, 'e'},
+ {"query-file", optional_argument, NULL, 'q'},
+ {"test-file", optional_argument, NULL, 't'},
{NULL, 0, NULL, 0}
};
-static const char *get_opt_string = "h:";
+static const char *get_opt_string = "i:q:e:t:";
+
+#define NUMBER_OP 6
+struct {
+ enum jptype__queryOp op;
+ const char *name;
+} operations[] = {
+ {jptype__queryOp__EQUAL, "=="},
+ {jptype__queryOp__UNEQUAL, "<>"},
+ {jptype__queryOp__LESS, "<"},
+ {jptype__queryOp__GREATER, ">"},
+ {jptype__queryOp__WITHIN, "in"},
+ {jptype__queryOp__EXISTS, "exists"},
+ {0, "unknown"}
+};
+
+
+/*
+ * set the value
+ */
+static void value_set(struct soap *soap, struct jptype__stringOrBlob **value, const char *str) {
+#if GSOAP_VERSION >= 20706
+ *value = soap_malloc(soap, sizeof(*value));
+ (*value)->__union_1 = SOAP_UNION_jptype__union_1_string;
+ (*value)->union_1.string = soap_strdup(soap, str);
+#else
+ *value = soap_malloc(soap, sizeof(*value));
+ (*value)->string = soap_strdup(soap, str);
+ (*value)->blob = NULL;
+#endif
+}
-#if USE_DUMP
-void query_example_fill(struct soap *soap, struct _jpisclient__QueryJobs *in) {
+/*
+ * print the query data in the soap structre
+ */
+static void value_print(FILE *out, const struct jptype__stringOrBlob *value) {
+ int i, size, maxsize;
+ unsigned char *ptr;
+
+ if (value) {
+#if GSOAP_VERSION >= 20706
+ if (value->__union_1 == SOAP_UNION_jptype__union_1_string) {
+ fprintf(out, "%s", value->union_1.string);
+ } else if (value->__union_1 == SOAP_UNION_jptype__union_1_blob) {
+ fprintf(out, "BLOB(");
+ ptr = value->union_1.blob->__ptr;
+ size = value->union_1.blob->__size;
+#else
+ if (value->string) fprintf(out, "%s", value->string);
+ else if (value->blob) {
+ fprintf(out, "BLOB(");
+ ptr = value->blob->__ptr;
+ size = value->blob->__size;
+#endif
+ maxsize = 10;
+ if (ptr) {
+ maxsize = size < 10 ? size : 10;
+ for (i = 0; i < maxsize; i++) fprintf(out, "%02X ", ptr[i]);
+ if (maxsize < size) fprintf(out, "...");
+ } else fprintf(out, "NULL");
+ fprintf(out, ")");
+ }
+ } else {
+ fprintf(out, "-");
+ }
+}
+
+
+/*
+ * fill the query soap structure with some example data
+ */
+static void query_example_fill(struct soap *soap, struct _jpisclient__QueryJobs *in) {
struct jptype__indexQuery *cond;
struct jptype__indexQueryRecord *rec;
rec = soap_malloc(soap, sizeof(*rec));
memset(rec, 0, sizeof(*rec));
rec->op = jptype__queryOp__EQUAL;
- rec->value = soap_malloc(soap, sizeof(*(rec->value)));
- rec->value->string = soap_strdup(soap, "Done");
- rec->value->blob = NULL;
+ value_set(soap, &rec->value, "Done");
cond->record[0] = rec;
// OR equal to Ready
rec = soap_malloc(soap, sizeof(*rec));
memset(rec, 0, sizeof(*rec));
rec->op = jptype__queryOp__EQUAL;
- rec->value = soap_malloc(soap, sizeof(*(rec->value)));
- rec->value->string = soap_strdup(soap, "Ready");
- rec->value->blob = NULL;
+ value_set(soap, &rec->value, "Ready");
cond->record[1] = rec;
in->conditions[0] = cond;
rec = soap_malloc(soap, sizeof(*rec));
memset(rec, 0, sizeof(*rec));
rec->op = jptype__queryOp__UNEQUAL;
- rec->value = soap_malloc(soap, sizeof(*(rec->value)));
- rec->value->string = soap_strdup(soap, "God");
- rec->value->blob = NULL;
+ value_set(soap, &rec->value, "God");
cond->record[0] = rec;
in->conditions[1] = cond;
}
-void query_example_free(struct soap *soap, struct _jpisclient__QueryJobs *in) {
+/*
+ * print info from the query soap structure
+ */
+static void query_print(FILE *out, const struct _jpisclient__QueryJobs *in) {
struct jptype__indexQueryRecord *rec;
- int i, j;
+ int i, j, k;
+ fprintf(out, "Conditions:\n");
for (i = 0; i < in->__sizeconditions; i++) {
- if (in->conditions[i]->attr) soap_dealloc(soap, in->conditions[i]->attr);
+ fprintf(out, "\t%s\n", in->conditions[i]->attr);
for (j = 0; j < in->conditions[i]->__sizerecord; j++) {
rec = in->conditions[i]->record[j];
+ for (k = 0; k <= NUMBER_OP; k++)
+ if (operations[k].op == rec->op) break;
+ fprintf(out, "\t\t%s", operations[k].name);
if (rec->value) {
- if (rec->value->string) soap_dealloc(soap, rec->value->string);
- if (rec->value->blob) soap_dealloc(soap, rec->value->blob);
- soap_dealloc(soap, rec->value);
+ fprintf(out, " ");
+ value_print(out, rec->value);
+ }
+ if (rec->value2) {
+ if (!rec->value) fprintf(out, "-");
+ fprintf(out, " ");
+ value_print(out, rec->value2);
}
- soap_dealloc(soap, in->conditions[i]->record[j]);
+ fprintf(out, "\n");
}
- soap_dealloc(soap, in->conditions[i]);
}
+ fprintf(out, "Attributes:\n");
for (i = 0; i < in->__sizeattributes; i++)
- soap_dealloc(soap, in->attributes[i]);
+ fprintf(out, "\t%s\n", in->attributes[i]);
}
-void query_example_dump(struct soap *soap, int fd) {
- struct _jpisclient__QueryJobs qj;
-
- memset(&qj, 0, sizeof(qj));
-
- soap->sendfd = fd;
- soap_begin(soap);
- query_example_fill(soap, &qj);
- soap_begin_send(soap);
- soap_serialize__jpisclient__QueryJobs(soap, &qj);
- soap_put__jpisclient__QueryJobs(soap, &qj, "queryJobs", "indexQuery");
- soap_end_send(soap);
- soap_end(soap);
-}
-#endif
-
-int query_recv(struct soap *soap, int fd, struct _jpisclient__QueryJobs *qj) {
+/*
+ * read the XML query
+ */
+static int query_recv(struct soap *soap, int fd, struct _jpisclient__QueryJobs *qj) {
memset(qj, 0, sizeof(*qj));
soap->recvfd = fd;
}
-static void usage(const char *name) {
- fprintf(stderr, "Usage: %s [-h JPIS:PORT]\n", name);
+/*
+ * dump the XML query
+ */
+static int query_dump(struct soap *soap, int fd, struct _jpisclient__QueryJobs *qj) {
+ int retval;
+
+ soap->sendfd = fd;
+ soap_begin_send(soap);
+ soap_serialize__jpisclient__QueryJobs(soap, qj);
+ retval = soap_put__jpisclient__QueryJobs(soap, qj, "queryJobs", "indexQuery");
+ soap_end_send(soap);
+
+ return retval;
+}
+
+
+/*
+ * dump the XML query with the example data
+ */
+static int query_example_dump(struct soap *soap, int fd) {
+ struct _jpisclient__QueryJobs qj;
+ int retval;
+
+ memset(&qj, 0, sizeof(qj));
+
+ soap_begin(soap);
+ query_example_fill(soap, &qj);
+ retval = query_dump(soap, fd, &qj);
+ soap_end(soap);
+
+ return retval;
+}
+
+
+/*
+ * help screen
+ */
+static void usage(const char *prog_name) {
+ fprintf(stderr, "Usage: %s OPTIONS\n", prog_name);
+ fprintf(stderr, "Options:\n");
+ fprintf(stderr, " -h|--help\n");
+ fprintf(stderr, " -i|--index-server JPIS:PORT (default: " DEFAULT_JPIS ")\n");
+ fprintf(stderr, " -q|--query-file IN_FILE.XML\n");
+ fprintf(stderr, " -t|--test-file IN_FILE.XML\n");
+ fprintf(stderr, " -e|--example-file OUT_FILE.XML\n");
+}
+
+
+/*
+ * process the result after calling soap
+ */
+static int check_fault(struct soap *soap, int err) {
+ struct SOAP_ENV__Detail *detail;
+ struct jptype__genericFault *f;
+ char *reason,indent[200] = " ";
+
+ switch(err) {
+ case SOAP_OK: fputs("OK", stderr);
+ putc('\n', stderr);
+ break;
+ case SOAP_FAULT:
+ case SOAP_SVR_FAULT:
+ if (soap->version == 2) {
+ detail = soap->fault->SOAP_ENV__Detail;
+#if GSOAP_VERSION >= 20706
+ reason = soap->fault->SOAP_ENV__Reason->SOAP_ENV__Text;
+#else
+ reason = soap->fault->SOAP_ENV__Reason;
+#endif
+ }
+ else {
+ detail = soap->fault->detail;
+ reason = soap->fault->faultstring;
+ }
+ fputs(reason, stderr);
+ putc('\n', stderr);
+ assert(detail->__type == SOAP_TYPE__genericFault);
+#if GSOAP_VERSION >= 20700
+ f = ((struct _genericFault *) detail->fault)
+#else
+ f = ((struct _genericFault *) detail->value)
+#endif
+ -> jpelem__genericFault;
+
+ while (f) {
+ fprintf(stderr,"%s%s: %s (%s)\n",indent,
+ f->source,f->text,f->description);
+ f = f->reason;
+ strcat(indent," ");
+ }
+ return -1;
+
+ default: soap_print_fault(soap,stderr);
+ return -1;
+ }
+ return 0;
+}
+
+
+/*
+ * print the data returned from JP IS
+ */
+static void queryJobsResponse_print(FILE *out, const struct _jpelem__QueryJobsResponse *in) {
+ struct jptype__attrValue *attr;
+ int i, j;
+
+ fprintf(out, "Result %d jobs:\n", in->__sizejobs);
+ for (j=0; j<in->__sizejobs; j++) {
+ fprintf(out, "\tjobid = %s, owner = %s\n", in->jobs[j]->jobid, in->jobs[j]->owner);
+ for (i=0; i<in->jobs[j]->__sizeattributes; i++) {
+ attr = in->jobs[j]->attributes[i];
+ fprintf(out, "\t\t%s\n", attr->name);
+ fprintf(out, "\t\t\tvalue = ");
+ value_print(out, attr->value);
+ fprintf(out, "\n");
+ fprintf(out, "\t\t\torigin = %d, %s\n", attr->origin, attr->originDetail);
+ fprintf(out, "\t\t\ttime = %s", ctime(&attr->timestamp));
+ }
+ }
}
int main(int argc, char * const argv[]) {
struct soap soap;
struct _jpisclient__QueryJobs qj;
- char *query_file = NULL;
- const char *name = NULL;
- int opt;
-
+ char *server, *example_file, *query_file, *test_file;
+ const char *prog_name;
+ int retval, opt, example_fd, query_fd, test_fd;
+
+ prog_name = server = NULL;
+ example_file = query_file = test_file = NULL;
+ query_fd = example_fd = test_fd = -1;
+ retval = 1;
+
+ /*
+ * Soap with registered plugin can't be used for reading XML.
+ * For communications with JP IS glite_gsplugin needs to be registered yet.
+ */
soap_init(&soap);
+ soap_set_namespaces(&soap, jpis_client__namespaces);
#ifdef SOAP_XML_INDENT
soap_omode(&soap, SOAP_XML_INDENT);
#endif
-#ifdef USE_DUMP
- query_example_dump(&soap, 1);
-#endif
-
- /* arguments */
- name = strrchr(argv[0], '/');
- if (name) name++;
- else name = argv[0];
+ /* program name */
+ prog_name = strrchr(argv[0], '/');
+ if (prog_name) prog_name++;
+ else prog_name = argv[0];
+ /* handle arguments */
while ((opt = getopt_long(argc, argv, get_opt_string, opts, NULL)) != EOF) switch (opt) {
- case 'h': free(query_file); query_file = strdup(optarg); break;
+ case 'i':
+ free(server);
+ server = strdup(optarg);
+ break;
+ case 'e':
+ free(example_file);
+ example_file = strdup(optarg);
+ break;
+ case 'q':
+ free(query_file);
+ query_file = strdup(optarg);
+ break;
+ case 't':
+ free(test_file);
+ test_file = strdup(optarg);
+ break;
default:
- usage(name);
- return 1;
+ usage(prog_name);
+ goto cleanup;
}
if (optind < argc) {
- usage(name);
- return 1;
+ usage(prog_name);
+ goto cleanup;
+ }
+ if (!server) server = strdup(DEFAULT_JPIS);
+
+ /* prepare steps according to the arguments */
+ if (query_file) {
+ if (strcmp(query_file, "-") == 0) query_fd = STDIN_FILENO;
+ else if ((query_fd = open(query_file, 0)) < 0) {
+ fprintf(stderr, "error opening %s: %s\n", query_file, strerror(errno));
+ goto cleanup;
+ }
+ free(query_file);
+ query_file = NULL;
+ }
+ if (example_file) {
+ if (strcmp(example_file, "-") == 0) example_fd = STDOUT_FILENO;
+ else if ((example_fd = creat(example_file, S_IREAD | S_IWRITE | S_IRGRP)) < 0) {
+ fprintf(stderr, "error creating %s: %s\n", example_file, strerror(errno));
+ goto cleanup;
+ }
+ free(example_file);
+ example_file = NULL;
+ }
+ if (test_file) {
+ if (strcmp(test_file, "-") == 0) example_fd = STDOUT_FILENO;
+ else if ((test_fd = open(test_file, 0)) < 0) {
+ fprintf(stderr, "error opening %s: %s\n", test_file, strerror(errno));
+ goto cleanup;
+ }
+ free(test_file);
+ test_file = NULL;
}
- soap_begin(&soap);
- if (query_recv(&soap, 0, &qj) != 0) {
- printf("chyba\n");
- } else {
- printf("qj.attributes[0] = %s\n", qj.attributes[0]);
+ /* the dump action */
+ if (example_fd >= 0) {
+ if (query_example_dump(&soap, example_fd) != 0) {
+ fprintf(stderr, "Error dumping example query XML.\n");
+ }
}
- soap_end(&soap); /* free decoded data */
- soap_done(&soap);
+ /* the test XML file action */
+ if (test_fd >= 0) {
+ soap_begin(&soap);
+ if (query_recv(&soap, test_fd, &qj) != 0) {
+ fprintf(stderr, "test: Error getting query XML\n");
+ } else {
+ query_print(stdout, &qj);
+ }
+ soap_end(&soap);
+ }
- return 0;
+ /* query action */
+ if (query_fd >= 0) {
+ struct _jpelem__QueryJobs in;
+ struct _jpelem__QueryJobsResponse out;
+ int ret;
+
+ soap_begin(&soap);
+ memset(&in, 0, sizeof(in));
+ memset(&out, 0, sizeof(out));
+ /*
+ * Right way would be copy data from client query structure to IS query
+ * structure. Just ugly retype to client here.
+ */
+ if (query_recv(&soap, query_fd, (struct _jpisclient__QueryJobs *)&in) != 0) {
+ fprintf(stderr, "test: Error getting query XML\n");
+ } else {
+ fprintf(stderr, "query: using JPIS %s\n\n", server);
+ query_print(stderr, &in);
+ fprintf(stderr, "\n");
+ soap_register_plugin(&soap, glite_gsplugin);
+ ret = check_fault(&soap, soap_call___jpsrv__QueryJobs(&soap, server, "", &in, &out));
+ if (ret == 0) {
+ queryJobsResponse_print(stderr, &out);
+ } else goto cleanup;
+ }
+ soap_end(&soap);
+ }
+
+ retval = 0;
+
+cleanup:
+ soap_done(&soap);
+ if (example_fd > STDERR_FILENO) close(example_fd);
+ if (query_fd > STDERR_FILENO) close(query_fd);
+ if (test_fd > STDERR_FILENO) close(test_fd);
+ free(server);
+ free(example_file);
+ free(query_file);
+ free(test_file);
+
+ return retval;
}
git://scientific.zcu.cz / jra1mw.git / commitdiff