X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Futil.hpp;h=efba787b4fae5e6d180f341071aab80825796c3e;hb=451ffea184560b0d10f369dfc3fccb0fa86b91a2;hp=fa6f96b334fc3e4673a67be945417108ed8363da;hpb=b54482cdb759f092fcd07a9be4fdc8c28009b895;p=metaproxy-moved-to-github.git diff --git a/src/util.hpp b/src/util.hpp index fa6f96b..efba787 100644 --- a/src/util.hpp +++ b/src/util.hpp @@ -1,17 +1,136 @@ -/* $Id: util.hpp,v 1.1 2005-10-26 18:53:49 adam Exp $ - Copyright (c) 2005, Index Data. +/* $Id: util.hpp,v 1.23 2007-01-02 15:35:36 marc Exp $ + Copyright (c) 2005-2006, Index Data. -%LICENSE% + See the LICENSE file for details */ #ifndef YP2_UTIL_HPP #define YP2_UTIL_HPP +#include "package.hpp" + #include + +#include +#include + +#include +#include +#include #include -namespace yp2 { - struct util { - static bool pqf(ODR odr, Z_APDU *apdu, const std::string &q); + + +namespace metaproxy_1 { + namespace util { + + + template + std::string to_string(const T& t) + { + std::ostringstream o; + if(o << t) + return o.str(); + return std::string(); + }; + + const char * + record_composition_to_esn(Z_RecordComposition *comp); + + std::string http_header_value(const Z_HTTP_Header* header, + const std::string name); + + std::string http_headers_debug(const Z_HTTP_Request &http_req); + + void http_response(metaproxy_1::Package &package, + const std::string &content, + int http_code = 200); + + + int memcmp2(const void *buf1, int len1, const void *buf2, int len2); + + std::string database_name_normalize(const std::string &s); + + bool pqf(ODR odr, Z_APDU *apdu, const std::string &q); + + std::string zQueryToString(Z_Query *query); + + Z_ReferenceId **get_referenceId(const Z_APDU *apdu); + + void transfer_referenceId(ODR odr, const Z_APDU *src, Z_APDU *dst); + + Z_APDU *create_APDU(ODR odr, int type, const Z_APDU *in_apdu); + + bool set_databases_from_zurl(ODR odr, std::string zurl, + int *db_num, char ***db_strings); + + void split_zurl(std::string zurl, std::string &host, + std::list &db); + + void get_vhost_otherinfo(Z_OtherInformation *otherInformation, + std::list &vhosts); + + int remove_vhost_otherinfo(Z_OtherInformation **otherInformation, + std::list &vhosts); + + void set_vhost_otherinfo(Z_OtherInformation **otherInformation, + ODR odr, + const std::string vhost, + const int cat = 1 ); + + void set_vhost_otherinfo(Z_OtherInformation **otherInformation, + ODR odr, + const std::list &vhosts); + + int get_or_remove_vhost_otherinfo( + Z_OtherInformation **otherInformation, + bool remove_flag, + std::list &vhosts); + + void get_init_diagnostics(Z_InitResponse *res, + int &error_code, std::string &addinfo); + + void get_default_diag(Z_DefaultDiagFormat *r, + int &error_code, std::string &addinfo); + + void piggyback(int smallSetUpperBound, + int largeSetLowerBound, + int mediumSetPresentNumber, + int result_set_size, + int &number_to_present); + }; + + class odr : public boost::noncopyable { + public: + odr(int type); + odr(); + ~odr(); + operator ODR() const; + Z_APDU *create_close(const Z_APDU *in_apdu, + int reason, const char *addinfo); + Z_APDU *create_initResponse(const Z_APDU *in_apdu, + int error, const char *addinfo); + Z_APDU *create_searchResponse(const Z_APDU *in_apdu, + int error, const char *addinfo); + Z_APDU *create_presentResponse(const Z_APDU *in_apdu, + int error, const char *addinfo); + Z_APDU *create_scanResponse(const Z_APDU *in_apdu, + int error, const char *addinfo); + Z_APDU *create_APDU(int type, const Z_APDU *in_apdu); + + Z_GDU *create_HTTP_Response(metaproxy_1::Session &session, + Z_HTTP_Request *req, int code); + private: + ODR m_odr; + }; + + class PlainFile { + class Rep; + boost::scoped_ptr m_p; + public: + PlainFile(); + ~PlainFile(); + bool open(const std::string &fname); + bool getline(std::vector &args); }; } #endif