Convert to ISO-8859-1 for indexing and retrieval
[idzebra-moved-to-github.git] / recctrl / recgrs.c
1 /*
2  * Copyright (C) 1994-2002, Index Data
3  * All rights reserved.
4  *
5  * $Id: recgrs.c,v 1.54 2002-07-05 16:07:02 adam Exp $
6  */
7
8 #include <stdio.h>
9 #include <assert.h>
10 #include <sys/types.h>
11 #ifndef WIN32
12 #include <unistd.h>
13 #endif
14
15 #include <yaz/log.h>
16 #include <yaz/oid.h>
17
18 #include <recctrl.h>
19 #include "grsread.h"
20
21 #define GRS_MAX_WORD 512
22
23 struct grs_handler {
24     RecTypeGrs type;
25     void *clientData;
26     int initFlag;
27     struct grs_handler *next;
28 };
29
30 struct grs_handlers {
31     struct grs_handler *handlers;
32 };
33
34 static int read_grs_type (struct grs_handlers *h,
35                           struct grs_read_info *p, const char *type,
36                           data1_node **root)
37 {
38     struct grs_handler *gh = h->handlers;
39     const char *cp = strchr (type, '.');
40
41     if (cp == NULL || cp == type)
42     {
43         cp = strlen(type) + type;
44         *p->type = 0;
45     }
46     else
47         strcpy (p->type, cp+1);
48     for (gh = h->handlers; gh; gh = gh->next)
49     {
50         if (!memcmp (type, gh->type->type, cp-type))
51         {
52             if (!gh->initFlag)
53             {
54                 gh->initFlag = 1;
55                 gh->clientData = (*gh->type->init)();
56             }
57             p->clientData = gh->clientData;
58             *root = (gh->type->read)(p);
59             gh->clientData = p->clientData;
60             return 0;
61         }
62     }
63     return 1;
64 }
65
66 static void grs_add_handler (struct grs_handlers *h, RecTypeGrs t)
67 {
68     struct grs_handler *gh = (struct grs_handler *) xmalloc (sizeof(*gh));
69     gh->next = h->handlers;
70     h->handlers = gh;
71     gh->initFlag = 0;
72     gh->clientData = 0;
73     gh->type = t;
74 }
75
76 static void *grs_init(RecType recType)
77 {
78     struct grs_handlers *h = (struct grs_handlers *) xmalloc (sizeof(*h));
79     h->handlers = 0;
80
81     grs_add_handler (h, recTypeGrs_sgml);
82     grs_add_handler (h, recTypeGrs_regx);
83 #if HAVE_TCL_H
84     grs_add_handler (h, recTypeGrs_tcl);
85 #endif
86     grs_add_handler (h, recTypeGrs_marc);
87 #if YAZ_HAVE_EXPAT
88     grs_add_handler (h, recTypeGrs_xml);
89 #endif
90     return h;
91 }
92
93 static void grs_destroy(void *clientData)
94 {
95     struct grs_handlers *h = (struct grs_handlers *) clientData;
96     struct grs_handler *gh = h->handlers, *gh_next;
97     while (gh)
98     {
99         gh_next = gh->next;
100         if (gh->initFlag)
101             (*gh->type->destroy)(gh->clientData);
102         xfree (gh);
103         gh = gh_next;
104     }
105     xfree (h);
106 }
107
108 static void index_xpath (data1_node *n, struct recExtractCtrl *p,
109                          int level, RecWord *wrd, int use)
110 {
111     int i;
112     char tag_path_full[1024];
113     size_t flen = 0;
114     data1_node *nn;
115
116     switch (n->which)
117     {
118     case DATA1N_data:
119         wrd->reg_type = 'w';
120         wrd->string = n->u.data.data;
121         wrd->length = n->u.data.len;
122         wrd->attrSet = VAL_IDXPATH,
123         wrd->attrUse = use;
124         if (p->flagShowRecords)
125         {
126             printf("%*s data=", (level + 1) * 4, "");
127             for (i = 0; i<wrd->length && i < 8; i++)
128                 fputc (wrd->string[i], stdout);
129             printf("\n");
130         }
131         else
132         {
133             (*p->tokenAdd)(wrd);
134         }
135         break;
136     case DATA1N_tag:
137         for (nn = n; nn; nn = nn->parent)
138         {
139             if (nn->which == DATA1N_tag)
140             {
141                 size_t tlen = strlen(nn->u.tag.tag);
142                 if (tlen + flen > (sizeof(tag_path_full)-2))
143                     return;
144                 memcpy (tag_path_full + flen, nn->u.tag.tag, tlen);
145                 flen += tlen;
146                 tag_path_full[flen++] = '/';
147             }
148             else if (nn->which == DATA1N_root)
149                 break;
150         }
151         wrd->reg_type = '0';
152         wrd->string = tag_path_full;
153         wrd->length = flen;
154         wrd->attrSet = VAL_IDXPATH;
155         wrd->attrUse = use;
156         if (p->flagShowRecords)
157         {
158             printf("%*s tag=", (level + 1) * 4, "");
159             for (i = 0; i<wrd->length && i < 40; i++)
160                 fputc (wrd->string[i], stdout);
161             if (i == 40)
162                 printf (" ..");
163             printf("\n");
164         }
165         else
166         {
167             (*p->tokenAdd)(wrd);
168         }
169         break;
170     }
171 }
172
173 static void index_termlist (data1_node *par, data1_node *n,
174                             struct recExtractCtrl *p, int level, RecWord *wrd)
175 {
176     data1_termlist *tlist = 0;
177     data1_datatype dtype = DATA1K_string;
178     /*
179      * cycle up towards the root until we find a tag with an att..
180      * this has the effect of indexing locally defined tags with
181      * the attribute of their ancestor in the record.
182      */
183     
184     while (!par->u.tag.element)
185         if (!par->parent || !(par=get_parent_tag(p->dh, par->parent)))
186             break;
187     if (!par || !(tlist = par->u.tag.element->termlists))
188         return;
189     if (par->u.tag.element->tag)
190         dtype = par->u.tag.element->tag->kind;
191     
192     for (; tlist; tlist = tlist->next)
193     {
194         char xattr[512];
195         /* consider source */
196         wrd->string = 0;
197         
198         if (!strcmp (tlist->source, "data") && n->which == DATA1N_data)
199         {
200             wrd->string = n->u.data.data;
201             wrd->length = n->u.data.len;
202         }
203         else if (!strcmp (tlist->source, "tag") && n->which == DATA1N_tag)
204         {
205             wrd->string = n->u.tag.tag;
206             wrd->length = strlen(n->u.tag.tag);
207         }
208         else if (sscanf (tlist->source, "attr(%511[^)])", xattr) == 1 &&
209             n->which == DATA1N_tag)
210         {
211             data1_xattr *p = n->u.tag.attributes;
212             while (p && strcmp (p->name, xattr))
213                 p = p->next;
214             if (p)
215             {
216                 wrd->string = p->value;
217                 wrd->length = strlen(p->value);
218             }
219         }
220         if (wrd->string)
221         {
222             if (p->flagShowRecords)
223             {
224                 int i;
225                 printf("%*sIdx: [%s]", (level + 1) * 4, "",
226                        tlist->structure);
227                 printf("%s:%s [%d] %s",
228                        tlist->att->parent->name,
229                        tlist->att->name, tlist->att->value,
230                        tlist->source);
231                 printf (" data=\"");
232                 for (i = 0; i<wrd->length && i < 8; i++)
233                     fputc (wrd->string[i], stdout);
234                 fputc ('"', stdout);
235                 if (wrd->length > 8)
236                     printf (" ...");
237                 fputc ('\n', stdout);
238             }
239             else
240             {
241                 wrd->reg_type = *tlist->structure;
242                 wrd->attrSet = (int) (tlist->att->parent->reference);
243                 wrd->attrUse = tlist->att->locals->local;
244                 (*p->tokenAdd)(wrd);
245             }
246         }
247     }
248 }
249
250 static int dumpkeys(data1_node *n, struct recExtractCtrl *p, int level,
251                     RecWord *wrd)
252 {
253     for (; n; n = n->next)
254     {
255         if (p->flagShowRecords) /* display element description to user */
256         {
257             if (n->which == DATA1N_root)
258             {
259                 printf("%*s", level * 4, "");
260                 printf("Record type: '%s'\n", n->u.root.type);
261             }
262             else if (n->which == DATA1N_tag)
263             {
264                 data1_element *e;
265
266                 printf("%*s", level * 4, "");
267                 if (!(e = n->u.tag.element))
268                     printf("Local tag: '%s'\n", n->u.tag.tag);
269                 else
270                 {
271                     printf("Elm: '%s' ", e->name);
272                     if (e->tag)
273                     {
274                         data1_tag *t = e->tag;
275
276                         printf("TagNam: '%s' ", t->names->name);
277                         printf("(");
278                         if (t->tagset)
279                             printf("%s[%d],", t->tagset->name, t->tagset->type);
280                         else
281                             printf("?,");
282                         if (t->which == DATA1T_numeric)
283                             printf("%d)", t->value.numeric);
284                         else
285                             printf("'%s')", t->value.string);
286                     }
287                     printf("\n");
288                 }
289             }
290         }
291
292         if (n->which == DATA1N_tag)
293         {
294             index_termlist (n, n, p, level, wrd);
295             /* index start tag */
296             if (!n->root->u.root.absyn)
297                 index_xpath (n, p, level, wrd, 1);
298         }
299
300         if (n->child)
301             if (dumpkeys(n->child, p, level + 1, wrd) < 0)
302                 return -1;
303
304
305         if (n->which == DATA1N_data)
306         {
307             data1_node *par = get_parent_tag(p->dh, n);
308
309             if (p->flagShowRecords)
310             {
311                 printf("%*s", level * 4, "");
312                 printf("Data: ");
313                 if (n->u.data.len > 32)
314                     printf("'%.24s ... %.6s'\n", n->u.data.data,
315                            n->u.data.data + n->u.data.len-6);
316                 else if (n->u.data.len > 0)
317                     printf("'%.*s'\n", n->u.data.len, n->u.data.data);
318                 else
319                     printf("NULL\n");
320             }
321
322             if (par)
323                 index_termlist (par, n, p, level, wrd);
324             if (!n->root->u.root.absyn)
325                 index_xpath (n, p, level, wrd, 1016);
326
327         }
328
329         if (n->which == DATA1N_tag)
330         {
331             /* index end tag */
332             if (!n->root->u.root.absyn)
333                 index_xpath (n, p, level, wrd, 2);
334         }
335
336
337         if (p->flagShowRecords && n->which == DATA1N_root)
338         {
339             printf("%*s-------------\n\n", level * 4, "");
340         }
341     }
342     return 0;
343 }
344
345 int grs_extract_tree(struct recExtractCtrl *p, data1_node *n)
346 {
347     oident oe;
348     int oidtmp[OID_SIZE];
349     RecWord wrd;
350
351     oe.proto = PROTO_Z3950;
352     oe.oclass = CLASS_SCHEMA;
353     if (n->u.root.absyn)
354     {
355         oe.value = n->u.root.absyn->reference;
356         
357         if ((oid_ent_to_oid (&oe, oidtmp)))
358             (*p->schemaAdd)(p, oidtmp);
359     }
360     (*p->init)(p, &wrd);
361
362     return dumpkeys(n, p, 0, &wrd);
363 }
364
365 static int grs_extract_sub(struct grs_handlers *h, struct recExtractCtrl *p,
366                            NMEM mem)
367 {
368     data1_node *n;
369     struct grs_read_info gri;
370     oident oe;
371     int oidtmp[OID_SIZE];
372     RecWord wrd;
373
374     gri.readf = p->readf;
375     gri.seekf = p->seekf;
376     gri.tellf = p->tellf;
377     gri.endf = p->endf;
378     gri.fh = p->fh;
379     gri.offset = p->offset;
380     gri.mem = mem;
381     gri.dh = p->dh;
382
383     if (read_grs_type (h, &gri, p->subType, &n))
384         return RECCTRL_EXTRACT_ERROR;
385     if (!n)
386         return RECCTRL_EXTRACT_EOF;
387     oe.proto = PROTO_Z3950;
388     oe.oclass = CLASS_SCHEMA;
389 #if 0
390     if (!n->u.root.absyn)
391         return RECCTRL_EXTRACT_ERROR;
392 #endif
393     if (n->u.root.absyn)
394     {
395         oe.value = n->u.root.absyn->reference;
396         if ((oid_ent_to_oid (&oe, oidtmp)))
397             (*p->schemaAdd)(p, oidtmp);
398     }
399 #if 0
400     data1_pr_tree (p->dh, n, stdout);
401 #endif
402     data1_iconv (p->dh, mem, n, "ISO-8859-1", "UTF-8");
403
404     (*p->init)(p, &wrd);
405     if (dumpkeys(n, p, 0, &wrd) < 0)
406     {
407         data1_free_tree(p->dh, n);
408         return RECCTRL_EXTRACT_ERROR;
409     }
410     data1_free_tree(p->dh, n);
411     return RECCTRL_EXTRACT_OK;
412 }
413
414 static int grs_extract(void *clientData, struct recExtractCtrl *p)
415 {
416     int ret;
417     NMEM mem = nmem_create ();
418     struct grs_handlers *h = (struct grs_handlers *) clientData;
419
420     ret = grs_extract_sub(h, p, mem);
421     nmem_destroy(mem);
422     return ret;
423 }
424
425 /*
426  * Return: -1: Nothing done. 0: Ok. >0: Bib-1 diagnostic.
427  */
428 static int process_comp(data1_handle dh, data1_node *n, Z_RecordComposition *c)
429 {
430     data1_esetname *eset;
431     Z_Espec1 *espec = 0;
432     Z_ElementSpec *p;
433
434     switch (c->which)
435     {
436     case Z_RecordComp_simple:
437         if (c->u.simple->which != Z_ElementSetNames_generic)
438             return 26; /* only generic form supported. Fix this later */
439         if (!(eset = data1_getesetbyname(dh, n->u.root.absyn,
440                                          c->u.simple->u.generic)))
441         {
442             logf(LOG_LOG, "Unknown esetname '%s'", c->u.simple->u.generic);
443             return 25; /* invalid esetname */
444         }
445         logf(LOG_DEBUG, "Esetname '%s' in simple compspec",
446              c->u.simple->u.generic);
447         espec = eset->spec;
448         break;
449     case Z_RecordComp_complex:
450         if (c->u.complex->generic)
451         {
452             /* insert check for schema */
453             if ((p = c->u.complex->generic->elementSpec))
454             {
455                 switch (p->which)
456                 {
457                 case Z_ElementSpec_elementSetName:
458                     if (!(eset =
459                           data1_getesetbyname(dh, n->u.root.absyn,
460                                               p->u.elementSetName)))
461                     {
462                         logf(LOG_LOG, "Unknown esetname '%s'",
463                              p->u.elementSetName);
464                         return 25; /* invalid esetname */
465                     }
466                     logf(LOG_DEBUG, "Esetname '%s' in complex compspec",
467                          p->u.elementSetName);
468                     espec = eset->spec;
469                     break;
470                 case Z_ElementSpec_externalSpec:
471                     if (p->u.externalSpec->which == Z_External_espec1)
472                     {
473                         logf(LOG_DEBUG, "Got Espec-1");
474                         espec = p->u.externalSpec-> u.espec1;
475                     }
476                     else
477                     {
478                         logf(LOG_LOG, "Unknown external espec.");
479                         return 25; /* bad. what is proper diagnostic? */
480                     }
481                     break;
482                 }
483             }
484         }
485         else
486             return 26; /* fix */
487     }
488     if (espec)
489     {
490         logf (LOG_DEBUG, "Element: Espec-1 match");
491         return data1_doespec1(dh, n, espec);
492     }
493     else
494     {
495         logf (LOG_DEBUG, "Element: all match");
496         return -1;
497     }
498 }
499
500 static void add_idzebra_info (struct recRetrieveCtrl *p, data1_node *top,
501                               NMEM mem)
502 {
503     const char *idzebra_ns[7];
504
505     idzebra_ns[0] = "xmlns:idzebra";
506     idzebra_ns[1] = "http://www.indexdata.dk/zebra/";
507     idzebra_ns[2] = 0;
508
509     data1_tag_add_attr (p->dh, mem, top, idzebra_ns);
510
511     data1_mk_tag_data_int (p->dh, top, "idzebra:size", p->recordSize,
512                            mem);
513     if (p->score != -1)
514         data1_mk_tag_data_int (p->dh, top, "idzebra:score",
515                                p->score, mem);
516     
517     data1_mk_tag_data_int (p->dh, top, "idzebra:localnumber", p->localno,
518                            mem);
519     if (p->fname)
520         data1_mk_tag_data_text(p->dh, top, "idzebra:filename",
521                                p->fname, mem);
522 }
523
524 static int grs_retrieve(void *clientData, struct recRetrieveCtrl *p)
525 {
526     data1_node *node = 0, *onode = 0, *top;
527     data1_node *dnew;
528     data1_maptab *map;
529     int res, selected = 0;
530     NMEM mem;
531     struct grs_read_info gri;
532     char *tagname;
533     struct grs_handlers *h = (struct grs_handlers *) clientData;
534     int requested_schema = VAL_NONE;
535     data1_marctab *marctab;
536     int dummy;
537     
538     mem = nmem_create();
539     gri.readf = p->readf;
540     gri.seekf = p->seekf;
541     gri.tellf = p->tellf;
542     gri.endf = NULL;
543     gri.fh = p->fh;
544     gri.offset = 0;
545     gri.mem = mem;
546     gri.dh = p->dh;
547
548     logf (LOG_DEBUG, "grs_retrieve");
549     if (read_grs_type (h, &gri, p->subType, &node))
550     {
551         p->diagnostic = 14;
552         nmem_destroy (mem);
553         return 0;
554     }
555     if (!node)
556     {
557         p->diagnostic = 14;
558         nmem_destroy (mem);
559         return 0;
560     }
561 #if 0
562     data1_pr_tree (p->dh, node, stdout);
563 #endif
564     top = data1_get_root_tag (p->dh, node);
565
566     logf (LOG_DEBUG, "grs_retrieve: size");
567     if ((dnew = data1_mk_tag_data_wd(p->dh, top, "size", mem)))
568     {
569         dnew->u.data.what = DATA1I_text;
570         dnew->u.data.data = dnew->lbuf;
571         sprintf(dnew->u.data.data, "%d", p->recordSize);
572         dnew->u.data.len = strlen(dnew->u.data.data);
573     }
574
575     tagname = res_get_def(p->res, "tagrank", "rank");
576     if (strcmp(tagname, "0") && p->score >= 0 &&
577         (dnew = data1_mk_tag_data_wd(p->dh, top, tagname, mem)))
578     {
579         logf (LOG_DEBUG, "grs_retrieve: %s", tagname);
580         dnew->u.data.what = DATA1I_num;
581         dnew->u.data.data = dnew->lbuf;
582         sprintf(dnew->u.data.data, "%d", p->score);
583         dnew->u.data.len = strlen(dnew->u.data.data);
584     }
585
586     tagname = res_get_def(p->res, "tagsysno", "localControlNumber");
587     if (strcmp(tagname, "0") && p->localno > 0 &&
588          (dnew = data1_mk_tag_data_wd(p->dh, top, tagname, mem)))
589     {
590         logf (LOG_DEBUG, "grs_retrieve: %s", tagname);
591         dnew->u.data.what = DATA1I_text;
592         dnew->u.data.data = dnew->lbuf;
593
594         sprintf(dnew->u.data.data, "%d", p->localno);
595         dnew->u.data.len = strlen(dnew->u.data.data);
596     }
597 #if 0
598     data1_pr_tree (p->dh, node, stdout);
599 #endif
600     if (p->comp && p->comp->which == Z_RecordComp_complex &&
601         p->comp->u.complex->generic &&
602         p->comp->u.complex->generic->schema)
603     {
604         oident *oe = oid_getentbyoid (p->comp->u.complex->generic->schema);
605         if (oe)
606             requested_schema = oe->value;
607     }
608
609     /* If schema has been specified, map if possible, then check that
610      * we got the right one 
611      */
612     if (requested_schema != VAL_NONE)
613     {
614         logf (LOG_DEBUG, "grs_retrieve: schema mapping");
615         for (map = node->u.root.absyn->maptabs; map; map = map->next)
616         {
617             if (map->target_absyn_ref == requested_schema)
618             {
619                 onode = node;
620                 if (!(node = data1_map_record(p->dh, onode, map, mem)))
621                 {
622                     p->diagnostic = 14;
623                     nmem_destroy (mem);
624                     return 0;
625                 }
626                 break;
627             }
628         }
629         if (node->u.root.absyn &&
630             requested_schema != node->u.root.absyn->reference)
631         {
632             p->diagnostic = 238;
633             nmem_destroy (mem);
634             return 0;
635         }
636     }
637     /*
638      * Does the requested format match a known syntax-mapping? (this reflects
639      * the overlap of schema and formatting which is inherent in the MARC
640      * family)
641      */
642     yaz_log (LOG_DEBUG, "grs_retrieve: syntax mapping");
643     if (node->u.root.absyn)
644         for (map = node->u.root.absyn->maptabs; map; map = map->next)
645         {
646             if (map->target_absyn_ref == p->input_format)
647             {
648                 onode = node;
649                 if (!(node = data1_map_record(p->dh, onode, map, mem)))
650                 {
651                     p->diagnostic = 14;
652                     nmem_destroy (mem);
653                     return 0;
654                 }
655                 break;
656             }
657         }
658     yaz_log (LOG_DEBUG, "grs_retrieve: schemaIdentifier");
659     if (node->u.root.absyn &&
660         node->u.root.absyn->reference != VAL_NONE &&
661         p->input_format == VAL_GRS1)
662     {
663         oident oe;
664         Odr_oid *oid;
665         int oidtmp[OID_SIZE];
666         
667         oe.proto = PROTO_Z3950;
668         oe.oclass = CLASS_SCHEMA;
669         oe.value = node->u.root.absyn->reference;
670         
671         if ((oid = oid_ent_to_oid (&oe, oidtmp)))
672         {
673             char tmp[128];
674             data1_handle dh = p->dh;
675             char *p = tmp;
676             int *ii;
677             
678             for (ii = oid; *ii >= 0; ii++)
679             {
680                 if (p != tmp)
681                         *(p++) = '.';
682                 sprintf(p, "%d", *ii);
683                 p += strlen(p);
684             }
685             *(p++) = '\0';
686                 
687             if ((dnew = data1_mk_tag_data_wd(dh, node, 
688                                              "schemaIdentifier", mem)))
689             {
690                 dnew->u.data.what = DATA1I_oid;
691                 dnew->u.data.data = (char *) nmem_malloc(mem, p - tmp);
692                 memcpy(dnew->u.data.data, tmp, p - tmp);
693                 dnew->u.data.len = p - tmp;
694             }
695         }
696     }
697
698     logf (LOG_DEBUG, "grs_retrieve: element spec");
699     if (p->comp && (res = process_comp(p->dh, node, p->comp)) > 0)
700     {
701         p->diagnostic = res;
702         if (onode)
703             data1_free_tree(p->dh, onode);
704         data1_free_tree(p->dh, node);
705         nmem_destroy(mem);
706         return 0;
707     }
708     else if (p->comp && !res)
709         selected = 1;
710
711 #if 0
712     data1_pr_tree (p->dh, node, stdout);
713 #endif
714 #if 1
715     data1_iconv (p->dh, mem, node, "ISO-8859-1", "UTF-8");
716 #endif
717     logf (LOG_DEBUG, "grs_retrieve: transfer syntax mapping");
718     switch (p->output_format = (p->input_format != VAL_NONE ?
719                                 p->input_format : VAL_SUTRS))
720     {
721         
722     case VAL_TEXT_XML:
723         add_idzebra_info (p, top, mem);
724
725         if (!(p->rec_buf = data1_nodetoidsgml(p->dh, node, selected,
726                                               &p->rec_len)))
727             p->diagnostic = 238;
728         else
729         {
730             char *new_buf = (char*) odr_malloc (p->odr, p->rec_len);
731             memcpy (new_buf, p->rec_buf, p->rec_len);
732             p->rec_buf = new_buf;
733         }
734         break;
735     case VAL_GRS1:
736         dummy = 0;
737         if (!(p->rec_buf = data1_nodetogr(p->dh, node, selected,
738                                           p->odr, &dummy)))
739             p->diagnostic = 238; /* not available in requested syntax */
740         else
741             p->rec_len = (size_t) (-1);
742         break;
743     case VAL_EXPLAIN:
744         if (!(p->rec_buf = data1_nodetoexplain(p->dh, node, selected,
745                                                p->odr)))
746             p->diagnostic = 238;
747         else
748             p->rec_len = (size_t) (-1);
749         break;
750     case VAL_SUMMARY:
751         if (!(p->rec_buf = data1_nodetosummary(p->dh, node, selected,
752                                                p->odr)))
753             p->diagnostic = 238;
754         else
755             p->rec_len = (size_t) (-1);
756         break;
757     case VAL_SUTRS:
758         if (!(p->rec_buf = data1_nodetobuf(p->dh, node, selected,
759                                            &p->rec_len)))
760             p->diagnostic = 238;
761         else
762         {
763             char *new_buf = (char*) odr_malloc (p->odr, p->rec_len);
764             memcpy (new_buf, p->rec_buf, p->rec_len);
765             p->rec_buf = new_buf;
766         }
767         break;
768     case VAL_SOIF:
769         if (!(p->rec_buf = data1_nodetosoif(p->dh, node, selected,
770                                             &p->rec_len)))
771             p->diagnostic = 238;
772         else
773         {
774             char *new_buf = (char*) odr_malloc (p->odr, p->rec_len);
775             memcpy (new_buf, p->rec_buf, p->rec_len);
776             p->rec_buf = new_buf;
777         }
778         break;
779     default:
780         if (!node->u.root.absyn)
781         {
782             p->diagnostic = 238;
783             break;
784         }
785         for (marctab = node->u.root.absyn->marc; marctab;
786              marctab = marctab->next)
787             if (marctab->reference == p->input_format)
788                 break;
789         if (!marctab)
790         {
791             p->diagnostic = 238;
792             break;
793         }
794         if (!(p->rec_buf = data1_nodetomarc(p->dh, marctab, node,
795                                         selected, &p->rec_len)))
796             p->diagnostic = 238;
797         else
798         {
799             char *new_buf = (char*) odr_malloc (p->odr, p->rec_len);
800             memcpy (new_buf, p->rec_buf, p->rec_len);
801                 p->rec_buf = new_buf;
802         }
803     }
804     if (node)
805         data1_free_tree(p->dh, node);
806     if (onode)
807         data1_free_tree(p->dh, onode);
808     nmem_destroy(mem);
809     return 0;
810 }
811
812 static struct recType grs_type =
813 {
814     "grs",
815     grs_init,
816     grs_destroy,
817     grs_extract,
818     grs_retrieve
819 };
820
821 RecType recTypeGrs = &grs_type;