diff options
Diffstat (limited to 'kresources/blogging/xmlrpcjob.cpp')
| -rw-r--r-- | kresources/blogging/xmlrpcjob.cpp | 430 |
1 files changed, 0 insertions, 430 deletions
diff --git a/kresources/blogging/xmlrpcjob.cpp b/kresources/blogging/xmlrpcjob.cpp deleted file mode 100644 index f2e516308..000000000 --- a/kresources/blogging/xmlrpcjob.cpp +++ /dev/null @@ -1,430 +0,0 @@ -/* 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 <klocale.h> -#include <kio/http.h> -#include <kmdcodec.h> -#include <kio/davjob.h> - - -#define KIO_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> ¶ms, 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"; - TQMap<TQString, TQVariant> map = arg.toMap(); - TQMap<TQString, TQVariant>::ConstIterator it = map.begin(); - TQMap<TQString, TQVariant>::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" ) { - - TQMap<TQString, TQVariant> 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> ¶ms, 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" |