You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
322 lines
9.1 KiB
322 lines
9.1 KiB
#include "core/globals.sp"
|
|
|
|
//#define RIPEXT_SUPPORT
|
|
#define STEAMWORKS_SUPPORT
|
|
|
|
#if defined RIPEXT_SUPPORT
|
|
#include <ripext>
|
|
#define PLUGIN_VERSION "1.0 (RipExt)"
|
|
#endif
|
|
|
|
#if defined STEAMWORKS_SUPPORT
|
|
#include <SteamWorks>
|
|
#include <json>
|
|
#define PLUGIN_VERSION "1.0 (SteamWorks)"
|
|
#endif
|
|
|
|
public Plugin myinfo = {
|
|
name = "Facti13 Backend Integration",
|
|
author = "gsd",
|
|
description = "Update server info directly without RCON",
|
|
version = PLUGIN_VERSION,
|
|
url = "https://tf2.pblr-nyk.pro"
|
|
}
|
|
|
|
Handle g_timer = INVALID_HANDLE;
|
|
int g_lastupdate = 0;
|
|
bool g_warned = true;
|
|
bool g_updating = false;
|
|
|
|
public OnPluginStart() {
|
|
SetupGlobalConVar();
|
|
RegAdminCmd("fbi_test", TestUpdate, ADMFLAG_ROOT);
|
|
g_timer = CreateTimer(15, timerCall, 0, TIMER_REPEAT);
|
|
}
|
|
|
|
public OnPluginEnd() {
|
|
UnSetupGlobalConvar();
|
|
if (g_timer != INVALID_HANDLE) {
|
|
KillTimer(g_timer);
|
|
}
|
|
}
|
|
|
|
#if defined STEAMWORKS_SUPPORT
|
|
|
|
public void OnJsonRequestComplete(Handle hRequest, bool bFailure, bool bRequestSuccessful, EHTTPStatusCode eStatusCode)
|
|
{
|
|
g_updating = false;
|
|
if (bFailure)
|
|
{
|
|
if(g_warned) {
|
|
LogMessage("Failed response! Code: %i", eStatusCode);
|
|
g_warned = false;
|
|
}
|
|
|
|
delete hRequest;
|
|
return;
|
|
}
|
|
|
|
if (!bRequestSuccessful || eStatusCode != k_EHTTPStatusCode200OK)
|
|
{
|
|
if(g_warned) {
|
|
LogMessage("Failed response! Code: %i", eStatusCode);
|
|
g_warned = false;
|
|
}
|
|
|
|
delete hRequest;
|
|
return;
|
|
}
|
|
|
|
if (eStatusCode == k_EHTTPStatusCode200OK) {
|
|
if(!g_warned) {
|
|
LogMessage("Success send payload, after error");
|
|
g_warned = true;
|
|
}
|
|
}
|
|
|
|
delete hRequest;
|
|
return;
|
|
}
|
|
|
|
stock void createRequest(const char[] sJsonPayload) {
|
|
char sURL[256];
|
|
Format(sURL, sizeof(sURL), "%s/report", g_url);
|
|
LogMessage("Use report endpoint: %s", sURL);
|
|
|
|
Handle hRequest = SteamWorks_CreateHTTPRequest(k_EHTTPMethodPOST, sURL);
|
|
if (hRequest == INVALID_HANDLE)
|
|
{
|
|
LogError("Не удалось создать запрос");
|
|
return;
|
|
}
|
|
|
|
SteamWorks_SetHTTPRequestRawPostBody(hRequest, "application/json; charset=UTF-8", sJsonPayload, strlen(sJsonPayload));
|
|
|
|
if (strlen(g_cookie) > 0)
|
|
{
|
|
SteamWorks_SetHTTPRequestHeaderValue(hRequest, "Cookie", g_cookie);
|
|
}
|
|
|
|
SteamWorks_SetHTTPCallbacks(hRequest, OnJsonRequestComplete);
|
|
|
|
if (!SteamWorks_SendHTTPRequest(hRequest))
|
|
{
|
|
LogError("Cannot send server info");
|
|
delete hRequest;
|
|
}
|
|
}
|
|
|
|
stock void ProcessUpdateStatus() {
|
|
JSON_Object payload = new JSON_Object();
|
|
payload.SetBool("status", true);
|
|
|
|
payload.SetInt("player_count", GetClientCount(true));
|
|
payload.SetInt("max_players", MaxClients);
|
|
|
|
char map_name[128];
|
|
GetCurrentMap(map_name, sizeof(map_name));
|
|
payload.SetString("map_name", map_name);
|
|
|
|
JSON_Array players = new JSON_Array();
|
|
|
|
for(int client = 0; client <= MaxClients; client++) {
|
|
if (IsValidClient(client)) {
|
|
JSON_Object player = new JSON_Object();
|
|
/* Name */
|
|
char name[64];
|
|
GetClientName(client, name, sizeof(name));
|
|
player.SetString("name", name);
|
|
/* Score */
|
|
player.SetInt("score", GetClientFrags(client));
|
|
player.SetInt("deads", GetClientDeaths(client));
|
|
/* Duration */
|
|
char duration[16];
|
|
int ct = RoundFloat(GetClientTime(client));
|
|
int h = ct / 3600;
|
|
int m = ct % 3600 / 60;
|
|
int s = ct % 60;
|
|
Format(duration, sizeof(duration), "%02d:%02d:%02d", h, m, s);
|
|
player.SetString("duration", duration);
|
|
/* Id */
|
|
player.SetInt("id", GetClientUserId(client));
|
|
/* Ip */
|
|
char ip[32];
|
|
GetClientIP(client, ip, sizeof(ip), false);
|
|
player.SetString("ip", ip);
|
|
/* Loss */
|
|
player.SetInt("loss",RoundFloat(GetClientAvgLoss(client, NetFlow_Both)*1000.0));
|
|
/* Ping */
|
|
player.SetInt("ping",RoundFloat(GetClientLatency(client, NetFlow_Both)*1000.0));
|
|
/* State */
|
|
player.SetString("state", "active")
|
|
/* Steam 2 так надо, не надо спрашивать почему*/
|
|
char steam2[32];
|
|
GetClientAuthId(client, AuthId_Steam3, steam2, sizeof(steam2));
|
|
player.SetString("steam2", steam2);
|
|
/* Position on map */
|
|
float pos[3];
|
|
GetClientAbsOrigin(client, pos);
|
|
player.SetFloat("pos_x", pos[0]);
|
|
player.SetFloat("pos_y", pos[1]);
|
|
player.SetFloat("pos_z", pos[2]);
|
|
/* Player class */
|
|
player.SetInt("clz", TF2_GetPlayerClass(client));
|
|
/* Player team */
|
|
player.SetInt("team", TF2_GetClientTeam(client));
|
|
/* push */
|
|
players.PushObject(player);
|
|
delete player;
|
|
}
|
|
}
|
|
|
|
payload.SetObject("players", players);
|
|
|
|
//int payload_size = 1024*8;
|
|
char payload_str[1024*8];
|
|
payload.Encode(payload_str, 1024*8);
|
|
|
|
delete players;
|
|
delete payload;
|
|
|
|
createRequest(payload_str);
|
|
}
|
|
|
|
#endif
|
|
|
|
#if defined RIPEXT_SUPPORT
|
|
stock HTTPRequest createRequest() {
|
|
HTTPRequest client = INVALID_HANDLE;
|
|
if (strlen(g_url)>0) {
|
|
client = new HTTPRequest(g_url);
|
|
client.SetHeader("Cookie", g_cookie);
|
|
client.Timeout = 3;
|
|
} else {
|
|
LogMessage("[FBI] Client not builded");
|
|
}
|
|
return client;
|
|
}
|
|
|
|
stock JSONObject createPayload() {
|
|
JSONObject payload = new JSONObject();
|
|
payload.SetBool("status", true);
|
|
|
|
payload.SetInt("player_count", GetClientCount(true));
|
|
payload.SetInt("max_players", MaxClients);
|
|
|
|
char map_name[128];
|
|
GetCurrentMap(map_name, sizeof(map_name));
|
|
payload.SetString("map_name", map_name);
|
|
|
|
JSONArray players = new JSONArray();
|
|
|
|
for(int client = 0; client <= MaxClients; client++) {
|
|
if (IsValidClient(client)) {
|
|
JSONObject player = new JSONObject();
|
|
/* Name */
|
|
char name[64];
|
|
GetClientName(client, name, sizeof(name));
|
|
player.SetString("name", name);
|
|
/* Score */
|
|
player.SetInt("score", GetClientFrags(client));
|
|
player.SetInt("deads", GetClientDeaths(client));
|
|
/* Duration */
|
|
char duration[16];
|
|
int ct = RoundFloat(GetClientTime(client));
|
|
int h = ct / 3600;
|
|
int m = ct % 3600 / 60;
|
|
int s = ct % 60;
|
|
Format(duration, sizeof(duration), "%02d:%02d:%02d", h, m, s);
|
|
player.SetString("duration", duration);
|
|
/* Id */
|
|
player.SetInt("id", GetClientUserId(client));
|
|
/* Ip */
|
|
char ip[32];
|
|
GetClientIP(client, ip, sizeof(ip), false);
|
|
player.SetString("ip", ip);
|
|
/* Loss */
|
|
player.SetInt("loss",RoundFloat(GetClientAvgLoss(client, NetFlow_Both)*1000.0));
|
|
/* Ping */
|
|
player.SetInt("ping",RoundFloat(GetClientLatency(client, NetFlow_Both)*1000.0));
|
|
/* State */
|
|
player.SetString("state", "active")
|
|
/* Steam 2 так надо, не надо спрашивать почему*/
|
|
char steam2[32];
|
|
GetClientAuthId(client, AuthId_Steam3, steam2, sizeof(steam2));
|
|
player.SetString("steam2", steam2);
|
|
/* Position on map */
|
|
float pos[3];
|
|
GetClientAbsOrigin(client, pos);
|
|
player.SetFloat("pos_x", pos[0]);
|
|
player.SetFloat("pos_y", pos[1]);
|
|
player.SetFloat("pos_z", pos[2]);
|
|
/* Player class */
|
|
player.SetInt("clz", TF2_GetPlayerClass(client));
|
|
/* Player team */
|
|
player.SetInt("team", TF2_GetClientTeam(client));
|
|
/* push */
|
|
players.Push(player);
|
|
}
|
|
|
|
}
|
|
|
|
payload.Set("players", players);
|
|
return payload;
|
|
}
|
|
|
|
stock void ProcessUpdateStatus() {
|
|
JSONObject payload = createPayload();
|
|
createRequest().Post(payload, Request_Callback);
|
|
}
|
|
|
|
static void Request_Callback(HTTPResponse response, any value){
|
|
g_updating = false;
|
|
if (response.Status == HTTPStatus_OK){
|
|
if(!g_warned) {
|
|
LogMessage("Success send payload, after error");
|
|
g_warned = true;
|
|
}
|
|
return;
|
|
}
|
|
else{
|
|
if(g_warned) {
|
|
LogMessage("Failed response! Code: %i", response.Status);
|
|
g_warned = false;
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
#endif
|
|
|
|
stock UpdateStatus(){
|
|
if (!g_setuped) return;
|
|
if (g_updating) return;
|
|
if (GetTime() - g_lastupdate < 5) return;
|
|
|
|
g_updating = true;
|
|
ProcessUpdateStatus();
|
|
g_lastupdate = GetTime();
|
|
}
|
|
|
|
public Action timerCall(Handle:t, any:d) {
|
|
UpdateStatus();
|
|
return Plugin_Continue;
|
|
}
|
|
|
|
public Action TestUpdate(int client, int args){
|
|
UpdateStatus();
|
|
ReplyToCommand(client, "OK! Last update: %d", g_lastupdate)
|
|
return Plugin_Handled;
|
|
}
|
|
|
|
public OnClientDisconnect(int client) {
|
|
UpdateStatus();
|
|
}
|
|
public OnClientAuthorized(int client) {
|
|
UpdateStatus();
|
|
}
|
|
public OnMapStart() {
|
|
UpdateStatus();
|
|
}
|
|
public OnMapEnd() {
|
|
UpdateStatus();
|
|
}
|