hyperestraier/trunk/estcall.c

/*************************************************************************************************
 * The command line interface for the node API
 *                                                      Copyright (C) 2004-2005 Mikio Hirabayashi
 * This file is part of Hyper Estraier.
 * Hyper Estraier is free software; you can redistribute it and/or modify it under the terms of
 * the GNU Lesser General Public License as published by the Free Software Foundation; either
 * version 2.1 of the License or any later version.  Hyper Estraier is distributed in the hope
 * that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public
 * License for more details.
 * You should have received a copy of the GNU Lesser General Public License along with Hyper
 * Estraier; if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
 * Boston, MA 02111-1307 USA.
 *************************************************************************************************/


#include "estraier.h"
#include "estmtdb.h"
#include "estnode.h"
#include "myconf.h"

#define AGENTNAME      "EstCall"         /* name of the agent */
#define NUMBUFSIZ      32                /* size of a buffer for a number */
#define IOBUFSIZ       8192              /* size of a buffer for I/O */
#define MINIBNUM       31                /* bucket number of a small map */
#define SEARCHMAX      10                /* maximum number of shown documents */

enum {                                   /* enumeration for viewing modes */
  VM_PROT,                               /* protocol simulation */
  VM_XML                                 /* XML */
};

/* global variables */
const char *g_progname = NULL;           /* program name */
const char *g_pxhost = NULL;             /* host name of the proxy */
int g_pxport = 0;                        /* host name of the proxy */
int g_timeout = -1;                      /* timeout in seconds */
const char *g_authname = NULL;           /* name of authority */
const char *g_authpass = NULL;           /* password of authority */
int g_viewmode = VM_PROT;                /* viewing mode */
int g_nonparse = FALSE;                  /* whether to output response headers */
CBLIST *g_exheaders = NULL;              /* extension headers */


/* function prototypes */
int main(int argc, char **argv);
static void usage(void);
static void printferror(const char *format, ...);
static void setproxy(const char *pxstr);
static int runput(int argc, char **argv);
static int runout(int argc, char **argv);
static int runget(int argc, char **argv);
static int runuriid(int argc, char **argv);
static int runinform(int argc, char **argv);
static int runsearch(int argc, char **argv);
static int runsetuser(int argc, char **argv);
static int runsetlink(int argc, char **argv);
static int runraw(int argc, char **argv);
static void xmlprintf(const char *format, ...);
static int procput(const char *nurl, const char *file);
static int procout(const char *nurl, int id, const char *uri);
static int procget(const char *nurl, int id, const char *uri, const char *attr);
static int procuriid(const char *nurl, const char *uri);
static int procinform(const char *nurl);
static int procsearch(const char *nurl, const char *phrase,
                      const CBLIST *attrs, const char *ord, int max, int depth);
static int procsetuser(const char *nurl, const char *name, int mode);
static int procsetlink(const char *nurl, const char *url, const char *label, int credit);
static int procraw(const char *url, const char *file);


/* main routine */
int main(int argc, char **argv){
  int rv;
  cbstdiobin();
  g_progname = argv[0];
  if(!est_init_net_env()){
    printferror("could not initialize network environment");
    exit(1);
  }
  atexit(est_free_net_env);
  if(argc < 2) usage();
  rv = 0;
  if(!strcmp(argv[1], "put")){
    rv = runput(argc, argv);
  } else if(!strcmp(argv[1], "out")){
    rv = runout(argc, argv);
  } else if(!strcmp(argv[1], "get")){
    rv = runget(argc, argv);
  } else if(!strcmp(argv[1], "uriid")){
    rv = runuriid(argc, argv);
  } else if(!strcmp(argv[1], "inform")){
    rv = runinform(argc, argv);
  } else if(!strcmp(argv[1], "search")){
    rv = runsearch(argc, argv);
  } else if(!strcmp(argv[1], "setuser")){
    rv = runsetuser(argc, argv);
  } else if(!strcmp(argv[1], "setlink")){
    rv = runsetlink(argc, argv);
  } else if(!strcmp(argv[1], "raw")){
    rv = runraw(argc, argv);
  } else {
    usage();
  }
  return rv;
}


