cqltransform.c

Go to the documentation of this file.

/* This file is part of the YAZ toolkit.
 * Copyright (C) Index Data
 * See the file LICENSE for details.
 */
#if HAVE_CONFIG_H
#include <config.h>
#endif
 
#include <assert.h>
#include <stdlib.h>
#include <string.h>
#include <yaz/rpn2cql.h>
#include <yaz/xmalloc.h>
#include <yaz/diagsrw.h>
#include <yaz/tokenizer.h>
#include <yaz/wrbuf.h>
#include <yaz/z-core.h>
#include <yaz/matchstr.h>
#include <yaz/oid_db.h>
#include <yaz/log.h>
#include <yaz/proxunit.h>
#include <yaz/snprintf.h>
 
struct cql_prop_entry {
    char *pattern;
    char *value;
    Z_AttributeList attr_list;
    struct cql_prop_entry *next;
};
 
struct cql_transform_t_ {
    struct cql_prop_entry *entry;
    yaz_tok_cfg_t tok_cfg;
    int error;
    WRBUF addinfo;
    NMEM nmem;
};
 
 
cql_transform_t cql_transform_create(void)
{
    cql_transform_t ct = (cql_transform_t) xmalloc(sizeof(*ct));
    ct->tok_cfg = yaz_tok_cfg_create();
    ct->error = 0;
    ct->addinfo = wrbuf_alloc();
    ct->entry = 0;
    ct->nmem = nmem_create();
    return ct;
}
 
static int cql_transform_parse_tok_line(cql_transform_t ct,
                                        const char *pattern,
                                        yaz_tok_parse_t tp)
{
    int ae_num = 0;
    Z_AttributeElement *ae[20];
    int ret = 0; /* 0=OK, != 0 FAIL */
    int t;
    WRBUF w = wrbuf_alloc();
 
    t = yaz_tok_move(tp);
 
    while (t == YAZ_TOK_STRING && ae_num < 20)
    {
        WRBUF type_str = wrbuf_alloc();
        WRBUF set_str = 0;
        Z_AttributeElement *elem = 0;
        const char *value_str = 0;
        /* attset type=value  OR  type=value */
 
        elem = (Z_AttributeElement *) nmem_malloc(ct->nmem, sizeof(*elem));
        elem->attributeSet = 0;
        ae[ae_num] = elem;
        wrbuf_puts(w, yaz_tok_parse_string(tp));
        wrbuf_puts(type_str, yaz_tok_parse_string(tp));
        t = yaz_tok_move(tp);
        if (t == YAZ_TOK_EOF)
        {
            wrbuf_destroy(type_str);
            if (set_str)
                wrbuf_destroy(set_str);
            break;
        }
        if (t == YAZ_TOK_STRING)
        {
            wrbuf_puts(w, " ");
            wrbuf_puts(w, yaz_tok_parse_string(tp));
            set_str = type_str;
 
            elem->attributeSet =
                yaz_string_to_oid_nmem(yaz_oid_std(), CLASS_ATTSET,
                                       wrbuf_cstr(set_str), ct->nmem);
 
            type_str = wrbuf_alloc();
            wrbuf_puts(type_str, yaz_tok_parse_string(tp));
            t = yaz_tok_move(tp);
        }
        elem->attributeType = nmem_intdup(ct->nmem, 0);
        if (sscanf(wrbuf_cstr(type_str), ODR_INT_PRINTF, elem->attributeType)
            != 1)
        {
            wrbuf_destroy(type_str);
            if (set_str)
                wrbuf_destroy(set_str);
            yaz_log(YLOG_WARN, "Expected numeric attribute type");
            ret = -1;
            break;
        }
 
        wrbuf_destroy(type_str);
        if (set_str)
            wrbuf_destroy(set_str);
 
        if (t != '=')
        {
            yaz_log(YLOG_WARN, "Expected = after after attribute type");
            ret = -1;
            break;
        }
        t = yaz_tok_move(tp);
        if (t != YAZ_TOK_STRING) /* value */
        {
            yaz_log(YLOG_WARN, "Missing attribute value");
            ret = -1;
            break;
        }
        value_str = yaz_tok_parse_string(tp);
        if (yaz_isdigit(*value_str))
        {
            elem->which = Z_AttributeValue_numeric;
            elem->value.numeric =
                nmem_intdup(ct->nmem, atoi(value_str));
        }
        else
        {
            Z_ComplexAttribute *ca = (Z_ComplexAttribute *)
                nmem_malloc(ct->nmem, sizeof(*ca));
            elem->which = Z_AttributeValue_complex;
            elem->value.complex = ca;
            ca->num_list = 1;
            ca->list = (Z_StringOrNumeric **)
                nmem_malloc(ct->nmem, sizeof(Z_StringOrNumeric *));
            ca->list[0] = (Z_StringOrNumeric *)
                nmem_malloc(ct->nmem, sizeof(Z_StringOrNumeric));
            ca->list[0]->which = Z_StringOrNumeric_string;
            ca->list[0]->u.string = nmem_strdup(ct->nmem, value_str);
            ca->num_semanticAction = 0;
            ca->semanticAction = 0;
        }
        wrbuf_puts(w, "=");
        wrbuf_puts(w, yaz_tok_parse_string(tp));
        t = yaz_tok_move(tp);
        wrbuf_puts(w, " ");
        ae_num++;
    }
    if (ret == 0) /* OK? */
    {
        struct cql_prop_entry **pp = &ct->entry;
        while (*pp)
            pp = &(*pp)->next;
        *pp = (struct cql_prop_entry *) xmalloc(sizeof(**pp));
        (*pp)->pattern = xstrdup(pattern);
        (*pp)->value = xstrdup(wrbuf_cstr(w));
 
        (*pp)->attr_list.num_attributes = ae_num;
        if (ae_num == 0)
            (*pp)->attr_list.attributes = 0;
        else
        {
            (*pp)->attr_list.attributes = (Z_AttributeElement **)
                nmem_malloc(ct->nmem,
                            ae_num * sizeof(Z_AttributeElement *));
            memcpy((*pp)->attr_list.attributes, ae,
                   ae_num * sizeof(Z_AttributeElement *));
        }
        (*pp)->next = 0;
 
        if (0)
        {
            ODR pr = odr_createmem(ODR_PRINT);
            Z_AttributeList *alp = &(*pp)->attr_list;
            odr_setprint_noclose(pr, yaz_log_file());
            z_AttributeList(pr, &alp, 0, 0);
            odr_destroy(pr);
        }
    }
    wrbuf_destroy(w);
    return ret;
}
 
