-/* $Id: filter_sru_to_z3950.cpp,v 1.1 2006-09-13 10:43:24 marc Exp $
+/* $Id: filter_sru_to_z3950.cpp,v 1.2 2006-09-13 14:56:07 marc Exp $
Copyright (c) 2005-2006, Index Data.
See the LICENSE file for details
*/
#include "config.hpp"
-
#include "filter.hpp"
#include "package.hpp"
-
-#include <boost/thread/mutex.hpp>
-
#include "util.hpp"
#include "filter_sru_to_z3950.hpp"
#include <yaz/zgdu.h>
+#include <yaz/srw.h>
+
+#include <boost/thread/mutex.hpp>
+
+#include <iostream>
+#include <sstream>
+#include <string>
+
namespace mp = metaproxy_1;
namespace yf = mp::filter;
+namespace metaproxy_1
+{
+
+ template<typename T>
+ std::string stringify(const T& x)
+ {
+ std::ostringstream o;
+ o << x;
+ return o.str();
+ }
+}
+
+
namespace metaproxy_1 {
namespace filter {
class SRUtoZ3950::Rep {
friend class SRUtoZ3950;
+ void process(metaproxy_1::Package & package) const;
//int dummy;
};
}
void yf::SRUtoZ3950::process(mp::Package &package) const
{
+ //std::cout << m_p->protocol_type(package) << "\n";
+ //m_p->debug_http_headers(package);
+ m_p->process(package);
+}
+
+void yf::SRUtoZ3950::Rep::process(mp::Package &package) const
+{
Z_GDU *zgdu_req = package.request().get();
// ignoring all non HTTP_Request packages
Z_HTTP_Request* http_req = zgdu_req->u.HTTP_Request;
// TODO: SRU package checking and translation to Z3950 package
+
+
+
+// int ret_code = 2; /* 2=NOT TAKEN, 1=TAKEN, 0=SOAP TAKEN */
+// Z_SRW_PDU *sru_res = 0;
+// Z_SOAP *soap_package = 0;
+// char *charset = 0;
+// Z_SRW_diagnostic *diagnostic = 0;
+// int num_diagnostic = 0;
+// mp::odr odr;
+
+// if (!(ret_code = yaz_sru_decode(http_req, &sru_res,
+// &soap_package, odr, &charset,
+// &diagnostic, &num_diagnostic)))
+// {
+// protocol = "SRU GET/POST";
+// }
+// else if (!(ret_code = yaz_srw_decode(http_req, &sru_res,
+// &soap_package, odr, &charset)))
+// {
+// protocol = "SRU SOAP";
+// }
+// else
+// {
+// protocol = "HTTP";
+// }
+
+ std::string protocol("HTTP");
+
+ const std::string mime_text_xml("text/xml");
+ const std::string mime_soap_xml("application/soap+xml");
+ const std::string mime_urlencoded("application/x-www-form-urlencoded");
+
+ const std::string http_method(http_req->method);
+ const std::string http_type(z_HTTP_header_lookup(http_req->headers,
+ "Content-Type"));
+
+
+ if (http_method == "GET")
+ protocol = "SRU GET";
+ else if ( http_method == "POST"
+ && http_type == mime_urlencoded)
+ protocol = "SRU POST";
+ else if ( http_method == "POST"
+ && (http_type == mime_text_xml
+ || http_type == mime_soap_xml))
+ protocol = "SRU SOAP";
+
+ std::cout << "SRUtoZ3950 " << protocol << "\n";
+
+ package.move();
+ return;
+
+
+
+ std::string message("<html>\n<body>\n<h1>"
+ "Metaproxy SRUtoZ3950 filter"
+ "</h1>\n");
+
+ message += "<h3>HTTP Info</h3><br/>\n";
+ message += "<p>\n";
+ message += "<b>Method: </b> " + std::string(http_req->method) + "<br/>\n";
+ message += "<b>Version:</b> " + std::string(http_req->version) + "<br/>\n";
+ message += "<b>Path: </b> " + std::string(http_req->path) + "<br/>\n";
+ message += "<b>Content-Type:</b>"
+ + std::string(z_HTTP_header_lookup(http_req->headers, "Content-Type"))
+ + "<br/>\n";
+ message += "<b>Content-Length:</b>"
+ + std::string(z_HTTP_header_lookup(http_req->headers,
+ "Content-Length"))
+ + "<br/>\n";
+ message += "</p>\n";
+
+ message += "<h3>Headers</h3><br/>\n";
+ message += "<p>\n";
+ Z_HTTP_Header* header = http_req->headers;
+ while (header){
+ message += "<b>Header: </b> <i>"
+ + std::string(header->name) + ":</i> "
+ + std::string(header->value) + "<br/>\n";
+ header = header->next;
+ }
+ message += "</p>\n";
+ message += "</body>\n</html>\n";
+
+ //std::cout << message << "\n";
+
+
// sending Z3950 package through pipeline
package.move();
Z_GDU *zgdu_res = 0;
- metaproxy_1::odr odr;
+ mp::odr odr;
zgdu_res
= odr.create_HTTP_Response(package.session(),
zgdu_req->u.HTTP_Request, 200);
- //zgdu_res->u.HTTP_Response->content_len = message.str().size();
- //zgdu_res->u.HTTP_Response->content_buf
- // = (char*) odr_malloc(odr, zgdu_res->u.HTTP_Response->content_len);
+
+// zgdu_res->u.HTTP_Response->content_len = message.size();
+// zgdu_res->u.HTTP_Response->content_buf
+// = (char*) odr_malloc(odr, zgdu_res->u.HTTP_Response->content_len);
- //strncpy(zgdu_res->u.HTTP_Response->content_buf,
- // message.str().c_str(), zgdu_res->u.HTTP_Response->content_len);
+// strncpy(zgdu_res->u.HTTP_Response->content_buf,
+// message.c_str(), zgdu_res->u.HTTP_Response->content_len);
// z_HTTP_header_add(o, &hres->headers,
// "Content-Type", content_type.c_str());
+
package.response() = zgdu_res;
}
+
static mp::filter::Base* filter_creator()
{
return new mp::filter::SRUtoZ3950;
projects / metaproxy-moved-to-github.git / commitdiff