UNLOZE/projects-jenz
11
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
44e5af3586
projects-jenz/AutismBotIngame/scripting/autism_bot_simulate_movement.sp

529 lines
15 KiB
SourcePawn
Executable File
Raw Blame History

#pragma semicolon 1
#pragma newdecls required
#define DEBUG
#define PLUGIN_AUTHOR "jenz"
#define PLUGIN_VERSION "1.9"
#define generic_length 256
#include <sourcemod>
#include <sdktools>
#include <AFKManager>
#include <sdkhooks>
#include <cstrike>
#include <socket>
#include <UNLOZE.secret>
int target_client[5]; //4 autism bots.
#define BUFFER_SIZE 198 // ~2 seconds at 66 tick
enum struct FrameData {
int buttons;
float vel[3];
float angles[3];
int impulse;
}
FrameData g_Buffer[MAXPLAYERS+1][BUFFER_SIZE];
int g_WriteHead[MAXPLAYERS+1]; // where were writing next
int g_FrameCount[MAXPLAYERS+1]; // total frames captured
int g_DelayTicks = 128; // delay
int ports[7] = {48470, 48471, 48472, 48473, 48474, 48479, 48480}; //last three indexes are ports its sending udp from in plugin
int server_ports[2] = {27015, 27035}; //server ports: ze, ze2
bool chat_cooldown = false;
//socket for bot input
Handle global_socket;
//timer handle
Handle g_hTimer_pressing = null;
Handle g_hTimer_bot_connect = null;
int specific_bot_player[MAXPLAYERS + 1];
public Plugin myinfo =
{
name = "autism bot simulate player movement",
author = PLUGIN_AUTHOR,
description = "just copies player movement to the autism bots",
version = PLUGIN_VERSION,
url = ""
};
public void OnPluginStart()
{
//talking
RegConsoleCmd("sm_autism", cmd_talk, "talking to the bot through java application");
RegConsoleCmd("sm_botrtv", cmd_botrtv, "making bots rtv");
HookEvent("round_start", Event_RoundStart, EventHookMode_PostNoCopy);
//UDP connection
connect_socket();
chat_cooldown = false;
g_hTimer_bot_connect = CreateTimer(90.0, bot_check_connect, _, TIMER_REPEAT);
g_hTimer_pressing = CreateTimer(2.0, check_team, _, TIMER_REPEAT);
target_client[1] = -1;
target_client[2] = -1;
target_client[3] = -1;
target_client[4] = -1;
for (int i = 1; i <= MaxClients; i++)
{
if (IsValidClient(i))
{
OnClientPostAdminCheck(i);
}
}
}
public void OnPluginEnd()
{
if (g_hTimer_pressing != null)
{
delete g_hTimer_pressing;
}
if (g_hTimer_bot_connect != null)
{
delete g_hTimer_bot_connect;
}
}
public void OnPlayerRunCmdPost(int client, int buttons, int impulse, const float vel[3], const float angles[3], int weapon, int subtype, int cmdnum, int tickcount, int seed, const int mouse[2])
{
if (!IsValidClient(client) || IsFakeClient(client))
{
return;
}
int head = g_WriteHead[client];
g_Buffer[client][head].buttons = buttons;
g_Buffer[client][head].impulse = impulse;
g_Buffer[client][head].vel = vel;
g_Buffer[client][head].angles = angles;
g_WriteHead[client] = (head + 1) % BUFFER_SIZE;
g_FrameCount[client]++;
}
public Action OnPlayerRunCmd(int client, int& buttons, int& impulse, float vel[3], float angles[3], int& weapon, int& subtype, int& cmdnum, int& tickcount, int& seed, int mouse[2])
{
if (specific_bot_player[client] == -1 || !IsValidClient(target_client[specific_bot_player[client]]))
{
return Plugin_Continue;
}
int target = target_client[specific_bot_player[client]];
// Read from the slot that is DelayTicks behind current write head
int readSlot = (g_WriteHead[target] - g_DelayTicks + BUFFER_SIZE) % BUFFER_SIZE;
buttons = g_Buffer[target][readSlot].buttons;
impulse = g_Buffer[target][readSlot].impulse;
vel = g_Buffer[target][readSlot].vel;
angles = g_Buffer[target][readSlot].angles;
return Plugin_Changed;
}
public void Event_RoundStart(Handle event, const char[] name, bool dontBroadcast)
{
target_client[1] = -1;
target_client[2] = -1;
target_client[3] = -1;
target_client[4] = -1;
chat_cooldown = false;
for (int i = 1; i <= MaxClients; i++)
{
if (IsValidClient(i) && IsPlayerAlive(i) && specific_bot_player[i] != -1)
{
for (int j = 1; j <= MaxClients; j++)
{
if (IsValidClient(j) && GetClientTeam(j) == GetClientTeam(i) && IsPlayerAlive(j) && GetClientIdleTime(j) < 20)
{
if (target_client[1] == j || target_client[2] == j || target_client[3] == j || target_client[4])
{
continue; //one of the autism bots already got this dude as their target.
}
float vec[3];
GetClientAbsOrigin(j, vec);
TeleportEntity(i, vec, NULL_VECTOR, NULL_VECTOR);
target_client[specific_bot_player[i]] = j;
break;
}
}
}
}
}
public void cmd_talk_help(int port, int client, char[] info)
{
char msg[generic_length * 5];
chat_cooldown = true;
char magic_code[16];
Format(magic_code, sizeof(magic_code), autism_bot_code); //included with unloze.secrets simply.
Format(msg, sizeof(msg), "clientmessage:%N %s %s", client, magic_code, info);
send_socket_msg(msg, strlen(msg), port);
CreateTimer(2.0, bot_chat_cooldown);
}
public void is_autism_bot1(int client)
{
char auth[50];
GetClientAuthId(client, AuthId_Engine, auth, sizeof(auth));
if (StrEqual("[U:1:120378081]", auth, false) || StrEqual("STEAM_0:1:60189040", auth, false))
{
specific_bot_player[client] = 1;
}
}
public void is_autism_bot2(int client)
{
char auth[50];
GetClientAuthId(client, AuthId_Engine, auth, sizeof(auth));
if (StrEqual("[U:1:1036189204]", auth, false) || StrEqual("STEAM_0:0:518094602", auth, false))
{
specific_bot_player[client] = 2;
}
}
public void is_autism_bot3(int client)
{
char auth[50];
GetClientAuthId(client, AuthId_Engine, auth, sizeof(auth));
if (StrEqual("[U:1:408797742]", auth, false) || StrEqual("STEAM_0:0:204398871", auth, false))
{
specific_bot_player[client] = 3;
}
}
public void is_autism_bot4(int client)
{
char auth[50];
GetClientAuthId(client, AuthId_Engine, auth, sizeof(auth));
if (StrEqual("[U:1:1221121532]", auth, false) || StrEqual("STEAM_0:0:610560766", auth, false))
{
specific_bot_player[client] = 4;
}
}
public Action cmd_botrtv(int client, int args)
{
if ((CheckCommandAccess(client, "sm_kick", ADMFLAG_KICK)) || (CheckCommandAccess(client, "sm_reserved", ADMFLAG_RESERVATION)))
{
for (int i = 1; i <= MaxClients; i++)
{
if (IsValidClient(i) && specific_bot_player[i] != -1)
{
FakeClientCommandEx(i, "say rtv");
}
}
}
return Plugin_Handled;
}
public Action cmd_talk(int client, int args)
{
char info[generic_length];
GetCmdArgString(info, sizeof(info));
if (strlen(info) == 0)
{
PrintToChat(client, "Add a message to the command if autism bot is ingame and running on discord");
return Plugin_Handled;
}
if (specific_bot_player[client] == -1)
{
return Plugin_Handled;
}
if (chat_cooldown)
{
PrintToChat(client, "spamming bot too much, applying cooldown");
return Plugin_Handled;
}
bool bot_found = false;
for (int i = 1; i <= MaxClients; i++)
{
if (IsValidClient(i) && specific_bot_player[i] != -1)
{
int port_number = specific_bot_player[i] - 1;
cmd_talk_help(ports[port_number], client, info);
bot_found = true;
}
}
if (!bot_found)
PrintToChat(client, "bot not connected to server");
return Plugin_Handled;
}
public Action bot_chat_cooldown(Handle timer, any data)
{
chat_cooldown = false;
return Plugin_Continue;
}
public void send_socket_msg(char[] query_msg, int len, int port)
{
//LogMessage("query_msg: %s port: %i", query_msg, port);
if (global_socket != INVALID_HANDLE && SocketIsConnected(global_socket))
SocketSendTo(global_socket, query_msg, len, "127.0.0.1", port); //udp
}
public Action bot_check_connect(Handle timer, any data)
{
//this is designed for being ran from several css servers
int client_count = GetClientCount(false);
char msg[generic_length];
int i_port = GetConVarInt(FindConVar("hostport"));
bool bot1_connected = false;
bool bot2_connected = false;
bool bot3_connected = false;
bool bot4_connected = false;
for (int i = 1; i <= MaxClients; i++)
if (IsValidClient(i) && !IsFakeClient(i))
{
if (specific_bot_player[i] == 1)
bot1_connected = true;
if (specific_bot_player[i] == 2)
bot2_connected = true;
if (specific_bot_player[i] == 3)
bot3_connected = true;
if (specific_bot_player[i] == 4)
bot4_connected = true;
}
if (i_port == server_ports[0])
{
int max_allowed_players = 55;
char current_map[128];
GetCurrentMap(current_map, sizeof(current_map));
if (client_count > max_allowed_players)
{
Format(msg, sizeof(msg), "connect to ze2");
send_socket_msg(msg, strlen(msg), ports[0]);
send_socket_msg(msg, strlen(msg), ports[1]);
send_socket_msg(msg, strlen(msg), ports[2]);
send_socket_msg(msg, strlen(msg), ports[3]);
}
else if (client_count < max_allowed_players - 5)
{
Format(msg, sizeof(msg), "connect to ze");
if (!bot1_connected)
send_socket_msg(msg, strlen(msg), ports[0]);
if (!bot2_connected)
send_socket_msg(msg, strlen(msg), ports[1]);
if (!bot3_connected)
send_socket_msg(msg, strlen(msg), ports[2]);
if (!bot4_connected)
send_socket_msg(msg, strlen(msg), ports[3]);
}
}
else
{
//in case the bot is not connected to ze2 anymore make sure that is_bot_connected_to_ze2 is set to false again
Format(msg, sizeof(msg), "not connected to ze2");
if (!bot1_connected)
send_socket_msg(msg, strlen(msg), ports[0]);
if (!bot2_connected)
send_socket_msg(msg, strlen(msg), ports[1]);
if (!bot3_connected)
send_socket_msg(msg, strlen(msg), ports[2]);
if (!bot4_connected)
send_socket_msg(msg, strlen(msg), ports[3]);
}
return Plugin_Continue;
}
public Action check_team(Handle timer, any data)
{
int valid_ct_counter = 0;
for (int client = 1; client <= MaxClients; client++)
{
if (!IsValidClient(client)) continue;
if (specific_bot_player[client] == -1 && GetClientTeam(client) > CS_TEAM_SPECTATOR)
{
valid_ct_counter++;
}
}
for (int client = 1; client <= MaxClients; client++)
{
if (!IsValidClient(client))
{
continue;
}
if (specific_bot_player[client] != -1 && GetClientTeam(client) <= CS_TEAM_SPECTATOR)
{
if (valid_ct_counter < 3)
{
continue;
}
ChangeClientTeam(client, CS_TEAM_T);
continue;
}
if (specific_bot_player[client] != -1)
{
if (IsPlayerAlive(client))
{
target_client[specific_bot_player[client]] = GetClosestClient_option1(client);
}
}
}
bool found_valid_ct = false;
for (int client = 1; client <= MaxClients; client++)
{
if (!IsValidClient(client)) continue;
if (specific_bot_player[client] == -1 && GetClientTeam(client) > CS_TEAM_SPECTATOR && IsPlayerAlive(client))
{
found_valid_ct = true;
break;
}
}
if (!found_valid_ct)
{
for (int client = 1; client <= MaxClients; client++)
{
if (!IsValidClient(client)) continue;
if (specific_bot_player[client] != -1 && IsPlayerAlive(client))
{
ForcePlayerSuicide(client);
}
}
}
return Plugin_Continue;
}
stock bool IsValidClient(int client)
{
if (client > 0 && client <= MaxClients && IsClientConnected(client) && IsClientInGame(client))
return true;
return false;
}
public int GetClosestClient_option1(int autism_client)
{
float nearestdistance = -1.0;
int nearest = -1;
for (int i = 1; i <= MaxClients; i++)
{
if (IsValidClient(i) && !IsFakeClient(i) && IsPlayerAlive(i) && i != autism_client)
{
if (GetClientIdleTime(i) > 20 || GetClientTeam(autism_client) != GetClientTeam(i))
{
continue;
}
float pos[3];
GetEntPropVector(i, Prop_Send, "m_vecOrigin", pos);
float dist_target = get_power_distance(autism_client, pos);
if (specific_bot_player[i] != -1)
{
//just making sure bots have lowest priority
dist_target = 9000000.0;
}
if (nearestdistance < 0 || dist_target < nearestdistance)
{
nearest = i;
nearestdistance = dist_target;
}
}
}
return nearest;
}
public float get_power_distance(int target_player, float pos[3])
{
float vec[3];
GetClientAbsOrigin(target_player, vec);
return GetVectorDistance(vec, pos);
}
public void OnClientPutInServer(int client)
{
specific_bot_player[client] = -1;
}
public void OnClientPostAdminCheck(int client)
{
specific_bot_player[client] = -1;
is_autism_bot1(client);
is_autism_bot2(client);
is_autism_bot3(client);
is_autism_bot4(client);
//checks if ze or ze2
int i_port = GetConVarInt(FindConVar("hostport"));
char msg[generic_length];
if (i_port == server_ports[0])
{
Format(msg, sizeof(msg), "autismo connected to ze");
}
else
{
Format(msg, sizeof(msg), "autismo connected to ze2");
}
if (specific_bot_player[client] != -1)
{
send_socket_msg(msg, strlen(msg), ports[specific_bot_player[client] - 1]);
}
}
public void OnSocketError(Handle socket, const int errorType, const int errorNum, any args)
{
CloseHandle(socket);
LogError("[MR] Socket error: %d (errno %d)", errorType, errorNum);
CreateTimer(10.0, TimerConnect, INVALID_HANDLE, TIMER_HNDL_CLOSE);
}
stock void connect_socket()
{
if (global_socket == INVALID_HANDLE || !SocketIsConnected(global_socket))
{
int i_port = GetConVarInt(FindConVar("hostport"));
int target_port = ports[4]; //default ze
if (i_port == server_ports[1])
{
//ze2
target_port = ports[5];
}
//socket otherwise declare in public OnConfigsExecuted(){}
global_socket = SocketCreate(SOCKET_UDP, OnSocketError);
SocketSetOption(global_socket, SocketReuseAddr, 1);
SocketBind(global_socket, "127.0.0.0", target_port);
SocketConnect(global_socket, OnSocketConnected, OnSocketReceive, OnSocketDisconnected, "127.0.0.1", target_port); //48474 on ze
}
}
public void OnClientDisconnect(int client)
{
specific_bot_player[client] = -1;
}
//Socket callback
public void OnSocketConnected(Handle socket, int arg)
{
}
//manage message
public void OnSocketReceive(Handle socket, char receiveData [3500], int dataSize, int hFile)
{
}
public void OnSocketDisconnected(Handle socket, int arg)
{
CreateTimer(10.0, TimerConnect, INVALID_HANDLE, TIMER_HNDL_CLOSE);
}
public Action TimerConnect(Handle timer, any arg)
{
connect_socket();
return Plugin_Handled;
}
Reference in New Issue View Git Blame Copy Permalink