int cql_transform_define_pattern(cql_transform_t ct, const char *pattern,
                                 const char *value)
{
    int r;
    yaz_tok_parse_t tp = yaz_tok_parse_buf(ct->tok_cfg, value);
    yaz_tok_cfg_single_tokens(ct->tok_cfg, "=");
    r = cql_transform_parse_tok_line(ct, pattern, tp);
    yaz_tok_parse_destroy(tp);
    return r;
}
 
cql_transform_t cql_transform_open_FILE(FILE *f)
{
    cql_transform_t ct = cql_transform_create();
    if (cql_transform_define_FILE(ct, f))
    {
        cql_transform_close(ct);
        return 0;
    }
    return ct;
}
 
int cql_transform_define_FILE(cql_transform_t ct, FILE *f)
{
    char line[1024];
    int ret = 0;
 
    yaz_tok_cfg_single_tokens(ct->tok_cfg, "=");
    while (ret == 0 && fgets(line, sizeof(line)-1, f))
    {
        yaz_tok_parse_t tp = yaz_tok_parse_buf(ct->tok_cfg, line);
        int t = yaz_tok_move(tp);
        if (t == YAZ_TOK_STRING)
        {
            char *pattern = xstrdup(yaz_tok_parse_string(tp)); /* copy as it's yaz_tok_move resets */
            t = yaz_tok_move(tp);
            if (t != '=')
                ret = -1;
            else
            {
                if (cql_transform_parse_tok_line(ct, pattern, tp))
                    ret = -1;
            }
            xfree(pattern);
        }
        else if (t != YAZ_TOK_EOF)
        {
            ret = -1;
        }
        yaz_tok_parse_destroy(tp);
    }
    return ret;
}
 
