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_