/*

 * StxXercesInputStream.cpp

 *

 *  Created on: Dec 8, 2008

 *      Author: honza

 */

#include "string.h"

#include "assert.h"

#include "StxXercesInputStream.hpp"

#define CHUNK_SIZE 4096

#define MIN(a,b) (a < b ? a : b)

StxXercesInputStream::StxXercesInputStream(OBJ stx_stream) {

  stx_stream_refcell = (OBJ*)malloc(sizeof ( OBJ*) );

  *stx_stream_refcell = stx_stream;

  __ADD_REFCELL_CPP(stx_stream_refcell);

  /* Create buffer (instance of ByteArray) */

  stx_buffer_refcell = (OBJ*)malloc(sizeof ( OBJ*) );

  *stx_buffer_refcell = __BYTEARRAY_UNINITIALIZED_NEW_INT_CPP(CHUNK_SIZE);  

  __ADD_REFCELL_CPP(stx_buffer_refcell);

  /* Create nextBytes:into: symbol */

  stx_symbol_refcell = (OBJ*)malloc(sizeof ( OBJ*) );

  *stx_symbol_refcell = __MKSYMBOL_CPP("nextBytes:into:");

  __ADD_REFCELL_CPP(stx_symbol_refcell);

}

StxXercesInputStream::~StxXercesInputStream() {  

  __REMOVE_REFCELL_CPP ( stx_stream_refcell );

  free ( stx_stream_refcell );

  /* Free buffer */

  __REMOVE_REFCELL_CPP ( stx_buffer_refcell );

  free ( stx_buffer_refcell );

  /* Free nextBytes:into: symbol */

  __REMOVE_REFCELL_CPP ( stx_symbol_refcell );

  free ( stx_symbol_refcell );

}

unsigned int StxXercesInputStream::curPos() const {

  //TODO

  return 0;

}

unsigned int StxXercesInputStream::readBytes(XMLByte* const toFill, const unsigned int maxToRead) {  

  OBJ bytesRead;

  bytesRead = __SSEND2_CPP(*stx_stream_refcell, *stx_symbol_refcell, 0, __MKINT_CPP(MIN(CHUNK_SIZE, maxToRead)), *stx_buffer_refcell);

  strncpy((char*)toFill, (char*)(__ByteArrayInstPtr(*stx_buffer_refcell)->ba_element), __intVal(bytesRead));  

  return __intVal(bytesRead);

}

// takto implementovana by mela postacovat

const XMLCh* StxXercesInputStream::getContentType() const {

  return 0;

}