modules/tex/SessionCompilePdf.cpp

/*
 * SessionCompilePdf.cpp
 *
 * Copyright (C) 2021 by RStudio, PBC
 *
 * Unless you have received this program directly from RStudio pursuant
 * to the terms of a commercial license agreement with RStudio, then
 * this program is licensed to you under the terms of version 3 of the
 * GNU Affero General Public License. This program is distributed WITHOUT
 * ANY EXPRESS OR IMPLIED WARRANTY, INCLUDING THOSE OF NON-INFRINGEMENT,
 * MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE. Please refer to the
 * AGPL (http://www.gnu.org/licenses/agpl-3.0.txt) for more details.
 *
 */

#include "SessionCompilePdf.hpp"

#include <set>

#include <boost/format.hpp>
#include <boost/enable_shared_from_this.hpp>

#include <shared_core/FilePath.hpp>
#include <core/Exec.hpp>
#include <core/Settings.hpp>
#include <core/Algorithm.hpp>
#include <core/FileSerializer.hpp>
#include <core/system/ShellUtils.hpp>

#include <core/tex/TexLogParser.hpp>
#include <core/tex/TexMagicComment.hpp>

#include <r/RSexp.hpp>
#include <r/RExec.hpp>
#include <r/RRoutines.hpp>

#include <session/SessionModuleContext.hpp>
#include <session/projects/SessionProjects.hpp>
#include <session/prefs/UserPrefs.hpp>

#include "SessionPdfLatex.hpp"
#include "SessionRnwWeave.hpp"
#include "SessionRnwConcordance.hpp"
#include "SessionSynctex.hpp"
#include "SessionCompilePdfSupervisor.hpp"
#include "SessionViewPdf.hpp"
#include "SessionTexUtils.hpp"

using namespace rstudio::core;

namespace rstudio {
namespace session {
namespace modules {
namespace tex {
namespace compile_pdf {

namespace {

// track compile pdf state so we can send it to the client on client init
class CompilePdfState : boost::noncopyable
{
public:
   CompilePdfState()
      : tabVisible_(false), running_(false)
   {
   }

   virtual ~CompilePdfState() {}
   // COPYING: noncoypable

   Error readFromJson(const json::Object& asJson)
   {
      clear();
      return json::readObject(asJson,
                              "tab_visible", tabVisible_,
                              "running", running_,
                              "target_file", targetFile_,
                              "output", output_,
                              "errors", errors_);
   }


   void onStarted(const std::string& targetFile)
   {
      clear();
      running_ = true;
      tabVisible_ = true;
      targetFile_ = targetFile;
   }

   void addOutput(const std::string& output)
   {
      output_ += output;
   }

   void setErrors(const json::Array& errors)
   {
      errors_ = errors;
   }

   void onCompleted()
   {
      running_ = false;
   }

   void clear()
   {
      tabVisible_ = false;
      running_ = false;
      targetFile_.clear();
      output_.clear();
      errors_.clear();
   }

