removing unnecessary comments
[idzebra-moved-to-github.git] / index / retrieve.c
index 3de8ff6..cffbc40 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: retrieve.c,v 1.43 2006-08-14 10:40:15 adam Exp $
+/* $Id: retrieve.c,v 1.54 2006-11-17 08:20:17 marc Exp $
    Copyright (C) 1995-2006
    Index Data ApS
 
@@ -33,256 +33,392 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 #endif
 
 #include "index.h"
+#include <yaz/diagbib1.h>
 #include <direntz.h>
 
-int zebra_record_ext_read (void *fh, char *buf, size_t count)
-{
-    struct zebra_fetch_control *fc = (struct zebra_fetch_control *) fh;
-    return read (fc->fd, buf, count);
-}
 
-off_t zebra_record_ext_seek (void *fh, off_t offset)
-{
-    struct zebra_fetch_control *fc = (struct zebra_fetch_control *) fh;
-    return lseek (fc->fd, offset + fc->record_offset, SEEK_SET);
-}
 
-off_t zebra_record_ext_tell (void *fh)
-{
-    struct zebra_fetch_control *fc = (struct zebra_fetch_control *) fh;
-    return lseek (fc->fd, 0, SEEK_CUR) - fc->record_offset;
+
+static int zebra_create_record_stream(ZebraHandle zh, 
+                               Record *rec,
+                               struct ZebraRecStream *stream){
+
+    RecordAttr *recordAttr = rec_init_attr(zh->reg->zei, *rec);
+
+    if ((*rec)->size[recInfo_storeData] > 0){ 
+        zebra_create_stream_mem(stream, (*rec)->info[recInfo_storeData],
+                                (*rec)->size[recInfo_storeData]);
+    }
+    else {
+        char full_rep[1024];
+        int fd;
+            
+        if (zh->path_reg && !yaz_is_abspath((*rec)->info[recInfo_filename])){
+            strcpy(full_rep, zh->path_reg);
+            strcat(full_rep, "/");
+            strcat(full_rep, (*rec)->info[recInfo_filename]);
+        }
+        else
+            strcpy(full_rep, (*rec)->info[recInfo_filename]);
+            
+        if ((fd = open (full_rep, O_BINARY|O_RDONLY)) == -1){
+            yaz_log (YLOG_WARN|YLOG_ERRNO, "Retrieve fail; missing file: %s",
+                     full_rep);
+            rec_free(rec);
+            return 14;
+        }
+        zebra_create_stream_fd(stream, fd, recordAttr->recordOffset);
+    }
+    return 0;
 }
+    
 
-off_t zebra_record_int_seek (void *fh, off_t offset)
+
+static void parse_zebra_elem(const char *elem,
+                             const char **index, size_t *index_len,
+                             const char **type, size_t *type_len)
 {
-    struct zebra_fetch_control *fc = (struct zebra_fetch_control *) fh;
-    return (off_t) (fc->record_int_pos = offset);
+    *type = 0;
+    *type_len = 0;
+
+    *index = 0;
+    *index_len = 0;
+
+    if (elem && *elem)
+    {
+        const char *cp = strchr(elem, ':');
+
+        if (!cp) /* no colon */
+        {
+            *index = elem;
+            *index_len = strlen(elem);
+        }
+        else if (cp[1] == '\0') /* 'index:' */
+        {
+            *index = elem;
+            *index_len = cp - elem;
+        }
+        else
+        {
+            *index = elem;
+            *index_len = cp - elem;
+            *type = cp+1;
+            *type_len = strlen(cp+1);
+        }
+    }
 }
 
