lokinet/test/link/test_llarp_link.cpp

#include <crypto/crypto_libsodium.hpp>
#include <ev/ev.h>
#include <iwp/iwp.hpp>
#include <llarp_test.hpp>
#include <iwp/iwp.hpp>
#include <memory>
#include <messages/link_intro.hpp>
#include <messages/discard.hpp>

#include <test_util.hpp>

#include <gtest/gtest.h>

using namespace ::llarp;
using namespace ::testing;

struct LinkLayerTest : public test::LlarpTest< llarp::sodium::CryptoLibSodium >
{
  static constexpr uint16_t AlicePort = 41163;
  static constexpr uint16_t BobPort   = 8088;

  struct Context
  {
    Context()
    {
      keyManager = std::make_shared< KeyManager >();

      SecretKey signingKey;
      CryptoManager::instance()->identity_keygen(signingKey);
      keyManager->identityKey = signingKey;

      SecretKey encryptionKey;
      CryptoManager::instance()->encryption_keygen(encryptionKey);
      keyManager->encryptionKey = encryptionKey;

      SecretKey transportKey;
      CryptoManager::instance()->encryption_keygen(transportKey);
      keyManager->transportKey = transportKey;

      rc.pubkey = signingKey.toPublic();
      rc.enckey = encryptionKey.toPublic();
    }

    std::shared_ptr< thread::ThreadPool > worker;

    std::shared_ptr< KeyManager > keyManager;

    RouterContact rc;

    bool madeSession = false;
    bool gotLIM      = false;

    bool
    IsGucci() const
    {
      return gotLIM && madeSession;
    }

    void
    Setup()
    {
      worker = std::make_shared< thread::ThreadPool >(1, 128, "test-worker");
      worker->start();
    }

    const RouterContact&
    GetRC() const
    {
      return rc;
    }

    RouterID
    GetRouterID() const
    {
      return rc.pubkey;
    }

    std::shared_ptr< ILinkLayer > link;

    static std::string
    localLoopBack()
    {
#if defined(__FreeBSD__) || defined(__OpenBSD__) || defined(__NetBSD__) \
    || (__APPLE__ && __MACH__) || (__sun)
      return "lo0";
#else
      return "lo";
#endif
    }

    bool
    Start(std::shared_ptr< Logic > logic, llarp_ev_loop_ptr loop, uint16_t port)
    {
      if(!link)
        return false;
      if(!link->Configure(loop, localLoopBack(), AF_INET, port))
        return false;
      /*
       * TODO: ephemeral key management
      if(!link->GenEphemeralKeys())
        return false;
       */
      rc.addrs.emplace_back();
      if(!link->GetOurAddressInfo(rc.addrs[0]))
        return false;
      if(!rc.Sign(keyManager->identityKey))
        return false;
      return link->Start(logic, worker);
    }

    void
    Stop()
    {
      if(link)
        link->Stop();
      if(worker)
      {
        worker->drain();
        worker->stop();
      }
    }

    void
    TearDown()
    {
      link.reset();
      worker.reset();
    }
  };

  Context Alice;
  Context Bob;

  bool success           = false;
  const bool shouldDebug = false;

  llarp_ev_loop_ptr netLoop;
  std::shared_ptr< Logic > m_logic;

  llarp_time_t oldRCLifetime;
  llarp::LogLevel oldLevel;

  LinkLayerTest() : netLoop(nullptr)
  {
  }

  void
  SetUp()
  {
    oldLevel = llarp::LogContext::Instance().curLevel;
    if(shouldDebug)
      llarp::SetLogLevel(eLogTrace);
    oldRCLifetime              = RouterContact::Lifetime;
    RouterContact::BlockBogons = false;
    RouterContact::Lifetime    = 500ms;
    netLoop                    = llarp_make_ev_loop();
    m_logic.reset(new Logic());
    Alice.Setup();
    Bob.Setup();
  }

  void
  TearDown()
  {
    Alice.TearDown();
    Bob.TearDown();
    m_logic.reset();
    netLoop.reset();
    RouterContact::BlockBogons = true;
    RouterContact::Lifetime    = oldRCLifetime;
    llarp::SetLogLevel(oldLevel);
  }

  void
  RunMainloop()
  {
    m_logic->call_later(5s, std::bind(&LinkLayerTest::Stop, this));
    llarp_ev_loop_run_single_process(netLoop, m_logic);
  }

  void
  Stop()
  {
    Alice.Stop();
    Bob.Stop();
    llarp_ev_loop_stop(netLoop);
    m_logic->stop();
  }
};

