Irohad: Check ledger keypair on init

Signed-off-by: Alexander Matson <alexmat2on@protonmail.com>

irohad/ametsuchi/impl/postgres_wsv_query.cpp

@@ -96,8 +96,14 @@ namespace iroha {
                 soci::use(public_key.hex(), "public_key"));
       });
 
-      return getPeersFromSociRowSet(result) | [](auto &&peers) {
-        return boost::make_optional(std::move(peers.front()));
+      return getPeersFromSociRowSet(result) | [](auto &&peers)
+                 -> boost::optional<
+                     std::shared_ptr<shared_model::interface::Peer>> {
+        if (!peers.empty()) {
+          assert(peers.size() == 1);
+          return boost::make_optional(std::move(peers.front()));
+        }
+        return boost::none;
       };
     }
   }  // namespace ametsuchi

irohad/main/application.cpp

@@ -156,6 +156,7 @@ Irohad::RunResult Irohad::init() {
                                       // to be sure it is consistent
   }
   | [this]{ return restoreWsv();}
+  | [this]{ return validateKeypair();}
   | [this]{ return initTlsCredentials();}
   | [this]{ return initPeerCertProvider();}
   | [this]{ return initCryptoProvider();}
@@ -324,6 +325,17 @@ Irohad::RunResult Irohad::restoreWsv() {
   };
 }
 
+Irohad::RunResult Irohad::validateKeypair() {
+  auto peers = storage->createPeerQuery() | [this](auto &&peer_query) {
+    return peer_query->getLedgerPeerByPublicKey(keypair.publicKey());
+  };
+  if (not peers) {
+    log_->warn("There is no peer in the ledger with my public key!");
+  }
+
+  return {};
+}
+
 /**
  * Initializing own TLS credentials.
  */

irohad/main/application.hpp

@@ -143,6 +143,11 @@ class Irohad {
    */
   RunResult restoreWsv();
 
+  /**
+   * Check that the provided keypair is present in the ledger
+   */
+  RunResult validateKeypair();
+
   /**
    * Drop wsv and block store
    */