Client.hpp

#pragma once


#include <winsock2.h>
#include <thread>
#include <vector>
#include <atomic>
#include <string>
#include <cstdint>
#include <openssl/ssl.h>
#include "pugixml.hpp"
#include "JID.hpp"
#include "Iq.hpp"
#include "Channels.hpp"
#include "Profile.hpp"

struct st_mysql;        
struct ssl_st;          
struct ssl_ctx_st;      

using MYSQL = st_mysql;
using SSL = ssl_st;
using SSL_CTX = ssl_ctx_st;


#define PORT 5222
#define BUFFER_SIZE 1024


enum BasicPackets : int
{
    STREAMSTREAM = 0,
    TLSSTART = 1,
    AUTH = 2,
    IQ = 3
};


#pragma pack(push, 1)
struct PacketHeader
{
    uint32_t magic;
    uint64_t length;
};
#pragma pack(pop)



class Client
{
public:
    explicit Client(SOCKET socket);
    ~Client() = default;

   
    void start();


    bool sendAll(SOCKET s, const char* data, int len);
    bool sendPacket(SOCKET s, const std::vector<char>& data);
    bool recvAll(SOCKET s, char* buf, int len);
    void sendMessage(const std::string& msg);
   //bool GetProfile(int64_t user_id);
   
    void StreamStream(Client* client);
    bool TLS();

 
    bool UserExists(MYSQL* conn,
        int64_t user_id,
        const std::string& token);

   
    bool IsAuthorized = false;
    bool tlsEnabled = false;
    BasicPackets count = STREAMSTREAM;

   
    SSL* g_ssl = nullptr;
    SSL_CTX* g_ctx = nullptr;
    Jid* JID = NULL;
    IqClass* Iq = NULL;
    uint64_t UserID = 0;
    SOCKET clientSocket;
    Channels* Channel = NULL;
    Player* Player = NULL;
private:
    std::thread clientThread;
    std::atomic<bool> isRunning{ true };

   
    void handle();
};