ScriptCommandRelay.cpp

Go to the documentation of this file.

/**********************************************************************
 
   Audacity - A Digital Audio Editor
   Copyright 1999-2018 Audacity Team
   File License: wxWidgets
 
   Dan Horgan
 
******************************************************************//****************************************************************//*******************************************************************/
 
#include "ScriptCommandRelay.h"
 
#include "CommandTargets.h"
#include "CommandBuilder.h"
#include "ActiveProject.h"
#include "AppCommandEvent.h"
#include "Project.h"
#include <wx/app.h>
#include <thread>
 
static int ExecCommand(wxString *pIn, wxString *pOut, bool fromMain)
{
   if (auto pProject = ::GetActiveProject().lock()) {
      CommandBuilder builder(*pProject, *pIn);
      if (builder.WasValid())
      {
         OldStyleCommandPointer cmd = builder.GetCommand();
 
         AppCommandEvent ev;
         ev.SetCommand(cmd);
 
         if (fromMain)
         {
            // Use SafelyProcessEvent, which stops exceptions, because this is
            // expected to be reached from within the XLisp runtime
            wxTheApp->SafelyProcessEvent(ev);
         }
         else
         {
            // Send the event to the main thread
            wxTheApp->AddPendingEvent(ev);
         }
      }
 
      // Wait for and retrieve the response
      *pOut = builder.GetResponse();
   }
   else
      *pOut = wxString{};
 
   return 0;
}
 
static int ExecFromWorker(wxString *pIn, wxString *pOut)
{
   return ExecCommand(pIn, pOut, false);
}
 
int ExecFromMain(wxString *pIn, wxString *pOut)
{
   return ExecCommand(pIn, pOut, true);
}
 
void ScriptCommandRelay::StartScriptServer(tpRegScriptServerFunc scriptFn)
{
   wxASSERT(scriptFn != NULL);
 
   auto server = [](tpRegScriptServerFunc function)
   {
      while (true)
      {
         function(ExecFromWorker);
      }
   };
 
   std::thread(server, scriptFn).detach();
}