StoreApi.hpp

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

class StoreApi : public privmx::endpoint::core::ExtendedPointer<StoreApiImpl> {
public:
    static StoreApi create(core::Connection& connection);

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

    std::string createStore(
        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 updateStore(
        const std::string& storeId,
        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 deleteStore(const std::string& storeId);

    Store getStore(const std::string& storeId);

    core::PagingList<Store> listStores(const std::string& contextId, const core::PagingQuery& pagingQuery);

    int64_t createFile(
        const std::string& storeId,
        const core::Buffer& publicMeta,
        const core::Buffer& privateMeta,
        const int64_t size,
        bool randomWriteSupport = false
    );

    int64_t updateFile(
        const std::string& fileId,
        const core::Buffer& publicMeta,
        const core::Buffer& privateMeta,
        const int64_t size
    );

    void updateFileMeta(const std::string& fileId, const core::Buffer& publicMeta, const core::Buffer& privateMeta);

    void writeToFile(const int64_t fileHandle, const core::Buffer& dataChunk, bool truncate = false);

    void deleteFile(const std::string& fileId);

    File getFile(const std::string& fileId);

    core::PagingList<File> listFiles(const std::string& storeId, const core::PagingQuery& pagingQuery);

    int64_t openFile(const std::string& fileId);

    core::Buffer readFromFile(const int64_t fileHandle, const int64_t length);

    void seekInFile(const int64_t fileHandle, const int64_t position);

    std::string closeFile(const int64_t fileHandle);

    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
    );

    void syncFile(const int64_t fileHandle);
 
private:
    StoreApi(const std::shared_ptr<StoreApiImpl>& impl);
};
 
} // namespace store
} // namespace endpoint
} // namespace privmx
 
#endif // _PRIVMXLIB_ENDPOINT_STORE_STOREAPI_HPP_