////////////////////////////////////////////////////////////////////////////
//
// Copyright 2015 Realm Inc.
//
// Licensed 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.
//
////////////////////////////////////////////////////////////////////////////

#ifndef REALM_REALM_HPP
#define REALM_REALM_HPP

#include <memory>
#include <thread>
#include <vector>
#include <mutex>
#include <set>
#include <map>

#include "object_store.hpp"

namespace realm {
    class RealmCache;
    class Realm;
    typedef std::shared_ptr<Realm> SharedRealm;
    typedef std::weak_ptr<Realm> WeakRealm;
    class ClientHistory;

    class Realm : public std::enable_shared_from_this<Realm>
    {
      public:
        typedef std::function<void(SharedRealm old_realm, SharedRealm realm)> MigrationFunction;

        struct Config
        {
            std::string path;
            bool read_only;
            bool in_memory;
            std::unique_ptr<char[]> encryption_key;

            std::unique_ptr<Schema> schema;
            uint64_t schema_version;

            MigrationFunction migration_function;

            Config() : read_only(false), in_memory(false), schema_version(ObjectStore::NotVersioned) {};
            Config(const Config& c);
        };

        // Get a cached Realm or create a new one if no cached copies exists
        // Caching is done by path - mismatches for inMemory and readOnly Config properties
        // will raise an exception
        // If schema/schema_version is specified, update_schema is called automatically on the realm
        // and a migration is performed. If not specified, the schema version and schema are dynamically
        // read from the the existing Realm.
        static SharedRealm get_shared_realm(Config &config);

        // Updates a Realm to a given target schema/version creating tables and updating indexes as necessary
        // Uses the existing migration function on the Config, and the resulting Schema and version with updated
        // column mappings are set on the realms config upon success.
        // returns if any changes were made
        bool update_schema(Schema &schema, uint64_t version);

        const Config &config() const { return m_config; }

        void begin_transaction();
        void commit_transaction();
        void cancel_transaction();
        bool is_in_transaction() { return m_in_transaction; }

        bool refresh();
        void set_auto_refresh(bool auto_refresh) { m_auto_refresh = auto_refresh; }
        bool auto_refresh() { return m_auto_refresh; }
        void notify();

        typedef std::shared_ptr<std::function<void(const std::string)>> NotificationFunction;
        void add_notification(NotificationFunction &notification) { m_notifications.insert(notification); }
        void remove_notification(NotificationFunction notification) { m_notifications.erase(notification); }
        void remove_all_notifications() { m_notifications.clear(); }

        void invalidate();
        bool compact();

        std::thread::id thread_id() const { return m_thread_id; }
        void verify_thread();

        const std::string RefreshRequiredNotification = "RefreshRequiredNotification";
        const std::string DidChangeNotification = "DidChangeNotification";

      private:
        Realm(Config &config);

        Config m_config;
        std::thread::id m_thread_id;
        bool m_in_transaction;
        bool m_auto_refresh;

        std::set<NotificationFunction> m_notifications;
        void send_local_notifications(const std::string &notification);

        typedef std::unique_ptr<std::function<void()>> ExternalNotificationFunction;
        void send_external_notifications() { if (m_external_notifier) (*m_external_notifier)(); }

        std::unique_ptr<ClientHistory> m_history;
        std::unique_ptr<SharedGroup> m_shared_group;
        std::unique_ptr<Group> m_read_only_group;

        Group *m_group;

        static std::mutex s_init_mutex;

      public:
        ExternalNotificationFunction m_external_notifier;

        // FIXME private
        Group *read_group();
        static RealmCache s_global_cache;
    };

    class RealmCache
    {
      public:
        SharedRealm get_realm(const std::string &path, std::thread::id thread_id = std::this_thread::get_id());
        SharedRealm get_any_realm(const std::string &path);
        void remove(const std::string &path, std::thread::id thread_id);
        void cache_realm(SharedRealm &realm, std::thread::id thread_id = std::this_thread::get_id());
        void clear();

      private:
        std::map<std::string, std::map<std::thread::id, WeakRealm>> m_cache;
        std::mutex m_mutex;
    };

    class RealmFileException : public std::runtime_error
    {
      public:
        enum class Kind
        {
            /** Thrown for any I/O related exception scenarios when a realm is opened. */
            AccessError,
            /** Thrown if the user does not have permission to open or create
             the specified file in the specified access mode when the realm is opened. */
            PermissionDenied,
            /** Thrown if no_create was specified and the file did already exist when the realm is opened. */
            Exists,
            /** Thrown if no_create was specified and the file was not found when the realm is opened. */
            NotFound,
            /** Thrown if the database file is currently open in another
             process which cannot share with the current process due to an
             architecture mismatch. */
            IncompatibleLockFile,
        };
        RealmFileException(Kind kind, std::string message) : std::runtime_error(message), m_kind(kind) {}
        Kind kind() const { return m_kind; }
        
      private:
        Kind m_kind;
    };

    class MismatchedConfigException : public std::runtime_error
    {
      public:
        MismatchedConfigException(std::string message) : std::runtime_error(message) {}
    };

    class InvalidTransactionException : public std::runtime_error
    {
      public:
        InvalidTransactionException(std::string message) : std::runtime_error(message) {}
    };

    class IncorrectThreadException : public std::runtime_error
    {
      public:
        IncorrectThreadException(std::string message) : std::runtime_error(message) {}
    };

    class UnitializedRealmException : public std::runtime_error
    {
      public:
        UnitializedRealmException(std::string message) : std::runtime_error(message) {}
    };
}

#endif /* defined(REALM_REALM_HPP) */