#pragma once

#include <string>
#include <mutex>
#include <queue>
#include <condition_variable>

namespace smtp::message
{
    struct Message
    {
        std::string subject;
        std::string text;
    };

    class ThreadSafeQueue
    {
    public:
        ThreadSafeQueue() = default;
        ~ThreadSafeQueue() = default;

        void Push( Message const& message );
        std::shared_ptr<Message> WaitAndPop();
    private:
        mutable std::mutex mMutex;
        std::queue<Message> mMessageQueue;
        std::condition_variable mCondition;
    };
}