#pragma once
#include <iostream>
#include <string>
#include <chrono>
#include <functional>
#include <WinSock2.h>
#include <map>
#include "ikcp.h"
#include <vector>
#include <thread>
#pragma comment(lib,"ws2_32.lib")

using Buffer = std::vector<char>;
class KSock
{
public:

	void Init(int kcpId,bool isReceiver = true);

	void Send(char* data, int len);

	void Recv(std::vector<char>& data);

	void Release();

	void KCPLoop();

	UINT32 NOW()
	{
		std::chrono::steady_clock::time_point ts = std::chrono::steady_clock::now();
		return ts.time_since_epoch().count();
	}
	SOCKET sock;
	SOCKADDR_IN sockAddr;
	std::string ip{ "127.0.0.1" };
	int port{6868};
	ikcpcb* kcp;
	volatile bool isRunning;
	Buffer RecvBuffer;
	Buffer SendBuffer;
};