/*
* Copyright (c) 2007 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:  Location Centre Server object.
*
*/


// SYSTEM INCLUDES
#include <badesca.h>    // CDesCArrayFlat
#include <s32file.h>    // CFileStore & CPermanentFileStore
#include <bautils.h>    // file helpers

// USER INCLUDES
#include "lcregappstore.h"

// CONSTANT DEFINTION
_LIT(KLcPrivateDbName,"lcregappinfo.db"); // Name of the Database file for storing registered app info.
_LIT(KAppInfoTable, "AppInfo");            // Name of the one table
_LIT(KAppUUIdCol, "UUID");           	   // First column

const TInt 	KMaxColumnLength = 32*1024;

// ----- Member funtions for CLcRegAppStore ---------------------------------

// ---------------------------------------------------------------------------
// CLcRegAppStore::CLcRegAppStore
// ---------------------------------------------------------------------------
//
CLcRegAppStore::CLcRegAppStore( RFs&  aFs )
	:iFsSession( aFs )
    {
    // C++ Default constructor. No allocations or functions which can Leave
    // should be called from here.Initiallize all the variable here
    }
         
// ---------------------------------------------------------------------------
// CLcRegAppStore::~CLcRegAppStore
// ---------------------------------------------------------------------------
//
CLcRegAppStore::~CLcRegAppStore()
    {
    // C++ Destructor. Free all resources associated with this class.
    Close();
    }
        
// ---------------------------------------------------------------------------
// CLcRegAppStore* CLcRegAppStore::NewL
// ---------------------------------------------------------------------------
//
CLcRegAppStore* CLcRegAppStore::NewL( RFs&  aFs )
    {
    CLcRegAppStore* self = NewLC( aFs );
    CleanupStack::Pop( self );
    return self;         
    }

// ---------------------------------------------------------------------------
// CLcRegAppStore* CLcRegAppStore::NewLC
// ---------------------------------------------------------------------------
//
CLcRegAppStore* CLcRegAppStore::NewLC( RFs&  aFs )
    {
    // Symbian Two phased constructor. Leaves the object on the Clean-up
    // stack.
    CLcRegAppStore* self = new ( ELeave )CLcRegAppStore( aFs );
    CleanupStack::PushL( self );
    self->ConstructL();
    return self;         
    }

// ---------------------------------------------------------------------------
// void CLcRegAppStore::ConstructL
// ---------------------------------------------------------------------------
//
void CLcRegAppStore::ConstructL()
    {
    // Obtain the Db file path
    User::LeaveIfError( iFsSession.SessionPath( iLcRegdbFile ) );

    // Create the Database Directory ie the private directory of the process
    if( !BaflUtils::PathExists( iFsSession, iLcRegdbFile ) )
	    {
    	User::LeaveIfError( iFsSession.MkDirAll( iLcRegdbFile ) );	    	
	    }
    
    // Generate the Db file
    iLcRegdbFile.Append( KLcPrivateDbName );

	// Check if the db file is exists or not.
    if( BaflUtils::FileExists( iFsSession, iLcRegdbFile ) )
        {
        OpenDbL( iLcRegdbFile );
        }
	else
		{
		CreateDbL( iLcRegdbFile );	
		}        
    }  

// ---------------------------------------------------------------------------
// void CLcRegAppStore::OpenDbL
// ---------------------------------------------------------------------------
//
void CLcRegAppStore::OpenDbL( const TFileName aRegAppInfoFile )
    {  	
    // if it is already open then close it.
    Close();
	// Check if the db file is exists or not.
    if( BaflUtils::FileExists( iFsSession, aRegAppInfoFile ) )
        {
		TRAPD(error, 
			iFileStore = CPermanentFileStore::OpenL( iFsSession, aRegAppInfoFile, 
				EFileRead|EFileWrite );
			//Set file store type	
			iFileStore->SetTypeL( iFileStore->Layout() );
			iRegAppInfoDb.OpenL( iFileStore,iFileStore->Root() )
			);

	    if( !error )
	    	{
	    	iDbStatus = ELcDbOpen;
	    	}
	    else
		    {
		    User::Leave( error );	
		    }
        }
    }

