qir.cpp

Trolltech公司发布的图形界面操作系统。可在qt-embedded-2.3.10平台上编译为嵌入式图形界面操作系统。

/**********************************************************************
** Copyright (C) 2000-2005 Trolltech AS and its licensors.
** All rights reserved.
**
** This file is part of the Qtopia Environment.
**
** This file may be distributed and/or modified under the terms of the
** GNU General Public License version 2 as published by the Free Software
** Foundation and appearing in the file LICENSE.GPL included in the
** packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.trolltech.com/gpl/ for GPL licensing information.
** See below for additional copyright and license information
**
** Contact [e-mail] if any conditions of this licensing are
** not clear to you.
**
**********************************************************************/
#include "qir.h"
#include "qirserver.h"
#include "receivedialog.h"
#include "sendwindow.h"

#include <qtopia/qpeapplication.h>
#include <qtopia/qcopenvelope_qws.h>
#include <qtopia/resource.h>
#include <qtopia/global.h>
#include <qtopia/qpeapplication.h>

#include <qdir.h>
#include <qmessagebox.h>
#include <qtimer.h>

#include <stdlib.h>

#define BEAM_TRAY_ID ((int) 0x43535345)

//#define QTOPIA_IR_DEBUG

static void notifyBeamBegin()
{
    QCopEnvelope("Qt/Tray", "setIcon(int,QPixmap)")
	<< BEAM_TRAY_ID << Resource::loadPixmap("beam");
    QPEApplication::setTempScreenSaverMode(QPEApplication::DisableSuspend);
}

static void notifyBeamDone()
{
    QCopEnvelope("Qt/Tray", "remove(int)")
	<< BEAM_TRAY_ID;
    QPEApplication::setTempScreenSaverMode(QPEApplication::Enable);
}

QIr::QIr( QObject *parent, const char *name )
    : QObject( parent, name ),
      receiveWindow( 0 ),
      sendWindow( 0 )
{
    obexServer = new QIrServer( this );
    connect( obexServer, SIGNAL(receiving(int,const QString&,const QString&)),
	    this, SLOT(receiving(int,const QString&,const QString&)) );
    connect( obexServer, SIGNAL(receiveDone()), this, SLOT(receiveDone()) );
    connect( obexServer, SIGNAL( receiveInit() ), this, SLOT( receiveInit() ) );
    connect( obexServer, SIGNAL( receiveError() ), this, SLOT( receiveError() ) );

    connect( obexServer, SIGNAL( beamDone() ), this, SLOT( beamDone() ) );
    connect( obexServer, SIGNAL( beamError() ), this, SLOT( beamError() ) );

    obexChannel = new QCopChannel( "QPE/Obex", this );
    connect( obexChannel, SIGNAL(received(const QCString&,const QByteArray&)),
	     this, SLOT(obexMessage(const QCString&,const QByteArray&)) );

    trayChannel = new QCopChannel( "Qt/Tray", this );
    connect( trayChannel, SIGNAL(received(const QCString&,const QByteArray&)),
	     this, SLOT(traySocket(const QCString&,const QByteArray&)) );

    ips = new IrPowerSave(this);

  receiveWindow = new ReceiveDialog(obexServer, 0, "irReceive");
}

QIr::~QIr()
{
    if ( sendWindow )
	delete sendWindow;

    if ( receiveWindow )
	delete receiveWindow;
    
    delete ips;
}

