PHP Code:
#pragma semicolon 1
#pragma newdecls required
#include <sourcemod>
#include <socket>
#define PLUGIN_VERSION "0.9.9"
#define PLUGIN_DESCRIPTION "Provides live server info with join option"
#define MAX_SERVERS 10
#define REFRESH_TIME 60.0
#define SERVER_TIMEOUT 10.0
#define MAX_STR_LEN 160
#define MAX_INFO_LEN 200
int
g_iServerCount,
g_iAdvertCount,
g_iAdvertInterval = 1,
g_iServerPort[MAX_SERVERS];
char
g_sServerName[MAX_SERVERS][MAX_STR_LEN],
g_sServerAddress[MAX_SERVERS][MAX_STR_LEN],
g_sServerInfo[MAX_SERVERS][MAX_INFO_LEN],
g_sAddress[MAXPLAYERS+1][MAX_STR_LEN],
g_sServer[MAXPLAYERS+1][MAX_INFO_LEN];
bool
g_bSocketError[MAX_SERVERS],
g_bConnectedFromFavorites[MAXPLAYERS+1],
g_bLateLoad,
g_bCoolDown;
Handle
g_hSocket[MAX_SERVERS];
ConVar
g_cvarHopTrigger,
g_cvarServerFormat,
g_cvarBroadcastHops,
g_cvarAdvert,
g_cvarAdvert_Interval;
public Plugin myinfo = {
name = "Server Hop",
author = "[GRAVE] rig0r, JoinedSenses",
description = PLUGIN_DESCRIPTION,
version = PLUGIN_VERSION,
url = "https://github.com/JoinedSenses/TF2-ServerHop"
};
public APLRes AskPluginLoad2(Handle myself, bool late, char[] error, int err_max) {
if (GetEngineVersion() == Engine_CSGO) {
strcopy(error, err_max, "ServerHop is incompatible with this game");
return APLRes_SilentFailure;
}
g_bLateLoad = late;
return APLRes_Success;
}
public void OnPluginStart() {
LoadTranslations("serverhop.phrases");
CreateConVar("sm_serverhop_version", PLUGIN_VERSION, PLUGIN_DESCRIPTION, FCVAR_SPONLY|FCVAR_REPLICATED|FCVAR_NOTIFY|FCVAR_DONTRECORD).SetString(PLUGIN_VERSION);
// convar setup
g_cvarHopTrigger = CreateConVar(
"sm_hop_trigger",
"!servers",
"What players have to type in chat to activate the plugin (besides !hop)"
);
g_cvarServerFormat = CreateConVar(
"sm_hop_serverformat",
"%name - %map (%numplayers/%maxplayers)",
"Defines how the server info should be presented"
);
g_cvarBroadcastHops = CreateConVar(
"sm_hop_broadcasthops",
"1",
"Set to 1 if you want a broadcast message when a player hops to another server"
);
g_cvarAdvert = CreateConVar(
"sm_hop_advertise",
"1",
"Set to 1 to enable server advertisements"
);
g_cvarAdvert_Interval = CreateConVar(
"sm_hop_advertisement_interval",
"1",
"Advertisement interval: advertise a server every x minute(s)"
);
AutoExecConfig(true, "plugin.serverhop");
Handle timer = CreateTimer(REFRESH_TIME, RefreshServerInfo, _, TIMER_REPEAT);
RegConsoleCmd("say", Command_Say);
RegConsoleCmd("say_team", Command_Say);
RegConsoleCmd("sm_hop", Command_Hop, "Hop servers.");
RegConsoleCmd("sm_servers", Command_Servers, "Hop servers.");
char path[MAX_STR_LEN];
BuildPath(Path_SM, path, sizeof(path), "configs/serverhop.cfg");
KeyValues kv = new KeyValues("Servers");
if (!kv.ImportFromFile(path)) {
LogToGame("Error loading server list");
SetFailState("Unable to import server list from file.");
}
int i;
kv.Rewind();
if (!kv.GotoFirstSubKey()) {
SetFailState("Unable to find first server in file.");
}
do {
kv.GetSectionName(g_sServerName[i], MAX_STR_LEN);
kv.GetString("address", g_sServerAddress[i], MAX_STR_LEN);
g_iServerPort[i] = kv.GetNum("port", 27015);
} while (++i < MAX_SERVERS && kv.GotoNextKey());
if (i == MAX_SERVERS && kv.GotoNextKey()) {
LogError("You have exceeded the cap for max servers of %i. To add more, edit the value of MAX_SERVERS and recompile.", MAX_SERVERS);
}
delete kv;
g_iServerCount = i;
TriggerTimer(timer);
if (g_bLateLoad) {
char clientConnectMethod[64];
for (int client = 1; client <= MaxClients; client++) {
if (IsClientInGame(client) && !IsFakeClient(client)) {
GetClientInfo(client, "cl_connectmethod", clientConnectMethod, sizeof(clientConnectMethod));
if (!StrEqual(clientConnectMethod, "serverbrowser_internet")) {
g_bConnectedFromFavorites[client] = true;
}
}
}
}
}
public Action Command_Hop(int client, int args) {
ServerMenu(client);
return Plugin_Handled;
}
public Action Command_Servers(int client, int args) {
ServerMenu(client);
return Plugin_Handled;
}
public Action Command_Say(int client, int args) {
char text[MAX_STR_LEN];
int startidx = 0;
if (!GetCmdArgString(text, sizeof(text))) {
return Plugin_Continue;
}
if (text[strlen(text)-1] == '\0') {
text[strlen(text)-1] = '\0';
startidx = 1;
}
char trigger[MAX_STR_LEN];
g_cvarHopTrigger.GetString(trigger, sizeof(trigger));
if (strcmp(text[startidx], trigger, false) == 0 || strcmp(text[startidx], "!hop", false) == 0) {
ServerMenu(client);
}
return Plugin_Continue;
}
public void OnClientPutInServer(int client) {
char clientConnectMethod[64];
GetClientInfo(client, "cl_connectmethod", clientConnectMethod, sizeof(clientConnectMethod));
if (!StrEqual(clientConnectMethod, "serverbrowser_internet")) {
g_bConnectedFromFavorites[client] = true;
}
}
public void OnClientDisconnect(int client) {
g_bConnectedFromFavorites[client] = false;
}
public Action ServerMenu(int client) {
char serverNumStr[MAX_STR_LEN];
char menuTitle[MAX_STR_LEN];
Menu menu = new Menu(Menu_Handler, MENU_ACTIONS_DEFAULT);
Format(menuTitle, sizeof(menuTitle), "%T", "SelectServer", client);
menu.SetTitle(menuTitle);
for (int i = 0; i < g_iServerCount; i++) {
if (strlen(g_sServerInfo[i]) > 0) {
IntToString(i, serverNumStr, sizeof(serverNumStr));
menu.AddItem(serverNumStr, g_sServerInfo[i]);
}
}
menu.Display(client, 20);
return Plugin_Handled;
}
public int Menu_Handler(Menu menu, MenuAction action, int param1, int param2) {
if (action == MenuAction_Select) {
char infobuf[MAX_STR_LEN];
menu.GetItem(param2, infobuf, sizeof(infobuf));
int serverNum = StringToInt(infobuf);
char menuTitle[MAX_STR_LEN];
Format(menuTitle, sizeof(menuTitle), "%T", "AboutToJoinServer", param1);
Format(g_sAddress[param1], MAX_STR_LEN, "%s:%i", g_sServerAddress[serverNum], g_iServerPort[serverNum]);
g_sServer[param1] = g_sServerInfo[serverNum];
if (!g_bConnectedFromFavorites[param1]) {
PrintToChat(param1, "\x01[\x03ServerHop\x01] Due to Valve game change, clients must connect via favorites to be redirected by server.");
PrintToChat(param1, "\x01[\x03ServerHop\x01] %s:\x03 %s", g_sServer[param1], g_sAddress[param1]);
return;
}
Panel panel = new Panel();
panel.SetTitle(menuTitle);
panel.DrawText(g_sServerInfo[serverNum]);
panel.DrawText("Is this correct?");
panel.CurrentKey = 3;
panel.DrawItem("Accept");
panel.DrawItem("Decline");
panel.Send(param1, MenuConfirmHandler, 15);
delete panel;
}
else if (action == MenuAction_End) {
delete menu;
}
}
public int MenuConfirmHandler(Menu menu, MenuAction action, int param1, int param2) {
if (param2 == 3) {
ClientCommand(param1, "redirect %s", g_sAddress[param1]);
// broadcast to all
if (g_cvarBroadcastHops.BoolValue) {
char clientName[MAX_NAME_LENGTH];
GetClientName(param1, clientName, sizeof(clientName));
PrintToChatAll("\x01[\x03hop\x01] %t", "HopNotification", clientName, g_sServer[param1]);
}
}
g_sAddress[param1][0] = '\0';
g_sServer[param1][0] = '\0';
}
public Action RefreshServerInfo(Handle timer) {
for (int i = 0; i < g_iServerCount; i++) {
g_sServerInfo[i][0] = '\0';
g_bSocketError[i] = false;
g_hSocket[i] = SocketCreate(SOCKET_UDP, OnSocketError);
SocketSetArg(g_hSocket[i], i);
SocketConnect(g_hSocket[i], OnSocketConnected, OnSocketReceive, OnSocketDisconnected, g_sServerAddress[i], g_iServerPort[i]);
}
CreateTimer(SERVER_TIMEOUT, CleanUp);
}
public Action CleanUp(Handle timer) {
for (int i = 0; i < g_iServerCount; i++) {
if (strlen(g_sServerInfo[i]) == 0 && !g_bSocketError[i]) {
LogError("Server %s:%i is down, no reply received within %0.0f seconds.", g_sServerAddress[i], g_iServerPort[i], SERVER_TIMEOUT);
delete g_hSocket[i];
}
}
// all server info is up to date: advertise
if (g_cvarAdvert.BoolValue) {
if (g_iAdvertInterval == g_cvarAdvert_Interval.FloatValue) {
Advertise();
}
if (++g_iAdvertInterval > g_cvarAdvert_Interval.FloatValue) {
g_iAdvertInterval = 1;
}
}
}
public void Advertise() {
char trigger[MAX_STR_LEN];
g_cvarHopTrigger.GetString(trigger, sizeof(trigger));
// skip servers being marked as down
while (strlen(g_sServerInfo[g_iAdvertCount]) == 0) {
if (++g_iAdvertCount >= g_iServerCount) {
g_iAdvertCount = 0;
break;
}
}
if (strlen(g_sServerInfo[g_iAdvertCount]) > 0) {
PrintToChatAll("\x01[\x03hop\x01] %t", "Advert", g_sServerInfo[g_iAdvertCount], trigger);
if (++g_iAdvertCount >= g_iServerCount) {
g_iAdvertCount = 0;
}
}
}
public void OnSocketConnected(Handle sock, any i) {
char requestStr[25];
Format(requestStr, sizeof(requestStr), "%s", "\xFF\xFF\xFF\xFF\x54Source Engine Query");
SocketSend(sock, requestStr, 25);
}
char GetString(char[] receiveData, int dataSize, int offset) {
char serverStr[MAX_STR_LEN] = "";
int j = 0;
for (int i = offset; i < dataSize; i++) {
serverStr[j++] = receiveData[i];
if (receiveData[i] == '\x0') {
break;
}
}
return serverStr;
}
public void OnSocketReceive(Handle sock, char[] receiveData, const int dataSize, any i) {
// parse server info
int offset = 2;
char srvName[MAX_STR_LEN];
srvName = GetString(receiveData, dataSize, offset);
offset += strlen(srvName) + 1;
char mapName[MAX_STR_LEN];
mapName = GetString(receiveData, dataSize, offset);
offset += strlen(mapName) + 1;
char gameDir[MAX_STR_LEN];
gameDir = GetString(receiveData, dataSize, offset);
offset += strlen(gameDir) + 1;
char gameDesc[MAX_STR_LEN];
gameDesc = GetString(receiveData, dataSize, offset);
offset += strlen(gameDesc) + 1;
offset += 2;
char numPlayers[4];
int players = receiveData[offset];
IntToString(players, numPlayers, sizeof(numPlayers));
++offset;
char maxPlayers[4];
IntToString(receiveData[offset], maxPlayers, sizeof(maxPlayers));
++offset;
char numBots[4];
int bots = receiveData[offset];
IntToString(bots, numBots, sizeof(numBots));
char humans[4];
IntToString(players - bots, humans, sizeof(humans));
char format[MAX_STR_LEN];
g_cvarServerFormat.GetString(format, sizeof(format));
ReplaceString(format, strlen(format), "%name", g_sServerName[i], false);
ReplaceString(format, strlen(format), "%map", mapName, false);
ReplaceString(format, strlen(format), "%numplayers", numPlayers, false);
ReplaceString(format, strlen(format), "%maxplayers", maxPlayers, false);
ReplaceString(format, strlen(format), "%humans", humans, false);
ReplaceString(format, strlen(format), "%bots", numBots, false);
g_sServerInfo[i] = format;
delete sock;
}
public void OnSocketDisconnected(Handle sock, any i) {
delete sock;
}
public void OnSocketError(Handle sock, const int errorType, const int errorNum, any i) {
if (!g_bCoolDown) {
LogError("Server %s:%i is down: socket error %d (errno %d)", g_sServerAddress[i], g_iServerPort[i], errorType, errorNum);
CreateTimer(600.0, timerErrorCooldown);
g_bCoolDown = true;
}
g_bSocketError[i] = true;
delete sock;
}
Action timerErrorCooldown(Handle timer) {
g_bCoolDown = false;
}
Linear Mode
