1 files changed, 119 insertions, 0 deletions

diff --git a/core/applets/obex/obex.cc b/core/applets/obex/obex.cc
new file mode 100644
index 0000000..f2ceff8
--- a/dev/null
+++ b/core/applets/obex/obex.cc
@@ -0,0 +1,119 @@
+
+
+#include "kprocess.h"
+#include "obex.h"
+
+using namespace  OpieObex;
+
+Obex::Obex( QObject *parent, const char* name ) 
+  : QObject(parent, name )
+{
+  m_rec = 0;
+  m_send=0;
+  m_count = 0;
+};
+Obex::~Obex() { 
+  delete m_rec;
+  delete m_send;
+}
+void Obex::receive()  {
+   m_rec = new KProcess();
+   *m_rec << "irobex_palm3";
+   // connect to the necessary slots
+   connect(m_rec,  SIGNAL(processExited(KProcess*) ),
+           this,  SLOT(slotExited(KProcess*) ) );
+   
+   connect(m_rec,  SIGNAL(receivedStdout(KProcess*, char*,  int ) ),
+           this,  SLOT(slotStdOut(KProcess*, char*, int) ) );
+   
+   if(!m_rec->start(KProcess::NotifyOnExit, KProcess::AllOutput) ) {
+     qWarning("could not start :(");
+     emit done( false );
+   }
+   emit currentTry(m_count );
+
+}
+void Obex::send( const QString& fileName) {
+  m_count = 0;
+  m_file = fileName;
+  sendNow();
+}
+void Obex::sendNow(){
+  if ( m_count >= 15 ) { // could not send
+    emit error(-1 );
+  }
+  // KProcess inititialisation
+  m_send = new KProcess();
+  *m_send << "irobex_palm3";
+  *m_send << m_file;
+  
+  // connect to slots Exited and and StdOut
+  connect(m_send,  SIGNAL(processExited(KProcess*) ),
+          this, SLOT(slotExited(KProcess*)) );
+  connect(m_send,  SIGNAL(receivedStdout(KProcess*, char*,  int )), 
+          this, SLOT(slotStdOut(KProcess*, char*, int) ) );
+  // now start it
+  if (!m_send->start(/*KProcess::NotifyOnExit,  KProcess::AllOutput*/ ) ) {
+    m_count = 15;
+    emit error(-1 );
+  }
+  // end
+  m_count++;
+  emit currentTry( m_count );
+}
+
+void Obex::slotExited(KProcess* proc ){
+   if (proc == m_rec ) { // recieve process
+        recieved();
+    }else if ( proc == m_send ) {
+        sendEnd();
+    }
+}
+void Obex::slotStdOut(KProcess* proc, char* buf, int len){
+  if ( proc == m_rec ) { // only recieve
+    QCString cstring( buf,  len );
+    m_outp.append( cstring.data() );
+  }
+}
+
+void Obex::recieved() {
+  if (m_rec->normalExit() ) {
+    if ( m_rec->exitStatus() == 0 ) { // we got one
+      QString filename = parseOut();
+      emit receivedFile( filename );
+    }
+  }else{
+    emit error(-1);
+  };
+  delete m_rec;
+}
+void Obex::sendEnd() {
+  if (m_send->normalExit() ) {
+    if ( m_send->exitStatus() == 0 ) {
+      delete m_send;
+      m_send=0;
+      emit sent();
+    }else if (m_send->exitStatus() == 255 ) { // it failed maybe the other side wasn't ready
+      // let's try it again
+      delete m_send;
+      m_send = 0;
+      sendNow();
+    }
+  }else {
+    emit error( -1 );
+    delete m_send;
+    m_send = 0;
+  }
+}
+QString Obex::parseOut(     ){
+  QString path;
+  QStringList list = QStringList::split("\n",  m_outp);
+  QStringList::Iterator it;
+  for (it = list.begin(); it != list.end(); ++it ) {
+    if ( (*it).startsWith("Wrote"  ) ) {
+      QStringList pathes = QStringList::split(' ', (*it) );
+      path = pathes[1];
+    }
+  }
+  return path;
+}