void cql_transform_close(cql_transform_t ct)
{
    struct cql_prop_entry *pe;
    if (!ct)
        return;
    pe = ct->entry;
    while (pe)
    {
        struct cql_prop_entry *pe_next = pe->next;
        xfree(pe->pattern);
        xfree(pe->value);
        xfree(pe);
        pe = pe_next;
    }
    wrbuf_destroy(ct->addinfo);
    yaz_tok_cfg_destroy(ct->tok_cfg);
    nmem_destroy(ct->nmem);
    xfree(ct);
}
 
cql_transform_t cql_transform_open_fname(const char *fname)
{
    cql_transform_t ct = cql_transform_create();
    if (cql_transform_define_fname(ct, fname))
    {
        cql_transform_close(ct);
        return 0;
    }
    return ct;
}
 
int cql_transform_define_fname(cql_transform_t ct, const char *fname)
{
    int ret;
    FILE *f = fopen(fname, "r");
    if (!f)
        return -2;
    ret = cql_transform_define_FILE(ct, f);
    fclose(f);
    return ret;
}
 
#if 0
struct Z_AttributeElement {
        Z_AttributeSetId *attributeSet; /* OPT */
        int *attributeType;
        int which;
        union {
                int *numeric;
                Z_ComplexAttribute *complex;
#define Z_AttributeValue_numeric 1
#define Z_AttributeValue_complex 2
        } value;
};
#endif
 
static int compare_attr(Z_AttributeElement *a, Z_AttributeElement *b)
{
    ODR odr_a = odr_createmem(ODR_ENCODE);
    ODR odr_b = odr_createmem(ODR_ENCODE);
    int len_a, len_b;
    char *buf_a, *buf_b;
    int ret;
 
    z_AttributeElement(odr_a, &a, 0, 0);
    z_AttributeElement(odr_b, &b, 0, 0);
 
    buf_a = odr_getbuf(odr_a, &len_a, 0);
    buf_b = odr_getbuf(odr_b, &len_b, 0);
 
    ret = yaz_memcmp(buf_a, buf_b, len_a, len_b);
 
    odr_destroy(odr_a);
    odr_destroy(odr_b);
    return ret;
}
 
const char *cql_lookup_reverse(cql_transform_t ct,
                               const char *category,
                               Z_AttributeList *attributes)
{
    struct cql_prop_entry *e;
    size_t clen = strlen(category);
    for (e = ct->entry; e; e = e->next)
    {
        if (!strncmp(e->pattern, category, clen))
        {
            /* category matches.. See if attributes in pattern value
               are all listed in actual attributes */
            int i;
            for (i = 0; i < e->attr_list.num_attributes; i++)
            {
                /* entry attribute */
                Z_AttributeElement *e_ae = e->attr_list.attributes[i];
                int j;
                for (j = 0; j < attributes->num_attributes; j++)
                {
                    /* actual attribute */
                    Z_AttributeElement a_ae = *attributes->attributes[j];
                    if (!compare_attr(e_ae, &a_ae))
                        break;
                    if (a_ae.attributeSet &&
                        !oid_oidcmp(a_ae.attributeSet, yaz_oid_attset_bib_1))
                        a_ae.attributeSet = 0;
                    if (!compare_attr(e_ae, &a_ae))
                        break;
                }
                if (j == attributes->num_attributes)
                    break; /* i was not found at all.. try next pattern */
 
            }
            if (i == e->attr_list.num_attributes)
                return e->pattern + clen;
        }
    }
    return 0;
}
 
static const char *cql_lookup_property(cql_transform_t ct,
                                       const char *pat1, const char *pat2,
                                       const char *pat3)
{
    char pattern[120];
    struct cql_prop_entry *e;
 
    if (pat1 && pat2 && pat3)
        yaz_snprintf(pattern, sizeof pattern, "%s.%s.%s", pat1, pat2, pat3);
    else if (pat1 && pat2)
        yaz_snprintf(pattern, sizeof pattern, "%s.%s", pat1, pat2);
    else if (pat1 && pat3)
        yaz_snprintf(pattern, sizeof pattern, "%s.%s", pat1, pat3);
    else if (pat1)
        yaz_snprintf(pattern, sizeof pattern, "%s", pat1);
    else
        return 0;
 
    for (e = ct->entry; e; e = e->next)
    {
        if (!cql_strcmp(e->pattern, pattern))
            return e->value;
    }
    return 0;
}
 