/* print the usage and exit */
static void usage(void){
  fprintf(stderr, "%s: command line utility for the node API of Hyper Estraier\n", g_progname);
  fprintf(stderr, "\n");
  fprintf(stderr, "usage:\n");
  fprintf(stderr, "  %s put [-proxy host:port] [-tout num] [-auth user pass]"
          " nurl [file]\n", g_progname);
  fprintf(stderr, "  %s out [-proxy host:port] [-tout num] [-auth user pass]"
          " nurl expr\n", g_progname);
  fprintf(stderr, "  %s get [-proxy host:port] [-tout num] [-auth user pass]"
          " nurl expr [attr]\n", g_progname);
  fprintf(stderr, "  %s uriid [-proxy host:port] [-tout num] [-auth user pass]"
          " nurl uri\n",g_progname);
  fprintf(stderr, "  %s inform [-proxy host:port] [-tout num] [-auth user pass]"
          " nurl\n", g_progname);
  fprintf(stderr, "  %s search [-proxy host:port] [-tout num] [-auth user pass]"
          " [-attr expr] [-ord expr] [-max num] [-dpt num] nurl [phrase]\n", g_progname);
  fprintf(stderr, "  %s setuser [-proxy host:port] [-tout num] [-auth user pass]"
          " nurl name mode\n", g_progname);
  fprintf(stderr, "  %s setlink [-proxy host:port] [-tout num] [-auth user pass]"
          " nurl url label credit\n", g_progname);
  fprintf(stderr, "  %s raw [-proxy host:port] [-tout num] [-auth user pass] [-np] [-eh expr]"
          " url [file]\n", g_progname);
  fprintf(stderr, "\n");
  exit(1);
}


/* print formatted error string and flush the buffer */
static void printferror(const char *format, ...){
  va_list ap;
  va_start(ap, format);
  fprintf(stderr, "%s: ERROR: ", g_progname);
  vfprintf(stderr, format, ap);
  fputc('\n', stderr);
  fflush(stderr);
  va_end(ap);
}


/* set proxy information */
static void setproxy(const char *pxstr){
  char *rp, *tmp;
  if((rp = strchr(pxstr, ':')) != NULL){
    tmp = cbmemdup(pxstr, rp - pxstr);
    if((g_pxport = atoi(rp + 1)) < 1) g_pxport = 80;
  } else {
    tmp = cbmemdup(pxstr, -1);
    g_pxport = 80;
  }
  cbglobalgc(tmp, free);
  g_pxhost = tmp;
}


/* parse arguments of the put command */
static int runput(int argc, char **argv){
  char *nurl, *file;
  int i, rv;
  nurl = NULL;
  file = NULL;
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else if(!file){
      file = argv[i];
    } else {
      usage();
    }
  }
  if(!nurl) usage();
  rv = procput(nurl, file);
  return rv;
}


/* parse arguments of the out command */
static int runout(int argc, char **argv){
  char *nurl, *expr;
  int i, id, rv;
  nurl = NULL;
  expr = NULL;
  id = 0;
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else if(!expr){
      expr = argv[i];
    } else {
      usage();
    }
  }
  if(!nurl || !expr) usage();
  if((id = atoi(expr)) > 0) expr = NULL;
  rv = procout(nurl, id, expr);
  return rv;
}


/* parse arguments of the get command */
static int runget(int argc, char **argv){
  char *nurl, *expr, *attr;
  int i, id, rv;
  nurl = NULL;
  expr = NULL;
  attr = NULL;
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else if(!expr){
      expr = argv[i];
    } else if(!attr){
      attr = argv[i];
    } else {
      usage();
    }
  }
  if(!nurl || !expr) usage();
  if((id = atoi(expr)) > 0) expr = NULL;
  rv = procget(nurl, id, expr, attr);
  return rv;
}


