/*

* Copyright (c) 2008 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:

*

*/

package com.nokia.mj.impl.push;

import java.io.IOException;

import com.nokia.mj.impl.utils.Uid;

import com.nokia.mj.impl.installer.pushregistrator.PushInfo;

import com.nokia.mj.impl.storage.*;

import java.lang.Integer;

import java.lang.String;

import com.nokia.mj.impl.utils.Logger;

/**

 * This class is used by PushRegistratorImpl class(i.e. Installer process) to read and manipulate

 * push data in the Storage.

 */

final class PushDbHandler

{

    /**

     *

     */

    public static void storePushRegs(StorageSession aSession, PushInfo[] aPushInfos)

    {

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.storePushRegs()");

        if (null == aPushInfos)

            return;

        for (int i = 0; i < aPushInfos.length; ++i)

        {

            StorageEntry entry = new StorageEntry();

            entry.addAttribute(new StorageAttribute(

                                   StorageNames.ID, aPushInfos[i].getUid().getStringValue()));

            entry.addAttribute(new StorageAttribute(

                                   StorageNames.URL, aPushInfos[i].getConnectionUrl()));

            entry.addAttribute(new StorageAttribute(

                                   StorageNames.NAME, aPushInfos[i].getClassName()));

            entry.addAttribute(new StorageAttribute(

                                   StorageNames.FILTER, aPushInfos[i].getFilter()));

            entry.addAttribute(new StorageAttribute(

                                   StorageNames.REGISTRATION_TYPE, Integer.toString(aPushInfos[i].getRegType()),

                                   StorageAttribute.INT_TYPE));

            aSession.write(StorageNames.PUSH_REGISTRATIONS_TABLE, entry);

        }//end for

    }//end storePushRegs

    /**

     *

     */

    public static void deletePushRegs(StorageSession aSession,Uid aUid)

    {

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.deletePushRegs()");

        aSession.remove(StorageNames.PUSH_REGISTRATIONS_TABLE,aUid);

    }//end deletePushRegs

    /**

     *

     */

    public static void deleteAlarm(StorageSession aSession,Uid aUid)

    {

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.deleteAlarm()");

        aSession.remove(StorageNames.ALARM_REGISTRATIONS_TABLE,aUid);

    }//end deleteAlarms

    /**

     *

     */

    public static PushInfo[] getPushRegs(StorageSession aSession,Uid aUid)

    {

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.getPushRegs()");

        StorageEntry query = new StorageEntry();

        query.addAttribute(new StorageAttribute(StorageNames.ID,aUid.getStringValue()));

        StorageEntry[] entries = aSession.search(StorageNames.PUSH_REGISTRATIONS_TABLE,query);

        return mapStorageEntryToPushInfo(entries);

    }//end getPushRegs

    /**

     * @param StorageSession This operation creates a StoreageSession if 'aSession' argument is null.

     *                       StorageSession is not closed if it is provided by user.

     */

    public static PushMidletData[] getClassNamesAndUidsOfMidletsInSuite(Uid aSuiteUid,StorageSession aSession)

    throws IOException

    {

        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushDbHandler.getClassNamesOfMidletsInSuite()");

        boolean sessionCreatedByUser = false;

        if (null != aSession)

            sessionCreatedByUser = true;

        StorageSession sessionObj = aSession;

        try

        {

            if (false == sessionCreatedByUser)

            {

                sessionObj = StorageFactory.createSession();

                sessionObj.open();

            }

            StorageEntry query = new StorageEntry();

            query.addAttribute(new StorageAttribute(StorageNames.PACKAGE_ID,aSuiteUid.getStringValue()));

            query.addAttribute(new StorageAttribute(StorageNames.MAIN_CLASS,""));

            query.addAttribute(new StorageAttribute(StorageNames.ID,""));

            query.addAttribute(new StorageAttribute(StorageNames.NAME,""));

            StorageEntry[] entries = sessionObj.search(StorageNames.APPLICATION_TABLE,query);

            if (null == entries)

                return null;

            if (0 == entries.length)

                return null;

            PushMidletData[] midletData = new PushMidletData[entries.length];

            for (int i = 0; i < entries.length; i++)

            {

                StorageAttribute attr = entries[i].getAttribute(StorageNames.ID);

                Uid newUid = Uid.createUid(attr.getValue());

                attr = entries[i].getAttribute(StorageNames.MAIN_CLASS);

                String mainClassName = attr.getValue();

                attr = entries[i].getAttribute(StorageNames.NAME);

                String midletName = attr.getValue();

                PushMidletData tmpObj = new PushMidletData(newUid,mainClassName,midletName);

                midletData[i] = tmpObj;

            }//end for

            return midletData;

        }

        catch (Throwable ex)

        {

            throw new IOException("Getting name of MIDlets failed: " + ex);

        }

        finally

        {

            if (false == sessionCreatedByUser)

            {

                if (null != sessionObj)

                {

                    sessionObj.close();

                    sessionObj.destroySession();

                }

            }//end if(false == sessionCreatedByUser)

        }//end finally

    }//end getClassNamesOfMidletsInSuite()

    /**

     *

     */

    public static PushInfo[] mapStorageEntryToPushInfo(StorageEntry[] aEntries)

    {

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.mapStorageEntryToPushInfo() +");

        if (null == aEntries)

            return null;

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.mapStorageEntryToPushInfo() #2");

        if (0 == aEntries.length)

            return null;

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.mapStorageEntryToPushInfo() #3");

        PushInfo[] pushInfoTable = new PushInfo[aEntries.length];

        for (int i = 0; i < aEntries.length; i++)

        {

            StorageAttribute attr = aEntries[i].getAttribute(StorageNames.ID);

            Uid newUid = Uid.createUid(attr.getValue());

            attr = aEntries[i].getAttribute(StorageNames.URL);

            String uri = attr.getValue();

            attr = aEntries[i].getAttribute(StorageNames.NAME);

            String className = attr.getValue();

            attr = aEntries[i].getAttribute(StorageNames.FILTER);

            String filter = attr.getValue();

            attr = aEntries[i].getAttribute(StorageNames.REGISTRATION_TYPE);

            int regType = Integer.parseInt(attr.getValue());

            PushInfo infoObj = new PushInfo(newUid,uri,className,filter,regType);

            pushInfoTable[i] = infoObj;

        }//end for

        Logger.LOG(Logger.EJavaInstaller, Logger.EInfo, "PushDbHandler.mapStorageEntryToPushInfo() -");

        return pushInfoTable;

    }//end mapStorageEntryToPushInfo

}