jackz/sourcemod-plugins
1
0
Fork 0
mirror of https://github.com/Jackzmc/sourcemod-plugins.git synced 2025-05-06 02:53:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Send some data even without viewers

Browse source
This commit is contained in:
Jackzie 2024-11-14 08:55:49 -06:00
parent 4285178c24
commit e54f7aa61a
2 changed files with 18 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

BIN
plugins/adminpanel.smx
View file

Binary file not shown.

27
scripting/adminpanel.sp
View file

@ -31,6 +31,7 @@ public Plugin myinfo =
int LIVESTATUS_VERSION = 0; int LIVESTATUS_VERSION = 0;
Regex CommandArgRegex; Regex CommandArgRegex;
ConVar cvar_flags;
ConVar cvar_debug; ConVar cvar_debug;
ConVar cvar_gamemode; char gamemode[32]; ConVar cvar_gamemode; char gamemode[32];
ConVar cvar_difficulty; int gameDifficulty; ConVar cvar_difficulty; int gameDifficulty;
@ -58,6 +59,7 @@ int pendingTries = 3;
bool lateLoaded; bool lateLoaded;
Socket g_socket; Socket g_socket;
int g_lastPayloadSent;
enum AuthState { enum AuthState {
Auth_Fail = -1, Auth_Fail = -1,
Auth_Pending, Auth_Pending,
@ -70,6 +72,10 @@ enum GameState {
State_Hibernating = 2, State_Hibernating = 2,
State_NewGame = 3 State_NewGame = 3
} }
enum PanelSettings {
Setting_None = 0,
Setting_DisableWithNoViewers = 1
}
GameState g_gameState; GameState g_gameState;
#define BUFFER_SIZE 2048 #define BUFFER_SIZE 2048
Buffer sendBuffer; Buffer sendBuffer;
@ -87,6 +93,7 @@ public void OnPluginStart() {
g_socket.SetOption(SocketSendBuffer, BUFFER_SIZE); g_socket.SetOption(SocketSendBuffer, BUFFER_SIZE);
uptime = GetTime(); uptime = GetTime();
cvar_flags = CreateConVar("sm_adminpanel_flags", "1", "Bit Flags.\n1=Disable when no viewers", FCVAR_NONE, true, 0.0);
cvar_debug = CreateConVar("sm_adminpanel_debug", "0", "Turn on debug mode", FCVAR_DONTRECORD, true, 0.0, true, 1.0); cvar_debug = CreateConVar("sm_adminpanel_debug", "0", "Turn on debug mode", FCVAR_DONTRECORD, true, 0.0, true, 1.0);
cvar_authToken = CreateConVar("sm_adminpanel_authtoken", "", "The token for authentication", FCVAR_PROTECTED); cvar_authToken = CreateConVar("sm_adminpanel_authtoken", "", "The token for authentication", FCVAR_PROTECTED);
@ -237,7 +244,7 @@ void OnSocketReceive(Socket socket, const char[] receiveData, int dataSize, int
int client = GetClientOfUserId(userid); int client = GetClientOfUserId(userid);
if(client > 0 && StartPayload(true)) { if(client > 0 && StartPayload(true)) {
PrintToServer("[AdminPanel] Sync requested for #%d, performing", userid); PrintToServer("[AdminPanel] Sync requested for #%d, performing", userid);
AddPlayerRecord(client, Client_Normal); AddPlayerRecord(client, Client_Connected);
SendPayload(); SendPayload();
} }
} else { } else {
@ -519,6 +526,8 @@ Action Command_PanelDebug(int client, int args) {
ConnectSocket(); ConnectSocket();
} else if(StrEqual(arg, "info")) { } else if(StrEqual(arg, "info")) {
ReplyToCommand(client, "Connected: %b\tAuthenticated: %d\tState: %d", g_socket.Connected, authState, g_gameState); ReplyToCommand(client, "Connected: %b\tAuthenticated: %d\tState: %d", g_socket.Connected, authState, g_gameState);
int timeFromLastPayload = GetTime() - g_lastPayloadSent;
ReplyToCommand(client, "Last Payload: %ds", timeFromLastPayload);
ReplyToCommand(client, "#Viewers: %d\t#Players: %d", numberOfViewers, numberOfPlayers); ReplyToCommand(client, "#Viewers: %d\t#Players: %d", numberOfViewers, numberOfPlayers);
ReplyToCommand(client, "Target Host: %s:%d", serverIp, serverPort); ReplyToCommand(client, "Target Host: %s:%d", serverIp, serverPort);
ReplyToCommand(client, "Buffer Size: %d", BUFFER_SIZE); ReplyToCommand(client, "Buffer Size: %d", BUFFER_SIZE);
@ -617,7 +626,7 @@ void Event_PlayerDeath(Event event, const char[] name, bool dontBroadcast) {
public void Event_PlayerToBot(Handle event, char[] name, bool dontBroadcast) { public void Event_PlayerToBot(Handle event, char[] name, bool dontBroadcast) {
int player = GetClientOfUserId(GetEventInt(event, "player")); int player = GetClientOfUserId(GetEventInt(event, "player"));
int bot = GetClientOfUserId(GetEventInt(event, "bot")); int bot = GetClientOfUserId(GetEventInt(event, "bot"));
if(player > 0 && !IsFakeClient(player) && StartPayload(true)) { if(player > 0 && !IsFakeClient(player) && StartPayload()) {
AddSurvivorRecord(player); AddSurvivorRecord(player);
SendPayload(); SendPayload();
} }
@ -626,7 +635,7 @@ public void Event_PlayerToBot(Handle event, char[] name, bool dontBroadcast) {
public void Event_BotToPlayer(Handle event, char[] name, bool dontBroadcast) { public void Event_BotToPlayer(Handle event, char[] name, bool dontBroadcast) {
int player = GetClientOfUserId(GetEventInt(event, "player")); int player = GetClientOfUserId(GetEventInt(event, "player"));
int bot = GetClientOfUserId(GetEventInt(event, "bot")); int bot = GetClientOfUserId(GetEventInt(event, "bot"));
if(player > 0 && !IsFakeClient(player) && StartPayload(true)) { if(player > 0 && !IsFakeClient(player) && StartPayload()) {
// Bot is going away, remove it: (prob unnecessary OnClientDisconnect happens) // Bot is going away, remove it: (prob unnecessary OnClientDisconnect happens)
AddPlayerRecord(bot, Client_Disconnected); AddPlayerRecord(bot, Client_Disconnected);
AddPlayerRecord(player, Client_Normal); AddPlayerRecord(player, Client_Normal);
@ -658,7 +667,7 @@ void Event_HealInterrupted(Event event, const char[] name, bool dontBroadcast) {
void Event_PlayerSpawn(Event event, const char[] name, bool dontBroadcast) { void Event_PlayerSpawn(Event event, const char[] name, bool dontBroadcast) {
RecalculatePlayerCount(); RecalculatePlayerCount();
int client = GetClientOfUserId(event.GetInt("userid")); int client = GetClientOfUserId(event.GetInt("userid"));
if(client > 0 && StartPayload()) { if(client > 0 && StartPayload(true)) {
AddPlayerRecord(client, Client_Normal); AddPlayerRecord(client, Client_Normal);
SendPayload(); SendPayload();
} }
@ -678,7 +687,7 @@ void SendPlayers() {
for(int i = 1; i <= MaxClients; i++) { for(int i = 1; i <= MaxClients; i++) {
if(IsClientInGame(i)) { if(IsClientInGame(i)) {
if(StartPayload(true)) { if(StartPayload(true)) {
AddPlayerRecord(i, Client_Normal); AddPlayerRecord(i, Client_Connected);
SendPayload(); SendPayload();
} }
} }
@ -805,15 +814,14 @@ Action Timer_UpdateItems(Handle h, int client) {
void SendNewClient(int client) { void SendNewClient(int client) {
if(!IsClientInGame(client)) return; if(!IsClientInGame(client)) return;
if(StartPayload()) { if(StartPayload(true)) {
PrintToServer("SendNewClient(%N)", client);
AddPlayerRecord(client, Client_Connected); AddPlayerRecord(client, Client_Connected);
SendPayload(); SendPayload();
} }
} }
public void OnClientDisconnect(int client) { public void OnClientDisconnect(int client) {
if(StartPayload()) { if(StartPayload(true)) {
// hopefully userid is valid here? // hopefully userid is valid here?
AddPlayerRecord(client, Client_Disconnected); AddPlayerRecord(client, Client_Disconnected);
SendPayload(); SendPayload();
@ -1024,7 +1032,7 @@ bool CanSendPayload(bool ignorePause = false) {
} }
return false; return false;
} }
if(!ignorePause && (numberOfViewers == 0 || numberOfPlayers == 0)) return false; if(cvar_flags.IntValue & view_as<int>(Setting_DisableWithNoViewers) && !ignorePause && (numberOfViewers == 0 || numberOfPlayers == 0)) return false;
return true; return true;
} }
@ -1209,6 +1217,7 @@ void SendPayload() {
if(cvar_debug.BoolValue) { if(cvar_debug.BoolValue) {
PrintToServer("[AdminPanel] Sending %d bytes of data (records = %s)", len, pendingRecords); PrintToServer("[AdminPanel] Sending %d bytes of data (records = %s)", len, pendingRecords);
} }
g_lastPayloadSent = GetTime();
g_socket.Send(sendBuffer.buffer, len); g_socket.Send(sendBuffer.buffer, len);
} }