diff options
Diffstat (limited to 'dev/lib/net/network.hpp')
| -rw-r--r-- | dev/lib/net/network.hpp | 117 |
1 files changed, 117 insertions, 0 deletions
diff --git a/dev/lib/net/network.hpp b/dev/lib/net/network.hpp new file mode 100644 index 0000000..22cc5b2 --- /dev/null +++ b/dev/lib/net/network.hpp @@ -0,0 +1,117 @@ +/* + * File: net/network.hpp + * Purpose: Modem concept in modern C++ + * Author: Amlal El Mahrouss (founder@snu.systems) + * Copyright 2025, Amlal El Mahrouss and SNU Systems Corp. + */ + +#ifndef _SNU_NET_NETWORK_HPP +#define _SNU_NET_NETWORK_HPP + +#include <arpa/inet.h> +#include <sys/socket.h> +#include <utility> +#include <cstddef> + +#define SNU_MODEM : protected snu::net::basic_delivery_modem + +namespace snu::net +{ + class basic_delivery_modem; + + typedef int64_t socket_type; + + /// @brief Delivery modem concept, a container to read and write on a network stream. + class basic_delivery_modem + { + public: + explicit basic_delivery_modem() = default; + virtual ~basic_delivery_modem() = default; + + basic_delivery_modem& operator=(const basic_delivery_modem&) = default; + basic_delivery_modem(const basic_delivery_modem&) = default; + + public: + static constexpr auto local_address = "127.0.0.1"; + static constexpr auto backlog_count = 18U; + + public: + socket_type fd_{}; + + template <typename T> + bool receive(T& out, std::size_t len) noexcept + { + static_assert(std::is_pointer<T>::value, "T is not a pointer!"); + + if (!out) + return false; + + if (!len) + return false; + + auto ret = ::recv(fd_, out, len, MSG_WAITALL); + + return ret > 0; + } + + template <typename T> + bool transmit(T& out, std::size_t len) noexcept + { + static_assert(std::is_pointer<T>::value, "T is not a pointer!"); + + if (!out) + return false; + + if (!len) + return false; + + auto ret = ::send(fd_, out, len, 0); + + return ret > 0; + } + + template <int32_t AF, int32_t Kind, int32_t IPProto, int32_t Port> + bool construct(const char* addr = basic_delivery_modem::local_address, const bool& is_server = false) noexcept + { + static_assert(AF != 0, "AF is zero"); + static_assert(Kind != 0, "Kind is zero"); + static_assert(IPProto != 0, "IPProto is zero"); + + fd_ = ::socket(AF, Kind, IPProto); + + if (fd_ < 1) + return false; + + struct sockaddr_in addr_ + { + }; + + addr_.sin_addr.s_addr = ::inet_addr(addr); + addr_.sin_port = Port; + + if (!is_server) + { + auto ret = ::connect(fd_, (struct sockaddr*)&addr_, sizeof(decltype(addr_))); + return ret == 0; + } + + ::listen(fd_, basic_delivery_modem::backlog_count); + + return true; + } + + bool destroy() noexcept + { + if (!fd_) + return false; + + ::shutdown(fd_, SHUT_RDWR); + + fd_ = 0U; + + return true; + } + }; +} // namespace snu::net + +#endif // ifndef _SNU_NET_NETWORK_HPP
\ No newline at end of file |