-/*
- * Copyright 2001-2007 Internet2
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+/**
+ * Licensed to the University Corporation for Advanced Internet
+ * Development, Inc. (UCAID) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for
+ * additional information regarding copyright ownership.
*
- * http://www.apache.org/licenses/LICENSE-2.0
+ * UCAID licenses this file to you under the Apache License,
+ * Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the
+ * License at
*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+ * either express or implied. See the License for the specific
+ * language governing permissions and limitations under the License.
*/
/**
#include "internal.h"
#include "exceptions.h"
#include "logging.h"
+#include "soap/HTTPSOAPTransport.h"
+#include "soap/OpenSSLSOAPTransport.h"
#include "soap/SOAP.h"
#include "soap/SOAPClient.h"
#include "util/XMLHelper.h"
using namespace soap11;
using namespace xmltooling::logging;
using namespace xmltooling;
+using namespace xercesc;
using namespace std;
+#if !defined(XMLTOOLING_NO_XMLSEC) && !defined(XMLTOOLING_LITE)
+namespace xmltooling {
+ PluginManager<SOAPTransport,string,SOAPTransport::Address>::Factory CURLSOAPTransportFactory;
+};
+#endif
+
+void xmltooling::registerSOAPTransports()
+{
+#if !defined(XMLTOOLING_NO_XMLSEC) && !defined(XMLTOOLING_LITE)
+ XMLToolingConfig& conf=XMLToolingConfig::getConfig();
+ conf.SOAPTransportManager.registerFactory("http", CURLSOAPTransportFactory);
+ conf.SOAPTransportManager.registerFactory("https", CURLSOAPTransportFactory);
+#endif
+}
+
+
+#ifdef XMLTOOLING_NO_XMLSEC
+void xmltooling::initSOAPTransports()
+{
+}
+
+void xmltooling::termSOAPTransports()
+{
+}
+#endif
+
+SOAPTransport::SOAPTransport()
+{
+}
+
+SOAPTransport::~SOAPTransport()
+{
+}
+
+bool SOAPTransport::setProviderOption(const char* provider, const char* option, const char* value)
+{
+ return false;
+}
+
+bool SOAPTransport::setCacheTag(string* cacheTag)
+{
+ return false;
+}
+
+void SOAPTransport::send(istream* in)
+{
+ if (!in)
+ throw IOException("SOAP transport does not support an empty request body.");
+ return send(*in);
+}
+
+long SOAPTransport::getStatusCode() const
+{
+ return 0;
+}
+
+HTTPSOAPTransport::HTTPSOAPTransport()
+{
+}
+
+HTTPSOAPTransport::~HTTPSOAPTransport()
+{
+}
+
+bool HTTPSOAPTransport::followRedirects(bool follow, unsigned int maxRedirs)
+{
+ return false;
+}
+
+#ifndef XMLTOOLING_NO_XMLSEC
+OpenSSLSOAPTransport::OpenSSLSOAPTransport()
+{
+}
+
+OpenSSLSOAPTransport::~OpenSSLSOAPTransport()
+{
+}
+#endif
+
+SOAPClient::SOAPClient(bool validate) : m_validate(validate), m_transport(nullptr)
+{
+}
+
SOAPClient::~SOAPClient()
{
delete m_transport;
}
+void SOAPClient::setValidating(bool validate)
+{
+ m_validate = validate;
+}
+
void SOAPClient::reset()
{
delete m_transport;
- m_transport=NULL;
+ m_transport=nullptr;
}
void SOAPClient::send(const Envelope& env, const SOAPTransport::Address& addr)
{
// Prepare a transport object.
- const char* pch = strchr(addr.m_endpoint,':');
+ const char* pch = addr.m_endpoint ? strchr(addr.m_endpoint,':') : nullptr;
if (!pch)
throw IOException("SOAP endpoint was not a URL.");
string scheme(addr.m_endpoint, pch-addr.m_endpoint);
m_transport = XMLToolingConfig::getConfig().SOAPTransportManager.newPlugin(scheme.c_str(), addr);
prepareTransport(*m_transport);
- Category& log = Category::getInstance(XMLTOOLING_LOGCAT".SOAPClient");
+ Category& log = Category::getInstance(XMLTOOLING_LOGCAT ".SOAPClient");
if (log.isDebugEnabled())
- log.debugStream() << "marshalled envelope: " << env << logging::eol;
+ log.debugStream() << "marshalled envelope:\n" << env << logging::eol;
// Serialize envelope.
stringstream s;
// If we can get the stream, then the call is still active.
istream& out = m_transport->receive();
if (!out)
- return NULL; // nothing yet
+ return nullptr; // nothing yet
// Check content type.
string s = m_transport->getContentType();
: XMLToolingConfig::getConfig().getParser()).parse(out);
XercesJanitor<DOMDocument> janitor(doc);
- Category& log = Category::getInstance(XMLTOOLING_LOGCAT".SOAPClient");
- if (log.isDebugEnabled())
- log.debugStream() << "received XML: " << *(doc->getDocumentElement()) << logging::eol;
+ Category& log = Category::getInstance(XMLTOOLING_LOGCAT ".SOAPClient");
+ if (log.isDebugEnabled()) {
+ string buf;
+ XMLHelper::serialize(doc->getDocumentElement(), buf);
+ log.debugStream() << "received XML:\n" << buf << logging::eol;
+ }
auto_ptr<XMLObject> xmlObject(XMLObjectBuilder::buildOneFromElement(doc->getDocumentElement(), true));
janitor.release();
- if (!m_validate)
- SchemaValidators.validate(xmlObject.get());
+
+ SchemaValidators.validate(xmlObject.get());
Envelope* env = dynamic_cast<Envelope*>(xmlObject.get());
if (!env)
return env;
}
+void SOAPClient::prepareTransport(SOAPTransport& transport)
+{
+}
+
bool SOAPClient::handleFault(const Fault& fault)
{
- const QName* code = (fault.getFaultcode() ? fault.getFaultcode()->getCode() : NULL);
- auto_ptr_char str((fault.getFaultstring() ? fault.getFaultstring()->getString() : NULL));
- Category::getInstance(XMLTOOLING_LOGCAT".SOAPClient").error(
+ const xmltooling::QName* code = (fault.getFaultcode() ? fault.getFaultcode()->getCode() : nullptr);
+ auto_ptr_char str((fault.getFaultstring() ? fault.getFaultstring()->getString() : nullptr));
+ Category::getInstance(XMLTOOLING_LOGCAT ".SOAPClient").error(
"SOAP client detected a Fault: (%s) (%s)",
(code ? code->toString().c_str() : "no code"),
(str.get() ? str.get() : "no message")