void QIr::obexMessage( const QCString &msg , const QByteArray &data )
{
#ifdef QTOPIA_IR_DEBUG
    qDebug("received message on QPE/Obex: msg=%s", msg.data() );
#endif
    QDataStream stream( data, IO_ReadOnly );
    QString name;
    QString filename;
    QString mimetype;
    if ( msg == "send(QString,QString,QString)" ) {
        stream >> name >> filename >> mimetype;
    } else if ( msg == "send(QString)" ) {
        QString filename;
        stream >> filename;
    } else {
	return;
    }
    
    if ( !filename.isEmpty() ) {
	QFileInfo fi(filename);
#ifdef QTOPIA_IR_DEBUG
	qDebug("sending obex object, filename=%s, mimetype=%s", filename.latin1(), mimetype.latin1());
#endif
	if ( obexServer->isBeaming() ) {
	    QString desc = name;
	    if ( name.isEmpty() )
		desc = filename;
	    
	    QString str = tr("Busy, dropping request %1").arg(desc);
	    Global::statusMessage(str);
	    return;
	}
	
	if ( !sendWindow )
	    sendWindow = new SendWindow(obexServer, 0, "irSend");
	
	// anoher test, just in case we used some time to create the sendwindow (and an incoming request came)
	if ( !obexServer->isBeaming() ) {
	    BeamItem item;
	    item.name = name;
	    item.fileName = fi.fileName();
	    item.mimeType = mimetype;
	    item.fileSize = fi.size();
	    
	    sendWindow->add( item );
	
	    ips->initBeam();

	    sendWindow->initBeam();
	    obexServer->beam( filename, mimetype );
	    sendWindow->beamingFirst();
	    notifyBeamBegin();
	} 
    }
}

void QIr::traySocket( const QCString &msg, const QByteArray &data)
{
    QDataStream stream( data, IO_ReadOnly );
    int id = 0;
    QPoint p;
    
    if ( msg == "popup(int,QPoint)" ) {
	stream >> id >> p;
    } else if ( msg == "clicked(int,QPoint)" || msg == "doubleClicked(int,QPoint)" ) {
	stream >> id >> p;
    }

    if ( id == BEAM_TRAY_ID ) {
	if ( obexServer->isBeaming() ) {
	    if ( sendWindow->isVisible() )
		sendWindow->raise();
	    else
		sendWindow->showMaximized();
	}
	if ( obexServer->isReceiving() ) {
	    if ( receiveWindow->isVisible() ) {
		receiveWindow->raise();
	    } else {
		receiveWindow->showMaximized();
		Global::statusMessage( "" );
	    }
	} else if ( !obexServer->isBeaming() ) {
	    notifyBeamDone();
	}
    }
}

void QIr::receiveInit()
{
    ips->initBeam();
    notifyBeamBegin();
}

void QIr::receiveDone()
{
    if ( !obexServer->isBeaming() ) {
	notifyBeamDone();
	ips->beamingDone(TRUE);
    }
}

void QIr::receiving( int, const QString&, const QString &mimetype )
{
    if( mimetype != "text/x-vCard" &&
	mimetype != "text/x-vCalendar" ) {
	if ( receiveWindow->isVisible() )
	    receiveWindow->raise();
	else
	    receiveWindow->showMaximized();
    }
    //don't show receive dialog for pim data
}

void QIr::receiveError()
{
    if ( !receiveWindow ) {
	qDebug("!!!bug!!! got receive error before receivewindow was created");
	return;
    }
    
    receiveWindow->failed();
    // no need to show the window - it will be already shown if sending something
   // other than PIM data
    /*
    if ( receiveWindow->isVisible() )
	receiveWindow->raise();
    else
	receiveWindow->showMaximized();
    */

    if ( !obexServer->isBeaming() ) {
	notifyBeamDone();
	ips->beamingDone(TRUE);
    }
}

void QIr::beamDone()
{
    sendWindow->itemBeamed();
    
    if ( sendWindow->count() ) {
	QTimer::singleShot(0, this, SLOT(beamNext()) );
    } else {
	sendWindow->finished();
	if ( !obexServer->isReceiving() ) {
	    ips->beamingDone();
	    notifyBeamDone();
	}
    }
}

void QIr::beamNext()
{
    if ( !sendWindow->count() )
	return;

    BeamItem item = sendWindow->next();
    obexServer->beam( item.fileName, item.mimeType );
    sendWindow->beamingFirst();
}

