/*

* Copyright (c) 2010 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 com.nokia.mj.impl.storage.StorageAttribute;

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

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

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

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

/**

 * Utility methods for handling push registrations.

 */

public final class PushUtil

{

    /**

     * Returns push registrations for specified application or

     * application suite.

     *

     * @param aSession StorageSesion to be used for fetching

     * the push registrations

     * @param aUid either application or application suite Uid

     * @return array of push registrations

     */

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

    {

        // Find push registrations using application uid.

        PushRegInfo[] pushRegs = getPushRegsForAppUid(aSession, aUid);

        if (pushRegs.length > 0)

        {

            return pushRegs;

        }

        // Push registrations not found, so find application uids using

        // suite uid and then push registrations using application uids.

        Uid[] appUids = getAppUids(aSession, aUid);

        PushRegInfo[][] pushRegArray = new PushRegInfo[appUids.length][];

        int pushRegCount = 0;

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

        {

            pushRegArray[i] = getPushRegs(aSession, appUids[i]);

            pushRegCount += pushRegArray[i].length;

        }

        pushRegs = new PushRegInfo[pushRegCount];

        int pushRegsIndex = 0;

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

        {

            for (int j = 0; j < pushRegArray[i].length; j++)

            {

                pushRegs[pushRegsIndex++] = pushRegArray[i][j];

            }

        }

        return pushRegs;

    }

    /**

     * Returns push registrations for specified application.

     *

     * @param aSession StorageSesion to be used for fetching

     * the push registrations

     * @param aUid application Uid

     * @return array of push registrations

     */

    private static PushRegInfo[] getPushRegsForAppUid(StorageSession aSession, Uid aUid)

    {

        PushRegInfo[] pushRegs = new PushRegInfo[0];

        StorageEntry query = new StorageEntry();

        query.addAttribute(

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

        StorageEntry[] entries = aSession.search(

            StorageNames.PUSH_REGISTRATIONS_TABLE, query);

        if (entries != null && entries.length > 0)

        {

            pushRegs = new PushRegInfo[entries.length];

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

            {

                Uid uid = Uid.createUid(

                    entries[i].getAttribute(StorageNames.ID).getValue());

                String name = entries[i].getAttribute(StorageNames.NAME).getValue();

                String url = entries[i].getAttribute(StorageNames.URL).getValue();

                String filter = entries[i].getAttribute(StorageNames.FILTER).getValue();

                int regType = Integer.parseInt(

                    entries[i].getAttribute(StorageNames.REGISTRATION_TYPE).getValue());

                pushRegs[i] = new PushRegInfo(uid, name, url, filter, regType);

            }

        }

        return pushRegs;

    }

    /**

     * Returns application Uids for specified application suite.

     *

     * @param aSession StorageSesion to be used for fetching the Uids

     * @param aSuiteUid application suite Uid

     * @return array of application Uids

     */

    private static Uid[] getAppUids(StorageSession aSession, Uid aUid)

    {

        Uid[] uids = new Uid[0];

        StorageEntry query = new StorageEntry();

        query.addAttribute(new StorageAttribute(

                               StorageNames.PACKAGE_ID, aUid.getStringValue()));

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

        StorageEntry[] entries =

            aSession.search(StorageNames.APPLICATION_TABLE, query);

        if (entries != null && entries.length > 0)

        {

            uids = new Uid[entries.length];

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

            {

                uids[i] = Uid.createUid(

                    entries[i].getAttribute(StorageNames.ID).getValue());

            }

        }

        return uids;

    }

    /**

     * PushRegInfo contains information of one push registration.

     */

    public static final class PushRegInfo

    {

        /** Dynamic push registration. */

        public static final int DYNAMIC = 0;

        /** Static push registration. */

        public static final int STATIC = 1;

        /** Application Uid. */

        private Uid iUid = null;

        /** Application name. */

        private String iName = null;

        /** Push registration URL */

        private String iUrl = null;

        /** Filter for incoming messages/connections. */

        private String iFilter = null;

        /** Registration type. Either DYNAMIC or STATIC. */

        private int iRegType = DYNAMIC;

        PushRegInfo(

            Uid aUid, String aName, String aUrl, String aFilter, int aRegType)

        {

            iUid = aUid;

            iName =  aName;

            iUrl = aUrl;

            iFilter = aFilter;

            iRegType = aRegType;

        }

        /** Returns application Uid. */

        public Uid getUid()

        {

            return iUid;

        }

        /** Returns application name. */

        public String getName()

        {

            return iName;

        }

        /** Returns push registration URL */

        public String getUrl()

        {

            return iUrl;

        }

        /** Returns filter for incoming messages/connections. */

        public String getFilter()

        {

            return iFilter;

        }

        /** Returns registration type. Either DYNAMIC or STATIC. */

        public int getRegType()

        {

            return iRegType;

        }

    }

}