LongOpControllerManager.h

#pragma once
 
#include <EditorEngineProcessFramework/LongOps/Implementation/LongOpManager.h>
 
class plLongOpProxy;
 
struct plLongOpControllerEvent
{
  enum class Type
  {
    OpAdded,    
    OpRemoved,  
    OpProgress, 
  };
 
  Type m_Type;
  plUuid m_OperationGuid; 
};
 
class PL_EDITORENGINEPROCESSFRAMEWORK_DLL plLongOpControllerManager final : public plLongOpManager
{
  PL_DECLARE_SINGLETON(plLongOpControllerManager);
 
public:
  plLongOpControllerManager();
  ~plLongOpControllerManager();
 
  struct ProxyOpInfo
  {
    plUniquePtr<plLongOpProxy> m_pProxyOp;
    plUuid m_OperationGuid;     
    plUuid m_DocumentGuid;      
    plUuid m_ComponentGuid;     
    plTime m_StartOrDuration;   
    float m_fCompletion = 0.0f; 
    bool m_bIsRunning = false;  
  };
 
  plEvent<const plLongOpControllerEvent&> m_Events;
 
  void RegisterLongOp(const plUuid& documentGuid, const plUuid& componentGuid, const char* szLongOpType);
 
  void UnregisterLongOp(const plUuid& documentGuid, const plUuid& componentGuid, const char* szLongOpType);
 
  void StartOperation(plUuid opGuid);
 
  void CancelOperation(plUuid opGuid);
 
  void CancelAndRemoveAllOpsForDocument(const plUuid& documentGuid);
 
  ProxyOpInfo* GetOperation(const plUuid& opGuid);
 
  const plDynamicArray<plUniquePtr<ProxyOpInfo>>& GetOperations() const { return m_ProxyOps; }
 
private:
  virtual void ProcessCommunicationChannelEventHandler(const plProcessCommunicationChannel::Event& e) override;
 
  void ReplicateToWorkerProcess(ProxyOpInfo& opInfo);
  void BroadcastProgress(ProxyOpInfo& opInfo);
  void RemoveOperation(plUuid opGuid);
 
  plDynamicArray<plUniquePtr<ProxyOpInfo>> m_ProxyOps;
};