/*

* 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.storage.*;

import java.lang.Integer;

import java.lang.String;

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

/**

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

 * push data in the Storage.

 */

final class PushRuntimeDbHandler

{

    /**

     * @return null if push reg by connection URI did not match to any push reg.

     */

    public static PushRegData getPushRegByConnection(String aUri,StorageSession aSession)

    {

        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.getUidAndRegTypeOfPushReg()");

        StorageEntry query = new StorageEntry();

        query.addAttribute(new StorageAttribute(StorageNames.URL,aUri));

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

        PushRegData[] pushInfoTable = mapStorageEntryToPushInfo(entries);

        if (null == pushInfoTable)

            return null;

        //There can be only one push registration because Uri is only one in the primary key.

        //Null is returned by mapStorageEntryToPushInfo() operation if size of the 'entries'

        //table is zero.

        return pushInfoTable[0];

    }//end getPushRegByConnection

    /**

     *

     */

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

    {

        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() +");

        if (null == aEntries)

            return null;

        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() #2");

        if (0 == aEntries.length)

            return null;

        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() #3");

        PushRegData[] pushInfoTable = new PushRegData[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.REGISTRATION_TYPE);

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

            PushRegData infoObj = new PushRegData(newUid,regType);

            pushInfoTable[i] = infoObj;

        }//end for

        Logger.LOG(Logger.EJavaPush, Logger.EInfo, "PushRuntimeDbHandler.mapStorageEntryToPushInfo() -");

        return pushInfoTable;

    }//end mapStorageEntryToPushInfo

}//end final class PushRuntimeDbHandler