/*
* 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
}