You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tdepim/tderesources/blogging/xmlrpcjob.cpp

431 lines
14 KiB

/* This file is part of the KDE libraries
Copyright (C) 2004 Reinhold Kainhofer <reinhold@kainhofer.com>
Based on the davjob:
Copyright (C) 2002 Jan-Pascal van Best <janpascal@vanbest.org>
XML-RPC specific parts taken from the xmlrpciface:
Copyright (C) 2003 - 2004 by Frerich Raabe <raabe@kde.org>
Tobias Koenig <tokoe@kde.org>
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Library General Public License for more details.
You should have received a copy of the GNU Library General Public License
along with this library; see the file COPYING.LIB. If not, write to
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
Boston, MA 02110-1301, USA.
*/
#include "xmlrpcjob.h"
#include <tqvariant.h>
#include <tqregexp.h>
#include <kdebug.h>
#include <tdelocale.h>
#include <tdeio/http.h>
#include <kmdcodec.h>
#include <tdeio/davjob.h>
#define TDEIO_ARGS TQByteArray packedArgs; \
TQDataStream stream( packedArgs, IO_WriteOnly ); stream
using namespace TDEIO;
namespace TDEIO {
class XMLRPCResult
{
friend class XmlrpcJob;
public:
XMLRPCResult() {}
bool success() const { return m_success; }
int errorCode() const { return m_errorCode; }
TQString errorString() const { return m_errorString; }
TQValueList<TQVariant> data() const { return m_data; }
private:
bool m_success;
int m_errorCode;
TQString m_errorString;
TQValueList<TQVariant> m_data;
};
}
class XmlrpcJob::XmlrpcJobPrivate
{
public:
// TQByteArray savedStaticData;
};
XmlrpcJob::XmlrpcJob( const KURL& url, const TQString& method,
const TQValueList<TQVariant> &params, bool showProgressInfo)
: TransferJob( url, TDEIO::CMD_SPECIAL, TQByteArray(), TQByteArray(),
showProgressInfo )
{
d = new XmlrpcJobPrivate;
// We couldn't set the args when calling the parent constructor,
// so do it now.
TQDataStream stream( m_packedArgs, IO_WriteOnly );
stream << (int)1 << url;
kdDebug()<<"XMLrpcJob::url="<<url.url()<<endl;
kdDebug()<<"XmlrpcJob::XmlrpcJob, method="<<method<<endl;
// Same for static data
if ( ! method.isEmpty() ) {
kdDebug()<<"XmlrpcJob::XmlrpcJob, method not empty."<<endl;
TQString call = markupCall( method, params );
staticData = call.utf8();
staticData.truncate( staticData.size() - 1 );
kdDebug() << "Message: " << call << endl;
// d->savedStaticData = staticData.copy();
}
addMetaData( "UserAgent", "KDE XML-RPC TransferJob" );
addMetaData( "content-type", "Content-Type: text/xml; charset=utf-8" );
addMetaData( "ConnectTimeout", "50" );
}
XmlrpcJob::~XmlrpcJob()
{
delete d;
d = 0;
}
TQString XmlrpcJob::markupCall( const TQString &cmd,
const TQValueList<TQVariant> &args )
{
kdDebug()<<"XmlrpcJob::markupCall, cmd="<<cmd<<endl;
TQString markup = "<?xml version=\"1.0\" ?>\r\n<methodCall>\r\n";
markup += "<methodName>" + cmd + "</methodName>\r\n";
if ( !args.isEmpty() )
{
markup += "<params>\r\n";
TQValueList<TQVariant>::ConstIterator it = args.begin();
TQValueList<TQVariant>::ConstIterator end = args.end();
for ( ; it != end; ++it )
markup += "<param>\r\n" + marshal( *it ) + "</param>\r\n";
markup += "</params>\r\n";
}
markup += "</methodCall>\r\n";
return markup;
}
void XmlrpcJob::slotData( const TQByteArray& data )
{
kdDebug()<<"XmlrpcJob::slotData()"<<endl;
if ( m_redirectionURL.isEmpty() || !m_redirectionURL.isValid() || m_error )
m_str_response.append( TQString( data ) );
}
void XmlrpcJob::slotFinished()
{
kdDebug() << "XmlrpcJob::slotFinished()" << endl;
kdDebug() << m_str_response << endl;
// TODO: Redirection with XML-RPC??
/* if (! m_redirectionURL.isEmpty() && m_redirectionURL.isValid() ) {
TQDataStream istream( m_packedArgs, IO_ReadOnly );
int s_cmd, s_method;
KURL s_url;
istream >> s_cmd;
istream >> s_url;
istream >> s_method;
// PROPFIND
if ( (s_cmd == 7) && (s_method == (int)TDEIO::HTTP_POST) ) {
m_packedArgs.truncate(0);
TQDataStream stream( m_packedArgs, IO_WriteOnly );
stream << (int)7 << m_redirectionURL << (int)TDEIO::HTTP_POST;
}
} else */
kdDebug() << "\033[35;40mResult: " << m_str_response << "\033[0;0m" << endl;
TQDomDocument doc;
TQString errMsg;
int errLine, errCol;
if ( doc.setContent( m_str_response, false, &errMsg, &errLine, &errCol ) ) {
if ( isMessageResponse( doc ) ) {
m_response = parseMessageResponse( doc ).data();
m_responseType = XMLRPCMessageResponse;
} else if ( isFaultResponse( doc ) ) {
// TODO: Set the error of the job
m_response.clear();
m_response << TQVariant( parseFaultResponse( doc ).errorString() );
m_responseType = XMLRPCFaultResponse;
} else {
// TODO: Set the error of the job
m_response.clear();
m_response << TQVariant( i18n( "Unknown type of XML markup received. "
"Markup: \n %1" ).arg( m_str_response ) );
m_responseType = XMLRPCUnknownResponse;
}
} else {
// TODO: if we can't parse the XML response, set the correct error message!
// emit fault( -1, i18n( "Received invalid XML markup: %1 at %2:%3" )
// .arg( errMsg ).arg( errLine ).arg( errCol ), m_id );
}
TransferJob::slotFinished();
// TODO: Redirect: if( d ) staticData = d->savedStaticData.copy();
// Need to send XMLRPC request to this host too
}
bool XmlrpcJob::isMessageResponse( const TQDomDocument &doc )
{
return doc.documentElement().firstChild().toElement()
.tagName().lower() == "params";
}
XMLRPCResult XmlrpcJob::parseMessageResponse( const TQDomDocument &doc )
{
XMLRPCResult response;
response.m_success = true;
TQDomNode paramNode = doc.documentElement().firstChild().firstChild();
while ( !paramNode.isNull() ) {
response.m_data << demarshal( paramNode.firstChild().toElement() );
paramNode = paramNode.nextSibling();
}
return response;
}
bool XmlrpcJob::isFaultResponse( const TQDomDocument &doc )
{
return doc.documentElement().firstChild().toElement()
.tagName().lower() == "fault";
}
XMLRPCResult XmlrpcJob::parseFaultResponse( const TQDomDocument &doc )
{
XMLRPCResult response;
response.m_success = false;
TQDomNode errorNode = doc.documentElement().firstChild().firstChild();
const TQVariant errorVariant = demarshal( errorNode.toElement() );
response.m_errorCode = errorVariant.toMap() [ "faultCode" ].toInt();
response.m_errorString = errorVariant.toMap() [ "faultString" ].toString();
return response;
}
TQString XmlrpcJob::marshal( const TQVariant &arg )
{
switch ( arg.type() )
{
case TQVariant::String:
case TQVariant::CString:
return "<value><string>" + arg.toString() + "</string></value>\r\n";
case TQVariant::Int:
return "<value><int>" + TQString::number( arg.toInt() ) +
"</int></value>\r\n";
case TQVariant::Double:
return "<value><double>" + TQString::number( arg.toDouble() ) +
"</double></value>\r\n";
case TQVariant::Bool:
{
TQString markup = "<value><boolean>";
markup += arg.toBool() ? "1" : "0";
markup += "</boolean></value>\r\n";
return markup;
}
case TQVariant::ByteArray:
return "<value><base64>" + KCodecs::base64Encode( arg.toByteArray() ) +
"</base64></value>\r\n";
case TQVariant::DateTime:
return "<value><datetime.iso8601>" +
arg.toDateTime().toString( TQt::ISODate ) +
"</datetime.iso8601></value>\r\n";
case TQVariant::List:
{
TQString markup = "<value><array><data>\r\n";
const TQValueList<TQVariant> args = arg.toList();
TQValueList<TQVariant>::ConstIterator it = args.begin();
TQValueList<TQVariant>::ConstIterator end = args.end();
for ( ; it != end; ++it )
markup += marshal( *it );
markup += "</data></array></value>\r\n";
return markup;
}
case TQVariant::Map:
{
TQString markup = "<value><struct>\r\n";
TQStringVariantMap map = arg.toMap();
TQStringVariantMap::ConstIterator it = map.begin();
TQStringVariantMap::ConstIterator end = map.end();
for ( ; it != end; ++it )
{
markup += "<member>\r\n";
markup += "<name>" + it.key() + "</name>\r\n";
markup += marshal( it.data() );
markup += "</member>\r\n";
}
markup += "</struct></value>\r\n";
return markup;
}
default:
kdWarning() << "Failed to marshal unknown variant type: "
<< arg.type() << endl;
};
return TQString();
}
TQVariant XmlrpcJob::demarshal( const TQDomElement &elem )
{
Q_ASSERT( elem.tagName().lower() == "value" );
if ( !elem.hasChildNodes() ) {
// it doesn't have child nodes, so no explicit type name was given,
// i.e. <value>here comes the value</value> instead of
// <value><string>here comes the value</string></value>
// Assume <string> in that case:
// Actually, the element will still have a child node, so this will not help here.
// The dirty hack is at the end of this method.
kdDebug()<<"XmlrpcJob::demarshal: No child nodes, assume type=string. Text: "<<elem.text()<<endl;
return TQVariant( elem.text() );
}
kdDebug()<<"Demarshalling element \"" << elem.text() <<"\"" << endl;
const TQDomElement typeElement = elem.firstChild().toElement();
const TQString typeName = typeElement.tagName().lower();
if ( typeName == "string" )
return TQVariant( typeElement.text() );
else if ( typeName == "i4" || typeName == "int" )
return TQVariant( typeElement.text().toInt() );
else if ( typeName == "double" )
return TQVariant( typeElement.text().toDouble() );
else if ( typeName == "boolean" )
{
if ( typeElement.text().lower() == "true" || typeElement.text() == "1" )
return TQVariant( true );
else
return TQVariant( false );
}
else if ( typeName == "base64" )
return TQVariant( KCodecs::base64Decode( typeElement.text().latin1() ) );
else if ( typeName == "datetime" || typeName == "datetime.iso8601" ) {
TQString text( typeElement.text() );
if ( text.find( TQRegExp("^[0-9]{8,8}T") ) >= 0 ) {
// It's in the format 20041120T...., so adjust it to correct
// ISO 8601 Format 2004-11-20T..., else TQDateTime::fromString won't work:
text = text.insert( 6, '-' );
text = text.insert( 4, '-' );
}
return TQVariant( TQDateTime::fromString( text, TQt::ISODate ) );
} else if ( typeName == "array" ) {
TQValueList<TQVariant> values;
TQDomNode valueNode = typeElement.firstChild().firstChild();
while ( !valueNode.isNull() ) {
values << demarshal( valueNode.toElement() );
valueNode = valueNode.nextSibling();
}
return TQVariant( values );
} else if ( typeName == "struct" ) {
TQStringVariantMap map;
TQDomNode memberNode = typeElement.firstChild();
while ( !memberNode.isNull() ) {
const TQString key = memberNode.toElement().elementsByTagName( "name" ).item( 0 ).toElement().text();
const TQVariant data = demarshal( memberNode.toElement().elementsByTagName( "value" ).item( 0 ).toElement() );
map[ key ] = data;
memberNode = memberNode.nextSibling();
}
return TQVariant( map );
} else {
kdWarning() << "Cannot demarshal unknown type " << typeName << ", text= " << typeElement.text() << endl;
// FIXME: This is just a workaround, for the issue mentioned at the beginning of this method.
return TQVariant( elem.text() );
}
return TQVariant();
}
/* Convenience methods */
XmlrpcJob* TDEIO::xmlrpcCall( const KURL& url, const TQString &method, const TQValueList<TQVariant> &params, bool showProgressInfo )
{
if ( url.isEmpty() ) {
kdWarning() << "Cannot execute call to " << method << ": empty server URL" << endl;
return 0;
}
XmlrpcJob *job = new XmlrpcJob( url, method, params, showProgressInfo );
// job->addMetaData( "xmlrpcDepth", depth );
return job;
}
XmlrpcJob* TDEIO::xmlrpcCall( const KURL& url, const TQString &method,
const TQVariant &arg, bool showProgressInfo )
{
TQValueList<TQVariant> args;
args << arg;
return TDEIO::xmlrpcCall( url, method, args, showProgressInfo );
}
XmlrpcJob* TDEIO::xmlrpcCall( const KURL& url, const TQString &method,
const TQStringList &arg, bool showProgressInfo )
{
TQValueList<TQVariant> args;
TQStringList::ConstIterator it = arg.begin();
TQStringList::ConstIterator end = arg.end();
for ( ; it != end; ++it )
args << TQVariant( *it );
return TDEIO::xmlrpcCall( url, method, args, showProgressInfo );
}
template <typename T>
XmlrpcJob* TDEIO::xmlrpcCall( const KURL& url, const TQString &method,
const TQValueList<T>&arg, bool showProgressInfo )
{
TQValueList<TQVariant> args;
typename TQValueList<T>::ConstIterator it = arg.begin();
typename TQValueList<T>::ConstIterator end = arg.end();
for ( ; it != end; ++it )
args << TQVariant( *it );
return TDEIO::xmlrpcCall( url, method, args, showProgressInfo );
}
#include "xmlrpcjob.moc"