1 files changed, 0 insertions, 376 deletions
diff --git a/libtransport/src/implementation/p2psecure_socket_producer.cc b/libtransport/src/implementation/p2psecure_socket_producer.cc
deleted file mode 100644
index 3748001fc..000000000
--- a/libtransport/src/implementation/p2psecure_socket_producer.cc
+++ /dev/null
@@ -1,376 +0,0 @@
-/*
- * Copyright (c) 2017-2020 Cisco and/or its affiliates.
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at:
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#include <hicn/transport/core/interest.h>
-#include <implementation/p2psecure_socket_producer.h>
-// #include <implementation/tls_rtc_socket_producer.h>
-#include <implementation/tls_socket_producer.h>
-#include <interfaces/tls_rtc_socket_producer.h>
-#include <interfaces/tls_socket_producer.h>
-#include <openssl/bio.h>
-#include <openssl/rand.h>
-#include <openssl/ssl.h>
-
-namespace transport {
-namespace implementation {
-
-/* Workaround to prevent content with expiry time equal to 0 to be lost when
- * pushed in the forwarder */
-#define HICN_HANDSHAKE_CONTENT_EXPIRY_TIME 100;
-
-P2PSecureProducerSocket::P2PSecureProducerSocket(
-    interface::ProducerSocket *producer_socket)
-    : ProducerSocket(producer_socket,
-                     ProductionProtocolAlgorithms::BYTE_STREAM),
-      mtx_(),
-      cv_(),
-      map_producers(),
-      list_producers() {}
-
-P2PSecureProducerSocket::P2PSecureProducerSocket(
-    interface::ProducerSocket *producer_socket, bool rtc,
-    const std::shared_ptr<auth::Identity> &identity)
-    : ProducerSocket(producer_socket,
-                     ProductionProtocolAlgorithms::BYTE_STREAM),
-      rtc_(rtc),
-      mtx_(),
-      cv_(),
-      map_producers(),
-      list_producers() {
-  /* Setup SSL context (identity and parameter to use TLS 1.3) */
-  cert_509_ = identity->getCertificate().get();
-  pkey_rsa_ = identity->getPrivateKey().get();
-
-  /* Set the callback so that when an interest is received we catch it and we
-   * decrypt the payload before passing it to the application.  */
-  ProducerSocket::setSocketOption(
-      ProducerCallbacksOptions::INTEREST_INPUT,
-      (ProducerInterestCallback)std::bind(
-          &P2PSecureProducerSocket::onInterestCallback, this,
-          std::placeholders::_1, std::placeholders::_2));
-}
-
-P2PSecureProducerSocket::~P2PSecureProducerSocket() {}
-
-void P2PSecureProducerSocket::initSessionSocket(
-    std::unique_ptr<TLSProducerSocket> &producer) {
-  producer->on_content_produced_application_ =
-      this->on_content_produced_application_;
-  producer->setSocketOption(CONTENT_OBJECT_EXPIRY_TIME,
-                            this->content_object_expiry_time_);
-  producer->setSocketOption(SIGNER, this->signer_);
-  producer->setSocketOption(MAKE_MANIFEST, this->making_manifest_);
-  producer->setSocketOption(DATA_PACKET_SIZE,
-                            (uint32_t)(this->data_packet_size_));
-  uint32_t output_buffer_size = 0;
-  this->getSocketOption(GeneralTransportOptions::OUTPUT_BUFFER_SIZE,
-                        output_buffer_size);
-  producer->setSocketOption(GeneralTransportOptions::OUTPUT_BUFFER_SIZE,
-                            output_buffer_size);
-
-  if (!rtc_) {
-    producer->setInterface(new interface::TLSProducerSocket(producer.get()));
-  } else {
-    // TODO
-    // TLSRTCProducerSocket *rtc_producer =
-    //     dynamic_cast<TLSRTCProducerSocket *>(producer.get());
-    // rtc_producer->setInterface(
-    //     new interface::TLSRTCProducerSocket(rtc_producer));
-  }
-}
-
-void P2PSecureProducerSocket::onInterestCallback(interface::ProducerSocket &p,
-                                                 Interest &interest) {
-  std::unique_lock<std::mutex> lck(mtx_);
-  std::unique_ptr<TLSProducerSocket> tls_producer;
-  auto it = map_producers.find(interest.getName());
-
-  if (it != map_producers.end()) {
-    return;
-  }
-
-  if (!rtc_) {
-    tls_producer =
-        std::make_unique<TLSProducerSocket>(nullptr, this, interest.getName());
-  } else {
-    // TODO
-    // tls_producer = std::make_unique<TLSRTCProducerSocket>(nullptr, this,
-    //                                                       interest.getName());
-  }
-
-  initSessionSocket(tls_producer);
-  TLSProducerSocket *tls_producer_ptr = tls_producer.get();
-  map_producers.insert({interest.getName(), move(tls_producer)});
-
-  DLOG_IF(INFO, VLOG_IS_ON(3)) << "Start handshake at " << interest.getName();
-
-  if (!rtc_) {
-    tls_producer_ptr->onInterest(*tls_producer_ptr, interest);
-    tls_producer_ptr->async_accept();
-  } else {
-    // TODO
-    // TLSRTCProducerSocket *rtc_producer_ptr =
-    //     dynamic_cast<TLSRTCProducerSocket *>(tls_producer_ptr);
-    // rtc_producer_ptr->onInterest(*rtc_producer_ptr, interest);
-    // rtc_producer_ptr->async_accept();
-  }
-}
-
-uint32_t P2PSecureProducerSocket::produceDatagram(
-    const Name &content_name, std::unique_ptr<utils::MemBuf> &&buffer) {
-  // TODO
-  throw errors::NotImplementedException();
-
-  if (!rtc_) {
-    throw errors::RuntimeException(
-        "RTC must be the transport protocol to start the production of current "
-        "data. Aborting.");
-  }
-
-  std::unique_lock<std::mutex> lck(mtx_);
-
-  if (list_producers.empty()) cv_.wait(lck);
-
-  // TODO
-  // for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-  // {
-  //   TLSRTCProducerSocket *rtc_producer =
-  //       dynamic_cast<TLSRTCProducerSocket *>(it->get());
-  //   rtc_producer->produce(utils::MemBuf::copyBuffer(buffer, buffer_size));
-  // }
-
-  return 0;
-}
-
-uint32_t P2PSecureProducerSocket::produceStream(
-    const Name &content_name, std::unique_ptr<utils::MemBuf> &&buffer,
-    bool is_last, uint32_t start_offset) {
-  if (rtc_) {
-    throw errors::RuntimeException(
-        "RTC transport protocol is not compatible with the production of "
-        "current data. Aborting.");
-  }
-
-  std::unique_lock<std::mutex> lck(mtx_);
-  uint32_t segments = 0;
-
-  if (list_producers.empty()) cv_.wait(lck);
-
-  for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-    segments += (*it)->produceStream(content_name, buffer->clone(), is_last,
-                                     start_offset);
-
-  return segments;
-}
-
-uint32_t P2PSecureProducerSocket::produceStream(const Name &content_name,
-                                                const uint8_t *buffer,
-                                                size_t buffer_size,
-                                                bool is_last,
-                                                uint32_t start_offset) {
-  if (rtc_) {
-    throw errors::RuntimeException(
-        "RTC transport protocol is not compatible with the production of "
-        "current data. Aborting.");
-  }
-
-  std::unique_lock<std::mutex> lck(mtx_);
-  uint32_t segments = 0;
-  if (list_producers.empty()) cv_.wait(lck);
-
-  for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-    segments += (*it)->produceStream(content_name, buffer, buffer_size, is_last,
-                                     start_offset);
-
-  return segments;
-}
-
-// void P2PSecureProducerSocket::asyncProduce(const Name &content_name,
-//                                            const uint8_t *buf,
-//                                            size_t buffer_size, bool is_last,
-//                                            uint32_t *start_offset) {
-//   if (rtc_) {
-//     throw errors::RuntimeException(
-//         "RTC transport protocol is not compatible with the production of "
-//         "current data. Aborting.");
-//   }
-
-//   std::unique_lock<std::mutex> lck(mtx_);
-//   if (list_producers.empty()) cv_.wait(lck);
-
-//   for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-//   {
-//     (*it)->asyncProduce(content_name, buf, buffer_size, is_last,
-//     start_offset);
-//   }
-// }
-
-void P2PSecureProducerSocket::asyncProduce(
-    Name content_name, std::unique_ptr<utils::MemBuf> &&buffer, bool is_last,
-    uint32_t offset, uint32_t **last_segment) {
-  if (rtc_) {
-    throw errors::RuntimeException(
-        "RTC transport protocol is not compatible with the production of "
-        "current data. Aborting.");
-  }
-
-  std::unique_lock<std::mutex> lck(mtx_);
-  if (list_producers.empty()) cv_.wait(lck);
-
-  for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++) {
-    (*it)->asyncProduce(content_name, buffer->clone(), is_last, offset,
-                        last_segment);
-  }
-}
-
-/* Redefinition of socket options to avoid name hiding */
-int P2PSecureProducerSocket::setSocketOption(
-    int socket_option_key, ProducerInterestCallback socket_option_value) {
-  if (!list_producers.empty()) {
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-  }
-
-  switch (socket_option_key) {
-    case ProducerCallbacksOptions::INTEREST_INPUT:
-      on_interest_input_decrypted_ = socket_option_value;
-      return SOCKET_OPTION_SET;
-
-    case ProducerCallbacksOptions::INTEREST_DROP:
-      on_interest_dropped_input_buffer_ = socket_option_value;
-      return SOCKET_OPTION_SET;
-
-    case ProducerCallbacksOptions::INTEREST_PASS:
-      on_interest_inserted_input_buffer_ = socket_option_value;
-      return SOCKET_OPTION_SET;
-
-    case ProducerCallbacksOptions::CACHE_HIT:
-      on_interest_satisfied_output_buffer_ = socket_option_value;
-      return SOCKET_OPTION_SET;
-
-    case ProducerCallbacksOptions::CACHE_MISS:
-      on_interest_process_decrypted_ = socket_option_value;
-      return SOCKET_OPTION_SET;
-
-    default:
-      return SOCKET_OPTION_NOT_SET;
-  }
-}
-
-int P2PSecureProducerSocket::setSocketOption(
-    int socket_option_key,
-    const std::shared_ptr<auth::Signer> &socket_option_value) {
-  if (!list_producers.empty())
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-
-  switch (socket_option_key) {
-    case GeneralTransportOptions::SIGNER: {
-      signer_.reset();
-      signer_ = socket_option_value;
-
-      return SOCKET_OPTION_SET;
-    }
-    default:
-      return SOCKET_OPTION_NOT_SET;
-  }
-}
-
-int P2PSecureProducerSocket::setSocketOption(int socket_option_key,
-                                             uint32_t socket_option_value) {
-  if (!list_producers.empty()) {
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-  }
-  switch (socket_option_key) {
-    case GeneralTransportOptions::CONTENT_OBJECT_EXPIRY_TIME:
-      content_object_expiry_time_ =
-          socket_option_value;  // HICN_HANDSHAKE_CONTENT_EXPIRY_TIME;
-      return SOCKET_OPTION_SET;
-  }
-  return ProducerSocket::setSocketOption(socket_option_key,
-                                         socket_option_value);
-}
-
-int P2PSecureProducerSocket::setSocketOption(int socket_option_key,
-                                             bool socket_option_value) {
-  if (!list_producers.empty())
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-
-  return ProducerSocket::setSocketOption(socket_option_key,
-                                         socket_option_value);
-}
-
-int P2PSecureProducerSocket::setSocketOption(int socket_option_key,
-                                             Name *socket_option_value) {
-  if (!list_producers.empty())
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-
-  return ProducerSocket::setSocketOption(socket_option_key,
-                                         socket_option_value);
-}
-
-int P2PSecureProducerSocket::setSocketOption(
-    int socket_option_key, ProducerContentObjectCallback socket_option_value) {
-  if (!list_producers.empty())
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-
-  return ProducerSocket::setSocketOption(socket_option_key,
-                                         socket_option_value);
-}
-
-int P2PSecureProducerSocket::setSocketOption(
-    int socket_option_key, ProducerContentCallback socket_option_value) {
-  if (!list_producers.empty())
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-
-  switch (socket_option_key) {
-    case ProducerCallbacksOptions::CONTENT_PRODUCED:
-      on_content_produced_application_ = socket_option_value;
-      break;
-
-    default:
-      return SOCKET_OPTION_NOT_SET;
-  }
-
-  return SOCKET_OPTION_SET;
-}
-
-int P2PSecureProducerSocket::setSocketOption(
-    int socket_option_key, auth::CryptoHashType socket_option_value) {
-  if (!list_producers.empty())
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-
-  return ProducerSocket::setSocketOption(socket_option_key,
-                                         socket_option_value);
-}
-
-int P2PSecureProducerSocket::setSocketOption(
-    int socket_option_key, const std::string &socket_option_value) {
-  if (!list_producers.empty())
-    for (auto it = list_producers.cbegin(); it != list_producers.cend(); it++)
-      (*it)->setSocketOption(socket_option_key, socket_option_value);
-
-  return ProducerSocket::setSocketOption(socket_option_key,
-                                         socket_option_value);
-}
-
-}  // namespace implementation
-}  // namespace transport