#include <qapplication.h>
#include <qmessagebox.h>
#include <qpe/qcopenvelope_qws.h>
#include <opie/oprocess.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()  {
  qWarning("Receive" );
   m_rec = new OProcess();
   *m_rec << "irobex_palm3";
   // connect to the necessary slots
   connect(m_rec,  SIGNAL(processExited(OProcess*) ),
	   this,  SLOT(slotExited(OProcess*) ) );

   connect(m_rec,  SIGNAL(receivedStdout(OProcess*, char*,  int ) ),
	   this,  SLOT(slotStdOut(OProcess*, char*, int) ) );

   if(!m_rec->start(OProcess::NotifyOnExit, OProcess::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 >= 25 ) { // could not send
    emit error(-1 );
    return;
  }
  // OProcess inititialisation
  m_send = new OProcess();
  *m_send << "irobex_palm3";
  *m_send << m_file;

  // connect to slots Exited and and StdOut
  connect(m_send,  SIGNAL(processExited(OProcess*) ),
	  this, SLOT(slotExited(OProcess*)) );
  connect(m_send,  SIGNAL(receivedStdout(OProcess*, char*,  int )),
	  this, SLOT(slotStdOut(OProcess*, char*, int) ) );
  // now start it
  if (!m_send->start(/*OProcess::NotifyOnExit,  OProcess::AllOutput*/ ) ) {
    qWarning("could not send" );
    m_count = 25;
    emit error(-1 );
  }
  // end
  m_count++;
  emit currentTry( m_count );
}

void Obex::slotExited(OProcess* proc ){
   if (proc == m_rec ) { // recieve process
        recieved();
    }else if ( proc == m_send ) {
        sendEnd();
    }
}
void Obex::slotStdOut(OProcess* 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;
      qWarning("done" );
      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;
      qWarning("try sending again" );
      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];
      qWarning("path %s", path.latin1() );
    }
  }
  return path;
}