/* parse arguments of the uriid command */
static int runuriid(int argc, char **argv){
  char *nurl, *uri;
  int i, rv;
  nurl = NULL;
  uri = NULL;
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else if(!uri){
      uri = argv[i];
    } else {
      usage();
    }
  }
  if(!nurl || !uri) usage();
  rv = procuriid(nurl, uri);
  return rv;
}


/* parse arguments of the inform command */
static int runinform(int argc, char **argv){
  char *nurl;
  int i, rv;
  nurl = NULL;
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else {
      usage();
    }
  }
  if(!nurl) usage();
  rv = procinform(nurl);
  return rv;
}


/* parse arguments of the search command */
static int runsearch(int argc, char **argv){
  CBDATUM *pbuf;
  CBLIST *attrs;
  char *nurl, *ord;
  int i, max, depth, rv;
  nurl = NULL;
  ord = NULL;
  max = SEARCHMAX;
  depth = 0;
  pbuf = cbdatumopen("", 0);
  cbglobalgc(pbuf, (void (*)(void *))cbdatumclose);
  attrs = cblistopen();
  cbglobalgc(attrs, (void (*)(void *))cblistclose);
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else if(!strcmp(argv[i], "-vx")){
        g_viewmode = VM_XML;
      } else if(!strcmp(argv[i], "-attr")){
        if(++i >= argc) usage();
        cblistpush(attrs, argv[i], -1);
      } else if(!strcmp(argv[i], "-ord")){
        if(++i >= argc) usage();
        ord = argv[i];
      } else if(!strcmp(argv[i], "-max")){
        if(++i >= argc) usage();
        max = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-dpt")){
        if(++i >= argc) usage();
        depth = atoi(argv[i]);
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else {
      if(cbdatumsize(pbuf) > 0) cbdatumcat(pbuf, " ", 1);
      cbdatumcat(pbuf, argv[i], -1);
    }
  }
  if(!nurl || depth < 0) usage();
  rv = procsearch(nurl, cbdatumptr(pbuf), attrs, ord, max, depth);
  return rv;
}


/* parse arguments of the setuser command */
static int runsetuser(int argc, char **argv){
  char *nurl, *name, *mstr;
  int i, mode, rv;
  nurl = NULL;
  name = NULL;
  mstr = NULL;
  mode = 0;
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else if(!name){
      name = argv[i];
    } else if(!mstr){
      mstr = argv[i];
    } else {
      usage();
    }
  }
  if(!nurl || !name || !mstr || (mode = atoi(mstr)) < 0) usage();
  rv = procsetuser(nurl, name, mode);
  return rv;
}


/* parse arguments of the setlink command */
static int runsetlink(int argc, char **argv){
  char *nurl, *url, *label, *cstr;
  int i, credit, rv;
  nurl = NULL;
  url = NULL;
  label = NULL;
  cstr = NULL;
  for(i = 2; i < argc; i++){
    if(!nurl && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else {
        usage();
      }
    } else if(!nurl){
      nurl = argv[i];
    } else if(!url){
      url = argv[i];
    } else if(!label){
      label = argv[i];
    } else if(!cstr){
      cstr = argv[i];
    } else {
      usage();
    }
  }
  if(!nurl || !url || !label || !cstr) usage();
  credit = atoi(cstr);
  rv = procsetlink(nurl, url, label, credit);
  return rv;
}