int cql_pr_attr_uri(cql_transform_t ct, WRBUF addinfo, const char *category,
                   const char *uri, const char *val, const char *default_val,
                   void (*pr)(const char *buf, void *client_data),
                   void *client_data,
                   int errcode)
{
    const char *res = 0;
    const char *eval = val ? val : default_val;
    const char *prefix = 0;
 
    if (uri)
    {
        struct cql_prop_entry *e;
 
        for (e = ct->entry; e; e = e->next)
            if (!memcmp(e->pattern, "set.", 4) && e->value &&
                !strcmp(e->value, uri))
            {
                prefix = e->pattern+4;
                break;
            }
        /* must have a prefix now - if not it's an error */
    }
 
    if (!uri || prefix)
    {
        if (!res)
            res = cql_lookup_property(ct, category, prefix, eval);
        /* we have some aliases for some relations unfortunately.. */
        if (!res && !prefix && !strcmp(category, "relation"))
        {
            if (!strcmp(val, "=="))
                res = cql_lookup_property(ct, category, prefix, "exact");
            if (!strcmp(val, "="))
                res = cql_lookup_property(ct, category, prefix, "eq");
            if (!strcmp(val, "<="))
                res = cql_lookup_property(ct, category, prefix, "le");
            if (!strcmp(val, ">="))
                res = cql_lookup_property(ct, category, prefix, "ge");
        }
        if (!res)
            res = cql_lookup_property(ct, category, prefix, "*");
    }
    if (res)
    {
        char buf[64];
 
        const char *cp0 = res, *cp1;
        while ((cp1 = strchr(cp0, '=')))
        {
            int i;
            while (*cp1 && *cp1 != ' ')
                cp1++;
            if (cp1 - cp0 >= (ptrdiff_t) sizeof(buf))
                break;
            memcpy(buf, cp0, cp1 - cp0);
            buf[cp1-cp0] = 0;
            (*pr)("@attr ", client_data);
 
            for (i = 0; buf[i]; i++)
            {
                if (buf[i] == '*')
                    (*pr)(eval, client_data);
                else
                {
                    char tmp[2];
                    tmp[0] = buf[i];
                    tmp[1] = '\0';
                    (*pr)(tmp, client_data);
                }
            }
            (*pr)(" ", client_data);
            cp0 = cp1;
            while (*cp0 == ' ')
                cp0++;
        }
        return 0;
    }
    /* error ... */
    if (errcode == 0)
        return 1; /* signal error, but do not set addinfo */
    if (val)
        wrbuf_puts(addinfo, val);
    return errcode;
}
 
int cql_pr_attr(cql_transform_t ct, WRBUF addinfo, const char *category,
                const char *val, const char *default_val,
                void (*pr)(const char *buf, void *client_data),
                void *client_data,
                int errcode)
{
    return cql_pr_attr_uri(ct, addinfo, category, 0 /* uri */,
                           val, default_val, pr, client_data, errcode);
}
 
 
static void cql_pr_int(int val,
                       void (*pr)(const char *buf, void *client_data),
                       void *client_data)
{
    char buf[21];              /* enough characters to 2^64 */
    yaz_snprintf(buf, sizeof buf, "%d", val);
    (*pr)(buf, client_data);
    (*pr)(" ", client_data);
}
 
 
static int cql_pr_prox(cql_transform_t ct, struct cql_node *mods,
                       WRBUF addinfo,
                       void (*pr)(const char *buf, void *client_data),
                       void *client_data)
{
    int exclusion = 0;
    int distance = -1;
    int ordered = 0;
    int proxrel = 2;            /* less than or equal */
    int unit = 2;               /* word */
 
    while (mods)
    {
        const char *name = mods->u.st.index;
        const char *term = mods->u.st.term;
        const char *relation = mods->u.st.relation;
 
        if (!strcmp(name, "distance")) {
            distance = strtol(term, (char**) 0, 0);
            if (!strcmp(relation, "="))
                proxrel = 3;
            else if (!strcmp(relation, ">"))
                proxrel = 5;
            else if (!strcmp(relation, "<"))
                proxrel = 1;
            else if (!strcmp(relation, ">="))
                proxrel = 4;
            else if (!strcmp(relation, "<="))
                proxrel = 2;
            else if (!strcmp(relation, "<>"))
                proxrel = 6;
            else
            {
                wrbuf_puts(addinfo, relation);
                return YAZ_SRW_UNSUPP_PROX_RELATION;
            }
        }
        else if (!strcmp(name, "ordered"))
            ordered = 1;
        else if (!strcmp(name, "unordered"))
            ordered = 0;
        else if (!strcmp(name, "unit"))
        {
            unit = z_str_to_ProxUnit(term);
            if (unit == 0)
            {
                wrbuf_puts(addinfo, term);
                return YAZ_SRW_UNSUPP_PROX_UNIT;
            }
        }
        else
        {
            wrbuf_puts(addinfo, name);
            return YAZ_SRW_UNSUPP_BOOLEAN_MODIFIER;
        }
        mods = mods->u.st.modifiers;
    }
 
    if (distance == -1)
        distance = (unit == 2) ? 1 : 0;
 
    cql_pr_int(exclusion, pr, client_data);
    cql_pr_int(distance, pr, client_data);
    cql_pr_int(ordered, pr, client_data);
    cql_pr_int(proxrel, pr, client_data);
    (*pr)("k ", client_data);
    cql_pr_int(unit, pr, client_data);
 
    return 0;
}
 
