implement publish command

Signed-off-by: Rafał Malinowski <rafal.przemyslaw.malinowski@gmail.com>

Author: vogel

docs/software/commands.md

@@ -60,6 +60,9 @@ stellar-core can be controlled via the following commands.
   controls type used for printing (default: auto).<br>
   Option --base64 alters the behavior to work on base64-encoded XDR rather than
   raw XDR.
+* **publish**: Execute publish of all items remaining in publish queue without
+  connecting to network. May not publish last checkpoint if last closed ledger
+  is on checkpoint boundary.
 * **report-last-history-checkpoint**: Download and report last history
   checkpoint from a history archive.
 * **run**: Runs stellar-core service.

src/main/ApplicationUtils.cpp

@@ -425,4 +425,54 @@ catchup(Application::pointer app, CatchupConfiguration cc,
     catchupInfo = app->getJsonInfo();
     return synced ? 0 : 3;
 }
+
+int
+publish(Application::pointer app)
+{
+    if (!checkInitialized(app))
+    {
+        return 1;
+    }
+
+    // set known cursors before starting maintenance job
+    ExternalQueue ps(*app);
+    ps.setInitialCursors(app->getConfig().KNOWN_CURSORS);
+    app->getMaintainer().start();
+
+    auto done = false;
+    app->getLedgerManager().loadLastKnownLedger(
+        [&done](asio::error_code const& ec) {
+            if (ec)
+            {
+                throw std::runtime_error(
+                    "Unable to restore last-known ledger state");
+            }
+
+            done = true;
+        });
+    auto& clock = app->getClock();
+    while (!done && clock.crank(true))
+        ;
+
+    auto& io = clock.getIOService();
+    asio::io_service::work mainWork(io);
+
+    auto lcl = app->getLedgerManager().getLastClosedLedgerNum();
+    auto isCheckpoint =
+        lcl == app->getHistoryManager().checkpointContainingLedger(lcl);
+    auto expectedPublishQueueSize = isCheckpoint ? 1 : 0;
+
+    app->getHistoryManager().publishQueuedHistory();
+    while (app->getHistoryManager().publishQueueLength() !=
+               expectedPublishQueueSize &&
+           clock.crank(true))
+    {
+    }
+
+    LOG(INFO) << "*";
+    LOG(INFO) << "* Publish finished.";
+    LOG(INFO) << "*";
+
+    return 0;
+}
 }

src/main/ApplicationUtils.h

@@ -25,4 +25,5 @@ void writeCatchupInfo(Json::Value const& catchupInfo,
                       std::string const& outputFile);
 int catchup(Application::pointer app, CatchupConfiguration cc,
             Json::Value& catchupInfo);
+int publish(Application::pointer app);
 }

src/main/CommandLine.cpp

@@ -414,6 +414,21 @@ runCatchup(CommandLineArgs const& args)
                        });
 }
 
+int
+runPublish(CommandLineArgs const& args)
+{
+    CommandLine::ConfigOption configOption;
+
+    return runWithHelp(args, {configurationParser(configOption)}, [&] {
+        auto config = configOption.getConfig();
+        config.setNoListen();
+
+        VirtualClock clock(VirtualClock::REAL_TIME);
+        auto app = Application::create(clock, config, false);
+        return publish(app);
+    });
+}
+
 int
 runCheckQuorum(CommandLineArgs const& args)
 {
@@ -712,6 +727,11 @@ handleCommandLine(int argc, char* const* argv)
          {"offline-info", "return information for an offline instance",
           runOfflineInfo},
          {"print-xdr", "pretty-print one XDR envelope, then quit", runPrintXdr},
+         {"publish",
+          "execute publish of all items remaining in publish queue without "
+          "connecting to network, may not publish last checkpoint if last "
+          "closed ledger is on checkpoint boundary",
+          runPublish},
          {"report-last-history-checkpoint",
           "report information about last checkpoint available in "
           "history archives",