// 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 <stdio.h>
#include "dbmsjni/com_symbian_store_StoreInputStream.h"
#include "StoreInputStream.h"
#include "Utils.h"
#include "errortranslator.h"

#define THROW_IOE_IF_ERROR(a,jni) if ( a != KErrNone ) {\
	TBuf8<256> exception;\
	TBuf8<256> message;\
	GetException(a, exception, message);\
	exception.Append('\0');\
	message.Append('\0');\
	ThrowExc(jni, exception, message);\
	return a;\
}

#define THROW_IOE_IF_ERROR_STR(a,jni) if ( a != KErrNone ) {\
	TBuf8<256> exception;\
	TBuf8<256> message;\
	GetException(a, exception, message);\
	exception.Append('\0');\
	message.Append('\0');\
	ThrowExc(jni, exception, message);\
	return NULL;\
}

// //
// StoreInputStream class implementation


// //
// JNI implementations


JNIEXPORT void JNICALL Java_com_symbian_store_StoreInputStream__1close
  (JNIEnv *, jobject, jint aPeerHandle) {
	StoreInputStream* stream = (StoreInputStream*)aPeerHandle;
	stream->iInput->Close();
	delete stream->iInput;
	delete stream;
}

//*
// * Class:     com_symbian_store_StoreInputStream
// * Method:    _create
// * Signature: (I)I
// */
//JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1create
//  (JNIEnv *, jobject, jint aStorePeerHandle, jint aStrId) {
//	StreamStore* streamStore = (StreamStore*)aStorePeerHandle;
//	StoreInputStream* inStream = new StoreInputStream();
//	inStream->iInput = new RStoreReadStream();
//	TStreamId id ( aStrId);
//	TRAPD(error, inStream->iInput->OpenL(*(streamStore->iStore), id));
//	if ( error < 0 ) {
//		return error;
//	}
//	return (jint)inStream;
//}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readByte
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readByte
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jint result = 0;
	TRAPD(err, result = os->iInput->ReadInt8L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readBytes
 * Signature: (I[BII)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readBytes
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jbyteArray aBuffer, jint aFrom, jint aLen) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf8 buf;
	TRAPD(err, buf.CreateL(aLen));
	THROW_IOE_IF_ERROR(err, aEnv);
	TRAP(err, os->iInput->ReadL(buf));
	THROW_IOE_IF_ERROR(err, aEnv);
	aEnv->SetByteArrayRegion(aBuffer, aFrom, aLen, (jbyte*)(buf.Ptr()));
	buf.Close();
	return aLen;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readInt16
 * Signature: (I)S
 */
JNIEXPORT jshort JNICALL Java_com_symbian_store_StoreInputStream__1readInt16
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jshort result = 0;
	TRAPD(err, result = os->iInput->ReadInt16L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readInt32
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readInt32
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jint result = 0;
	TRAPD(err, result = os->iInput->ReadInt32L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
}

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readInt8
 * Signature: (I)B
 */
JNIEXPORT jbyte JNICALL Java_com_symbian_store_StoreInputStream__1readInt8
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jbyte result = 0;
	TRAPD(err, result = os->iInput->ReadInt8L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
  }
/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readReal32
 * Signature: (I)F
 */
JNIEXPORT jfloat JNICALL Java_com_symbian_store_StoreInputStream__1readReal32
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jfloat result = 0;
	TRAPD(err, result = os->iInput->ReadReal32L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
  }

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readReal64
 * Signature: (I)D
 */
JNIEXPORT jdouble JNICALL Java_com_symbian_store_StoreInputStream__1readReal64
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jdouble result = 0;
	TRAPD(err, result = os->iInput->ReadReal64L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
  }

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readUInt32
 * Signature: (I)J
 */
JNIEXPORT jlong JNICALL Java_com_symbian_store_StoreInputStream__1readUInt32
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jlong result = 0;
	TRAPD(err, result = os->iInput->ReadUint32L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readUInt16
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readUInt16
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jint result = 0;
	TRAPD(err, result = os->iInput->ReadUint16L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readUInt8
 * Signature: (I)S
 */
JNIEXPORT jshort JNICALL Java_com_symbian_store_StoreInputStream__1readUInt8
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	jshort result = 0;
	TRAPD(err, result = os->iInput->ReadUint8L());
	THROW_IOE_IF_ERROR(err, aEnv);
	return result;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readDes16
 * Signature: (II)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_symbian_store_StoreInputStream__1readDes16__II
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jint aLen) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf16 buf;
	TRAPD(err, buf.CreateL(aLen));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TRAP(err, os->iInput->ReadL(buf, aLen));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	jstring string = CreateJavaString(aEnv, buf);
	buf.Close();
	return string;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readDes16
 * Signature: (I[SI)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readDes16__I_3SI
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jshortArray aBuffer, jint aLen) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf16 buf;
	TRAPD(err, buf.CreateL(aLen));
	THROW_IOE_IF_ERROR(err, aEnv);
	TRAP(err, os->iInput->ReadL(buf));
	THROW_IOE_IF_ERROR(err, aEnv);
	aEnv->SetShortArrayRegion(aBuffer, 0, aLen, (jshort*)(buf.Ptr()));
	buf.Close();
	return aLen;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readDes16
 * Signature: (IC)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_symbian_store_StoreInputStream__1readDes16__IC
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jchar aDelimiter) {
	THROW_IOE_IF_ERROR_STR(KErrNotSupported, aEnv);
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readDes16
 * Signature: (I[SC)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readDes16__I_3SC
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jshortArray aArray, jchar aDelimiter) {
	THROW_IOE_IF_ERROR(KErrNotSupported, aEnv);
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readDes8
 * Signature: (I[BC)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readDes8
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jbyteArray aArray, jchar aDelimiter) {
	THROW_IOE_IF_ERROR(KErrNotSupported, aEnv);
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readDes8String
 * Signature: (IC)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_symbian_store_StoreInputStream__1readDes8String__IC
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jchar aDelimiter) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf16 buf;
	RBuf8 buf8;
	TInt mxlen = 8192;
	TRAPD(err, buf.CreateL(mxlen));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TRAP(err, buf8.CreateL(mxlen));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TChar ch(aDelimiter);
	TRAP(err, os->iInput->ReadL(buf8, ch));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	buf.Copy(buf8);
	jstring string = CreateJavaString(aEnv, buf);
	buf.Close();
	buf8.Close();
	return string;
}


/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readDes8String
 * Signature: (II)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_symbian_store_StoreInputStream__1readDes8String__II
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jint aLen) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf16 buf;
	RBuf8 buf8;
	TRAPD(err, buf.CreateL(aLen));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TRAP(err, buf8.CreateL(aLen));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TRAP(err, os->iInput->ReadL(buf8));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	buf.Copy(buf8);
	jstring string = CreateJavaString(aEnv, buf);
	buf.Close();
	buf8.Close();
	return string;
}


void doReadCardinalityL(JNIEnv *aEnv, jobject, jint aPeerHandle, TCardinality& card) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	(*(os->iInput))>>card;
}

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readCardinality
 * Signature: (I)I
 */