/* ### checks for CQL relation-name rather than Type-1 attribute */
static int has_modifier(struct cql_node *cn, const char *name) {
    struct cql_node *mod;
    for (mod = cn->u.st.modifiers; mod != 0; mod = mod->u.st.modifiers) {
        if (!mod->u.st.term && !strcmp(mod->u.st.index, name))
            return 1;
    }
 
    return 0;
}
 
static int emit_term(cql_transform_t ct,
                     struct cql_node *cn, WRBUF addinfo,
                     const char *term, int length,
                     void (*pr)(const char *buf, void *client_data),
                     void *client_data)
{
    int i, r;
    const char *ns = cn->u.st.index_uri;
    int z3958_mode = 0;
    int process_term = 1;
 
 
    if (has_modifier(cn, "regexp"))
        process_term = 0;
    else if (has_modifier(cn, "unmasked"))
        process_term = 0;
    else if (cql_lookup_property(ct, "truncation", 0, "cql"))
    {
        process_term = 0;
        r = cql_pr_attr(ct, addinfo, "truncation", "cql", 0,
                        pr, client_data, YAZ_SRW_MASKING_CHAR_UNSUPP);
        if (r)
            return r;
    }
    assert(cn->which == CQL_NODE_ST);
 
    if (process_term)
    {   /* convert term via truncation.things */
        unsigned anchor = 0;
        unsigned trunc = 0;
        for (i = 0; i < length; i++)
        {
            if (term[i] == '\\' && i < length - 1)
                i++;
            else
            {
                switch (term[i])
                {
                case '^':
                    if (i == 0)
                        anchor |= 1;
                    else if (i == length - 1)
                        anchor |= 2;
                    break;
                case '*':
                    if (i == 0)
                        trunc |= 1;
                    else if (i == length - 1)
                        trunc |= 2;
                    else
                        z3958_mode = 1;
                    break;
                case '?':
                    z3958_mode = 1;
                    break;
                }
            }
        }
        if (anchor == 3)
        {
            r = cql_pr_attr(ct, addinfo, "position", "firstAndLast", 0,
                            pr, client_data,
                            YAZ_SRW_ANCHORING_CHAR_IN_UNSUPP_POSITION);
            if (r)
                return r;
            term++;
            length -= 2;
        }
        else if (anchor == 1)
        {
            r = cql_pr_attr(ct, addinfo, "position", "first", 0,
                            pr, client_data,
                            YAZ_SRW_ANCHORING_CHAR_IN_UNSUPP_POSITION);
            if (r)
                return r;
            term++;
            length--;
        }
        else if (anchor == 2)
        {
            r = cql_pr_attr(ct, addinfo, "position", "last", 0,
                            pr, client_data,
                            YAZ_SRW_ANCHORING_CHAR_IN_UNSUPP_POSITION);
            if (r)
                return r;
            length--;
        }
        else
        {
            r = cql_pr_attr(ct, addinfo, "position", "any", 0,
                        pr, client_data,
                            YAZ_SRW_ANCHORING_CHAR_IN_UNSUPP_POSITION);
            if (r)
                return r;
        }
        if (z3958_mode == 0)
        {
            if (trunc == 3 && !cql_pr_attr(ct, addinfo, "truncation",
                                          "both", 0, pr, client_data, 0))
            {
                term++;
                length -= 2;
            }
            else if (trunc == 1 && !cql_pr_attr(ct, addinfo, "truncation",
                                               "left", 0, pr, client_data, 0))
            {
                term++;
                length--;
            }
            else if (trunc == 2 && !cql_pr_attr(ct, addinfo, "truncation",
                                                "right", 0, pr, client_data, 0))
            {
                length--;
            }
            else if (trunc)
                z3958_mode = 1;
            else
                cql_pr_attr(ct, addinfo, "truncation", "none", 0,
                            pr, client_data, 0);
        }
        if (z3958_mode)
        {
            r = cql_pr_attr(ct, addinfo, "truncation", "z3958", 0,
                            pr, client_data, YAZ_SRW_MASKING_CHAR_UNSUPP);
            if (r)
                return r;
        }
    }
    if (ns)
    {
        r = cql_pr_attr_uri(ct, addinfo, "index", ns,
                            cn->u.st.index, "serverChoice",
                            pr, client_data, YAZ_SRW_UNSUPP_INDEX);
        if (r)
            return r;
    }
    if (cn->u.st.modifiers)
    {
        struct cql_node *mod = cn->u.st.modifiers;
        for (; mod; mod = mod->u.st.modifiers)
        {
            if (!mod->u.st.term)
            {
                r = cql_pr_attr(ct, addinfo,
                                "relationModifier", mod->u.st.index, 0,
                                pr, client_data,
                                YAZ_SRW_UNSUPP_RELATION_MODIFIER);
                if (r)
                    return r;
            }
        }
    }
    (*pr)("\"", client_data);
    if (process_term)
        for (i = 0; i < length; i++)
        {
            char x[2]; /* temp buffer */
            if (term[i] == '\\' && i < length - 1)
            {
                i++;
                if (strchr("\"\\", term[i]))
                    pr("\\", client_data);
                if (z3958_mode && strchr("#?", term[i]))
                    pr("\\\\", client_data); /* double \\ to survive PQF parse */
                x[0] = term[i];
                x[1] = '\0';
                pr(x, client_data);
            }
            else if (z3958_mode && term[i] == '*')
            {
                pr("?", client_data);
                if (i < length - 1 && yaz_isdigit(term[i+1]))
                    pr("\\\\", client_data); /* dbl \\ to survive PQF parse */
            }
            else if (z3958_mode && term[i] == '?')
            {
                pr("#", client_data);
            }
            else
            {
                if (term[i] == '\"')
                    pr("\\", client_data);
                if (z3958_mode && strchr("#?", term[i]))
                    pr("\\\\", client_data); /* dbl \\ to survive PQF parse */
                x[0] = term[i];
                x[1] = '\0';
                pr(x, client_data);
            }
        }
    else
    {
        for (i = 0; i < length; i++)
        {
            char x[2];
            x[0] = term[i];
            x[1] = '\0';
            pr(x, client_data);
        }
    }
    (*pr)("\" ", client_data);
    return 0;
}
 
