/*
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:
*
*/
#include "xqaccsensor_p.h"
#include "xqaccsensor.h"
#include <sensrvaccelerometersensor.h>
#include <sensrvchannel.h>

XQAccelerationSensorPrivate::XQAccelerationSensorPrivate(XQSensor& qq) :
    XQSensorPrivate(qq)
{
}

XQAccelerationSensorPrivate::~XQAccelerationSensorPrivate()
{
    close();
    delete iXyzAxisChannel;
}

void XQAccelerationSensorPrivate::open()
{
    TRAP(iError,
        if(!iXyzAxisChannel) {
            iXyzAxisChannel = CreateChannelL(KSensrvChannelTypeIdAccelerometerXYZAxisData);
        }
        iXyzAxisChannel->OpenChannelL();
    )
}

void XQAccelerationSensorPrivate::close()
{
    if (iXyzAxisChannel) {
        iXyzAxisChannel->CloseChannel();
    }
}

void XQAccelerationSensorPrivate::startReceiving()
{
    if (iXyzAxisChannel) {
        TRAP(iError,
            iXyzAxisChannel->StartDataListeningL(this, 1, 16, 0);
        )
    } else {
        iError = KErrNotReady;
    }
}

void XQAccelerationSensorPrivate::stopReceiving()
{
    if (iXyzAxisChannel) {
        iXyzAxisChannel->StopDataListening();
    }
}

void XQAccelerationSensorPrivate::DataReceived(CSensrvChannel& aChannel,
    TInt aCount, TInt aDataLost)
{
    TSensrvChannelTypeId typeId = aChannel.GetChannelInfo().iChannelType;
    if (typeId == KSensrvChannelTypeIdAccelerometerXYZAxisData) {
        HandleXyzAxisData(aChannel, aCount, aDataLost);
    }
}

void XQAccelerationSensorPrivate::HandleXyzAxisData(CSensrvChannel& aChannel, TInt aCount, TInt /*aDataLost*/)
{
    for(TInt i = 0; i < aCount; i++) {
        TPckgBuf<TSensrvAccelerometerAxisData> dataBuf;
        if (aChannel.GetData(dataBuf) == KErrNone) {
            TSensrvAccelerometerAxisData data = dataBuf();
            for (int i = iFilters.size() - 1; i >= 0; --i) {
                XQAbstractAccelerationSensorFilter* filter = iFilters.at(i);
                if (filter->filter(data.iAxisX, data.iAxisY, data.iAxisZ))
                    break;
            }
            iXAcceleration = data.iAxisX;
            iYAcceleration = data.iAxisY;
            iZAcceleration = data.iAxisZ;
        }
    }
}

XQSensor::Error XQAccelerationSensorPrivate::error() const
{
    switch (iError) {
        case KErrNone:
            return XQSensor::NoError;
        case KErrNoMemory:
            return XQSensor::OutOfMemoryError;
        case KErrNotFound:
            return XQSensor::NotFoundError;
        default:
            return XQSensor::UnknownError;
    }
}

void XQAccelerationSensorPrivate::addFilter(XQAbstractAccelerationSensorFilter& filter)
{
    iFilters.append(&filter);
}

QList<XQAbstractAccelerationSensorFilter*>& XQAccelerationSensorPrivate::filters()
{
    return iFilters;
}

int XQAccelerationSensorPrivate::xAcceleration() const
{
    return iXAcceleration;
}

int XQAccelerationSensorPrivate::yAcceleration() const
{
    return iYAcceleration;
}

int XQAccelerationSensorPrivate::zAcceleration() const
{
    return iZAcceleration;
}

bool XQAccelerationDataPostFilter::filter(int& xAcceleration, int& yAcceleration, int& zAcceleration)
{
    const int maxAcceleration = 127;    //for framework
    xAcceleration = xAcceleration * 100 / maxAcceleration;
    yAcceleration = yAcceleration * 100 / maxAcceleration;
    zAcceleration = zAcceleration * 100 / maxAcceleration;
    return false;
}

XQAccelerationDataPostFilter::XQAccelerationDataPostFilter()
{
}

// End of file