filter_record_transform.cpp File Reference

#include "config.hpp"
#include "filter_record_transform.hpp"
#include <metaproxy/package.hpp>
#include <metaproxy/util.hpp>
#include "gduutil.hpp"
#include <yaz/diagbib1.h>
#include <yaz/zgdu.h>
#include <yaz/retrieval.h>
#include <yaz/oid_db.h>
#include <boost/thread/mutex.hpp>
#include <iostream>

Include dependency graph for filter_record_transform.cpp:

Go to the source code of this file.

Classes
class	metaproxy_1::filter::RecordTransform::Impl

Namespaces
	metaproxy_1
	metaproxy_1::filter

Functions
static void	convert_npr (yaz_record_conv_t rc, Odr_oid *match_syntax, ODR odr_en, Z_NamePlusRecordList *records, int i)
static mp::filter::Base *	filter_creator ()

Variables
struct metaproxy_1_filter_struct	metaproxy_1_filter_record_transform

Function Documentation

convert_npr()

static void convert_npr ( yaz_record_conv_t  rc, Odr_oid *  match_syntax, ODR  odr_en, Z_NamePlusRecordList *  records, int  i  )

static

Definition at line 244 of file filter_record_transform.cpp.

{
    Z_NamePlusRecord *npr = records->records[i];
    const char *details = 0;
    mp::wrbuf output_record;
    Z_External *r = npr->u.databaseRecord;
    int ret_trans = -1;
    if (npr->which != Z_NamePlusRecord_databaseRecord)
        return;
    r = npr->u.databaseRecord;
    if (r->which == Z_External_OPAC)
    {
        ret_trans = yaz_record_conv_opac_record(rc, r->u.opac,
                                                output_record);
        details = yaz_record_conv_get_error(rc);
    }
    else if (r->which == Z_External_octet)
    {
        ret_trans =
            yaz_record_conv_record(
                rc, (const char *) r->u.octet_aligned->buf,
                r->u.octet_aligned->len, output_record);
        details = yaz_record_conv_get_error(rc);
    }
    else
    {
        details = "unsupported record type for record_conv";
    }
    if (ret_trans)
    {
        records->records[i] =
            zget_surrogateDiagRec(
                odr_en, npr->databaseName,
                YAZ_BIB1_SYSTEM_ERROR_IN_PRESENTING_RECORDS,
                details);
    }
    else
    {
        if (!oid_oidcmp(match_syntax, yaz_oid_recsyn_opac))
        {
            yaz_iconv_t cd = 0;
            yaz_marc_t mt = yaz_marc_create();
            Z_OPACRecord *opac = 0;
            const char *output_charset =
                yaz_record_get_output_charset(rc);
            if (output_charset)
                cd = yaz_iconv_open(output_charset, "utf-8");
            if (yaz_xml_to_opac(mt, output_record.buf(),
                                output_record.len(),
                                &opac, cd,
                                ((ODR )odr_en)->mem, 0)
                && opac)
            {
                npr->u.databaseRecord =
                    z_ext_record_oid(odr_en, match_syntax,
                                     (const char *) opac, -1);
            }
            else
            {
                records->records[i] =
                    zget_surrogateDiagRec(
                        odr_en, npr->databaseName,
                        YAZ_BIB1_SYSTEM_ERROR_IN_PRESENTING_RECORDS,
                        "XML to OPAC conversion failed");
            }
            yaz_marc_destroy(mt);
        }
        else
        {
            npr->u.databaseRecord = z_ext_record_oid(odr_en, match_syntax,
                                                     output_record.buf(),
                                                     output_record.len());
        }
    }
}

Referenced by metaproxy_1::filter::RecordTransform::Impl::process().

filter_creator()

static mp::filter::Base* filter_creator ( )

static

Definition at line 546 of file filter_record_transform.cpp.

{
    return new mp::filter::RecordTransform;
}

Variable Documentation

metaproxy_1_filter_record_transform

struct metaproxy_1_filter_struct metaproxy_1_filter_record_transform

Initial value:

= {
        0,
        "record_transform",
        filter_creator
    }

Definition at line 546 of file filter_record_transform.cpp.

Referenced by metaproxy_1::FactoryStatic::FactoryStatic().