X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=src%2Fhttp_command.c;h=848370571eeaa1a844d8d8df2c5e7050b4bc923f;hb=bdde87cfaf2307da5d3f6fcb911f621a9df114fe;hp=4068cc84dd35ca9abb6822ccc63caae9f51c381e;hpb=41b3d6e76417912fda803543325e1edba21896ba;p=pazpar2-moved-to-github.git diff --git a/src/http_command.c b/src/http_command.c index 4068cc8..8483705 100644 --- a/src/http_command.c +++ b/src/http_command.c @@ -1,5 +1,5 @@ /* - * $Id: http_command.c,v 1.9 2007-01-08 12:43:41 adam Exp $ + * $Id: http_command.c,v 1.21 2007-01-12 23:41:35 quinn Exp $ */ #include @@ -17,6 +17,7 @@ #include +#include "config.h" #include "util.h" #include "eventl.h" #include "pazpar2.h" @@ -99,7 +100,7 @@ unsigned int make_sessionid() if (gettimeofday(&t, 0) < 0) abort(); res = t.tv_sec; - res = ((res << 8) | (seq & 0xff)) & ((unsigned int) (1 << 31) - 1); + res = ((res << 8) | (seq & 0xff)) & ((1U << 31) - 1); return res; } @@ -270,12 +271,76 @@ static void cmd_bytarget(struct http_channel *c) http_send_response(c); } +static void write_metadata(WRBUF w, struct conf_service *service, + struct record_metadata **ml, int full) +{ + int imeta; + + for (imeta = 0; imeta < service->num_metadata; imeta++) + { + struct conf_metadata *cmd = &service->metadata[imeta]; + struct record_metadata *md; + if (!cmd->brief && !full) + continue; + for (md = ml[imeta]; md; md = md->next) + { + wrbuf_printf(w, "", cmd->name); + switch (cmd->type) + { + case Metadata_type_generic: + wrbuf_puts(w, md->data.text); + break; + case Metadata_type_year: + wrbuf_printf(w, "%d", md->data.year.year1); + if (md->data.year.year1 != md->data.year.year2) + wrbuf_printf(w, "-%d", md->data.year.year2); + break; + default: + wrbuf_puts(w, "[can't represent]"); + } + wrbuf_printf(w, "", cmd->name); + } + } +} + +static void cmd_record(struct http_channel *c) +{ + struct http_response *rs = c->response; + struct http_request *rq = c->request; + struct http_session *s = locate_session(rq, rs); + struct record_cluster *rec; + struct conf_service *service = global_parameters.server->service; + char *idstr = http_argbyname(rq, "id"); + int id; + + if (!s) + return; + if (!idstr) + { + error(rs, "417", "Must supply id", 0); + return; + } + wrbuf_rewind(c->wrbuf); + id = atoi(idstr); + if (!(rec = show_single(s->psession, id))) + { + error(rs, "500", "Record missing", 0); + return; + } + wrbuf_puts(c->wrbuf, "\n"); + wrbuf_printf(c->wrbuf, "%d", rec->recid); + write_metadata(c->wrbuf, service, rec->metadata, 1); + wrbuf_puts(c->wrbuf, "\n"); + rs->payload = nmem_strdup(c->nmem, wrbuf_buf(c->wrbuf)); + http_send_response(c); +} + static void show_records(struct http_channel *c, int active) { struct http_request *rq = c->request; struct http_response *rs = c->response; struct http_session *s = locate_session(rq, rs); - struct record **rl; + struct record_cluster **rl; NMEM nmem_show; char *start = http_argbyname(rq, "start"); char *num = http_argbyname(rq, "num"); @@ -312,13 +377,16 @@ static void show_records(struct http_channel *c, int active) { int ccount; struct record *p; + struct record_cluster *rec = rl[i]; + struct conf_service *service = global_parameters.server->service; wrbuf_puts(c->wrbuf, "\n"); - wrbuf_printf(c->wrbuf, "%s\n", rl[i]->title); - for (ccount = 1, p = rl[i]->next_cluster; p; p = p->next_cluster, ccount++) + write_metadata(c->wrbuf, service, rec->metadata, 0); + for (ccount = 0, p = rl[i]->records; p; p = p->next, ccount++) ; if (ccount > 1) wrbuf_printf(c->wrbuf, "%d\n", ccount); + wrbuf_printf(c->wrbuf, "%d\n", rec->recid); wrbuf_puts(c->wrbuf, "\n"); } @@ -431,6 +499,26 @@ static void cmd_stat(struct http_channel *c) http_send_response(c); } +static void cmd_info(struct http_channel *c) +{ + char yaz_version_str[20]; + struct http_request *rq = c->request; + struct http_response *rs = c->response; + + wrbuf_rewind(c->wrbuf); + wrbuf_puts(c->wrbuf, "\n"); + wrbuf_printf(c->wrbuf, " \n"); + wrbuf_printf(c->wrbuf, " %s\n", VERSION); + + yaz_version(yaz_version_str, 0); + wrbuf_printf(c->wrbuf, " %s\n", + YAZ_VERSION, yaz_version_str); + wrbuf_printf(c->wrbuf, " \n"); + + wrbuf_puts(c->wrbuf, ""); + rs->payload = nmem_strdup(c->nmem, wrbuf_buf(c->wrbuf)); + http_send_response(c); +} struct { char *name; @@ -444,6 +532,8 @@ struct { { "termlist", cmd_termlist }, { "exit", cmd_exit }, { "ping", cmd_ping }, + { "record", cmd_record }, + { "info", cmd_info }, {0,0} }; @@ -454,6 +544,10 @@ void http_command(struct http_channel *c) int i; c->response = rs; + + http_addheader(rs, "Expires", "Thu, 19 Nov 1981 08:52:00 GMT"); + http_addheader(rs, "Cache-Control", "no-store, no-cache, must-revalidate, post-check=0, pre-check=0"); + if (!command) { error(rs, "417", "Must supply command", 0);