collaboration_service.h

Go to the documentation of this file.

#ifndef YAZE_APP_NET_COLLABORATION_SERVICE_H_
#define YAZE_APP_NET_COLLABORATION_SERVICE_H_
 
#include <memory>
#include <string>
#include <vector>
 
#include "absl/status/status.h"
#include "app/net/rom_version_manager.h"
#include "app/net/websocket_client.h"
#include "app/rom.h"
 
namespace yaze {
 
namespace net {
 
class CollaborationService {
 public:
  struct Config {
    bool auto_sync_enabled = true;
    int sync_interval_ms = 5000;  // 5 seconds
    bool require_approval_for_sync = true;
    bool create_snapshot_before_sync = true;
  };
  
  explicit CollaborationService(Rom* rom);
  ~CollaborationService();
  
  absl::Status Initialize(
      const Config& config,
      RomVersionManager* version_mgr,
      ProposalApprovalManager* approval_mgr);
  
  absl::Status Connect(const std::string& host, int port = 8765);
  
  void Disconnect();
  
  absl::Status HostSession(
      const std::string& session_name,
      const std::string& username,
      bool ai_enabled = true);
  
  absl::Status JoinSession(
      const std::string& session_code,
      const std::string& username);
  
  absl::Status LeaveSession();
  
  absl::Status SubmitChangesAsProposal(
      const std::string& description,
      const std::string& username);
  
  absl::Status ApplyRomSync(
      const std::string& diff_data,
      const std::string& rom_hash,
      const std::string& sender);
  
  absl::Status HandleIncomingProposal(
      const std::string& proposal_id,
      const nlohmann::json& proposal_data,
      const std::string& sender);
  
  absl::Status VoteOnProposal(
      const std::string& proposal_id,
      bool approved,
      const std::string& username);
  
  absl::Status ApplyApprovedProposal(const std::string& proposal_id);
  
  bool IsConnected() const;
  
  absl::StatusOr<SessionInfo> GetSessionInfo() const;
  
  WebSocketClient* GetClient() { return client_.get(); }
  
  void SetAutoSync(bool enabled);
  
 private:
  Rom* rom_;
  RomVersionManager* version_mgr_;
  ProposalApprovalManager* approval_mgr_;
  std::unique_ptr<WebSocketClient> client_;
  Config config_;
  
  // Sync state
  std::string last_sync_hash_;
  bool sync_in_progress_;
  
  // Callbacks for network events
  void OnRomSyncReceived(const nlohmann::json& payload);
  void OnProposalReceived(const nlohmann::json& payload);
  void OnProposalUpdated(const nlohmann::json& payload);
  void OnParticipantJoined(const nlohmann::json& payload);
  void OnParticipantLeft(const nlohmann::json& payload);
  
  // Helper functions
  std::string GenerateDiff(const std::string& from_hash, const std::string& to_hash);
  absl::Status ApplyDiff(const std::string& diff_data);
  bool ShouldAutoSync();
};
 
}  // namespace net
 
}  // namespace yaze
 
#endif  // YAZE_APP_NET_COLLABORATION_SERVICE_H_