/*
 * 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.
 */

#pragma once

#ifndef GEODE_PERSISTENCEMANAGER_H_
#define GEODE_PERSISTENCEMANAGER_H_

#include <memory>

#include "Serializable.hpp"
#include "internal/geode_globals.hpp"

/**
 * @file
 */

namespace apache {
namespace geode {
namespace client {

class CacheableKey;
class Properties;
class PersistenceManager;
class Region;

typedef std::shared_ptr<PersistenceManager> (*getPersistenceManagerInstance)(
    const std::shared_ptr<Region>&);

/**
 * @class PersistenceManager PersistenceManager.hpp
 * PersistenceManager API for persistence and overflow.
 * This class abstracts the disk-related operations in case of persistence or
 * overflow to disk.
 * A specific disk storage implementation will implement all the methods
 * described here.
 */
class APACHE_GEODE_EXPORT PersistenceManager {
 public:
  /**
   * Returns the current persistence manager.
   * @return persistence manager
   */
  static std::shared_ptr<PersistenceManager> getPersistenceManager();

  /**
   * Writes a key, value pair of region to the disk. The actual file or database
   * related write operations should be implemented
   * in this method by the class implementing this method.
   * @param key the key to write.
   * @param value the value to write
   * @param persistenceInfo related persistence information.
   * @throws RegionDestroyedException is the region is already destroyed.
   * @throws OutofMemoryException if the disk is full
   * @throws DiskFailureException if the write fails due to disk fail.
   */
  virtual void write(const std::shared_ptr<CacheableKey>& key,
                     const std::shared_ptr<Cacheable>& value,
                     std::shared_ptr<void>& persistenceInfo) = 0;

  /**
   * Writes all the entries for a region. Refer persistance requirement doc for
   * the use case.
   * @throws DiskFailureException if the write fails due to disk fail.
   */
  virtual bool writeAll() = 0;

  /**
   * This method gets called after an implementation object is created.
   * Initializes all the implementation
   * specific environments needed.
   * @throws InitfailedException if the persistence manager cannot be
   * initialized.
   */
  virtual void init(const std::shared_ptr<Region>& region,
                    const std::shared_ptr<Properties>& diskProperties) = 0;

  /**
   * Reads the value for the key from the disk.
   * @param key is the key for which the value has to be read.
   * @param PersistenceInfo related persistence information.
   * @returns value of type std::shared_ptr<Cacheable>.
   * @throws DiskCorruptException if the data to be read is corrupt.
   */
  virtual std::shared_ptr<Cacheable> read(
      const std::shared_ptr<CacheableKey>& key,
      const std::shared_ptr<void>& PersistenceInfo) = 0;

  /**
   * Reads all the values from the region.
   * @return true
   */
  virtual bool readAll() = 0;

  /**
   * destroys the entry specified by the key in the argument.
   * @param key is the key of the entry which is being destroyed.
   * @param PersistenceInfo related persistence information.
   * @throws RegionDestroyedException is the region is already destroyed.
   * @throws EntryNotFoundException if the entry is not found on the disk.
   */
  virtual void destroy(const std::shared_ptr<CacheableKey>& key,
                       const std::shared_ptr<void>& PersistenceInfo) = 0;

  /**
   * Closes the persistence manager instance.
   * @throws ShutdownFailedException if close is not successful.
   */
  virtual void close() = 0;

  explicit PersistenceManager(const std::shared_ptr<Region>& regionPtr)
      : m_regionPtr(regionPtr) {}

  PersistenceManager() = default;

  virtual ~PersistenceManager() = default;

 protected:
  /** Region for this persistence manager.
   */
  std::shared_ptr<Region> m_regionPtr;
};
}  // namespace client
}  // namespace geode
}  // namespace apache

#endif  // GEODE_PERSISTENCEMANAGER_H_