-off_t zebra_record_int_tell (void *fh)
+
+int zebra_special_index_fetch(ZebraHandle zh, SYSNO sysno, ODR odr,
+                          Record rec,
+                          const char *elemsetname,
+                          oid_value input_format,
+                          oid_value *output_format,
+                          char **rec_bufp, int *rec_lenp)
 {
-    struct zebra_fetch_control *fc = (struct zebra_fetch_control *) fh;
-    return (off_t) fc->record_int_pos;
+    const char *retrieval_index;
+    size_t retrieval_index_len; 
+    const char *retrieval_type;
+    size_t retrieval_type_len;
+    WRBUF wrbuf = 0;
+    zebra_rec_keys_t keys;
+    
+    /* set output variables before processing possible error states */
+    /* *rec_lenp = 0; */
+
+    /* only accept XML and SUTRS requests */
+    if (input_format != VAL_TEXT_XML
+        && input_format != VAL_SUTRS){
+        yaz_log(YLOG_WARN, "unsupported format for element set zebra::%s", 
+                elemsetname);
+        *output_format = VAL_NONE;
+        return YAZ_BIB1_NO_SYNTAXES_AVAILABLE_FOR_THIS_REQUEST;
+    }
+
+    parse_zebra_elem(elemsetname,
+                     &retrieval_index, &retrieval_index_len,
+                     &retrieval_type,  &retrieval_type_len);
+
+    if (retrieval_type_len != 0 && retrieval_type_len != 1)
+    {
+        return YAZ_BIB1_SPECIFIED_ELEMENT_SET_NAME_NOT_VALID_FOR_SPECIFIED_;
+    }
+
+    if (retrieval_index_len)
+    {
+        char retrieval_index_cstr[256];
+
+        if (retrieval_index_len  < sizeof(retrieval_index_cstr) -1)
+        {
+            memcpy(retrieval_index_cstr, retrieval_index, retrieval_index_len);
+            retrieval_index_cstr[retrieval_index_len] = '\0';
+            
+            if (zebraExplain_lookup_attr_str(zh->reg->zei,
+                                             zinfo_index_category_index,
+                                             (retrieval_type_len == 0 ? -1 : 
+                                              retrieval_type[0]),
+                                             retrieval_index_cstr) == -1)
+            {
+                return YAZ_BIB1_SPECIFIED_ELEMENT_SET_NAME_NOT_VALID_FOR_SPECIFIED_;
+            }
+        }
+    }
+
+    keys = zebra_rec_keys_open();
+    zebra_rec_keys_set_buf(keys, rec->info[recInfo_delKeys],
+                           rec->size[recInfo_delKeys], 0);
+
+    wrbuf = wrbuf_alloc();
+    if (zebra_rec_keys_rewind(keys)){
+        size_t slen;
+        const char *str;
+        struct it_key key_in;
+
+        if (input_format == VAL_TEXT_XML){
+            *output_format = VAL_TEXT_XML;
+            /*wrbuf_printf(wrbuf, 
+              "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n");*/
+            
+            wrbuf_printf(wrbuf, 
+                         "<record xmlns="
+                         "\"http://www.indexdata.com/zebra/\""
+                         " sysno=\"" ZINT_FORMAT "\""
+                         " set=\"zebra::index::%s/\">\n",
+                         sysno, elemsetname);
+        }
+        else if (input_format == VAL_SUTRS)
+            *output_format = VAL_SUTRS;
+
+
+        while(zebra_rec_keys_read(keys, &str, &slen, &key_in)){
+            int i;
+            int ord = CAST_ZINT_TO_INT(key_in.mem[0]);
+            int index_type;
+            const char *db = 0;
+            const char *string_index = 0;
+            size_t string_index_len;
+            char dst_buf[IT_MAX_WORD];
+            
+            zebraExplain_lookup_ord(zh->reg->zei, ord, &index_type, &db,
+                                    &string_index);
+            string_index_len = strlen(string_index);
+            if (retrieval_index == 0 
+                || (string_index_len == retrieval_index_len 
+                    && !memcmp(string_index, retrieval_index,
+                               string_index_len))){
+                
+                if (retrieval_type == 0 
+                    || (retrieval_type_len == 1 
+                        && retrieval_type[0] == index_type)){
+                    
+                    if (input_format == VAL_TEXT_XML){
+                        wrbuf_printf(wrbuf, "  <index name=\"%s\"", 
+                                     string_index);
+                        
+                        wrbuf_printf(wrbuf, " type=\"%c\"", index_type);
+                        
+                        wrbuf_printf(wrbuf, " seq=\"" ZINT_FORMAT "\">", 
+                                     key_in.mem[key_in.len -1]);
+                        
+                        zebra_term_untrans(zh, index_type, dst_buf, str);
+                        wrbuf_xmlputs(wrbuf, dst_buf);
+                        wrbuf_printf(wrbuf, "</index>\n");
+                    }
+                    else if (input_format == VAL_SUTRS){
+                        wrbuf_printf(wrbuf, "%s ", string_index);
+                    
+                        wrbuf_printf(wrbuf, "%c", index_type);
+                    
+                        for (i = 1; i < key_in.len; i++)
+                            wrbuf_printf(wrbuf, " " ZINT_FORMAT, 
+                                         key_in.mem[i]);
+
+                        zebra_term_untrans(zh, index_type, dst_buf, str);
+                        wrbuf_printf(wrbuf, " %s", dst_buf);
+                        
+                        wrbuf_printf(wrbuf, "\n");
+                    }
+                }
+            }
+        }
+        if (input_format == VAL_TEXT_XML)
+            wrbuf_printf(wrbuf, "</record>\n");
+     }
+    *rec_lenp = wrbuf_len(wrbuf);
+    *rec_bufp = odr_malloc(odr, *rec_lenp);
+    memcpy(*rec_bufp, wrbuf_buf(wrbuf), *rec_lenp);
+    wrbuf_free(wrbuf, 1);
+    zebra_rec_keys_close(keys);
+    return 0;
 }
 