// ---------------------------------------------------------------------------
// void CLcRegAppStore::CreateDbL()
//
// Create a new database. The database will be in exclusive access mode.
// ---------------------------------------------------------------------------
void CLcRegAppStore::CreateDbL( const TFileName aRegAppInfoFile )
    {
    // if it is already open then close it.
    Close();

    // Create empty database file.
    TRAPD(error,
    	iFileStore = CPermanentFileStore::ReplaceL(iFsSession, aRegAppInfoFile, 
    		EFileRead|EFileWrite);
    	iFileStore->SetTypeL( iFileStore->Layout() );// Set file store type
    	TStreamId id = iRegAppInfoDb.CreateL( iFileStore );// Create stream object
    	iFileStore->SetRootL( id );// Keep database id as root of store
    	iFileStore->CommitL();// Complete creation by commiting
    	// Create appinfo tables
    	CreateAppInfoTableL();
    	);
    
    if( !error )
    	{
    	iDbStatus = ELcDbCreate;
    	}
    else
	    {
	    User::Leave( error );	
	    }
    }

// ---------------------------------------------------------------------------
// void CLcRegAppStore::Close()
//
// Close the database.
// ---------------------------------------------------------------------------
void CLcRegAppStore::Close()
    {
    iRegAppInfoDb.Close();
    delete iFileStore;
    iFileStore = NULL;
    }

// ---------------------------------------------------------------------------
// void CLcRegAppStore::CreateAppInfoTableL()
//
// Creates Appinfo table. Leaves, if the table cannot be created.
// ---------------------------------------------------------------------------
void CLcRegAppStore::CreateAppInfoTableL()
    {
    // Specify columns for appinfo table
    TDbCol uuidCol( KAppUUIdCol, EDbColLongText8,KMaxColumnLength );   // Using default length

    // Add the columns to column set
    CDbColSet* appInfoColSet = CDbColSet::NewLC();
    appInfoColSet->AddL( uuidCol );

    // Create the appinfo table
    User::LeaveIfError( iRegAppInfoDb.CreateTable(KAppInfoTable,
        *appInfoColSet) );
    CleanupStack::PopAndDestroy( appInfoColSet );
    }

// ---------------------------------------------------------------------------
// void CLcRegAppStore::AddDataToTable()
//
// Add item to database using RDbTable API
// ---------------------------------------------------------------------------
void CLcRegAppStore::AddDataToTableL( const TDesC8& aAppUid )
    {
    // Create an updateable database table object
    RDbTable table;
    CleanupClosePushL( table );
    
    User::LeaveIfError( table.Open( iRegAppInfoDb, KAppInfoTable, table.EUpdatable ));
    
	CDbColSet* dbColSet = table.ColSetL();
    CleanupStack::PushL( dbColSet );
	    
    //table.Reset();
    TBool lRowPos = table.FirstL();
    
    TDbColNo colNo = dbColSet->ColNo(KAppUUIdCol);
	    
    // Do first time insert and then do Update
    if( iDbStatus == ELcDbOpen && lRowPos )
        {
    	table.UpdateL();
       	table.SetColL( colNo, aAppUid ); // col = 1
        }
    else
        {
    	table.InsertL();
       	table.SetColL( colNo, aAppUid ); // col = 1
        iDbStatus = ELcDbOpen;    	    	
        }	        

    table.PutL();    // Complete changes (the insertion)

    CleanupStack::PopAndDestroy( dbColSet );    	
    CleanupStack::PopAndDestroy();
    }

// ---------------------------------------------------------------------------
// void CLcRegAppStore::GetUuidValueL()
//
// Get packed Uuid from database according to column name 
// ---------------------------------------------------------------------------
void CLcRegAppStore::GetUuidValueL(TDes8& aUuid)
    {
    aUuid.Zero();
    if(!BaflUtils::FileExists( iFsSession, iLcRegdbFile ) )
        {
        return;
        }

	_LIT(KSelectAll,"SELECT * FROM AppInfo" );

    // Create a view on the database
    RDbView view;
    CleanupClosePushL( view );
    TInt lResult = view.Prepare( iRegAppInfoDb, TDbQuery( KSelectAll ), view.EReadOnly );
    if( lResult == KErrNone )
	    {
	    lResult = view.EvaluateAll();

	    CDbColSet* colSet = view.ColSetL();
	    CleanupStack::PushL( colSet );

	    // Append each result row
	    if ( view.FirstL() )
	        {
	        view.GetL();
	    	TDbColNo colNo = colSet->ColNo( KAppUUIdCol );	        
	        RDbColReadStream readStream;       // A stream object for long columns
	        readStream.OpenLC( view, colNo );
	        readStream.ReadL( aUuid, view.ColLength( colNo ) );
	        CleanupStack::Pop(); //readStream
	        readStream.Close();
	        }
	    CleanupStack::PopAndDestroy( colSet );
	    }
    CleanupStack::PopAndDestroy( &view );
    }
// End of file