X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Futil.hpp;h=7727391487adbf772d7011c9e0e244593ff290f0;hb=2f00992d42d660fe3b9cebe30f383d7d5fd08c3b;hp=9918d45b642f07abea82b2a4893e1f4215788466;hpb=93d4dd6d4f9698c7aaa74cadb343a2da8ef8ff5a;p=metaproxy-moved-to-github.git diff --git a/src/util.hpp b/src/util.hpp index 9918d45..7727391 100644 --- a/src/util.hpp +++ b/src/util.hpp @@ -1,20 +1,97 @@ -/* $Id: util.hpp,v 1.3 2005-10-30 18:51:21 adam Exp $ - Copyright (c) 2005, Index Data. +/* $Id: util.hpp,v 1.22 2006-10-04 14:04:00 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 +#include + + +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); -namespace yp2 { - struct util { - static bool pqf(ODR odr, Z_APDU *apdu, const std::string &q); + 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::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 { @@ -23,12 +100,33 @@ namespace yp2 { odr(); ~odr(); operator ODR() const; - Z_APDU *create_close(int reason, const char *addinfo); - Z_APDU *create_initResponse(int error, const char *addinfo); + 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 /*