-int zebra_record_int_read (void *fh, char *buf, size_t count)
+
+int zebra_special_fetch(ZebraHandle zh, SYSNO sysno, ODR odr,
+                           const char *elemsetname,
+                           oid_value input_format,
+                           oid_value *output_format,
+                           char **rec_bufp, int *rec_lenp)
 {
-    struct zebra_fetch_control *fc = (struct zebra_fetch_control *) fh;
-    int l = fc->record_int_len - fc->record_int_pos;
-    if (l <= 0)
+    Record rec;
+    
+    /* set output variables before processing possible error states */
+    /* *rec_lenp = 0; */
+
+    /* only accept XML and SUTRS requests */
+    if (input_format != VAL_TEXT_XML
+        && input_format != VAL_SUTRS){
+        yaz_log(YLOG_WARN, "unsupported format for element set zebra::%s", 
+                elemsetname);
+        return YAZ_BIB1_NO_SYNTAXES_AVAILABLE_FOR_THIS_REQUEST;
+    }
+    
+    /* processing zebra::meta::sysno elemset without fetching binary data */
+    if (elemsetname  && 0 == strcmp(elemsetname, "meta::sysno"))
+    {
+       char rec_str[128];
+        if (input_format == VAL_SUTRS){
+            sprintf(rec_str, ZINT_FORMAT, sysno);
+            *output_format = VAL_SUTRS;
+        } 
+        else if (input_format == VAL_TEXT_XML){
+            sprintf(rec_str, "<record xmlns="
+                    "\"http://www.indexdata.com/zebra/\""
+                             " sysno=\"" ZINT_FORMAT "\""
+                             " set=\"zebra::%s\"/>\n",
+                    sysno, elemsetname);
+            *output_format = VAL_TEXT_XML;
+        }
+       *rec_lenp = strlen(rec_str);
+        if (*rec_lenp){
+            *rec_bufp = odr_strdup(odr, rec_str);
+            return 0;
+        } else {
+            return YAZ_BIB1_SYSTEM_ERROR_IN_PRESENTING_RECORDS;
+        }
+    }
+
+    /* fetching binary record up for all other display elementsets */
+    rec = rec_get(zh->reg->records, sysno);
+    if (!rec){
+        yaz_log(YLOG_WARN, "rec_get fail on sysno=" ZINT_FORMAT, sysno);
+        return YAZ_BIB1_SYSTEM_ERROR_IN_PRESENTING_RECORDS;
+    }
+
+    /* processing special elementsetnames zebra::index:: */
+    if (elemsetname && 0 == strncmp(elemsetname, "index::", 7)){
+        
+        int ret = zebra_special_index_fetch(zh, sysno, odr, rec,
+                                            elemsetname + 7,
+                                            input_format, output_format,
+                                            rec_bufp, rec_lenp);
+        
+        rec_free(&rec);
+        return ret;
+    }
+
+    /* processing special elementsetnames zebra::data */    
+    if (elemsetname && 0 == strcmp(elemsetname, "data")){
+        struct ZebraRecStream stream;
+        RecordAttr *recordAttr = rec_init_attr(zh->reg->zei, rec); 
+        zebra_create_record_stream(zh, &rec, &stream);
+        *output_format = input_format;
+        *rec_lenp = recordAttr->recordSize;
+        *rec_bufp = (char *) odr_malloc(odr, *rec_lenp);
+        stream.readf(&stream, *rec_bufp, *rec_lenp);
+        stream.destroy(&stream);
+        rec_free(&rec);
         return 0;
-    l = (l < (int) count) ? l : (int) count;
-    memcpy (buf, fc->record_int_buf + fc->record_int_pos, l);
-    fc->record_int_pos += l;
-    return l;
-}
+    }
 