void QIr::beamError()
{
    if ( !sendWindow ) {
	qDebug("!!!bug!!! got beam error before beamwindow was created");
	return;
    }
    
    sendWindow->failed();
    if ( !obexServer->isReceiving() ) {
	notifyBeamDone();
	ips->beamingDone();
    }
}


/*    IrPowerSave	*/

const char* servicecmd = "/etc/rc.d/init.d/irda";
const char* servicefile = "/var/lock/subsys/irda";

IrPowerSave::IrPowerSave( QObject *parent, const char *name)
    : QObject(parent, name)
{
    running = FALSE;
    inUse = FALSE;
    state = Off;
    time = 0;
    timer = 0;

    if ( QFile::exists(servicefile) ) {
	state = On;
	running = TRUE;
    }
    
    QCopChannel *obexChannel = new QCopChannel( "QPE/Obex", this );
    connect( obexChannel, SIGNAL(received(const QCString&,const QByteArray&)),
	     this, SLOT(obexMessage(const QCString&,const QByteArray&)) );

}

IrPowerSave::~IrPowerSave()
{
    // save state
}

void IrPowerSave::initBeam()
{
    if ( !running )
	service("start"); // No tr

    inUse = TRUE;
}

void IrPowerSave::beamingDone(bool received)
{
    inUse = FALSE;

    switch( state ) {
	case Off:
	    service("stop"); // No tr
	    break;
	case On:
	    break;
	case On1Item:
	    if ( received ) {
		state = Off;
		service("stop"); // No tr
	    }
	    break;
	case OnMinutes:
	    if ( !timer->isActive() ) {
		state = Off;
		service("stop"); // No tr
	    }
	    break;
    }
}

void IrPowerSave::obexMessage(const QCString &msg, const QByteArray &data)
{
    State newState = state;;

    if ( msg == "turnOn()") {
	newState = On;
    } else if ( msg == "turnOff()") {
	newState = Off;
    } else if ( msg == "turnOn1Item()" ) {
	newState = On1Item;
    } else if ( msg == "turnOnTimed(int)") {
	newState = OnMinutes;
	QDataStream stream( data, IO_ReadOnly );
	stream >> time;
	time *= (60*1000);
    }
    
    if ( newState != state )
	applyReceiveState( newState );
}

/*  Apply requested beam receive state.  Be careful not to
    mess up any ongoing transmissions	*/
void IrPowerSave::applyReceiveState(State s)
{
    // The user might choose on5, then on1, which is why we need to stop the timer.
    // Other combinations will be handled ok. 
    if ( timer )
	timer->stop();

    state = s;

    switch( state ) {
	case Off:
	    if ( !inUse && running )
		service("stop"); // No tr
	    break;
	case On:
	    if ( !running )
		service("start"); // No tr
	    break;
	case On1Item:
	    if ( !running ) {
		service("start"); // No tr
	    }
	    break;
	case OnMinutes:
	    if ( !timer ) {
		timer = new QTimer(this);
		connect(timer, SIGNAL(timeout() ), this, SLOT(timeout()) );
	    }
	    
	    if ( !running )
		service("start"); // No tr
	    timer->start(time, TRUE);
	    break;
    }
}

void IrPowerSave::timeout()
{
    timer->stop();
    if ( state != Off && !inUse )
	applyReceiveState( Off );
    // If inUse, will turn off in beamingDone().
}

void IrPowerSave::service(const QString& command)
{
    system((QString(servicecmd) + " " + command).latin1());

    if ( command == "start" ) { // No tr
	qDebug("started ir service");
	running = TRUE;
    } else {
	qDebug("stopped ir service");
	running = FALSE;
	// Don't really need to set this one here, but it's safer
	inUse = FALSE;
	QCopEnvelope("QPE/Obex", "turnedOff()");
    }
}