rfxCaptureProcess.h

Go to the documentation of this file.

/*********************************************************************************
** Copyright (c) 2024 MAK Technologies, Inc.
** All rights reserved.
*********************************************************************************/

#pragma once

#include <radarFxServer/export.h>
#include <radarFxServer/rfxBaseProcess.h>

#include <radarFxShared/rfxImageMessage.h>

#include <makArchives/DtObserverStateRecord.h>

#include <vrvUtil/DtWindowConfiguration.h>
#include <vrvUtil/DtSignalConnectionManager.h>

namespace makVrv
{
   class DtDe;
   class DtVideoStream;
   class DtObserver;
   class DtVideoFrameBuffer;
   class DtCoordinateSystem;
   class DtOsgChannel;
   class DtObserverMode;
}

namespace makRadarFx
{
   class DT_DLL_RFXSERVER DtCaptureProcess : public DtBaseProcess
   {
   public:

      struct DtImageCaptureConfig
      {
         DtImageCaptureConfig();
         virtual ~DtImageCaptureConfig();
         std::string myRequestorId;
         int myRequestId;

         bool myUseObserverLoc;
         bool myUseObserverOrientation;
         DtVector myOwnshipLocation;
         DtTaitBryan myOwnshipOrientation;

         double mySystemTime;

         DtVector myTargetLocation;

         std::string mySensorName;
         DtImageSize myImageSize;
         DtImageFormat myImageFormat;
         DtImageDataType myImageDataType;
         DtImageRotation myImageRotation;
         unsigned int myImageReturnMethod;
         std::string myImageSavePath;
         std::string myImageFilename;
         bool mySingleChannelRaw;

         DtVector myObserverOffsetLocation;
         DtTaitBryan myObserverOffsetOrientation;
         bool myRestoreState;
      };

   public:
      DtCaptureProcess(makVrv::DtDe& de, DtImageRequest* msg);
      virtual ~DtCaptureProcess();

      virtual void tick();

      virtual bool isDone();

      virtual void processFrame(makVrv::DtVideoFrameBuffer* frame) = 0;
      
      virtual DtImageCaptureConfig* captureConfiguration() const;

   protected:

      enum ProcessStep { WAITING, CONFIGURE_OBSERVER, CONFIGURE_VIEWPORT, WAIT_TERRAIN, FRAME_CAPTURE, CONFIGURE_OBSERVER_WAIT_FRAME, WAIT_FRAME, FRAME_RECEIVED, END_REQUEST, END_ERROR };

      struct DtObserverState
      {
         makArchives::DtObserverStateRecord myObserverState;
         makVrv::DtWindowConfiguration myWindowConfiguration;
         bool myIsValid;
      };

   protected:
      
      virtual void beginRequest();
      virtual void configureViewport();
      virtual void configureViewportHelper(const std::string& observerName, const makVrv::DtObserverMode& mode);
      virtual void configureObserver();
      virtual void waitTerrain();
      virtual void installFrameCapture();
      virtual void respondError(std::string errorMsg, DtImageError err) = 0;
      virtual void endRequest();

      virtual void restoreDisplay();

      virtual void configureSensor(const std::string& sensorName) = 0;

      virtual std::string generateFilename(const std::string& path, const std::string& filename, 
         DtImageFormat format);

      virtual bool pagingComplete(makVrv::DtDe& de, makVrv::DtOsgChannel* osgChannel);

      virtual void slot_coordinateSystemChanged();

   protected:

      DtImageCaptureConfig *myCaptureConfig;

      makVrv::DtSignalConnectionManager myConnections;
      
      makVrv::DtCoordinateSystem* myCoordinateSystem = nullptr;

      ProcessStep myProcessStep;

      makVrv::DtVideoStream* myVideoStream;
      makVrv::DtObserver* myObserver;
      DtObserverState* myOriginalState;

      double myWaitTime;
      int myWaitTerrainFrames;
      double myLastTime;
      double myTerrainTimeout;
      bool myTerrainTimeoutFlag;
      int myWaitFrameCount;
      int myNumFramesSinceForestsNotRendered;
   };
}