1 files changed, 153 insertions, 0 deletions
diff --git a/kode/kwsdl/kung/dispatcher.cpp b/kode/kwsdl/kung/dispatcher.cpp
new file mode 100644
index 000000000..79f6bd949
--- /dev/null
+++ b/kode/kwsdl/kung/dispatcher.cpp
@@ -0,0 +1,153 @@
+/*
+    This file is part of Kung.
+
+    Copyright (c) 2005 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 <qapplication.h>
+#include <qtimer.h>
+#include <qwidget.h>
+
+#include <kinputdialog.h>
+#include <klocale.h>
+#include <kmessagebox.h>
+
+#include "generalconversationmanager.h"
+#include "inputdialog.h"
+#include "inputfieldfactory.h"
+#include "outputdialog.h"
+#include "pageinputfield.h"
+#include "transport.h"
+
+#include "dispatcher.h"
+
+Dispatcher::Dispatcher()
+  : QObject( 0, "Dispatcher" ),
+    mConversationManager( 0 )
+{
+}
+
+Dispatcher::~Dispatcher()
+{
+  delete mConversationManager;
+  mConversationManager = 0;
+}
+
+void Dispatcher::setWSDL( const KWSDL::WSDL &wsdl )
+{
+  mWSDL = wsdl;
+
+  InputFieldFactory::self()->setTypes( mWSDL.types() );
+
+  mConversationManager = new GeneralConversationManager( mWSDL );
+
+  mTransport = new Transport( mWSDL.service().ports().first().mLocation );
+  connect( mTransport, SIGNAL( result( const QString& ) ),
+           this, SLOT( result( const QString& ) ) );
+  connect( mTransport, SIGNAL( error( const QString& ) ),
+           this, SLOT( error( const QString& ) ) );
+}
+
+void Dispatcher::run()
+{
+  nextMessage();
+}
+
+void Dispatcher::nextMessage()
+{
+  if ( !mConversationManager ) {
+    qDebug( "No conversation manager set... aborting" );
+    return;
+  }
+
+  QStringList items = mConversationManager->nextActions( mLastMessage, QString() );
+
+  mCurrentMessage = QString();
+  if ( items.count() > 1 ) {
+    mCurrentMessage = KInputDialog::getItem( i18n( "Select a functionality of the service:" ), i18n( "Functions" ),
+                                         items );
+  } else
+    mCurrentMessage = items.first();
+
+  if ( mCurrentMessage.isEmpty() ) {
+    qApp->quit();
+    return;
+  }
+
+  KWSDL::Message message = mWSDL.findMessage( mCurrentMessage );
+  InputField *field = new PageInputField( message.name(), message );
+  QWidget *page = field->createWidget( 0 );
+
+  InputDialog dlg( page, 0 );
+  if ( dlg.exec() ) {
+    QDomDocument doc( "kwsdl" );
+    doc.appendChild( doc.createProcessingInstruction( "xml", "version=\"1.0\" encoding=\"UTF-8\"" ) );
+    QDomElement env = doc.createElement( "SOAP-ENV:Envelope" );
+    env.setAttribute( "xmlns:SOAP-ENV", "http://schemas.xmlsoap.org/soap/envelope/" );
+    env.setAttribute( "xmlns:xsi", "http://www.w3.org/1999/XMLSchema-instance" );
+    env.setAttribute( "xmlns:xsd", "http://www.w3.org/1999/XMLSchema" );
+    doc.appendChild( env );
+
+    QDomElement body = doc.createElement( "SOAP-ENV:Body" );
+    env.appendChild( body );
+
+    field->xmlData( doc, body );
+
+    QDomElement method = body.firstChild().toElement();
+    QString nameSpace = mWSDL.findBindingOperation( "", message.name() ).input().nameSpace();
+    method.setAttribute( "xmlns:ns1", "urn:GoogleSearch" );
+    method.setAttribute( "SOAP-ENV:encodingStyle", "http://schemas.xmlsoap.org/soap/encoding/" );
+    body.appendChild( method );
+
+    if ( mTransport ) {
+      qDebug( "%s", doc.toString( 2 ).latin1() );
+      mTransport->query( doc.toString( 2 ) );
+    }
+  } else
+    qApp->quit();
+}
+
+void Dispatcher::result( const QString &xml )
+{
+  qDebug( "Got data %s", xml.latin1() );
+
+  KWSDL::Message message = mWSDL.findOutputMessage( mCurrentMessage );
+  InputField *field = new PageInputField( message.name(), message );
+
+  QDomDocument doc;
+  doc.setContent( xml, true );
+
+  field->setXMLData( doc.documentElement().firstChild().firstChild().toElement() );
+  QWidget *page = field->createWidget( 0 );
+
+  OutputDialog dlg( page, 0 );
+  dlg.exec();
+
+  mLastMessage = mCurrentMessage;
+
+  QTimer::singleShot( 0, this, SLOT( nextMessage() ) );
+}
+
+void Dispatcher::error( const QString &errorMsg )
+{
+  KMessageBox::error( 0, errorMsg );
+
+  QTimer::singleShot( 0, this, SLOT( nextMessage() ) );
+}
+
+#include "dispatcher.moc"