JNIEXPORT jint JNICALL Java_com_symbian_store_StoreInputStream__1readCardinality
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	TCardinality card;
	TRAPD(err, doReadCardinalityL(aEnv, NULL, aPeerHandle, card));
	THROW_IOE_IF_ERROR(err, aEnv);
	return card;
}

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readBuf8
 * Signature: (I)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_symbian_store_StoreInputStream__1readBuf8
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jint aMaxSize) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf8 buf;
	TRAPD(err, buf.CreateL(aMaxSize));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TRAP(err, InternalizeL(buf, *(os->iInput)) );
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	RBuf buf16;
	TRAP(err, buf16.CreateL(aMaxSize));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	buf16.Copy(buf);
	jstring string = CreateJavaString(aEnv, buf16);
	buf.Close();
	buf16.Close();
	return string;
}

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readBuf16
 * Signature: (I)Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_symbian_store_StoreInputStream__1readBuf16
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jint aMaxSize) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf16 buf;
	TRAPD(err, buf.CreateL(aMaxSize));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TRAP(err, InternalizeL(buf, *(os->iInput)) );
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	jstring string = CreateJavaString(aEnv, buf);
	buf.Close();
	return string;
}

JNIEXPORT jbyteArray JNICALL Java_com_symbian_store_StoreInputStream__1readBuf8Raw
  (JNIEnv *aEnv, jobject, jint aPeerHandle, jint aMaxSize) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	RBuf8 buf;
	TRAPD(err, buf.CreateL(aMaxSize));
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	TRAP(err, InternalizeL(buf, *(os->iInput)) );
	THROW_IOE_IF_ERROR_STR(err, aEnv);
	jbyteArray buffer = aEnv->NewByteArray(buf.Length());
	aEnv->SetByteArrayRegion(buffer, 0, buf.Length(), (jbyte *)(buf.Ptr()));
	buf.Close();
	return buffer;
}

void doReadInt64L(JNIEnv *aEnv, jobject, jint aPeerHandle, TInt64& value) {
	StoreInputStream* os = (StoreInputStream*)aPeerHandle;
	(*(os->iInput))>>value;
}

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readInt64
 * Signature: (I)J
 */
JNIEXPORT jlong JNICALL Java_com_symbian_store_StoreInputStream__1readInt64
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	TInt64 value;
	TRAPD(err, doReadInt64L(aEnv, NULL, aPeerHandle, value));
	THROW_IOE_IF_ERROR(err, aEnv);
	return (jlong)value;
}

/*
 * Class:     com_symbian_store_StoreInputStream
 * Method:    _readUInt64
 * Signature: (I)J
 */
JNIEXPORT jlong JNICALL Java_com_symbian_store_StoreInputStream__1readUInt64
  (JNIEnv *aEnv, jobject, jint aPeerHandle) {
	// cant read TUint64 as that is not supported by stream. Must read Int64 instead
	TInt64 value;
	TRAPD(err, doReadInt64L(aEnv, NULL, aPeerHandle, value));
	THROW_IOE_IF_ERROR(err, aEnv);
	return (jlong)value;
}