/* parse arguments of the raw command */
static int runraw(int argc, char **argv){
  char *url, *file;
  int i, rv;
  g_exheaders = cblistopen();
  cbglobalgc(g_exheaders, (void (*)(void *))cblistclose);
  url = NULL;
  file = NULL;
  for(i = 2; i < argc; i++){
    if(!url && argv[i][0] == '-'){
      if(!strcmp(argv[i], "-proxy")){
        if(++i >= argc) usage();
        setproxy(argv[i]);
      } else if(!strcmp(argv[i], "-tout")){
        if(++i >= argc) usage();
        g_timeout = atoi(argv[i]);
      } else if(!strcmp(argv[i], "-auth")){
        if(++i >= argc) usage();
        g_authname = argv[i];
        if(++i >= argc) usage();
        g_authpass = argv[i];
      } else if(!strcmp(argv[i], "-np")){
        g_nonparse = TRUE;
      } else if(!strcmp(argv[i], "-eh")){
        if(++i >= argc) usage();
        cblistpush(g_exheaders, argv[i], -1);
      } else {
        usage();
      }
    } else if(!url){
      url = argv[i];
    } else if(!file){
      file = argv[i];
    } else {
      usage();
    }
  }
  if(!url) usage();
  rv = procraw(url, file);
  return rv;
}


/* output escaped string */
static void xmlprintf(const char *format, ...){
  va_list ap;
  char *tmp, cbuf[32];
  unsigned char c;
  int cblen;
  va_start(ap, format);
  while(*format != '\0'){
    if(*format == '%'){
      cbuf[0] = '%';
      cblen = 1;
      format++;
      while(strchr("0123456789 .+-", *format) && *format != '\0' && cblen < 31){
        cbuf[cblen++] = *format;
        format++;
      }
      cbuf[cblen++] = *format;
      cbuf[cblen] = '\0';
      switch(*format){
      case 's':
        tmp = va_arg(ap, char *);
        if(!tmp) tmp = "(null)";
        printf(cbuf, tmp);
        break;
      case 'd':
        printf(cbuf, va_arg(ap, int));
        break;
      case 'o': case 'u': case 'x': case 'X': case 'c':
        printf(cbuf, va_arg(ap, unsigned int));
        break;
      case 'e': case 'E': case 'f': case 'g': case 'G':
        printf(cbuf, va_arg(ap, double));
        break;
      case '@':
        tmp = va_arg(ap, char *);
        if(!tmp) tmp = "(null)";
        while(*tmp){
          switch(*tmp){
          case '&': printf("&amp;"); break;
          case '<': printf("&lt;"); break;
          case '>': printf("&gt;"); break;
          case '"': printf("&quot;"); break;
          default:
            if(!((*tmp >= 0 && *tmp <= 0x8) || (*tmp >= 0x0e && *tmp <= 0x1f))) putchar(*tmp);
            break;
          }
          tmp++;
        }
        break;
      case '?':
        tmp = va_arg(ap, char *);
        if(!tmp) tmp = "(null)";
        while(*tmp){
          c = *(unsigned char *)tmp;
          if((c >= 'A' && c <= 'Z') || (c >= 'a' && c <= 'z') ||
             (c >= '0' && c <= '9') || (c != '\0' && strchr("_-.", c))){
            putchar(c);
          } else {
            printf("%%%02X", c);
          }
          tmp++;
        }
        break;
      case '%':
        putchar('%');
        break;
      }
    } else {
      putchar(*format);
    }
    format++;
  }
  va_end(ap);
}


/* perform the put command */
static int procput(const char *nurl, const char *file){
  ESTNODE *node;
  ESTDOC *doc;
  char *draft;
  int err;
  if(!(draft = cbreadfile(file, NULL))){
    printferror("%s: could not open", file ? file : "(stdin)");
    return 1;
  }
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  doc = est_doc_new_from_draft(draft);
  if(!est_node_put_doc(node, doc)){
    printferror("failed: %d", est_node_status(node));
    err = TRUE;
  }
  est_doc_delete(doc);
  est_node_delete(node);
  free(draft);
  return err ? 1 : 0;
}


/* perform the out command */
static int procout(const char *nurl, int id, const char *uri){
  ESTNODE *node;
  int err;
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  if(uri ? !est_node_out_doc_by_uri(node, uri) : !est_node_out_doc(node, id)){
    printferror("failed: %d", est_node_status(node));
    err = TRUE;
  }
  est_node_delete(node);
  return err ? 1 : 0;
}


