ThreadApi.hpp

#ifndef _PRIVMXLIB_ENDPOINT_THREAD_THREADAPI_HPP_
#define _PRIVMXLIB_ENDPOINT_THREAD_THREADAPI_HPP_
 
#include <memory>
#include <optional>
#include <string>
#include <vector>
 
#include "privmx/endpoint/core/Connection.hpp"
#include "privmx/endpoint/core/Types.hpp"
#include "privmx/endpoint/thread/Types.hpp"
#include <privmx/endpoint/core/ExtendedPointer.hpp>
 
namespace privmx {
namespace endpoint {
namespace thread {
 
class ThreadApiImpl;

class ThreadApi : public privmx::endpoint::core::ExtendedPointer<ThreadApiImpl>  {
public:
    static ThreadApi create(core::Connection& connetion);

    ThreadApi();
    ThreadApi(const ThreadApi& obj);
    ThreadApi& operator=(const ThreadApi& obj);
    ThreadApi(ThreadApi&& obj);
    ~ThreadApi();

    std::string createThread(const std::string& contextId, const std::vector<core::UserWithPubKey>& users,
                             const std::vector<core::UserWithPubKey>& managers, const core::Buffer& publicMeta, 
                             const core::Buffer& privateMeta, const std::optional<core::ContainerPolicy>& policies = std::nullopt);
    
    void updateThread(const std::string& threadId, const std::vector<core::UserWithPubKey>& users,
                      const std::vector<core::UserWithPubKey>& managers, const core::Buffer& publicMeta, const core::Buffer& privateMeta,
                      const int64_t version, const bool force, const bool forceGenerateNewKey, const std::optional<core::ContainerPolicy>& policies = std::nullopt);

    void deleteThread(const std::string& threadId);

    Thread getThread(const std::string& threadId);

    core::PagingList<Thread> listThreads(const std::string& contextId, const core::PagingQuery& pagingQuery);
    
    Message getMessage(const std::string& messageId);
    
    core::PagingList<Message> listMessages(const std::string& threadId, const core::PagingQuery& pagingQuery);
    
    std::string sendMessage(const std::string& threadId, const core::Buffer& publicMeta,
                            const core::Buffer& privateMeta, const core::Buffer& data);
    
    void deleteMessage(const std::string& messageId);

    void updateMessage(const std::string& messageId, const core::Buffer& publicMeta,
                            const core::Buffer& privateMeta, const core::Buffer& data);

    std::vector<std::string> subscribeFor(const std::vector<std::string>& subscriptionQueries);

    void unsubscribeFrom(const std::vector<std::string>& subscriptionIds);

    std::string buildSubscriptionQuery(EventType eventType, EventSelectorType selectorType, const std::string& selectorId);
 
private:
    ThreadApi(const std::shared_ptr<ThreadApiImpl>& impl);
};
 
}  // namespace thread
}  // namespace endpoint
}  // namespace privmx
 
#endif  // _PRIVMXLIB_ENDPOINT_THREAD_THREADAPI_HPP_