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_