blob: 9430cfca9f49c356f870ce77010f0611d119216d [file] [log] [blame]
/*
* Copyright (C) 2004-2023 Savoir-faire Linux Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
#include "dnc.h"
#include "certstore.h"
#include "connectionmanager.h"
#include "fileutils.h"
#include "../common.h"
#include <opendht/log.h>
#include <opendht/crypto.h>
#include <asio.hpp>
#include <fcntl.h>
#include <unistd.h>
#include <iostream>
#include <chrono>
#include <string>
#include <string_view>
#include <filesystem>
#include <memory>
namespace dhtnet {
std::pair<std::string, std::string>
Dnc::parseName(const std::string_view name)
{
// Find the position of the first ':' character after "nc//"
size_t ip_add_start = name.find("nc//") + 6; // Adding 5 to skip "nc//"
size_t colonPos = name.find(':', ip_add_start);
if (colonPos == std::string::npos) {
// Return an empty pair if ':' is not found
return std::make_pair("", "");
}
std::string ip_add(name.substr(ip_add_start, colonPos - ip_add_start));
std::string port(name.substr(colonPos + 1));
return std::make_pair(ip_add, port);
}
// Build a server
Dnc::Dnc(dht::crypto::Identity identity,
const std::string& bootstrap_ip_add,
const std::string& bootstrap_port)
: logger(dht::log::getStdLogger())
, certStore(std::string(getenv("HOME")) + "/.dhtnetTools/certstore", logger)
{
ioContext = std::make_shared<asio::io_context>();
ioContextRunner = std::thread([context = ioContext, logger = logger] {
try {
auto work = asio::make_work_guard(*context);
context->run();
} catch (const std::exception& ex) {
if (logger)
logger->error("Error in ioContextRunner: {}", ex.what());
}
});
auto config = connectionManagerConfig(identity, bootstrap_ip_add, bootstrap_port, logger, certStore, ioContext, iceFactory);
// create a connection manager
connectionManager = std::make_unique<ConnectionManager>(std::move(config));
connectionManager->onDhtConnected(identity.first->getPublicKey());
connectionManager->onICERequest([this](const dht::Hash<32>&) { // handle ICE request
if (logger)
logger->debug("ICE request received");
return true;
});
std::mutex mtx;
std::unique_lock<std::mutex> lk {mtx};
connectionManager->onChannelRequest(
[&](const std::shared_ptr<dht::crypto::Certificate>&, const std::string& name) {
// handle channel request
if (logger)
logger->debug("Channel request received");
return true;
});
connectionManager->onConnectionReady([&](const DeviceId&,
const std::string& name,
std::shared_ptr<ChannelSocket> mtlxSocket) {
if (name.empty()) {
// Handle the empty input case here
return;
}
try {
auto parsedName = parseName(name);
asio::ip::tcp::resolver resolver(*ioContext);
asio::ip::tcp::resolver::results_type endpoints = resolver.resolve(parsedName.first,
parsedName.second);
// Create a TCP socket
auto socket = std::make_shared<asio::ip::tcp::socket>(*ioContext);
asio::async_connect(
*socket,
endpoints,
[this, socket, mtlxSocket](const std::error_code& error,
const asio::ip::tcp::endpoint& ep) {
if (!error) {
if (logger)
logger->debug("Connected!");
mtlxSocket->setOnRecv([socket, this](const uint8_t* data, size_t size) {
auto data_copy = std::make_shared<std::vector<uint8_t>>(data,
data + size);
asio::async_write(*socket,
asio::buffer(*data_copy),
[data_copy, this](const std::error_code& error,
std::size_t bytesWritten) {
if (error) {
if (logger)
logger->error("Write error: {}",
error.message());
}
});
return size;
});
// Create a buffer to read data into
auto buffer = std::make_shared<std::vector<uint8_t>>(65536);
readFromPipe(mtlxSocket, socket, buffer);
} else {
if (logger)
logger->error("Connection error: {}", error.message());
}
});
} catch (std::exception& e) {
if (logger)
logger->error("Exception: {}", e.what());
}
});
}
// Build a client
Dnc::Dnc(dht::crypto::Identity identity,
const std::string& bootstrap_ip_add,
const std::string& bootstrap_port,
dht::InfoHash peer_id,
int port,
const std::string& ip_add)
: Dnc(identity, bootstrap_ip_add, bootstrap_port)
{
std::condition_variable cv;
auto name = fmt::format("nc://{:s}:{:d}", ip_add, port);
connectionManager->connectDevice(peer_id,
name,
[&](std::shared_ptr<ChannelSocket> socket,
const dht::InfoHash&) {
if (socket) {
socket->setOnRecv(
[this, socket](const uint8_t* data, size_t size) {
std::cout.write((const char*) data, size);
std::cout.flush();
return size;
});
// Create a buffer to read data into
auto buffer = std::make_shared<std::vector<uint8_t>>(65536);
// Create a shared_ptr to the stream_descriptor
auto stdinPipe = std::make_shared<asio::posix::stream_descriptor>(*ioContext,
::dup(STDIN_FILENO));
readFromPipe(socket, stdinPipe, buffer);
socket->onShutdown([this]() {
if (logger)
logger->error("Exit program");
std::exit(EXIT_FAILURE);
});
}
});
connectionManager->onConnectionReady([&](const DeviceId&,
const std::string& name,
std::shared_ptr<ChannelSocket> mtlxSocket) {
if (logger)
logger->debug("Connected!");
});
}
void
Dnc::run()
{
ioContext->run();
}
Dnc::~Dnc()
{
ioContext->stop();
ioContextRunner.join();
}
} // namespace dhtnet