mirror of
https://github.com/rehlds/rehlds.git
synced 2025-04-09 11:00:08 +03:00
245 lines
11 KiB
C++
245 lines
11 KiB
C++
#pragma once
|
|
#ifdef _WIN32
|
|
|
|
#include "osconfig.h"
|
|
#include "testsuite.h"
|
|
#include "funccalls.h"
|
|
|
|
class CAnonymizingEngExtInterceptor;
|
|
|
|
class CSteamAppsAnonymizingWrapper : public ISteamApps
|
|
{
|
|
private:
|
|
ISteamApps* m_Wrapped;
|
|
CAnonymizingEngExtInterceptor* m_Anonymizer;
|
|
|
|
public:
|
|
CSteamAppsAnonymizingWrapper(ISteamApps* original, CAnonymizingEngExtInterceptor* anonymizer);
|
|
|
|
virtual bool BIsSubscribed();
|
|
virtual bool BIsLowViolence();
|
|
virtual bool BIsCybercafe();
|
|
virtual bool BIsVACBanned();
|
|
virtual const char *GetCurrentGameLanguage();
|
|
virtual const char *GetAvailableGameLanguages();
|
|
|
|
virtual bool BIsSubscribedApp(AppId_t appID);
|
|
virtual bool BIsDlcInstalled(AppId_t appID);
|
|
|
|
virtual uint32 GetEarliestPurchaseUnixTime(AppId_t nAppID);
|
|
virtual bool BIsSubscribedFromFreeWeekend();
|
|
|
|
virtual int GetDLCCount();
|
|
virtual bool BGetDLCDataByIndex(int iDLC, AppId_t *pAppID, bool *pbAvailable, char *pchName, int cchNameBufferSize);
|
|
|
|
virtual void InstallDLC(AppId_t nAppID);
|
|
virtual void UninstallDLC(AppId_t nAppID);
|
|
|
|
virtual void RequestAppProofOfPurchaseKey(AppId_t nAppID);
|
|
|
|
virtual bool GetCurrentBetaName(char *pchName, int cchNameBufferSize);
|
|
virtual bool MarkContentCorrupt(bool bMissingFilesOnly);
|
|
virtual uint32 GetInstalledDepots(AppId_t appID, DepotId_t *pvecDepots, uint32 cMaxDepots);
|
|
|
|
virtual uint32 GetAppInstallDir(AppId_t appID, char *pchFolder, uint32 cchFolderBufferSize);
|
|
|
|
virtual bool BIsAppInstalled(AppId_t appID);
|
|
virtual CSteamID GetAppOwner();
|
|
virtual const char *GetLaunchQueryParam(const char *pchKey);
|
|
virtual bool GetDlcDownloadProgress(AppId_t nAppID, uint64 *punBytesDownloaded, uint64 *punBytesTotal);
|
|
virtual int GetAppBuildId();
|
|
virtual void RequestAllProofOfPurchaseKeys();
|
|
virtual SteamAPICall_t GetFileDetails(const char *pszFileName);
|
|
virtual int GetLaunchCommandLine(char *pszCommandLine, int cubCommandLine);
|
|
virtual bool BIsSubscribedFromFamilySharing();
|
|
virtual bool BIsTimedTrial(uint32 *punSecondsAllowed, uint32 *punSecondsPlayed);
|
|
virtual bool SetDlcContext(AppId_t nAppID);
|
|
virtual int GetNumBetas(int *pnAvailable, int *pnPrivate);
|
|
virtual bool GetBetaInfo(int iBetaIndex, uint32 *punFlags, uint32 *punBuildID, char *pchBetaName, int cchBetaName, char *pchDescription, int cchDescription);
|
|
virtual bool SetActiveBeta(const char *pchBetaName);
|
|
};
|
|
|
|
class CSteamGameServerAnonymizingWrapper : public ISteamGameServer
|
|
{
|
|
private:
|
|
ISteamGameServer* m_Wrapped;
|
|
CAnonymizingEngExtInterceptor* m_Anonymizer;
|
|
|
|
public:
|
|
CSteamGameServerAnonymizingWrapper(ISteamGameServer* original, CAnonymizingEngExtInterceptor* anonymizer);
|
|
|
|
virtual bool InitGameServer(uint32 unIP, uint16 usGamePort, uint16 usQueryPort, uint32 unFlags, AppId_t nGameAppId, const char *pchVersionString);
|
|
virtual void SetProduct(const char *pszProduct);
|
|
virtual void SetGameDescription(const char *pszGameDescription);
|
|
virtual void SetModDir(const char *pszModDir);
|
|
virtual void SetDedicatedServer(bool bDedicated);
|
|
virtual void LogOn(const char *pszToken);
|
|
virtual void LogOnAnonymous();
|
|
virtual void LogOff();
|
|
virtual bool BLoggedOn();
|
|
virtual bool BSecure();
|
|
virtual CSteamID GetSteamID();
|
|
virtual bool WasRestartRequested();
|
|
virtual void SetMaxPlayerCount(int cPlayersMax);
|
|
virtual void SetBotPlayerCount(int cBotplayers);
|
|
virtual void SetServerName(const char *pszServerName);
|
|
virtual void SetMapName(const char *pszMapName);
|
|
virtual void SetPasswordProtected(bool bPasswordProtected);
|
|
virtual void SetSpectatorPort(uint16 unSpectatorPort);
|
|
virtual void SetSpectatorServerName(const char *pszSpectatorServerName);
|
|
virtual void ClearAllKeyValues();
|
|
virtual void SetKeyValue(const char *pKey, const char *pValue);
|
|
virtual void SetGameTags(const char *pchGameTags);
|
|
virtual void SetGameData(const char *pchGameData);
|
|
virtual void SetRegion(const char *pszRegion);
|
|
virtual bool SendUserConnectAndAuthenticate(uint32 unIPClient, const void *pvAuthBlob, uint32 cubAuthBlobSize, CSteamID *pSteamIDUser);
|
|
virtual CSteamID CreateUnauthenticatedUserConnection();
|
|
virtual void SendUserDisconnect(CSteamID steamIDUser);
|
|
virtual bool BUpdateUserData(CSteamID steamIDUser, const char *pchPlayerName, uint32 uScore);
|
|
virtual HAuthTicket GetAuthSessionTicket(void *pTicket, int cbMaxTicket, uint32 *pcbTicket, const SteamNetworkingIdentity *pSnid);
|
|
virtual EBeginAuthSessionResult BeginAuthSession(const void *pAuthTicket, int cbAuthTicket, CSteamID steamID);
|
|
virtual void EndAuthSession(CSteamID steamID);
|
|
virtual void CancelAuthTicket(HAuthTicket hAuthTicket);
|
|
virtual EUserHasLicenseForAppResult UserHasLicenseForApp(CSteamID steamID, AppId_t appID);
|
|
virtual bool RequestUserGroupStatus(CSteamID steamIDUser, CSteamID steamIDGroup);
|
|
virtual void GetGameplayStats();
|
|
virtual SteamAPICall_t GetServerReputation();
|
|
virtual SteamIPAddress_t GetPublicIP();
|
|
virtual bool HandleIncomingPacket(const void *pData, int cbData, uint32 srcIP, uint16 srcPort);
|
|
virtual int GetNextOutgoingPacket(void *pOut, int cbMaxOut, uint32 *pNetAdr, uint16 *pPort);
|
|
virtual void SetAdvertiseServerActive(bool bActive);
|
|
virtual void SetMasterServerHeartbeatInterval(int iHeartbeatInterval);
|
|
virtual void ForceMasterServerHeartbeat();
|
|
virtual SteamAPICall_t AssociateWithClan(CSteamID steamIDClan);
|
|
virtual SteamAPICall_t ComputeNewPlayerCompatibility(CSteamID steamIDNewPlayer);
|
|
};
|
|
|
|
class CSteamCallbackAnonymizingWrapper : public CCallbackBase
|
|
{
|
|
private:
|
|
void* Anonymize(void* data);
|
|
void* Anonymize(void* data, bool bIOFailure, SteamAPICall_t hSteamAPICall);
|
|
public:
|
|
CSteamCallbackAnonymizingWrapper(CAnonymizingEngExtInterceptor* anonymizer, CCallbackBase* cb, int id);
|
|
virtual void Run(void *pvParam);
|
|
virtual void Run(void *pvParam, bool bIOFailure, SteamAPICall_t hSteamAPICall);
|
|
virtual int GetCallbackSizeBytes();
|
|
|
|
int getRehldsCallbackId() { return m_Id; }
|
|
|
|
protected:
|
|
CAnonymizingEngExtInterceptor* m_Anonymizer;
|
|
CCallbackBase* m_Wrapped;
|
|
int m_Id;
|
|
int m_Size;
|
|
};
|
|
|
|
class CAnonymizingEngExtInterceptor : public IReHLDSPlatform {
|
|
friend class CSteamAppsAnonymizingWrapper;
|
|
friend class CSteamGameServerAnonymizingWrapper;
|
|
friend class CSteamCallbackAnonymizingWrapper;
|
|
|
|
private:
|
|
SOCKET m_ServerSocket;
|
|
|
|
int m_SteamCallbacksCounter;
|
|
std::unordered_map<CCallbackBase*, CSteamCallbackAnonymizingWrapper*> m_SteamCallbacks;
|
|
CSteamAppsAnonymizingWrapper* m_SteamAppsWrapper;
|
|
|
|
CSteamCallbackAnonymizingWrapper* getOrCreateCallbackWrapper(CCallbackBase *pCallback);
|
|
|
|
CSteamGameServerAnonymizingWrapper* m_GameServerWrapper;
|
|
void* m_SteamBreakpadContext;
|
|
|
|
IReHLDSPlatform* m_BasePlatform;
|
|
|
|
std::unordered_map<uint32, uint32> m_Fake2RealIpMap;
|
|
std::unordered_map<uint32, uint32> m_Real2FakeIpMap;
|
|
|
|
uint32 Fake2RealIp(uint32 fakeIp, const char* callsite);
|
|
uint32 Real2FakeIp(uint32 realIp, const char* callsite);
|
|
|
|
void Real2FakeSockaddr(sockaddr* saddr, const char* callsite);
|
|
void Fake2RealSockaddr(sockaddr* saddr, const char* callsite);
|
|
char* IpToString(uint32 ip);
|
|
|
|
std::unordered_map<uint64, uint64> m_Fake2RealSteamId;
|
|
std::unordered_map<uint64, uint64> m_Real2FakeSteamId;
|
|
|
|
CSteamID Real2FakeSteamId(CSteamID realId, const char* callsite);
|
|
CSteamID Fake2RealSteamId(CSteamID fakeId, const char* callsite);
|
|
|
|
|
|
char* SteamIdToString(const CSteamID& steamid);
|
|
void ProcessConnectionlessPacket(uint8* data, unsigned int *len);
|
|
void ProcessConnectPacket(uint8* data, unsigned int *len);
|
|
|
|
std::unordered_map<std::string, std::string> m_Real2FakeName;
|
|
std::unordered_map<std::string, std::string> m_Fake2RealName;
|
|
|
|
std::string Real2FakeName(const char* realName, const char* callsite);
|
|
std::string Fake2RealName(const char* fakeName, const char* callsite);
|
|
uint8 m_OriginalConnectPacketData[4096];
|
|
unsigned int m_OriginalConnectPacketLen;
|
|
|
|
std::unordered_map<std::string, std::string> m_Real2FakeHost;
|
|
std::unordered_map<std::string, std::string> m_Fake2RealHost;
|
|
|
|
std::string Real2FakeHost(const char* realHost, const char* callsite);
|
|
std::string Fake2RealHost(const char* fakeHost, const char* callsite);
|
|
|
|
public:
|
|
CAnonymizingEngExtInterceptor(IReHLDSPlatform* basePlatform);
|
|
|
|
virtual uint32 time(uint32* pTime);
|
|
virtual struct tm* localtime(uint32 time);
|
|
virtual void srand(uint32 seed);
|
|
virtual int rand();
|
|
|
|
virtual void Sleep(DWORD msec);
|
|
virtual BOOL QueryPerfCounter(LARGE_INTEGER* counter);
|
|
virtual BOOL QueryPerfFreq(LARGE_INTEGER* freq);
|
|
virtual DWORD GetTickCount();
|
|
virtual void GetLocalTime(LPSYSTEMTIME time);
|
|
virtual void GetSystemTime(LPSYSTEMTIME time);
|
|
virtual void GetTimeZoneInfo(LPTIME_ZONE_INFORMATION zinfo);
|
|
virtual BOOL GetProcessTimes(HANDLE hProcess, LPFILETIME lpCreationTime, LPFILETIME lpExitTime, LPFILETIME lpKernelTime, LPFILETIME lpUserTime);
|
|
virtual void GetSystemTimeAsFileTime(LPFILETIME lpSystemTimeAsFileTime);
|
|
|
|
virtual SOCKET socket(int af, int type, int protocol);
|
|
virtual int ioctlsocket(SOCKET s, long cmd, u_long *argp);
|
|
virtual int setsockopt(SOCKET s, int level, int optname, const char* optval, int optlen);
|
|
virtual int closesocket(SOCKET s);
|
|
virtual int recvfrom(SOCKET s, char* buf, int len, int flags, struct sockaddr* from, socklen_t *fromlen);
|
|
virtual int sendto(SOCKET s, const char* buf, int len, int flags, const struct sockaddr* to, int tolen);
|
|
virtual int bind(SOCKET s, const struct sockaddr* addr, int namelen);
|
|
virtual int getsockname(SOCKET s, struct sockaddr* name, socklen_t* namelen);
|
|
virtual int WSAGetLastError();
|
|
virtual struct hostent* gethostbyname(const char *name);
|
|
virtual int gethostname(char *name, int namelen);
|
|
|
|
virtual void SteamAPI_SetBreakpadAppID(uint32 unAppID);
|
|
virtual void SteamAPI_UseBreakpadCrashHandler(char const *pchVersion, char const *pchDate, char const *pchTime, bool bFullMemoryDumps, void *pvContext, PFNPreMinidumpCallback m_pfnPreMinidumpCallback);
|
|
virtual void SteamAPI_RegisterCallback(CCallbackBase *pCallback, int iCallback);
|
|
virtual ESteamAPIInitResult SteamAPI_InitInternal(const char *pszInternalCheckInterfaceVersions, SteamErrMsg *pOutErrMsg);
|
|
virtual void SteamAPI_UnregisterCallResult(class CCallbackBase *pCallback, SteamAPICall_t hAPICall);
|
|
virtual ISteamApps* SteamApps();
|
|
virtual bool SteamGameServer_Init(uint32 unIP, uint16 usSteamPort, uint16 usGamePort, uint16 usQueryPort, EServerMode eServerMode, const char *pchVersionString);
|
|
virtual ISteamGameServer* SteamGameServer();
|
|
virtual void SteamGameServer_RunCallbacks();
|
|
virtual void SteamAPI_RunCallbacks();
|
|
virtual void SteamGameServer_Shutdown();
|
|
virtual void SteamAPI_UnregisterCallback(CCallbackBase *pCallback);
|
|
|
|
void AnonymizeAddr(const netadr_t& real, const netadr_t& fake);
|
|
void AnonymizeAddr(const char* real, const char* fake);
|
|
void AnonymizeSteamId(const CSteamID& real, const CSteamID& fake);
|
|
void AnonymizeSteamId(const char* real, const char* fake);
|
|
void AnonymizeName(const char* real, const char* fake);
|
|
void AnonymizeHost(const char* real, const char* fake);
|
|
|
|
|
|
};
|
|
|
|
#endif //_WIN32
|