summaryrefslogtreecommitdiff
path: root/src/session.cpp
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2025-03-11 13:37:25 +0800
committerlittleblack111 <littleblack11111@gmail.com>2025-03-20 23:44:58 +0800
commit4764b5f494fd5c0fe41dbc01779738c450198933 (patch)
treea7880b2e6beb97152414cea6f451204c41ddf110 /src/session.cpp
parent513623fc0e5182d37aaf91c6dc42670bca3aa888 (diff)
clang-format
Diffstat (limited to 'src/session.cpp')
-rw-r--r--src/session.cpp36
1 files changed, 17 insertions, 19 deletions
diff --git a/src/session.cpp b/src/session.cpp
index 1c8dbf1..b3994ee 100644
--- a/src/session.cpp
+++ b/src/session.cpp
@@ -1,26 +1,25 @@
#include "session.hpp"
+#include "chatManager.hpp"
#include "log.hpp"
#include "sessionManager.hpp"
#include <cerrno>
#include <cstring>
#include <sys/socket.h>
-#include "chatManager.hpp"
-
CSession::CSession(Hyprutils::OS::CFileDescriptor sockfd)
: m_sockfd(std::move(sockfd)) {
if (!m_sockfd.isValid())
throw std::runtime_error("session: Failed to create socket");
- log(TRACE, "session: initialized");
+ log(TRACE, "session: initialized");
}
CSession::~CSession() {
onDisconnect();
m_sockfd.reset();
- self->second.reset();
- log(TRACE, "session({}): bye", m_name);
+ self->second.reset();
+ log(TRACE, "session({}): bye", m_name);
}
void CSession::onConnect() {
@@ -55,7 +54,7 @@ void CSession::recvLoop() {
if (!recvData.good)
break;
- g_pChatManager->newMessage({.msg=recvData.data, .username=m_name});
+ g_pChatManager->newMessage({.msg = recvData.data, .username = m_name});
}
}
@@ -82,10 +81,9 @@ CSession::SRecvData CSession::read(const std::string &msg) {
void CSession::run() {
onConnect();
- registerSession() ?
- recvLoop() :
- // TODO: get ip and print the ip also
- log(LOG, "User exited without even registering");
+ registerSession() ? recvLoop() :
+ // TODO: get ip and print the ip also
+ log(LOG, "User exited without even registering");
g_pSessionManager->removeSession(self);
}
@@ -98,19 +96,19 @@ bool CSession::registerSession() {
if (recvData.data[0] == '\n' || recvData.data[0] == ' ') {
write("Name cannot be empty", eFormatType::ERR);
return registerSession();
- }
+ }
- *std::remove(recvData.data, recvData.data+strlen(recvData.data), '\n') = '\0';
- if (g_pSessionManager->nameExists(recvData.data)) {
- write("Name already exists", eFormatType::ERR);
- return registerSession();
- }
+ *std::remove(recvData.data, recvData.data + strlen(recvData.data), '\n') = '\0';
+ if (g_pSessionManager->nameExists(recvData.data)) {
+ write("Name already exists", eFormatType::ERR);
+ return registerSession();
+ }
this->m_name = recvData.data;
log(LOG, "Client registered as: {}", m_name);
- return true;
+ return true;
}
bool CSession::isValid() {
@@ -148,6 +146,6 @@ void CSession::setSelf(std::pair<std::jthread, std::shared_ptr<CSession>> *self)
}
void CSession::onShutdown() {
- write(SYS, "Shutting down, bye");
- g_pSessionManager->removeSession(self);
+ write(SYS, "Shutting down, bye");
+ g_pSessionManager->removeSession(self);
}