// Copyright 2018 Proyectos y Sistemas de Mantenimiento SL (eProsima).

//

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

/**

 * @file PersistenceFactory.cpp

 *

 */

#include <rtps/persistence/PersistenceService.h>

#if HAVE_SQLITE3

#include <rtps/persistence/SQLite3PersistenceService.h>

#endif // if HAVE_SQLITE3

#include <fastdds/rtps/attributes/PropertyPolicy.hpp>

#include <fastdds/rtps/history/WriterHistory.hpp>

namespace eprosima {

namespace fastdds {

namespace rtps {

std::vector<CacheChange_t*>& IPersistenceService::get_changes(

        WriterHistory* history)

{

    return history->m_changes;

}

void IPersistenceService::set_fragments(

        WriterHistory* history,

        CacheChange_t* change)

{

    history->set_fragments(change);

}

IPersistenceService* PersistenceFactory::create_persistence_service(

        const PropertyPolicy& property_policy)

{

    IPersistenceService* ret_val = nullptr;

    const std::string* plugin_property = PropertyPolicyHelper::find_property(property_policy, "dds.persistence.plugin");

    if (plugin_property != nullptr)

    {

#if HAVE_SQLITE3

        if (plugin_property->compare("builtin.SQLITE3") == 0)

        {

            const std::string* filename_property = PropertyPolicyHelper::find_property(property_policy,

                            "dds.persistence.sqlite3.filename");

#ifdef ANDROID

            const char* filename = (filename_property == nullptr) ?

                    "/data/local/tmp/persistence.db" : filename_property->c_str();

#else

            const char* filename = (filename_property == nullptr) ?

                    "persistence.db" : filename_property->c_str();

#endif // if ANDROID

            bool update_schema = false;

            const std::string* update_schema_value = PropertyPolicyHelper::find_property(property_policy,

                            "dds.persistence.update_schema");

            if (update_schema_value != nullptr &&

                    ((update_schema_value->compare("TRUE") == 0) ||

                    (update_schema_value->compare("true") == 0)))

            {

                update_schema = true;

            }

            ret_val = create_SQLite3_persistence_service(filename, update_schema);

        }

#endif // if HAVE_SQLITE3

    }

    return ret_val;

}

} /* namespace rtps */

} /* namespace fastdds */

} /* namespace eprosima */