static int emit_terms(cql_transform_t ct, struct cql_node *cn,
                      WRBUF addinfo,
                      void (*pr)(const char *buf, void *client_data),
                      void *client_data,
                      const char *op)
{
    struct cql_node *ne = cn->u.st.extra_terms;
    int r;
    if (ne)
    {
        (*pr)("@", client_data);
        (*pr)(op, client_data);
        (*pr)(" ", client_data);
    }
    r = emit_term(ct, cn, addinfo, cn->u.st.term, strlen(cn->u.st.term),
                  pr, client_data);
    for (; !r && ne; ne = ne->u.st.extra_terms)
    {
        if (ne->u.st.extra_terms)
        {
            (*pr)("@", client_data);
            (*pr)(op, client_data);
            (*pr)(" ", client_data);
        }
        r = emit_term(ct, cn, addinfo, ne->u.st.term, strlen(ne->u.st.term),
                      pr, client_data);
    }
    return r;
}
 
static int emit_wordlist(cql_transform_t ct, struct cql_node *cn,
                         WRBUF addinfo,
                         void (*pr)(const char *buf, void *client_data),
                         void *client_data,
                         const char *op)
{
    int r = 0;
    const char *cp0 = cn->u.st.term;
    const char *cp1;
    const char *last_term = 0;
    int last_length = 0;
    while (!r && cp0)
    {
        while (*cp0 == ' ')
            cp0++;
        cp1 = strchr(cp0, ' ');
        if (last_term)
        {
            (*pr)("@", client_data);
            (*pr)(op, client_data);
            (*pr)(" ", client_data);
            r = emit_term(ct, cn, addinfo, last_term, last_length,
                          pr, client_data);
        }
        last_term = cp0;
        if (cp1)
            last_length = cp1 - cp0;
        else
            last_length = strlen(cp0);
        cp0 = cp1;
    }
    if (!r && last_term)
        r = emit_term(ct, cn, addinfo, last_term, last_length, pr, client_data);
    return r;
}
 
