#pragma once

#include <functional>

using namespace std;

namespace pEp {
    namespace Adapter {
        extern messageToSend_t _messageToSend;
        extern notifyHandshake_t _notifyHandshake;
        extern messageToSend_t _messageToSend_sync;
        extern notifyHandshake_t _notifyHandshake_sync;
        extern std::thread *_sync_thread;

        extern ::utility::locked_queue< SYNC_EVENT > q;
        extern std::mutex m;

        SYNC_EVENT _retrieve_next_sync_event(void *management, time_t threshold);

        template< class T > void sync_thread(T *obj, function< void(T *) > _startup, function< void(T *) > _shutdown)
        {
            PEP_STATUS status = register_sync_callbacks(session(), nullptr,
                _notifyHandshake, _retrieve_next_sync_event);
            throw_status(status);

            if (obj && _startup)
                _startup(obj);

            do_sync_protocol(session(), (void *)obj);
            unregister_sync_callbacks(session());

            session(release);

            if (obj && _shutdown)
                _shutdown(obj);
        }

        template< class T > void startup(
            messageToSend_t messageToSend,
            notifyHandshake_t notifyHandshake,
            messageToSend_t messageToSend_sync,
            notifyHandshake_t notifyHandshake_sync,
            T *obj,
            function< void(T *) > _startup,
            function< void(T *) > _shutdown
        )
        {
            if (messageToSend)
                _messageToSend = messageToSend;

            if (notifyHandshake)
                _notifyHandshake = notifyHandshake;

            if (messageToSend_sync)
                _messageToSend_sync = messageToSend_sync;

            if (notifyHandshake_sync)
                _notifyHandshake_sync = notifyHandshake_sync;

            session();

            {
                lock_guard<mutex> lock(m);

                if (!_sync_thread)
                    _sync_thread = new thread(sync_thread<T>, obj, _startup, _shutdown);
            }
        }
    }
}