TEST_F(LinkLayerTest, TestIWP)
{
#ifdef WIN32
  GTEST_SKIP();
#else
  auto sendDiscardMessage = [](ILinkSession* s, auto callback) -> bool {
    // send discard message in reply to complete unit test
    std::vector< byte_t > tmp(32);
    llarp_buffer_t otherBuf(tmp);
    DiscardMessage discard;
    if(!discard.BEncode(&otherBuf))
      return false;
    return s->SendMessageBuffer(std::move(tmp), callback);
  };
  Alice.link = iwp::NewInboundLink(
      // KeyManager
      Alice.keyManager,

      // GetRCFunc
      [&]() -> const RouterContact& { return Alice.GetRC(); },

      // LinkMessageHandler
      [&](ILinkSession* s, const llarp_buffer_t& buf) -> bool {
        llarp_buffer_t copy(buf.base, buf.sz);
        if(not Alice.gotLIM)
        {
          LinkIntroMessage msg;
          if(msg.BDecode(&copy))
          {
            Alice.gotLIM = s->GotLIM(&msg);
          }
        }
        return Alice.gotLIM;
      },

      // SignBufferFunc
      [&](Signature& sig, const llarp_buffer_t& buf) -> bool {
        return m_crypto.sign(sig, Alice.keyManager->identityKey, buf);
      },

      // SessionEstablishedHandler
      [&, this](ILinkSession* s) -> bool {
        const auto rc = s->GetRemoteRC();
        if(rc.pubkey != Bob.GetRC().pubkey)
          return false;
        LogInfo("alice established with bob");
        Alice.madeSession = true;
        sendDiscardMessage(s, [&](auto status) {
          success =
              status == llarp::ILinkSession::DeliveryStatus::eDeliverySuccess;
          LogInfo("message sent to bob suceess=", success);
          this->Stop();
        });
        return true;
      },

      // SessionRenegotiateHandler
      [&](RouterContact, RouterContact) -> bool { return true; },

      // TimeoutHandler
      [&](ILinkSession* session) {
        ASSERT_FALSE(session->IsEstablished());
        Stop();
      },

      // SessionClosedHandler
      [&](RouterID router) { ASSERT_EQ(router, Alice.GetRouterID()); },

      // PumpDoneHandler
      []() {});

  Bob.link = iwp::NewInboundLink(
      // KeyManager
      Bob.keyManager,

      // GetRCFunc
      [&]() -> const RouterContact& { return Bob.GetRC(); },

      // LinkMessageHandler
      [&](ILinkSession* s, const llarp_buffer_t& buf) -> bool {
        llarp_buffer_t copy(buf.base, buf.sz);
        if(not Bob.gotLIM)
        {
          LinkIntroMessage msg;
          if(msg.BDecode(&copy))
          {
            Bob.gotLIM = s->GotLIM(&msg);
          }
          return Bob.gotLIM;
        }
        DiscardMessage discard;
        if(discard.BDecode(&copy))
        {
          LogInfo("bog got discard message from alice");
          return true;
        }
        return false;
      },

      // SignBufferFunc
      [&](Signature& sig, const llarp_buffer_t& buf) -> bool {
        return m_crypto.sign(sig, Bob.keyManager->identityKey, buf);
      },

      // SessionEstablishedHandler
      [&](ILinkSession* s) -> bool {
        if(s->GetRemoteRC().pubkey != Alice.GetRC().pubkey)
          return false;
        LogInfo("bob established with alice");
        Bob.madeSession = true;

        return true;
      },

      // SessionRenegotiateHandler
      [&](RouterContact newrc, RouterContact oldrc) -> bool {
        return newrc.pubkey == oldrc.pubkey;
      },

      // TimeoutHandler
      [&](ILinkSession* session) { ASSERT_FALSE(session->IsEstablished()); },

      // SessionClosedHandler
      [&](RouterID router) { ASSERT_EQ(router, Alice.GetRouterID()); },

      // PumpDoneHandler
      []() {});

  ASSERT_TRUE(Alice.Start(m_logic, netLoop, AlicePort));
  ASSERT_TRUE(Bob.Start(m_logic, netLoop, BobPort));

  LogicCall(m_logic,
            [&]() { ASSERT_TRUE(Alice.link->TryEstablishTo(Bob.GetRC())); });

  RunMainloop();
  ASSERT_TRUE(Alice.IsGucci());
  ASSERT_TRUE(Bob.IsGucci());
  ASSERT_TRUE(success);
#endif
};