/* perform the get command */
static int procget(const char *nurl, int id, const char *uri, const char *attr){
  ESTNODE *node;
  ESTDOC *doc;
  char *draft;
  int err;
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  err = FALSE;
  if(attr){
    if((draft = uri ? est_node_get_doc_attr_by_uri(node, uri, attr) :
        est_node_get_doc_attr(node, id, attr)) != NULL){
      printf("%s\n", draft);
      free(draft);
    } else {
      printferror("failed: %d", est_node_status(node));
      err = TRUE;
    }
  } else {
    if((doc = uri ? est_node_get_doc_by_uri(node, uri) : est_node_get_doc(node, id)) != NULL){
      draft = est_doc_dump_draft(doc);
      printf("%s", draft);
      free(draft);
      est_doc_delete(doc);
    } else {
      printferror("failed: %d", est_node_status(node));
      err = TRUE;
    }
  }
  est_node_delete(node);
  return err ? 1 : 0;
}


/* perform the uriid command */
static int procuriid(const char *nurl, const char *uri){
  ESTNODE *node;
  int err, id;
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  err = FALSE;
  if((id = est_node_uri_to_id(node, uri)) != -1){
    printf("%d\n", id);
  } else {
    printferror("failed: %d", est_node_status(node));
    err = TRUE;
  }
  est_node_delete(node);
  return err ? 1 : 0;
}


/* perform the inform command */
static int procinform(const char *nurl){
  ESTNODE *node;
  const char *name, *label;
  int err, dnum, wnum;
  double size;
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  err = FALSE;
  name = est_node_name(node);
  label = est_node_label(node);
  dnum = est_node_doc_num(node);
  wnum = est_node_word_num(node);
  size = est_node_size(node);
  if(name && label && dnum >= 0 && wnum >= 0 && size >= 0.0){
    printf("%s\t%s\t%d\t%d\t%.0f\n", name, label, dnum, wnum, size);
  } else {
    printferror("failed: %d", est_node_status(node));
    err = TRUE;
  }
  est_node_delete(node);
  return err ? 1 : 0;
}


