/*

 * 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(const File& aFile)

    : path(aFile)

    {}

  File path;

  Pool pool;

  apr_file_t* fileptr{ nullptr };

  void open();

};

IMPLEMENT_LOG4CXX_OBJECT(FileInputStream)

FileInputStream::FileInputStream(const LogString& filename) :

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

{

  m_priv->open();

}

FileInputStream::FileInputStream(const logchar* filename) :

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

{

  m_priv->open();

}

void FileInputStream::FileInputStreamPrivate::open()

{

  apr_fileperms_t perm = APR_OS_DEFAULT;

  apr_int32_t flags = APR_READ;

  apr_status_t stat = apr_file_open(&this->fileptr, this->path.getAPRPath(), flags, perm, this->pool.getAPRPool());

  if (stat != APR_SUCCESS)

  {

    throw IOException(this->path.getAPRPath(), stat);

  }

}

FileInputStream::FileInputStream(const File& aFile) :

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

{

  m_priv->open();

}

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.increment_position(bytesRead);

    retval = (int)bytesRead;

  }

  return retval;

}