diff options
| author | littleblack111 <littleblack11111@gmail.com> | 2025-06-15 14:23:00 +0800 |
|---|---|---|
| committer | littleblack111 <littleblack11111@gmail.com> | 2025-06-16 22:22:10 +0800 |
| commit | 366e5004e6f09f69d945a1f41816cef08e442a2b (patch) | |
| tree | 765c2858bcd630ec358ae5770c0ee33406d194cd /src/server/client.cpp | |
| parent | 82b6612418908654a61b7947550b796ce4ed57d6 (diff) | |
fix: server types
Diffstat (limited to 'src/server/client.cpp')
| -rw-r--r-- | src/server/client.cpp | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/src/server/client.cpp b/src/server/client.cpp index 9efad18..5de8b79 100644 --- a/src/server/client.cpp +++ b/src/server/client.cpp @@ -1,28 +1,30 @@ #include "libsock/server/client.hpp" +#include "libsock/server/server.hpp" #include "libsock/types.hpp" #include "misc/FileDescriptor.hpp" -// #include "chatManager.hpp" -#include "libsock/server/server.hpp" -// #include "sessionManager.hpp" #include <algorithm> #include <arpa/inet.h> -#include <cerrno> #include <cstring> #include <format> +#include <memory> #include <optional> #include <sys/socket.h> -using namespace LibSock::Client; +using namespace LibSock::Server; -Client::Client(bool track, bool oneShot) : m_track(track), m_oneShot(oneShot) { +Client::Client(SP<Server> server, SP<Clients> clients, bool track, bool oneShot) + : m_track(track) + , m_oneShot(oneShot) { + if (!pServer || !pClients) + throw std::runtime_error("server:client: Server/ClientManager doesn't exist"); m_sockfd = std::make_shared<LibSock::CFileDescriptor>( - accept(LibSock::Server::pServer->getSocket()->get(), - reinterpret_cast<sockaddr *>(&m_addr), - &m_addrLen)); // if this is in the init list, it will run before - // m_addrLen, so it won't work :/ + accept(pServer->getSocket()->get(), reinterpret_cast<sockaddr *>(&m_addr), + &m_addrLen) + ); // if this is in the init list, it will run before + // m_addrLen, so it won't work :/ if (!m_sockfd->isValid()) - throw std::runtime_error("session: Failed to create socket"); + throw std::runtime_error("server:client: Failed to create socket"); m_ip.resize(INET_ADDRSTRLEN); inet_ntop(AF_INET, &m_addr.sin_addr, &m_ip[0], INET_ADDRSTRLEN); @@ -68,7 +70,7 @@ void SRecvData::sanitize() { if (const auto start = data.find_first_not_of(" \t\r\n"); start != std::string::npos) { const auto end = data.find_last_not_of(" \t\r\n"); - data = data.substr(start, end - start + 1); + data = data.substr(start, end - start + 1); } else data.clear(); } @@ -98,8 +100,7 @@ Client::read(std::optional<std::function<void(const SRecvData &)>> cb) { } UP<SRecvData> -Client::read(const std::string &msg, - std::optional<std::function<void(const SRecvData &)>> cb) { +Client::read(const std::string &msg, std::optional<std::function<void(const SRecvData &)>> cb) { write("{}", msg); m_szReading = msg; return read(); @@ -118,18 +119,17 @@ bool Client::isValid() { if (!m_sockfd->isValid() || m_name.empty()) return false; - int err = 0; + int err = 0; socklen_t size = sizeof(err); return getsockopt(m_sockfd->get(), SOL_SOCKET, SO_ERROR, &err, &size) >= 0 && err == 0; } -bool Client::write(const std::string &msg, - std::optional<std::function<void(const SRecvData &)>> cb) { +bool Client::write(const std::string &msg, std::optional<std::function<void(const SRecvData &)>> cb) { const auto r = write("{}", msg); if (cb) { - auto recvData = std::make_unique<SRecvData>(); + auto recvData = std::make_unique<SRecvData>(); recvData->data = msg; recvData->good = r; (*cb)(*recvData); |