static int emit_node(cql_transform_t ct, struct cql_node *cn,
                     WRBUF addinfo,
                     void (*pr)(const char *buf, void *client_data),
                     void *client_data)
{
    const char *ns;
    int r = 0;
    struct cql_node *mods;
 
    if (!cn)
        return 0;
    switch (cn->which)
    {
    case CQL_NODE_ST:
        ns = cn->u.st.index_uri;
        if (ns)
        {
            if (!strcmp(ns, cql_uri())
                && cn->u.st.index && !cql_strcmp(cn->u.st.index, "resultSet"))
            {
                (*pr)("@set \"", client_data);
                (*pr)(cn->u.st.term, client_data);
                (*pr)("\" ", client_data);
                return 0;
            }
        }
        else
        {
            return YAZ_SRW_UNSUPP_CONTEXT_SET;
        }
        if (cn->u.st.modifiers)
        {
            struct cql_node *mod = cn->u.st.modifiers;
            for (; mod; mod = mod->u.st.modifiers)
            {
                if (mod->u.st.term) /* only modifiers with name+value */
                {
                    /* only relation = supported at the moment */
                    if (mod->u.st.relation && strcmp(mod->u.st.relation, "="))
                    {
                        wrbuf_puts(addinfo, mod->u.st.relation);
                        return YAZ_SRW_UNSUPP_RELATION;
                    }
                    pr("@prox 0 0 0 0 k 8 ", client_data);
                }
            }
        }
        cql_pr_attr(ct, addinfo, "always", 0, 0, pr, client_data, 0);
        r = cql_pr_attr(ct, addinfo, "relation", cn->u.st.relation, 0,
                        pr, client_data, YAZ_SRW_UNSUPP_RELATION);
        if (r)
            return r;
        r = cql_pr_attr(ct, addinfo, "structure", cn->u.st.relation, 0,
                        pr, client_data,
                        YAZ_SRW_UNSUPP_COMBI_OF_RELATION_AND_TERM);
        if (r)
            return r;
        if (cn->u.st.relation && !cql_strcmp(cn->u.st.relation, "all"))
            r = emit_wordlist(ct, cn, addinfo, pr, client_data, "and");
        else if (cn->u.st.relation && !cql_strcmp(cn->u.st.relation, "any"))
            r = emit_wordlist(ct, cn, addinfo, pr, client_data, "or");
        else
            r = emit_terms(ct, cn, addinfo, pr, client_data, "and");
 
        if (cn->u.st.modifiers)
        {
            struct cql_node *mod = cn->u.st.modifiers;
            for (; mod; mod = mod->u.st.modifiers)
            {
                if (mod->u.st.term)
                {
                    r = cql_pr_attr_uri(ct, addinfo, "index",
                                        mod->u.st.index_uri,
                                        mod->u.st.index, "serverChoice",
                                        pr, client_data, YAZ_SRW_UNSUPP_INDEX);
                    if (r)
                        return r;
                    pr(mod->u.st.term, client_data);
                    pr(" ", client_data);
                }
            }
        }
        break;
    case CQL_NODE_BOOL:
        (*pr)("@", client_data);
        (*pr)(cn->u.boolean.value, client_data);
        (*pr)(" ", client_data);
        mods = cn->u.boolean.modifiers;
        if (!strcmp(cn->u.boolean.value, "prox"))
        {
            r = cql_pr_prox(ct, mods, addinfo, pr, client_data);
            if (r)
                return r;
        }
        else if (mods)
        {
            /* Boolean modifiers other than on proximity not supported */
            wrbuf_puts(addinfo, mods->u.st.index);
            return YAZ_SRW_UNSUPP_BOOLEAN_MODIFIER;
        }
 
        r = emit_node(ct, cn->u.boolean.left, addinfo, pr, client_data);
        if (r)
            return r;
        r = emit_node(ct, cn->u.boolean.right, addinfo, pr, client_data);
        if (r)
            return r;
        break;
    case CQL_NODE_SORT:
        r = emit_node(ct, cn->u.sort.search, addinfo, pr, client_data);
        break;
    default:
        fprintf(stderr, "Fatal: impossible CQL node-type %d\n", cn->which);
        abort();
    }
    return r;
}
 
