RemoteProtocol.hxx

Go to the documentation of this file.

#pragma once
 
#include "../../services/ISubject.hxx"
#include "../../core/include/RepositoryManager.hxx"
 
#include <string>
#include <vector>
#include <unordered_set>
#include <memory>
#include <iostream>

 */
namespace svcs::server {
 
using namespace svcs::core;
using namespace svcs::services;

class RemoteProtocol {
public:
    RemoteProtocol(std::shared_ptr<ISubject> event_bus,
                   std::shared_ptr<RepositoryManager> repository_manager);

    ~RemoteProtocol() = default;

    bool handleReceivePack();

    bool handleUploadPack();
 
private:
    // Receive-pack (Push) Protocol Methods
    bool processPushNegotiation();

    bool receiveObjects(const std::unordered_set<std::string>& wanted_objects);

    bool updateReferences(const std::vector<std::pair<std::string, std::string>>& ref_updates);
 
    // Upload-pack (Pull) Protocol Methods
    bool processPullNegotiation();

    std::unordered_set<std::string> findMissingObjects(const std::unordered_set<std::string>& client_has);

    bool sendObjects(const std::unordered_set<std::string>& objects_to_send);
 
    // Object and Reference Management Methods
    bool objectExists(const std::string& object_hash) const;

    std::string readObject(const std::string& object_hash) const;

    bool writeObject(const std::string& object_hash, const std::string& object_data);

    std::unordered_set<std::string> getAllReferences() const;

    bool updateReference(const std::string& ref_name, const std::string& new_hash);
 
    // Protocol Communication Methods
    bool readLine(std::string& line) const;

    bool sendLine(const std::string& line) const;

    bool sendData(const std::string& data) const;

    bool sendError(const std::string& error) const;
 
    // Validation Methods
    bool isValidObjectHash(const std::string& hash) const;

    bool isValidReference(const std::string& ref_name) const;
 
    // Notification Methods
    void notifyDebug(const std::string& message) const;

    void notifyInfo(const std::string& message) const;

    void notifyError(const std::string& message) const;

    void notifyProtocolStart(const std::string& message) const;

    void notifyProtocolSuccess(const std::string& message) const;

    void notifyProtocolError(const std::string& message) const;

    void notifyNetworkSend(const std::string& message) const;

    void notifyNetworkReceive(const std::string& message) const;

    void notifyObjectTransfer(const std::string& message) const;

    void notifyReferenceUpdate(const std::string& message) const;

    void notifyNegotiation(const std::string& message) const;

    bool sendProtocolError(const std::string& error) const;
 
private:
    std::shared_ptr<ISubject> event_bus_;

    std::shared_ptr<RepositoryManager> repository_manager_;
};
 
}