luaEmbarkationEgressPointsQueryJob.h

Go to the documentation of this file.

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

#pragma once

#include "vrfLua/vrfLuaDefines.h"
#include "vrfLua/luaAsyncJob.h"
#include "vrfobjcore/vrfObject.h"
#include "vrfutil/scriptGeometry.h"
#include "vrfutil/asciiSerializable.h"
#include "vrfutil/algorithmManager.h"
#include "vrfmsgs/ifEmbarkationSlotInformationResponse.h"
#include "vrfmsgs/ifEmbarkationEgressPointsResponse.h"

#include "vlutil/vlMutex.h"

#include <luabind/luabind.hpp>

#include <boost/scoped_ptr.hpp>

class DtSimManager;
class DtSimMessage;

class DT_DLL_vrfLua DtLuaEmbarkationEgressPointsQueryJob : public DtLuaAsyncJob
{
public:
   typedef std::vector<DtLocation3D> Points;

   static boost::shared_ptr<DtLuaEmbarkationEgressPointsQueryJob> Make(
      DtSimManager* mgr,
      DtSharedVrfObjectReference queryingObject,
      DtSharedVrfObjectReference objectToBeQueried);

   DtLuaEmbarkationEgressPointsQueryJob();

   ~DtLuaEmbarkationEgressPointsQueryJob();

   luabind::object getObject(lua_State* L, int& index, std::string& message);

   luabind::object getDebugObject(lua_State* L) { return luabind::newtable(L); }

   virtual void cancel(lua_State* L) {};

   static void responseCallback(DtSimMessage* msg, void* usr);
   virtual void processResponse(DtSimMessage* msg);

   //
   //

   static DtAsciiSerializable* creator();

   DtString serialize();
   bool deserialize(const DtString&);
   DtString objectType() const;

   boost::shared_ptr<DtLuaEmbarkationEgressPointsQueryJob> shared_from_this();
   boost::shared_ptr<const DtLuaEmbarkationEgressPointsQueryJob> shared_from_this() const;

protected:

   static int nextRequestId()
   {
      static int theRequestId = 0;

      return ++theRequestId;
   }

   class PathTask;
   friend class PathTask;

   DtLuaEmbarkationEgressPointsQueryJob(
      DtSimManager* mgr,
      DtSharedVrfObjectReference queryingObject,
      DtSharedVrfObjectReference objectToBeQueried);

   void start();

   void taskComplete();

   DtSharedVrfObjectReference myQueryingObject;
   DtSharedVrfObjectReference myObjectBeingQueried;

   int myRequestId;

   bool myGotResponse;
   //DtIfEmbarkationSlotInformationResponse::SlotInformationMap mySlotInfo;
   DtIfEmbarkationEgressPointsResponse::EgressPointInformationMap myEgressInfo;

   typedef DtMutex Mutex;

   mutable Mutex myMutex;
};