-void zebra_record_int_end (void *fh, off_t off)
-{
-    struct zebra_fetch_control *fc = (struct zebra_fetch_control *) fh;
-    fc->offset_end = off;
+    if (rec)
+        rec_free(&rec);
+    return YAZ_BIB1_SPECIFIED_ELEMENT_SET_NAME_NOT_VALID_FOR_SPECIFIED_;
 }
 
-int zebra_record_fetch (ZebraHandle zh, SYSNO sysno, int score,
-                       zebra_snippets *hit_snippet, ODR stream,
-                       oid_value input_format, Z_RecordComposition *comp,
-                       oid_value *output_format, char **rec_bufp,
-                       int *rec_lenp, char **basenamep,
-                       char **addinfo)
+                          
+int zebra_record_fetch(ZebraHandle zh, SYSNO sysno, int score,
+                       zebra_snippets *hit_snippet, ODR odr,
+                       oid_value input_format, Z_RecordComposition *comp,
+                       oid_value *output_format,
+                       char **rec_bufp, int *rec_lenp, char **basenamep,
+                       char **addinfo)
 {
     Record rec;
     char *fname, *file_type, *basename;
-    RecType rt;
-    struct recRetrieveCtrl retrieveCtrl;
-    struct zebra_fetch_control fc;
+    const char *elemsetname;
+    struct ZebraRecStream stream;
     RecordAttr *recordAttr;
     void *clientData;
-    int raw_mode = 0;
+    int return_code = 0;
 
     *basenamep = 0;
     *addinfo = 0;
-    if (comp && comp->which == Z_RecordComp_simple &&
-        comp->u.simple->which == Z_ElementSetNames_generic && 
-        !strcmp (comp->u.simple->u.generic, "_sysno_"))
-    {
-       char rec_str[60];
-       sprintf(rec_str, ZINT_FORMAT, sysno);
-       *output_format = VAL_SUTRS;
-       *rec_lenp = strlen(rec_str);
-       *rec_bufp = odr_strdup(stream, rec_str);
-       return 0;
-    }
-    rec = rec_get (zh->reg->records, sysno);
+    elemsetname = yaz_get_esn(comp);
+
+    /* processing zebra special elementset names of form 'zebra:: */
+    if (elemsetname && 0 == strncmp(elemsetname, "zebra::", 7))
+        return  zebra_special_fetch(zh, sysno, odr,
+                                    elemsetname + 7,
+                                    input_format, output_format,
+                                    rec_bufp, rec_lenp);
+
+
+    /* processing all other element set names */
+    rec = rec_get(zh->reg->records, sysno);
     if (!rec)
     {
-        yaz_log (YLOG_DEBUG, "rec_get fail on sysno=" ZINT_FORMAT, sysno);
+        yaz_log(YLOG_WARN, "rec_get fail on sysno=" ZINT_FORMAT, sysno);
         *basenamep = 0;
-        return 14;
+        return YAZ_BIB1_SYSTEM_ERROR_IN_PRESENTING_RECORDS;
     }
-    recordAttr = rec_init_attr (zh->reg->zei, rec);
+
+
+    recordAttr = rec_init_attr(zh->reg->zei, rec);
 
     file_type = rec->info[recInfo_fileType];
     fname = rec->info[recInfo_filename];
     basename = rec->info[recInfo_databaseName];
-    *basenamep = (char *) odr_malloc (stream, strlen(basename)+1);
+    *basenamep = (char *) odr_malloc (odr, strlen(basename)+1);
     strcpy (*basenamep, basename);
 
-    if (comp && comp->which == Z_RecordComp_simple &&
-        comp->u.simple->which == Z_ElementSetNames_generic && 
-        !strcmp (comp->u.simple->u.generic, "_storekeys_"))
-    {
-       WRBUF wrbuf = wrbuf_alloc();
-       zebra_rec_keys_t keys = zebra_rec_keys_open();
-       zebra_rec_keys_set_buf(keys,
-                              rec->info[recInfo_delKeys],
-                              rec->size[recInfo_delKeys],
-                              0);
-       if (zebra_rec_keys_rewind(keys))
-       {
-           size_t slen;
-           const char *str;
-           struct it_key key_in;
-           while(zebra_rec_keys_read(keys, &str, &slen, &key_in))
-           {
-               int i;
-               int ord = CAST_ZINT_TO_INT(key_in.mem[0]);
-               int index_type;
-               const char *db = 0;
-               int set = 0;
-               int use = 0;
-               const char *string_index = 0;
-               char dst_buf[IT_MAX_WORD];
-               
-               zebraExplain_lookup_ord(zh->reg->zei, ord, &index_type, &db,
-                                       &string_index);
-
-               if (string_index)
-                   wrbuf_printf(wrbuf, "%s", string_index);
-               else
-                   wrbuf_printf(wrbuf, "set=%d,use=%d", set, use);
-
-               zebra_term_untrans(zh, index_type, dst_buf, str);
-               wrbuf_printf(wrbuf, " %s", dst_buf);
-
-               for (i = 1; i < key_in.len; i++)
-                   wrbuf_printf(wrbuf, " " ZINT_FORMAT, key_in.mem[i]);
-               wrbuf_printf(wrbuf, "\n");
-
-           }
-       }
-       *output_format = VAL_SUTRS;
-       *rec_lenp = wrbuf_len(wrbuf);
-       *rec_bufp = odr_malloc(stream, *rec_lenp);
-       memcpy(*rec_bufp, wrbuf_buf(wrbuf), *rec_lenp);
-       wrbuf_free(wrbuf, 1);
-       zebra_rec_keys_close(keys);
-       return 0;
-    }
-    if (comp && comp->which == Z_RecordComp_simple &&
-        comp->u.simple->which == Z_ElementSetNames_generic && 
-        !strcmp (comp->u.simple->u.generic, "R"))
-    {
-       raw_mode = 1;
-    }
-    if (!(rt = recType_byName (zh->reg->recTypes, zh->res,
-                              file_type, &clientData)))
-    {
-        yaz_log (YLOG_WARN, "Retrieve: Cannot handle type %s",  file_type);
-       return 14;
-    }
-    yaz_log (YLOG_DEBUG, "retrieve localno=" ZINT_FORMAT " score=%d", sysno,score);
-    retrieveCtrl.fh = &fc;
-    fc.fd = -1;
-    retrieveCtrl.fname = fname;
-    if (rec->size[recInfo_storeData] > 0)
-    {
-        retrieveCtrl.readf = zebra_record_int_read;
-        retrieveCtrl.seekf = zebra_record_int_seek;
-        retrieveCtrl.tellf = zebra_record_int_tell;
-        fc.record_int_len = rec->size[recInfo_storeData];
-        fc.record_int_buf = rec->info[recInfo_storeData];
-        fc.record_int_pos = 0;
-        yaz_log (YLOG_DEBUG, "Internal retrieve. %d bytes", fc.record_int_len);
-       if (raw_mode)
-       {
-            *output_format = VAL_SUTRS;
-            *rec_lenp = rec->size[recInfo_storeData];
-                   *rec_bufp = (char *) odr_malloc(stream, *rec_lenp);
-           memcpy(*rec_bufp, rec->info[recInfo_storeData], *rec_lenp);
-            rec_rm (&rec);
-           return 0;
-       }
-    }
-    else
-    {
-        char full_rep[1024];
-
-        if (zh->path_reg && !yaz_is_abspath (fname))
-        {
-            strcpy (full_rep, zh->path_reg);
-            strcat (full_rep, "/");
-            strcat (full_rep, fname);
-        }
-        else
-            strcpy (full_rep, fname);
+    yaz_log(YLOG_DEBUG, "retrieve localno=" ZINT_FORMAT " score=%d",
+            sysno, score);
 
-        if ((fc.fd = open (full_rep, O_BINARY|O_RDONLY)) == -1)
-        {
-            yaz_log (YLOG_WARN|YLOG_ERRNO, "Retrieve fail; missing file: %s",
-                 full_rep);
-            rec_rm (&rec);
-            return 14;
-        }
-       fc.record_offset = recordAttr->recordOffset;
-
-        retrieveCtrl.readf = zebra_record_ext_read;
-        retrieveCtrl.seekf = zebra_record_ext_seek;
-        retrieveCtrl.tellf = zebra_record_ext_tell;
-
-        zebra_record_ext_seek (retrieveCtrl.fh, 0);
-       if (raw_mode)
-       {
-            *output_format = VAL_SUTRS;
-            *rec_lenp = recordAttr->recordSize;
-                   *rec_bufp = (char *) odr_malloc(stream, *rec_lenp);
-           zebra_record_ext_read(&fc, *rec_bufp, *rec_lenp);
-            rec_rm (&rec);
-            close (fc.fd);
-           return 0;
-       }
-    }
-    retrieveCtrl.localno = sysno;
-    retrieveCtrl.staticrank = recordAttr->staticrank;
-    retrieveCtrl.score = score;
-    retrieveCtrl.recordSize = recordAttr->recordSize;
-    retrieveCtrl.odr = stream;
-    retrieveCtrl.input_format = retrieveCtrl.output_format = input_format;
-    retrieveCtrl.comp = comp;
-    retrieveCtrl.encoding = zh->record_encoding;
-    retrieveCtrl.diagnostic = 0;
-    retrieveCtrl.addinfo = 0;
-    retrieveCtrl.dh = zh->reg->dh;
-    retrieveCtrl.res = zh->res;
-    retrieveCtrl.rec_buf = 0;
-    retrieveCtrl.rec_len = -1;
-    retrieveCtrl.hit_snippet = hit_snippet;
-    retrieveCtrl.doc_snippet = zebra_snippets_create();
+    zebra_create_record_stream(zh, &rec, &stream);
     
-    if (1)
     {
        /* snippets code */
        zebra_snippets *snippet;
-
        zebra_rec_keys_t reckeys = zebra_rec_keys_open();
-       
+        RecType rt;
+        struct recRetrieveCtrl retrieveCtrl;
+
+        retrieveCtrl.stream = &stream;
+        retrieveCtrl.fname = fname;
+        retrieveCtrl.localno = sysno;
+        retrieveCtrl.staticrank = recordAttr->staticrank;
+        retrieveCtrl.score = score;
+        retrieveCtrl.recordSize = recordAttr->recordSize;
+        retrieveCtrl.odr = odr;
+        retrieveCtrl.input_format = retrieveCtrl.output_format = input_format;
+        retrieveCtrl.comp = comp;
+        retrieveCtrl.encoding = zh->record_encoding;
+        retrieveCtrl.diagnostic = 0;
+        retrieveCtrl.addinfo = 0;
+        retrieveCtrl.dh = zh->reg->dh;
+        retrieveCtrl.res = zh->res;
+        retrieveCtrl.rec_buf = 0;
+        retrieveCtrl.rec_len = -1;
+        retrieveCtrl.hit_snippet = hit_snippet;
+        retrieveCtrl.doc_snippet = zebra_snippets_create();
+
        zebra_rec_keys_set_buf(reckeys,
                               rec->info[recInfo_delKeys],
                               rec->size[recInfo_delKeys], 
                               0);
-       zebra_snippets_rec_keys(zh, reckeys, retrieveCtrl.doc_snippet);
+       zebra_rec_keys_to_snippets(zh, reckeys, retrieveCtrl.doc_snippet);
        zebra_rec_keys_close(reckeys);
 
-
 #if 0
        /* for debugging purposes */
        yaz_log(YLOG_LOG, "DOC SNIPPET:");
@@ -298,27 +434,33 @@ int zebra_record_fetch (ZebraHandle zh, SYSNO sysno, int score,
        yaz_log(YLOG_LOG, "WINDOW SNIPPET:");
        zebra_snippets_log(snippet, YLOG_LOG);
 #endif
-       (*rt->retrieve)(clientData, &retrieveCtrl);
 
-       zebra_snippets_destroy(snippet);
-    }
-    else
-    {
-       (*rt->retrieve)(clientData, &retrieveCtrl);
-    }
+        if (!(rt = recType_byName(zh->reg->recTypes, zh->res,
+                                  file_type, &clientData)))
+        {
+            return_code = YAZ_BIB1_SYSTEM_ERROR_IN_PRESENTING_RECORDS;
+        }
+        else
+        {
+            (*rt->retrieve)(clientData, &retrieveCtrl);
+            return_code = retrieveCtrl.diagnostic;
 
-    zebra_snippets_destroy(retrieveCtrl.doc_snippet);
+            *output_format = retrieveCtrl.output_format;
+            *rec_bufp = (char *) retrieveCtrl.rec_buf;
+            *rec_lenp = retrieveCtrl.rec_len;
+            *addinfo = retrieveCtrl.addinfo;
+        }
 
-    *output_format = retrieveCtrl.output_format;
-    *rec_bufp = (char *) retrieveCtrl.rec_buf;
-    *rec_lenp = retrieveCtrl.rec_len;
-    if (fc.fd != -1)
-        close (fc.fd);
-    rec_rm (&rec);
+       zebra_snippets_destroy(snippet);
+        zebra_snippets_destroy(retrieveCtrl.doc_snippet);
+     }
+
+    stream.destroy(&stream);
+    rec_free(&rec);
 
-    *addinfo = retrieveCtrl.addinfo;
-    return retrieveCtrl.diagnostic;
+    return return_code;
 }
+
 /*
  * Local variables:
  * c-basic-offset: 4