/*

 * Licensed to the Apache Software Foundation (ASF) under one or more

 * contributor license agreements.  See the NOTICE file distributed with

 * this work for additional information regarding copyright ownership.

 * The ASF licenses this file to You under the Apache License, Version 2.0

 * (the "License"); you may not use this file except in compliance with

 * the License.  You may obtain a copy of the License at

 *

 *      http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */

#include <log4cxx/logstring.h>

#include <log4cxx/helpers/fileinputstream.h>

#include <log4cxx/helpers/exception.h>

#include <log4cxx/helpers/bytebuffer.h>

#include <log4cxx/helpers/pool.h>

#include <apr_file_io.h>

using namespace LOG4CXX_NS;

using namespace LOG4CXX_NS::helpers;

struct FileInputStream::FileInputStreamPrivate

{

  FileInputStreamPrivate() : fileptr(nullptr) {}

  Pool pool;

  apr_file_t* fileptr;

};

IMPLEMENT_LOG4CXX_OBJECT(FileInputStream)

FileInputStream::FileInputStream(const LogString& filename) :

  m_priv(std::make_unique<FileInputStreamPrivate>())

{

  open(filename);

}

FileInputStream::FileInputStream(const logchar* filename) :

  m_priv(std::make_unique<FileInputStreamPrivate>())

{

  LogString fn(filename);

  open(fn);

}

void FileInputStream::open(const LogString& filename)

{

  apr_fileperms_t perm = APR_OS_DEFAULT;

  apr_int32_t flags = APR_READ;

  apr_status_t stat = File().setPath(filename).open(&m_priv->fileptr, flags, perm, m_priv->pool);

  if (stat != APR_SUCCESS)

  {

    throw IOException(filename, stat);

  }

}

FileInputStream::FileInputStream(const File& aFile) :

  m_priv(std::make_unique<FileInputStreamPrivate>())

{

  apr_fileperms_t perm = APR_OS_DEFAULT;

  apr_int32_t flags = APR_READ;

  apr_status_t stat = aFile.open(&m_priv->fileptr, flags, perm, m_priv->pool);

  if (stat != APR_SUCCESS)

  {

    throw IOException(aFile.getName(), stat);

  }

}

FileInputStream::~FileInputStream()

{

  if (m_priv->fileptr)

  {

    apr_file_close(m_priv->fileptr);

  }

}

void FileInputStream::close()

{

  apr_status_t stat = apr_file_close(m_priv->fileptr);

  if (stat == APR_SUCCESS)

  {

    m_priv->fileptr = NULL;

  }

  else

  {

    throw IOException(stat);

  }

}

int FileInputStream::read(ByteBuffer& buf)

{

  apr_size_t bytesRead = buf.remaining();

  apr_status_t stat = apr_file_read(m_priv->fileptr, buf.current(), &bytesRead);

  int retval = -1;

  if (!APR_STATUS_IS_EOF(stat))

  {

    if (stat != APR_SUCCESS)

    {

      throw IOException(stat);

    }

    buf.position(buf.position() + bytesRead);

    retval = (int)bytesRead;

  }

  return retval;

}