combine net

This commit is contained in:
Nikola Petrov 2025-01-30 22:55:41 +01:00
parent b88cd9fe7c
commit 3d42b59b60
5 changed files with 27 additions and 28 deletions

View File

@ -9,7 +9,6 @@
#include "sys.hpp"
#include "DnaStore.hpp"
#include "TcpSocket.hpp"
#include "NetConst.hpp"
#include <raylib.h>

View File

@ -17,6 +17,7 @@ const char get_gen[] = "SELECT lt.HASH, lt.POS, lt.LIKED FROM like_table lt JOIN
const char get_user_table_id[] = "SELECT ID FROM user_table WHERE USER_ID = ? AND GEN = ?;";
const char rem_like_w_user_table_id[] = "DELETE FROM like_table WHERE USER_TABLE_ID = ?;";
const char rem_user_table_id[] = "DELETE FROM user_table WHERE ID = ?;";
const char set_checked[] = "UPDATE user_table SET CHECKED = 1 WHERE USER_ID = ? AND GEN = ?;";

View File

@ -1,5 +1,4 @@
#include "TcpSocket.hpp"
#include "NetConst.hpp"
#include "sql.hpp"
#include "values/DnaManager.hpp"
#include "checker.hpp"

View File

@ -1,17 +0,0 @@
#include <cinttypes>
constexpr int64_t StartHeader = 1737720524UL;
constexpr uint16_t serverPort = 9000;
enum Mess
{
RES_OK,
RES_NO,
REQ_SEND_GEN,
};
struct Message
{
Mess mess;
uint32_t data;
};

View File

@ -1,25 +1,42 @@
#include <string>
#include <netinet/in.h>
#include <cinttypes>
#define AS_DEFAULT_BUFFER_SIZE 0x1000 /*4096 bytes*/
constexpr int64_t StartHeader = 1737720524UL;
constexpr uint16_t serverPort = 9000;
enum Mess
{
RES_OK,
RES_NO,
REQ_SEND_GEN,
};
struct Message
{
Mess mess;
uint32_t data;
};
namespace TcpSocket
{
void setTimeout(int seconds, int sock);
void setTimeout(int seconds, int sock);
ssize_t sendt(int sock, const void *bytes, size_t byteslength);
ssize_t sendt(int sock, const void *bytes, size_t byteslength);
ssize_t recvt(int sock, void *bytes, size_t byteslength);
ssize_t recvt(int sock, void *bytes, size_t byteslength);
void closet(int sock);
void closet(int sock);
std::string remoteAddress(sockaddr_in &address);
std::string remoteAddress(sockaddr_in &address);
int remotePort(sockaddr_in &address);
int connectt(const char *host, uint16_t port);
int remotePort(sockaddr_in &address);
int connectt(const char *host, uint16_t port);
typedef void(OnNewConnectionCallBack)(int sock, sockaddr_in newSocketInfo);
int listent(const char *host, uint16_t port, OnNewConnectionCallBack callback);
typedef void(OnNewConnectionCallBack)(int sock, sockaddr_in newSocketInfo);
int listent(const char *host, uint16_t port, OnNewConnectionCallBack callback);
} // namespace TcpSocket