/* perform the inform command */
static int procsearch(const char *nurl, const char *phrase,
                      const CBLIST *attrs, const char *ord, int max, int depth){
  ESTNODE *node;
  ESTNODERES *nres;
  ESTRESDOC *rdoc;
  ESTCOND *cond;
  CBMAP *hints;
  CBLIST *names, *elems, *lines;
  const char *kbuf, *vbuf;
  char tbuf[NUMBUFSIZ];
  int i, j, err, ksiz, vsiz, dnum, wnum, id, ld;
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  err = FALSE;
  cond = est_cond_new();
  while(*phrase > '\0' && *phrase <= ' '){
    phrase++;
  }
  if(phrase[0] != '\0' || cblistnum(attrs) < 1) est_cond_set_phrase(cond, phrase);
  for(i = 0; i < cblistnum(attrs); i++){
    est_cond_add_attr(cond, cblistval(attrs, i, NULL));
  }
  if(ord) est_cond_set_order(cond, ord);
  if(max >= 0) est_cond_set_max(cond, max);
  if((nres = est_node_search(node, cond, depth)) != NULL){
    hints = est_noderes_hints(nres);
    switch(g_viewmode){
    case VM_XML:
      xmlprintf("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n");
      xmlprintf("<estresult version=\"%@\">\n", est_version);
      xmlprintf("<meta>\n");
      if((vbuf = cbmapget(hints, "NODE", -1, NULL)) != NULL)
        xmlprintf("<node url=\"%@\"/>\n", vbuf);
      if((vbuf = cbmapget(hints, "HIT", -1, NULL)) != NULL)
        xmlprintf("<hit number=\"%@\"/>\n", vbuf);
      for(i = 1; i < cbmaprnum(hints); i++){
        sprintf(tbuf, "HINT#%d", i);
        if(!(vbuf = cbmapget(hints, tbuf, -1, &vsiz))) break;
        elems = cbsplit(vbuf, vsiz, "\t");
        if(cblistnum(elems) == 2){
          xmlprintf("<hit key=\"%@\" number=\"%@\"/>\n",
                    cblistval(elems, 0, NULL), cblistval(elems, 1, NULL));
        }
        cblistclose(elems);
      }
      if((vbuf = cbmapget(hints, "TIME", -1, NULL)) != NULL)
        xmlprintf("<time time=\"%@\"/>\n", vbuf);
      dnum = 0;
      wnum = 0;
      if((vbuf = cbmapget(hints, "DOCNUM", -1, NULL)) != NULL) dnum = atoi(vbuf);
      if((vbuf = cbmapget(hints, "WORDNUM", -1, NULL)) != NULL) wnum = atoi(vbuf);
      xmlprintf("<total documents=\"%d\" words=\"%d\"/>\n", dnum, wnum);
      for(i = 0; i < cbmaprnum(hints); i++){
        sprintf(tbuf, "LINK#%d", i);
        if(!(vbuf = cbmapget(hints, tbuf, -1, &vsiz))) break;
        elems = cbsplit(vbuf, vsiz, "\t");
        if(cblistnum(elems) == 7){
          xmlprintf("<link url=\"%@\" label=\"%@\" credit=\"%@\" docnum=\"%@\" wordnum=\"%@\""
                    " size=\"%@\" hit=\"%@\"/>\n",
                    cblistval(elems, 0, NULL), cblistval(elems, 1, NULL),
                    cblistval(elems, 2, NULL), cblistval(elems, 3, NULL),
                    cblistval(elems, 4, NULL), cblistval(elems, 5, NULL),
                    cblistval(elems, 6, NULL));
        }
        cblistclose(elems);
      }
      xmlprintf("</meta>\n");
      for(i = 0; i < est_noderes_doc_num(nres); i++){
        rdoc = est_noderes_get_doc(nres, i);
        id = -1;
        if((vbuf = est_resdoc_attr(rdoc, ESTDATTRID)) != NULL) id = atoi(vbuf);
        xmlprintf("<document id=\"%d\" uri=\"%@\">\n", id, est_resdoc_uri(rdoc));
        names = est_resdoc_attr_names(rdoc);
        for(j = 0; j < cblistnum(names); j++){
          kbuf = cblistval(names, j, NULL);
          if(!strcmp(kbuf, ESTDATTRID) || !strcmp(kbuf, ESTDATTRURI)) continue;
          xmlprintf("<attribute name=\"%@\" value=\"%s\"/>\n",
                    kbuf, est_resdoc_attr(rdoc, kbuf));
        }
        cblistclose(names);
        xmlprintf("<snippet>");
        lines = cbsplit(est_resdoc_snippet(rdoc), -1, "\n");
        ld = TRUE;
        for(j = 0; j < cblistnum(lines); j++){
          vbuf = cblistval(lines, j, &vsiz);
          elems = cbsplit(vbuf, vsiz, "\t");
          if(vbuf[0] == '\0'){
            if(!ld) xmlprintf("<delimiter/>");
            ld = TRUE;
          } else if(cblistnum(elems) == 1){
            xmlprintf("%@", cblistval(elems, 0, NULL));
            ld = FALSE;
          } else {
            xmlprintf("<key normal=\"%@\">%@</key>",
                      cblistval(elems, 1, NULL), cblistval(elems, 0, NULL));
            ld = FALSE;
          }
          cblistclose(elems);
        }
        cblistclose(lines);
        xmlprintf("</snippet>\n");
        xmlprintf("</document>\n");
      }
      xmlprintf("</estresult>\n");
      break;
    default:
      printf("%s\n", est_border_str());
      cbmapiterinit(hints);
      while((kbuf = cbmapiternext(hints, &ksiz)) != NULL){
        printf("%s\t%s\n", kbuf, cbmapget(hints, kbuf, ksiz, NULL));
      }
      printf("\n");
      for(i = 0; i < est_noderes_doc_num(nres); i++){
        printf("%s\n", est_border_str());
        rdoc = est_noderes_get_doc(nres, i);
        names = est_resdoc_attr_names(rdoc);
        for(j = 0; j < cblistnum(names); j++){
          kbuf = cblistval(names, j, NULL);
          printf("%s=%s\n", kbuf, est_resdoc_attr(rdoc, kbuf));
        }
        cblistclose(names);
        printf("\n");
        printf("%s", est_resdoc_snippet(rdoc));
      }
      printf("%s:END\n", est_border_str());
      break;
    }
    est_noderes_delete(nres);
  } else {
    printferror("failed: %d", est_node_status(node));
    err = TRUE;
  }
  est_cond_delete(cond);
  est_node_delete(node);
  return err ? 1 : 0;
}