   json::Object asJson() const
   {
      json::Object obj;
      obj["tab_visible"] = tabVisible_;
      obj["running"] = running_;
      obj["target_file"] = targetFile_;
      obj["output"] = output_;
      obj["errors"] = errors_;
      return obj;
   }

private:
   bool tabVisible_;
   bool running_;
   std::string targetFile_;
   std::string output_;
   json::Array errors_;
};

CompilePdfState s_compilePdfState;

void onSuspend(Settings* pSettings)
{
   pSettings->set("compile_pdf_state", s_compilePdfState.asJson().write());
}


void onResume(const Settings& settings)
{
   std::string state = settings.get("compile_pdf_state");
   if (!state.empty())
   {
      json::Value stateJson;
      if (stateJson.parse(state))
      {
         LOG_WARNING_MESSAGE("invalid compile pdf state json");
         return;
      }

      Error error = s_compilePdfState.readFromJson(stateJson.getObject());
      if (error)
         LOG_ERROR(error);
   }
}

FilePath ancillaryFilePath(const FilePath& texFilePath, const std::string& ext)
{
   return texFilePath.getParent().completeChildPath(texFilePath.getStem() + ext);
}

bool isSynctexAvailable(const FilePath& texFilePath)
{
   return ancillaryFilePath(texFilePath, ".synctex.gz").exists() ||
          ancillaryFilePath(texFilePath, ".synctex").exists();
}

void enqueOutputEvent(const std::string& output)
{
   s_compilePdfState.addOutput(output);

   using namespace module_context;
   CompileOutput compileOutput(kCompileOutputNormal, output);

   ClientEvent event(client_events::kCompilePdfOutputEvent,
                     compileOutputAsJson(compileOutput));

   module_context::enqueClientEvent(event);
}

void enqueStartedEvent(const FilePath& texFilePath)
{
   std::string targetFile =
                module_context::createAliasedPath(texFilePath);

   s_compilePdfState.onStarted(targetFile);

   json::Object dataJson;
   dataJson["target_file"] = targetFile;
   FilePath pdfPath = ancillaryFilePath(texFilePath, ".pdf");
   dataJson["pdf_path"] = module_context::createAliasedPath(pdfPath);

   ClientEvent event(client_events::kCompilePdfStartedEvent,
                     dataJson);

   module_context::enqueClientEvent(event);
}

void enqueCompletedEvent(bool succeeded,
                         const json::Object& sourceLocation,
                         const FilePath& texFilePath)
{
   s_compilePdfState.onCompleted();

   json::Object dataJson;
   dataJson["succeeded"] = succeeded;
   dataJson["target_file"] =
                  module_context::createAliasedPath(texFilePath);

   FilePath pdfPath = ancillaryFilePath(texFilePath, ".pdf");
   dataJson["pdf_path"] = module_context::createAliasedPath(pdfPath);
   dataJson["view_pdf_url"] = tex::view_pdf::createViewPdfUrl(pdfPath);
   bool synctexAvailable = isSynctexAvailable(texFilePath);
   dataJson["synctex_available"] = synctexAvailable;
   if (synctexAvailable)
   {
      json::Value pdfLocation;
      Error error = modules::tex::synctex::forwardSearch(texFilePath,
                                                         sourceLocation,
                                                         &pdfLocation);
      if (error)
         LOG_ERROR(error);
      dataJson["pdf_location"] = pdfLocation;
   }

   ClientEvent event(client_events::kCompilePdfCompletedEvent,
                     dataJson);
   module_context::enqueClientEvent(event);
}

void enqueCompletedWithFailureEvent(const FilePath& texFilePath,
                                    json::Object& sourceLocation)
{
   enqueCompletedEvent(false, sourceLocation, texFilePath);
}

void enqueCompletedWithSuccessEvent(const FilePath& texFilePath,
                                    const json::Object& sourceLocation)
{
   enqueCompletedEvent(true, sourceLocation, texFilePath);
}

void enqueErrorsEvent(const json::Array& logEntriesJson)
{
   s_compilePdfState.setErrors(logEntriesJson);

   ClientEvent event(client_events::kCompilePdfErrorsEvent, logEntriesJson);
   module_context::enqueClientEvent(event);
}

// NOTE: sync changes with SessionModuleContext.cpp sourceMarkerJson
json::Object logEntryJson(const core::tex::LogEntry& logEntry)
{
   json::Object obj;
   obj["type"] = static_cast<int>(logEntry.type());
   obj["path"] = module_context::createAliasedPath(logEntry.filePath());
   obj["line"] = logEntry.line();
   obj["column"] = 1;
   obj["message"] = core::html_utils::HTML(logEntry.message()).text();
   obj["log_path"] = module_context::createAliasedPath(logEntry.logFilePath());
   obj["log_line"] = logEntry.logLine();
   obj["show_error_list"] = true;
   return obj;
}

void showLogEntries(const core::tex::LogEntries& logEntries,
                    const rnw_concordance::Concordances& rnwConcordances =
                                             rnw_concordance::Concordances())
{
   json::Array logEntriesJson;
   for (const core::tex::LogEntry& logEntry : logEntries)
   {
      using namespace tex::rnw_concordance;
      core::tex::LogEntry rnwEntry = rnwConcordances.fixup(logEntry);
      logEntriesJson.push_back(logEntryJson(rnwEntry));
   }

   enqueErrorsEvent(logEntriesJson);
}

void writeLogEntriesOutput(const core::tex::LogEntries& logEntries)
{
   if (logEntries.empty())
      return;

   std::string output = "\n";
   for (const core::tex::LogEntry& logEntry : logEntries)
   {
      switch(logEntry.type())
      {
         case core::tex::LogEntry::Error:
            output += "Error: ";
            break;
         case core::tex::LogEntry::Warning:
            output += "Warning: ";
            break;
         case core::tex::LogEntry::Box:
            output += "Bad Box: ";
            break;
      }

      output += logEntry.filePath().getFilename();
      int line = logEntry.line();
      if (line >= 0)
         output += ":" + safe_convert::numberToString(line);

      output += ": " + logEntry.message() + "\n";
   }
   output += "\n";

   enqueOutputEvent(output);

}


bool includeLogEntry(const core::tex::LogEntry& logEntry)
{
   return true;
}

// filter out log entries which we view as superflous or distracting
void filterLatexLog(const core::tex::LogEntries& logEntries,
                    core::tex::LogEntries* pFilteredLogEntries)
{
   core::algorithm::copy_if(logEntries.begin(),
                            logEntries.end(),
                            std::back_inserter(*pFilteredLogEntries),
                            includeLogEntry);
}

bool isLogEntryFromTargetFile(const core::tex::LogEntry& logEntry,
                              const FilePath& texPath)
{
   return logEntry.filePath() == texPath;
}

void getLogEntries(const FilePath& texPath,
                   core::tex::LogEntries* pLogEntries)
{
   // latex log file
   FilePath logPath = ancillaryFilePath(texPath, ".log");
   if (logPath.exists())
   {
      core::tex::LogEntries logEntries;
      Error error = core::tex::parseLatexLog(logPath, &logEntries);
      if (error)
         LOG_ERROR(error);

      filterLatexLog(logEntries, pLogEntries);

      // re-arrange so that issues in the target file always end up at the top
      // of the error display
      std::partition(pLogEntries->begin(),
                     pLogEntries->end(),
                     boost::bind(isLogEntryFromTargetFile, _1, texPath));
   }

   // bibtex log file
   core::tex::LogEntries bibtexLogEntries;
   logPath = ancillaryFilePath(texPath, ".blg");
   if (logPath.exists())
   {
      Error error = core::tex::parseBibtexLog(logPath, &bibtexLogEntries);
      if (error)
         LOG_ERROR(error);
   }

   // concatenate them together
   std::copy(bibtexLogEntries.begin(),
             bibtexLogEntries.end(),
             std::back_inserter(*pLogEntries));
}

void removeExistingAncillary(const FilePath& texFilePath,
                             const std::string& extension)
{
   Error error = ancillaryFilePath(texFilePath, extension).removeIfExists();
   if (error)
      LOG_ERROR(error);
}

void removeExistingLatexAncillaryFiles(const FilePath& texFilePath)
{
   removeExistingAncillary(texFilePath, ".log");
   removeExistingAncillary(texFilePath, ".blg");
   removeExistingAncillary(texFilePath, ".synctex");
   removeExistingAncillary(texFilePath, ".synctex.gz");
 }

std::string buildIssuesMessage(const core::tex::LogEntries& logEntries)
{
   if (logEntries.empty())
      return std::string();

   // count error types
   int errors = 0, warnings = 0, badBoxes = 0;
   for (const core::tex::LogEntry& logEntry : logEntries)
   {
      if (logEntry.type() == core::tex::LogEntry::Error)
         errors++;
      else if (logEntry.type() == core::tex::LogEntry::Warning)
         warnings++;
      else if (logEntry.type() == core::tex::LogEntry::Box)
         badBoxes++;
   }

   std::string issues;
   boost::format fmt("%1% %2%");
   if (errors > 0)
   {
      issues += boost::str(fmt % errors % "error");
      if (errors > 1)
         issues += "s";
   }
   if (warnings > 0)
   {
      if (!issues.empty())
         issues += ", ";
      issues += boost::str(fmt % warnings % "warning");
      if (warnings > 1)
         issues += "s";
   }
   if (badBoxes > 0)
   {
      if (!issues.empty())
         issues += ", ";
      issues += boost::str(fmt % badBoxes % "bad");
      if (badBoxes > 1)
         issues += "boxes";
      else
         issues += "box";
   }

   if (!issues.empty())
      return "Issues: " + issues;
   else
      return std::string();
}

class AuxillaryFileCleanupContext : boost::noncopyable
{
public:
   AuxillaryFileCleanupContext()
      : cleanLog_(true)
   {
   }