int cql_transform_r(cql_transform_t ct, struct cql_node *cn,
                    WRBUF addinfo,
                    void (*pr)(const char *buf, void *client_data),
                    void *client_data)
{
    struct cql_prop_entry *e;
    NMEM nmem = nmem_create();
    int r;
 
    for (e = ct->entry; e ; e = e->next)
    {
        if (!cql_strncmp(e->pattern, "set.", 4))
            cql_apply_prefix(nmem, cn, e->pattern+4, e->value);
        else if (!cql_strcmp(e->pattern, "set"))
            cql_apply_prefix(nmem, cn, 0, e->value);
    }
    r  = emit_node(ct, cn, addinfo, pr, client_data);
    nmem_destroy(nmem);
    return r;
}
 
int cql_transform(cql_transform_t ct, struct cql_node *cn,
                  void (*pr)(const char *buf, void *client_data),
                  void *client_data)
{
    WRBUF addinfo = wrbuf_alloc();
    int r = cql_transform_r(ct, cn, addinfo, pr, client_data);
    cql_transform_set_error(ct, r, wrbuf_cstr(addinfo));
    wrbuf_destroy(addinfo);
    return r;
}
 
int cql_transform_FILE(cql_transform_t ct, struct cql_node *cn, FILE *f)
{
    return cql_transform(ct, cn, cql_fputs, f);
}
 
int cql_transform_buf(cql_transform_t ct, struct cql_node *cn,
                      char *out, int max)
{
    struct cql_buf_write_info info;
    int r;
 
    info.off = 0;
    info.max = max;
    info.buf = out;
    r = cql_transform(ct, cn, cql_buf_write_handler, &info);
    if (info.off < 0) {
        /* Attempt to write past end of buffer.  For some reason, this
           SRW diagnostic is deprecated, but it's so perfect for our
           purposes that it would be stupid not to use it. */
        char numbuf[30];
        yaz_snprintf(numbuf, sizeof numbuf, "%ld", (long) info.max);
        cql_transform_set_error(ct, YAZ_SRW_TOO_MANY_CHARS_IN_QUERY, numbuf);
        return -1;
    }
    if (info.off >= 0)
        info.buf[info.off] = '\0';
    return r;
}
 
int cql_transform_error(cql_transform_t ct, const char **addinfo)
{
    *addinfo = wrbuf_len(ct->addinfo) ? wrbuf_cstr(ct->addinfo) : 0;
    return ct->error;
}
 
void cql_transform_set_error(cql_transform_t ct, int error, const char *addinfo)
{
    wrbuf_rewind(ct->addinfo);
    if (addinfo)
        wrbuf_puts(ct->addinfo, addinfo);
    ct->error = error;
}
 
/*
 * Local variables:
 * c-basic-offset: 4
 * c-file-style: "Stroustrup"
 * indent-tabs-mode: nil
 * End:
 * vim: shiftwidth=4 tabstop=8 expandtab
 */