/* perform the setuser command */
static int procsetuser(const char *nurl, const char *name, int mode){
  ESTNODE *node;
  int err;
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  err = FALSE;
  if(!est_node_set_user(node, name, mode)){
    printferror("failed: %d", est_node_status(node));
    err = TRUE;
  }
  est_node_delete(node);
  return err ? 1 : 0;
}


/* perform the setlink command */
static int procsetlink(const char *nurl, const char *url, const char *label, int credit){
  ESTNODE *node;
  int err;
  err = FALSE;
  node = est_node_new(nurl);
  if(g_pxhost) est_node_set_proxy(node, g_pxhost, g_pxport);
  if(g_timeout >= 0) est_node_set_timeout(node, g_timeout);
  if(g_authname && g_authpass) est_node_set_auth(node, g_authname, g_authpass);
  err = FALSE;
  if(!est_node_set_link(node, url, label, credit)){
    printferror("failed: %d", est_node_status(node));
    err = TRUE;
  }
  est_node_delete(node);
  return err ? 1 : 0;
}


/* perform the raw command */
static int procraw(const char *url, const char *file){
  CBMAP *resheads;
  CBDATUM *resbody;
  const char *ptr;
  char *auth, *reqbody;
  int i, err, rbsiz, rescode, size;
  if(file){
    if(!(reqbody = cbreadfile(strcmp(file, "-") ? file : NULL, &rbsiz))){
      printferror("%s: could not open", file);
      return 1;
    }
  } else {
    reqbody = NULL;
    rbsiz = 0;
  }
  err = FALSE;
  resheads = cbmapopenex(MINIBNUM);
  resbody = cbdatumopen("", 0);
  auth = (g_authname && g_authpass) ? cbsprintf("%s:%s", g_authname, g_authpass) : NULL;
  if(est_url_shuttle(url, g_pxhost, g_pxport, g_timeout, auth,
                     g_exheaders, reqbody, rbsiz, &rescode, resheads, resbody)){
    if(rescode < 200 && rescode >= 300) err = TRUE;
    if(g_nonparse){
      printf("%s\r\n", cbmapget(resheads, "", 0, NULL));
      cbmapiterinit(resheads);
      while((ptr = cbmapiternext(resheads, &size)) != NULL){
        if(size < 1) continue;
        printf("%s: %s\r\n", ptr, cbmapget(resheads, ptr, size, NULL));
      }
      printf("\r\n");
    }
    ptr = cbdatumptr(resbody);
    size = cbdatumsize(resbody);
    for(i = 0; i < size; i++){
      putchar(ptr[i]);
    }
  } else {
    printferror("%s: connection failed", url);
    err = TRUE;
  }
  free(auth);
  cbdatumclose(resbody);
  cbmapclose(resheads);
  free(reqbody);
  return err ? 1 : 0;
}


/* END OF FILE */