   virtual ~AuxillaryFileCleanupContext()
   {
      try
      {
         cleanup();
      }
      catch(...)
      {
      }
   }

   void init(const FilePath& targetFilePath)
   {
      basePath_ = targetFilePath.getParent().completeChildPath(
         targetFilePath.getStem()).getAbsolutePath();
   }

   void preserveLog()
   {
      cleanLog_ = false;
   }

   void preserveLogReferencedFiles(
               const core::tex::LogEntries& logEntries)
   {
      for (const core::tex::LogEntry& logEntry : logEntries)
      {
         logRefFiles_.insert(logEntry.filePath());
      }
   }

   void cleanup()
   {
      if (!basePath_.empty())
      {
         // remove known auxillary files
         remove(".out");
         remove(".aux");

         // only clean bbl if .bib exists
         if (exists(".bib"))
            remove(".bbl");

         // clean anciallary logs if requested (never clean latex log)
         if (cleanLog_)
         {
            remove(".blg");
         }

         // reset base path so we only do this once
         basePath_.clear();
      }
   }

private:
   bool exists(const std::string& extension)
   {
      return FilePath(basePath_ + extension).exists();
   }

   // remove the specified file (but don't if it's referenced
   // from the log)
   void remove(const std::string& extension)
   {
      FilePath filePath(basePath_ + extension);
      if (logRefFiles_.find(filePath) == logRefFiles_.end())
      {
         Error error = filePath.removeIfExists();
         if (error)
            LOG_ERROR(error);
      }
   }

private:
   std::string basePath_;
   bool cleanLog_;
   std::set<FilePath> logRefFiles_;
};

// implement pdf compilation within a class so we can maintain state
// accross the various async callbacks the compile is composed of
class AsyncPdfCompiler : boost::noncopyable,
                    public boost::enable_shared_from_this<AsyncPdfCompiler>
{
public:
   static void start(const FilePath& targetFilePath,
                     const std::string& encoding,
                     const json::Object& sourceLocation,
                     const boost::function<void()>& onCompleted)
   {
      boost::shared_ptr<AsyncPdfCompiler> pCompiler(
            new AsyncPdfCompiler(targetFilePath,
                                 encoding,
                                 sourceLocation,
                                 onCompleted));

      pCompiler->start();
   }

   virtual ~AsyncPdfCompiler() {}

private:
   AsyncPdfCompiler(const FilePath& targetFilePath,
                    const std::string& encoding,
                    const json::Object& sourceLocation,
                    const boost::function<void()>& onCompleted)
      : targetFilePath_(targetFilePath),
        encoding_(encoding),
        sourceLocation_(sourceLocation),
        onCompleted_(onCompleted)
   {
      if (targetFilePath_.exists())
      {
         Error error = core::system::realPath(targetFilePath_, &targetFilePath_);
         if (error)
            LOG_ERROR(error);
      }
   }

   void start()
   {
      // enque started event
      enqueStartedEvent(targetFilePath_);

      // terminate if the file doesn't exist
      if (!targetFilePath_.exists())
      {
         terminateWithError("Target document not found: '" +
                               targetFilePath_.getAbsolutePath() + "'");
         return;
      }

      // ensure no spaces in path
      std::string filename = targetFilePath_.getFilename();
      if (filename.find(' ') != std::string::npos)
      {
         terminateWithError("Invalid filename: '" + filename +
                     "' (TeX does not understand paths with spaces)");
         return;
      }

      // parse magic comments
      Error error = core::tex::parseMagicComments(targetFilePath_,
                                                  &magicComments_);
      if (error)
         LOG_ERROR(error);

      // add tinytex to the PATH if appropriate
      module_context::addTinytexToPathIfNecessary();

      // determine tex program path
      std::string userErrMsg;
      if (!pdflatex::latexProgramForFile(magicComments_,
                                         &texProgramPath_,
                                         &userErrMsg))
      {
         terminateWithError(userErrMsg);
         return;
      }

      // see if we need to weave
      std::string ext = targetFilePath_.getExtensionLowerCase();
      bool isRnw = ext == ".rnw" || ext == ".snw" || ext == ".nw" || ext == ".rtex";
      if (isRnw)
      {
         // remove existing ancillary files + concordance
         removeExistingLatexAncillaryFiles(targetFilePath_);
         removeExistingAncillary(targetFilePath_, "-concordance.tex");

         // attempt to weave the rnw
         rnw_weave::runWeave(targetFilePath_,
                             encoding_,
                             magicComments_,
                             enqueOutputEvent,
                             boost::bind(
                              &AsyncPdfCompiler::onWeaveCompleted,
                                 AsyncPdfCompiler::shared_from_this(), _1));
      }
      else if (prefs::userPrefs().useTinytex())
      {
         runTinytex(targetFilePath_);
      }
      else
      {
         runLatexCompiler(false);
      }

   }

private:

   void onWeaveCompleted(const rnw_weave::Result& result)
   {
      if (result.succeeded)
      {
         if (prefs::userPrefs().useTinytex())
         {
            // compute tex file path
            std::string texFileName = targetFilePath_.getStem() + ".tex";
            FilePath texFilePath = targetFilePath_.getParent().completePath(texFileName);
            runTinytex(texFilePath);
         }
         else
         {
            runLatexCompiler(true, result.concordances);
         }
      }
      else if (!result.errorLogEntries.empty())
         terminateWithErrorLogEntries(result.errorLogEntries);
      else
         terminateWithError(result.errorMessage);
   }

   void onTinytexOutput(const std::string& output)
   {
      enqueOutputEvent(output);
   }

   void onTinytexCompileCompleted(int status, const std::string& output)
   {
      onLatexCompileCompleted(status, targetFilePath_);
   }

   void runTinytex(const FilePath& latexFilePath)
   {
      Error error;

      // build arguments
      using Argument = std::pair<std::string, std::string>;
      std::vector<Argument> latexmkArgs;

      std::string file = latexFilePath.getAbsolutePath();
      latexmkArgs.push_back({std::string(), shell_utils::escape(file)});

      std::string engine = string_utils::toLower(prefs::userPrefs().defaultLatexProgram());
      latexmkArgs.push_back({"engine", shell_utils::escape(engine)});

      bool clean = prefs::userPrefs().cleanTexi2dviOutput();
      latexmkArgs.push_back({"clean", clean ? "TRUE" : "FALSE"});

      if (prefs::userPrefs().latexShellEscape())
      {
         latexmkArgs.push_back({"engine_args", shell_utils::escape("-shell-escape")});
      }

      auto collapse = [](const Argument& argument)
      {
         return argument.first.empty()
               ? argument.second
               : argument.first + " = " + argument.second;
      };

      std::string arguments = core::algorithm::join(
               latexmkArgs.begin(),
               latexmkArgs.end(),
               ", ",
               collapse);

      std::string code =
            "cat('Compiling document with tinytex ... ');"
            "invisible(tinytex::latexmk(" + arguments + "))";

      codePath_ = module_context::tempFile("tinytex-runner-", ".R");
      error = writeStringToFile(codePath_, code);
      if (error)
      {
         terminateWithError(error.getSummary());
         return;
      }

      FilePath rScriptPath;
      error = module_context::rScriptPath(&rScriptPath);
      if (error)
      {
         terminateWithError(error.getSummary());
         return;
      }

      std::vector<std::string> args;
      args.push_back("-s");
      args.push_back("-f");
      args.push_back(string_utils::utf8ToSystem(codePath_.getAbsolutePath()));

      error = compile_pdf_supervisor::runProgram(
               rScriptPath,
               args,
               tex::utils::rTexInputsEnvVars(),
               latexFilePath.getParent(),
               boost::bind(
                  &AsyncPdfCompiler::onTinytexOutput,
                  AsyncPdfCompiler::shared_from_this(),
                  _1),
               boost::bind(
                  &AsyncPdfCompiler::onTinytexCompileCompleted,
                  AsyncPdfCompiler::shared_from_this(),
                  _1,
                  _2));

      if (error)
         terminateWithError("Unable to compile pdf: " + error.getSummary());

   }

   void runLatexCompiler(bool targetWeaved,
                         const rnw_concordance::Concordances& concordances =
                                            rnw_concordance::Concordances())
   {
      // configure pdflatex options
      pdflatex::PdfLatexOptions options;
      options.fileLineError = false;
      options.syncTex = !isTargetRnw() || !concordances.empty();
      options.shellEscape = prefs::userPrefs().latexShellEscape();

      // get back-end version info
      core::system::ProcessResult result;
      Error error = core::system::runProgram(
                  string_utils::utf8ToSystem(texProgramPath_.getAbsolutePath()),
                  core::shell_utils::ShellArgs() << "--version",
                  "",
                  core::system::ProcessOptions(),
                  &result);
      if (error)
         LOG_ERROR(error);
      else if (result.exitStatus != EXIT_SUCCESS)
         LOG_ERROR_MESSAGE("Error probing for latex version: "+ result.stdErr);
      else
         options.versionInfo = result.stdOut;

      // compute tex file path
      FilePath texFilePath;
      if (targetWeaved)
      {
         texFilePath = targetFilePath_.getParent().completePath(
                                          targetFilePath_.getStem() + ".tex");
      }
      else
      {
         texFilePath = targetFilePath_;
      }

      // remove log files if they exist (avoids confusion created by parsing
      // old log files for errors)
      removeExistingLatexAncillaryFiles(texFilePath);

      // setup cleanup context if clean was specified
      if (prefs::userPrefs().cleanTexi2dviOutput())
         auxillaryFileCleanupContext_.init(texFilePath);

      // run latex compile

      // this is our "simulated" texi2dvi -- this was originally
      // coded as a sequence of sync calls to pdflatex, bibtex, and
      // makeindex. re-coding it as async is going to be a bit
      // involved so considering that this is not the default
      // codepath we'll leave it sync for now (and then just call
      // the (typically) async callback function onLatexCompileCompleted
      // directly after the function returns

      enqueOutputEvent("Running " + texProgramPath_.getFilename() +
                       " on " + texFilePath.getFilename() + "...");

      error = tex::pdflatex::texToPdf(texProgramPath_,
                                      texFilePath,
                                      options,
                                      &result);

      if (error)
      {
         terminateWithError("Unable to compile pdf: " + error.getSummary());
      }
      else
      {
         onLatexCompileCompleted(result.exitStatus,
                                 texFilePath,
                                 concordances);
      }

   }

   void onLatexCompileCompleted(int exitStatus,
                                const FilePath& texFilePath,
                                const rnw_concordance::Concordances& concords = rnw_concordance::Concordances())
   {
      // remove code file if we had one
      codePath_.removeIfExists();

      // collect errors from the log
      core::tex::LogEntries logEntries;
      getLogEntries(texFilePath, &logEntries);

      // determine whether they will be shown in the list
      // list or within the console
      bool showIssuesList = !isTargetRnw() || !concords.empty();

      // notify the cleanp context of log entries (so it can
      // preserve any referenced files)
      auxillaryFileCleanupContext_.preserveLogReferencedFiles(
                                                      logEntries);

      // show log entries and build issues message
      std::string issuesMsg;
      if (showIssuesList && !logEntries.empty())
      {
         showLogEntries(logEntries, concords);
         issuesMsg = buildIssuesMessage(logEntries);
      }

      if (exitStatus == EXIT_SUCCESS)
      {
         FilePath pdfPath = ancillaryFilePath(texFilePath, ".pdf");
         std::string pdfFile = module_context::createAliasedPath(
                                                          pdfPath);
         std::string completed = "completed\n\nCreated PDF: " + pdfFile + "\n";
         if (!issuesMsg.empty())
            completed += "\n" + issuesMsg;
         enqueOutputEvent(completed);

         // show issues in console if necessary
         if (!showIssuesList)
             writeLogEntriesOutput(logEntries);

         if (onCompleted_)
            onCompleted_();

         enqueCompletedWithSuccessEvent(targetFilePath_, sourceLocation_);
      }
      else
      {
         std::string failedMsg = "failed\n";
         if (!issuesMsg.empty())
            failedMsg += "\n" + issuesMsg;
         enqueOutputEvent(failedMsg);

         // don't remove the log
         auxillaryFileCleanupContext_.preserveLog();

         // if there were no error found in the log file then just
         // print the error and exit code
         if (logEntries.empty())
         {
            boost::format fmt("Error running %1% (exit code %2%)");
            std::string msg(boost::str(fmt % texProgramPath_.getAbsolutePath()
                                           % exitStatus));
            enqueOutputEvent(msg + "\n");
         }

         // show issues in console if necessary
         if (!showIssuesList)
            writeLogEntriesOutput(logEntries);

         enqueCompletedWithFailureEvent(targetFilePath_, sourceLocation_);
      }
   }

   void terminateWithError(const std::string& message)
   {
      enqueOutputEvent(message + "\n");
      enqueCompletedWithFailureEvent(targetFilePath_, sourceLocation_);
   }

   void terminateWithErrorLogEntries(const core::tex::LogEntries& logEntries)
   {
      showLogEntries(logEntries);
      enqueCompletedWithFailureEvent(targetFilePath_, sourceLocation_);
   }

   bool isTargetRnw() const
   {
      return targetFilePath_.getExtensionLowerCase() == ".rnw" ||
             targetFilePath_.getExtensionLowerCase() == ".rtex";
   }

private:
   FilePath targetFilePath_;
   FilePath codePath_;
   std::string encoding_;
   json::Object sourceLocation_;
   const boost::function<void()> onCompleted_;
   core::tex::TexMagicComments magicComments_;
   FilePath texProgramPath_;
   AuxillaryFileCleanupContext auxillaryFileCleanupContext_;
};


} // anonymous namespace


bool startCompile(const core::FilePath& targetFilePath,
                  const std::string& encoding,
                  const json::Object& sourceLocation,
                  const boost::function<void()>& onCompleted)
{
   if (!compile_pdf_supervisor::hasRunningChildren())
   {
      AsyncPdfCompiler::start(targetFilePath,
                              encoding,
                              sourceLocation,
                              onCompleted);
      return true;
   }
   else
   {
      return false;
   }
}

bool compileIsRunning()
{
   return compile_pdf_supervisor::hasRunningChildren();
}

bool terminateCompile()
{
   Error error = compile_pdf_supervisor::terminateAll(
                                             boost::posix_time::seconds(1));
   if (error)
   {
      LOG_ERROR(error);
      return false;
   }
   else
   {
      enqueOutputEvent("\n[Compile PDF Stopped]\n");
      return true;
   }
}

void notifyTabClosed()
{
   s_compilePdfState.clear();
}

json::Object currentStateAsJson()
{
   return s_compilePdfState.asJson();
}

Error initialize()
{
   // register suspend handler
   using namespace module_context;
   addSuspendHandler(SuspendHandler(boost::bind(onSuspend, _2), onResume));

   return Success();
}

} // namespace compile_pdf
} // namespace tex
} // namespace modules
} // namespace session
} // namespace rstudio