// Copyright (c) 1998-2009 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:

//

#include <jni.h>

#include "dbmsjni/com_symbian_store_StreamStore.h"

#include "StreamStore.h"

#include "Utils.h"

#include <s32stor.h>

#include <errortranslator.h>

extern CTrapCleanup* gCleanup; // clean-up stack

extern TPanicHandler gPanicHandler;

extern jclass gExcCls;

// //

// StreamStore class implementation

// nothing to implement

// //

// JNI implementations

JNIEXPORT jint JNICALL Java_com_symbian_store_StreamStore__1initNative

  (JNIEnv *aEnv, jobject) {

	if ( gCleanup == NULL ) {

		// init globals

		gCleanup=CTrapCleanup::New(); // get clean-up stack

		gPanicHandler = &SosPanicHandler;

		jclass excCls = aEnv->FindClass("java/lang/RuntimeException");

		if ( excCls == NULL )

			{

			printf("Could not create exception class java/lang/RuntimeException in DbmsConnection::init ...\n");

			return KErrGeneral;

			}

		else

			{

			gExcCls = (jclass)(aEnv->NewGlobalRef(excCls));

			if ( gExcCls == NULL )

				{

				printf("Could not create glref to exception class java/lang/RuntimeException in DbmsConnection::init ...\n");

				return KErrGeneral;

				}

			}

	}

	return KErrNone;

}

/*

 * Class:     com_symbian_store_StreamStore

 * Method:    _delete

 * Signature: (II)I

 */

JNIEXPORT jint JNICALL Java_com_symbian_store_StreamStore__1delete

  (JNIEnv *, jobject, jint aPeerHandle, jint aStreamId) {

	TStreamId strid(aStreamId);

	StreamStore* store = (StreamStore*) aPeerHandle;

	TRAPD(error, store->iStore->DeleteL(strid));

	return error;

}

/*

 * Class:     com_symbian_store_StreamStore

 * Method:    _compact

 * Signature: (I)I

 */

JNIEXPORT jint JNICALL Java_com_symbian_store_StreamStore__1compact

  (JNIEnv *, jobject, jint aPeerHandle) {

	StreamStore* store = (StreamStore*) aPeerHandle;

	TRAPD(error, store->iStore->CompactL());

	return error;

}

/*

 * Class:     com_symbian_store_StreamStore

 * Method:    _extend

 * Signature: (I)I

 */

JNIEXPORT jint JNICALL Java_com_symbian_store_StreamStore__1extend

  (JNIEnv *, jobject, jint aPeerHandle) {

	StreamStore* store = (StreamStore*) aPeerHandle;

	TInt strid;

	TRAPD(error, strid = (store->iStore->ExtendL()).Value());

	if ( error < KErrNone ) {

		return error;

	}

	return strid;

}

/*

 * Class:     com_symbian_store_StreamStore

 * Method:    _reclaim

 * Signature: (I)I

 */

JNIEXPORT jint JNICALL Java_com_symbian_store_StreamStore__1reclaim

  (JNIEnv *, jobject, jint aPeerHandle) {

	StreamStore* store = (StreamStore*) aPeerHandle;

	TRAPD(error, store->iStore->ReclaimL());

	return error;

}

/*

 * Class:     com_symbian_store_StreamStore

 * Method:    _commit

 * Signature: (I)I

 */

JNIEXPORT jint JNICALL Java_com_symbian_store_StreamStore__1commit

  (JNIEnv *, jobject, jint aPeerHandle) {

	StreamStore* store = (StreamStore*) aPeerHandle;

	TRAPD(error, store->iStore->CommitL());

	return error;

}

/*

 * Class:     com_symbian_store_StreamStore

 * Method:    _revert

 * Signature: (I)I

 */

JNIEXPORT jint JNICALL Java_com_symbian_store_StreamStore__1revert

  (JNIEnv *, jobject, jint aPeerHandle) {

	StreamStore* store = (StreamStore*) aPeerHandle;

	TRAPD(error, store->iStore->RevertL());

	return error;

}

JNIEXPORT jstring JNICALL Java_com_symbian_store_StreamStore__1translateNativeError

  (JNIEnv *aEnv, jclass, jint aErrorCode) {

	TBuf8<256> buf;

	TranslateError(aErrorCode, buf);

	TBuf<256> buf16;

	buf16.Copy(buf);

	jstring jstr = CreateJavaString(aEnv, buf16);

	return jstr;

}