/*

* 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 <QFile>

#include <QTextStream>

#include <QStringList>

#include <QLocalSocket>

#include <qcoreapplication.h>

#include "irsymbiandocument.h"

#include "irsymbianapplication.h"

#include "irsymbianappui.h"

const QString KEqual("=");

const QString KFile("File");

const QString KTitle("Title");

const QString KLength("Length");

const QString KPlsExtension(".pls");

const QString KM3uExtension(".m3u");

IRSymbianDocument * IRSymbianDocument::documentInstance = NULL;

IRPlsPlayListItem::IRPlsPlayListItem(const QString &aFile, const QString &aTitle, int aLength) :

                                     iFile(aFile), iTitle(aTitle), iLength(aLength)

{

}

const QString & IRPlsPlayListItem::file() const

{

    return iFile;

}

const QString & IRPlsPlayListItem::title() const

{

    return iTitle;

}

IRSymbianDocument * IRSymbianDocument::getInstance()

{

    if (NULL == documentInstance)

    {

        documentInstance = new IRSymbianDocument(*IRSymbianApplication::getInstance());

    }

    return documentInstance;

}

bool IRSymbianDocument::isPlsAvailable() const

{

    return iPlsList.count() > 0;

}

int IRSymbianDocument::getNumberOfEntries() const

{

    return iPlsList.count();

}

IRPlsPlayListItem* IRSymbianDocument::getEntry(int aIndex)

{

    if (aIndex >=0 && aIndex < iPlsList.count())

    {

        return iPlsList.at(aIndex);

    }

    return NULL;

}

IRSymbianDocument::IRSymbianDocument(CEikApplication &mainApplication) : QS60MainDocument(mainApplication)

{

}

IRSymbianDocument::~IRSymbianDocument()

{

    clearPlsList();

}

void IRSymbianDocument::OpenFileL(CFileStore*& aFileStore, RFile& aFile)

{

    aFileStore = NULL;

    TBuf<255> fileName;

    aFile.FullName(fileName);

    TParsePtr ptr(fileName);    

    TPtrC extension = ptr.Ext();

    QString qExtension = QString::fromUtf16(extension.Ptr(), extension.Length());

    if (0 == qExtension.compare(KPlsExtension, Qt::CaseInsensitive) ||

        0 == qExtension.compare(KM3uExtension, Qt::CaseInsensitive) ) 

    { 

        QString qFileName = QString::fromUtf16(fileName.Ptr(), fileName.Length());

        IRSymbianApplication *symbianApp = static_cast<IRSymbianApplication*>(Application());

        if (symbianApp->getInstanceFlag())

        {

            //if an instance is already running, send the file name to that instance through socket

            QLocalSocket socket;

            QString serverName = QCoreApplication::applicationName();

            socket.connectToServer(serverName);

            if (socket.waitForConnected(500)) 

            {

                QTextStream stream(&socket);

                stream << qFileName;

                stream.flush();

                socket.waitForBytesWritten();

            }

        }

        else

        {

            parseFile(qFileName);

        }

    }

}

CEikAppUi* IRSymbianDocument::CreateAppUiL()

{

    return new (ELeave) IRSymbianAppui;

}

void IRSymbianDocument::parseFile(const QString &aFileName)

{

    QString extension = aFileName.right(4);

    if (0 == extension.compare(KPlsExtension, Qt::CaseInsensitive))

    {

        parsePlsFile(aFileName);

    }

    else if (0 == extension.compare(KM3uExtension, Qt::CaseInsensitive))

    {

        parseM3uFile(aFileName);

    }

    else

    {

        Q_ASSERT(false);

    }

}

void IRSymbianDocument::parsePlsFile(const QString &aFileName)

{

    if (aFileName.length() == 0)

    {

        return;

    }

    clearPlsList();

    QFile file(aFileName);

    if (!file.open(QIODevice::ReadOnly))

    {

        return;

    }

    QTextStream stream(&file);

    QString readStr = stream.readLine().trimmed();

    if (readStr.compare("[playlist]", Qt::CaseInsensitive))

    {

        file.close();

        return;

    }

    readStr = stream.readLine().trimmed();

    QStringList splitStr = readStr.split(KEqual);

    if (splitStr.count() != 2)

    {

        file.close();

        return;

    }

    int nbEntries = 0;

    if (0 == splitStr.first().compare("NumberOfEntries", Qt::CaseInsensitive))

    {

        nbEntries = splitStr.last().toInt();

    }

    if (nbEntries <= 0)

    {

        file.close();

        return;

    }

    for (int i = 0; i < nbEntries; ++i)

    {

        //read file line : File=xxx     

        QString filePath = readValue(stream, KFile);

        if (filePath.length() == 0)

        {

            break;

        }

        //read title line : Title=xxx

        QString title = readValue(stream, KTitle);

        if (title.length() == 0)

        {

            break;

        }

        //read length line : Length=xxx

        QString strLength = readValue(stream, KLength);

        if (strLength.length() == 0)

        {

            break;

        }

        int length = strLength.toInt();

        //all information is ready

        if (length == -1)

        {

            IRPlsPlayListItem *item = new IRPlsPlayListItem(filePath, title, length);

            iPlsList.append(item);

        }

    }

    file.close();

}

void IRSymbianDocument::parseM3uFile(const QString &aFileName)

{

    clearPlsList();

    QFile file(aFileName);

    if (!file.open(QIODevice::ReadOnly))

    {

        return;

    }

    QTextStream stream(&file);

    QString readStr;

    int stationCount = 0;

    while (!stream.atEnd())

    {

        readStr = stream.readLine().trimmed();

        if (readStr.startsWith("http://", Qt::CaseInsensitive))

        {

            IRPlsPlayListItem *item = new IRPlsPlayListItem(readStr, "Station " + QString::number(++stationCount), -1);

            iPlsList.append(item);

        }

    }

    file.close();

}

void IRSymbianDocument::clearPlsList()

{

    while (!iPlsList.isEmpty())

    {

        IRPlsPlayListItem *firstItem = iPlsList.takeFirst();

        delete firstItem;

    }

}

QString IRSymbianDocument::readValue(QTextStream &aStream, const QString &aKey)

{

    QString readStr;

    QStringList splitStr;

    do

    {

        readStr = aStream.readLine().trimmed();    

    }while (readStr.length() == 0 && !aStream.atEnd());

    splitStr = readStr.split(KEqual);

    if (splitStr.count() != 2 || !splitStr.first().startsWith(aKey, Qt::CaseInsensitive))

    {

        return QString();

    }

    else

    {

        return splitStr.last();

    }

}