If you copy and paste this into a file and name it that, in the install folder, then if perl is installed, you can run that script (from cmd prompt) by typing : C:\Strawberry\perl\bin\perl.exe eqemu_server.pl new_server (also make sure that VC_redist.x64.exe is installed) it came with the installer files.
Code:
#!/usr/bin/perl
###########################################################
#::: General EQEmu Server Administration Script
#::: Purpose - Handles:
#::: Automatic database versioning (bots and normal DB)
#::: Updating server assets (binary, opcodes, maps, configuration files)
#::: Original Author: Akkadius
#::: Contributors: Uleat, Ali
#::: Purpose: To upgrade databases with ease and maintain versioning
###########################################################
use Config;
use File::Copy qw(copy);
use POSIX qw(strftime);
use File::Path;
use File::Find;
use Time::HiRes qw(usleep);
#############################################
# variables
#############################################
my $install_repository_request_url = "https://raw.githubusercontent.com/Akkadius/eqemu-install-v2/master/";
my $eqemu_repository_request_url = "https://raw.githubusercontent.com/EQEmu/Server/master/";
my $opcodes_path = "";
my $patches_path = "";
my $time_stamp = strftime('%m-%d-%Y', gmtime());
my $db_run_stage = 0; #::: Sets database run stage check
my $bin_dir = "";
#############################################
# os
#############################################
my $OS = "";
my $os_flavor = "";
if ($Config{osname} =~ /freebsd|linux/i) {
$OS = "Linux";
$os_flavor = "";
if (-e "/etc/debian_version") {
$os_flavor = "debian";
}
elsif (-e "/etc/fedora-release") {
$os_flavor = "fedora_core";
}
elsif (-e "/etc/redhat-release") {
$os_flavor = "red_hat";
}
}
if ($Config{osname} =~ /Win|MS/i) {
$OS = "Windows";
}
#############################################
# internet check
#############################################
my $has_internet_connection = check_internet_connection();
if (-e "skip_internet_connection_check.txt") {
$has_internet_connection = 1;
}
#############################################
# skip self update
#############################################
my $skip_self_update_check = 0;
if (-e "eqemu_server_skip_update.txt") {
$skip_self_update_check = 1;
}
#############################################
# skip maps update
#############################################
my $skip_self_maps_update_check = 0;
if (-e "eqemu_server_skip_maps_update.txt") {
$skip_self_maps_update_check = 1;
}
#############################################
# bin dir
#############################################
if (-d "bin") {
$bin_dir = "bin/";
}
#############################################
# run routines
#############################################
get_windows_wget();
check_xml_to_json_conversion() if $ARGV[0] eq "convert_xml";
do_self_update_check_routine() if !$skip_self_update_check;
get_perl_version();
if (-e "eqemu_config.json") {
read_eqemu_config_json();
}
else {
#::: This will need to stay for servers who simply haven't updated yet
# This script can still update without the server bins being updated
read_eqemu_config_xml();
}
get_mysql_path();
#::: Remove old eqemu_update.pl
if (-e "eqemu_update.pl") {
unlink("eqemu_update.pl");
}
print "[Info] For EQEmu Server management utilities - run eqemu_server.pl\n" if $ARGV[0] eq "ran_from_world";
my $skip_checks = 0;
if ($ARGV[0] && $ARGV[0] eq "new_server") {
$skip_checks = 1;
}
if ($skip_checks == 0) {
check_db_version_table();
#::: Check if db_version table exists...
if (trim(get_mysql_result("SHOW COLUMNS FROM db_version LIKE 'Revision'")) ne "" && $db) {
print get_mysql_result("DROP TABLE db_version");
print "[Database] Old db_version table present, dropping...\n\n";
}
}
check_for_world_bootup_database_update();
sub urlencode
{
my ($rv) = @_;
$rv =~ s/([^A-Za-z0-9])/sprintf("%%%2.2X", ord($1)) /ge;
return $rv;
}
sub urldecode
{
my ($rv) = @_;
$rv =~ s/\+/ /g;
$rv =~ s/%(..)/pack("c", hex($1)) /ge;
return $rv;
}
sub analytics_insertion
{
$event_name = urlencode($_[0]);
$event_data = urlencode($_[1]);
#::: Check for internet connection before doing analytics
if (!$has_internet_connection || $can_see_analytics_server == -1) {
return;
}
#::: Check for analytics server connectivity so that the script doesn't break when its offline
if (!$can_see_analytics_server) {
if ($OS eq "Linux") {
$count = "c";
}
if ($OS eq "Windows") {
$count = "n";
}
if (`ping analytics.akkadius.com -$count 1 -w 500` =~ /Reply from|1 received/i) {
$can_see_analytics_server = 1;
}
else {
$can_see_analytics_server = -1;
}
}
$server_name = "";
if ($long_name) {
$server_name = "&server_name=" . urlencode($long_name);
}
if (!$extended_os) {
if ($OS eq "Linux") {
$extended_os = `cat /proc/version`;
$extended_os = trim($extended_os);
}
if ($OS eq "Windows") {
my $output = `ver`;
my @os_version = split("\n", $output);
foreach my $val (@os_version) {
if ($val =~ /Windows/i) {
$extended_os = trim($val);
}
}
}
}
$url = "http://analytics.akkadius.com/";
$url .= "?api_key=24a0bde2e5bacd65bcab06a9ac40b62c";
$url .= "&event=" . $event_name;
$url .= "&event_data=" . $event_data;
$url .= "&OS=" . urlencode($OS);
$url .= "&extended_os=" . urlencode($extended_os);
$url .= $server_name;
# print "Calling url :: '" . $url . "'\n";
if ($OS eq "Windows") {
eval('require LWP::UserAgent;');
my $ua = LWP::UserAgent->new;
$ua->timeout(1);
$ua->env_proxy;
my $response = $ua->get($url);
}
if ($OS eq "Linux") {
$api_call = `curl -s "$url"`;
}
}
sub show_install_summary_info
{
print "[Install] Installation complete...\n";
print "[Install] Server Info (Save somewhere if needed):\n";
if (-e "install_variables.txt") {
$file_to_open = "install_variables.txt";
}
elsif (-e "../install_variables.txt") {
$file_to_open = "../install_variables.txt";
}
open(INSTALL_VARS, $file_to_open);
while (<INSTALL_VARS>) {
chomp;
$o = $_;
@data = split(":", $o);
print " - " . $data[0] . "\t" . $data[1] . "\n";
}
close(INSTALL_VARS);
if ($OS eq "Windows") {
print "[Install] Windows Utility Scripts:\n";
print " - t_start_server.bat Starts EQEmu server with 30 dynamic zones, UCS & Queryserv, dynamic zones\n";
print " - t_start_server_with_loginserver.bat Starts EQEmu server with 30 zones with loginserver\n";
print " - t_stop_server.bat Stops EQEmu Server (No warning)\n";
print " - t_database_backup.bat Backs up the Database to backups/ folder - do not run during server is online\n";
print " - t_server_crash_report.pl Will parse any zone crashes for reporting to developers\n";
}
if ($OS eq "Linux") {
print "[Install] Linux Utility Scripts:\n";
print " - server_start.sh Starts EQEmu server (Quiet) with 30 dynamic zones, UCS & Queryserv, dynamic zones\n";
print " - server_start_dev.sh Starts EQEmu server with 10 dynamic zones, UCS & Queryserv, dynamic zones all verbose\n";
print " - server_stop.sh Stops EQEmu Server (No warning)\n";
print " - server_status.sh Prints the status of the EQEmu Server processes\n";
}
print "[Configure] eqemu_config.json Edit to change server settings and name\n";
analytics_insertion("install_complete", "null");
}
sub new_server
{
$file_count = 0;
opendir(DIR, ".") or die $!;
while (my $file = readdir(DIR)) {
next if ($file =~ m/^\./);
$file_count++;
}
closedir(DIR);
if ($file_count > 4 && (!-e "install_variables.txt" && !-e "../install_variables.txt")) {
print "[New Server] ERROR: You must run eqemu_server.pl in an empty directory\n";
<>;
exit;
}
if (-e "install_variables.txt" || -e "../install_variables.txt") {
get_installation_variables();
}
while (1) {
$database_name = $installation_variables{"mysql_eqemu_db_name"};
$database_user = $installation_variables{"mysql_eqemu_user"};
$database_password = $installation_variables{"mysql_eqemu_password"};
if ($database_name ne "") {
$mysql_pass = 1;
}
else {
print "\n";
print "[New Server] For a new server folder install, we assume Perl and MySQL are configured\n";
print "[New Server] This will install a fresh PEQ Database, with all server assets\n";
print "[New Server] You will need to supply database credentials to get started...\n\n";
check_for_input("MySQL User: ");
$database_user = trim($input);
check_for_input("MySQL Password: ");
$database_password = trim($input);
$check_connection =
`mysql -u $database_user -p$database_password -N -B -e "SHOW PROCESSLIST" > mysqlcheck.txt`;
$mysql_pass = 0;
open(MYSQL_CHECK, "mysqlcheck.txt");
while (<MYSQL_CHECK>) {
chomp;
$o = $_;
if ($o =~ /Error/i) {$mysql_pass = 0;}
if ($o =~ /SHOW PROCESSLIST/i) {$mysql_pass = 1;}
}
close(MYSQL_CHECK);
unlink("mysqlcheck.txt");
}
if ($mysql_pass == 1) {
if ((!-e "install_variables.txt" && !-e "../install_variables.txt")) {
print "[New Server] Success! We have a database connection\n";
check_for_input("Specify a NEW database name that PEQ will be installed to: ");
$database_name = trim($input);
#::: Write install vars
open(INSTALL_VARS, '>', 'install_variables.txt');
print INSTALL_VARS "";
print INSTALL_VARS "mysql_eqemu_db_name:" . $database_name . "\n";
print INSTALL_VARS "mysql_eqemu_user:" . $database_user . "\n";
print INSTALL_VARS "mysql_eqemu_password:" . $database_password . "\n";
close(INSTALL_VARS);
}
analytics_insertion("new_server::install", $database_name);
if ($OS eq "Linux") {
build_linux_source("login");
}
do_installer_routines();
if ($OS eq "Linux") {
print `chmod 755 *.sh`;
}
analytics_insertion("new_server::install_complete",
$database_name . " :: Binary DB Version / Local DB Version :: " . $binary_database_version . " / " . $local_database_version);
print "[New Server] New server folder install complete\n";
print "[New Server] Below is your installation info:\n";
show_install_summary_info();
if ($OS eq "Linux") {
unlink('/home/eqemu/install_variables.txt');
}
rmtree('updates_staged');
return;
}
else {
print "[New Server] MySQL authorization failed or no MySQL installed\n";
}
}
}
sub check_xml_to_json_conversion
{
if (-e "eqemu_config.xml" && !-e "eqemu_config.json") {
if ($OS eq "Windows") {
get_remote_file("https://raw.githubusercontent.com/EQEmu/Server/master/utils/xmltojson/xmltojson-windows-x86.exe",
"xmltojson.exe");
print "Converting eqemu_config.xml to eqemu_config.json\n";
print `xmltojson eqemu_config.xml`;
}
if ($OS eq "Linux") {
get_remote_file("https://raw.githubusercontent.com/EQEmu/Server/master/utils/xmltojson/xmltojson-linux-x86",
"xmltojson");
print "Converting eqemu_config.xml to eqemu_config.json\n";
print `chmod 755 xmltojson`;
print `./xmltojson eqemu_config.xml`;
}
#::: Prettify and alpha order the config
use JSON;
my $json = new JSON();
my $content;
open(my $fh, '<', "eqemu_config.json") or die "cannot open file $filename"; {
local $/;
$content = <$fh>;
}
close($fh);
$result = $json->decode($content);
$json->canonical(1);
print $json->pretty->utf8->encode($result), "\n";
open(my $fh, '>', 'eqemu_config.json');
print $fh $json->pretty->utf8->encode($result);
close $fh;
mkdir('backups');
copy_file("eqemu_config.xml", "backups/eqemu_config.xml");
unlink('eqemu_config.xml');
unlink('db_dumper.pl');
print "[Server Maintenance] eqemu_config.xml is now DEPRECATED \n";
print "[Server Maintenance] eqemu_config.json is now the new Server config format \n";
print " A backup of this old config is located in the backups folder of your server directory\n";
print " --- \n";
print " You may have some plugins and/or applications that still require reference of this config file\n";
print " Please update these plugins/applications to use the new configuration format if needed\n";
print " --- \n";
print " Thanks for your understanding\n";
print " The EQEmulator Team\n\n";
exit;
}
}
sub build_linux_source
{
$build_options = $_[0];
$cmake_options = "";
$source_folder_post_fix = "";
if ($build_options =~ /bots/i) {
$cmake_options .= " -DEQEMU_ENABLE_BOTS=ON";
$source_folder_post_fix = "_bots";
}
$current_directory = `pwd`;
@directories = split('/', $current_directory);
foreach my $val (@directories) {
if (trim($val) ne "") {
$last_directory = trim($val);
}
}
my $eqemu_server_directory = "/home/eqemu";
my $source_dir = $eqemu_server_directory . '/' . $last_directory . '_source' . $source_folder_post_fix;
$current_directory = trim($current_directory);
mkdir($source_dir) if (!-e $source_dir);
# print 'server_dir: ' . $eqemu_server_directory . "\n";
# print 'source_dir: ' . $source_dir . "\n";
# print 'current_dir: \'' . $current_directory . "'\n";
chdir($source_dir);
print `git clone https://github.com/EQEmu/Server.git`;
mkdir($source_dir . "/Server/build") if (!-e $source_dir . "/Server/build");
chdir($source_dir . "/Server");
print `git submodule init`;
print `git submodule update`;
chdir($source_dir . "/Server/build");
print "Generating CMake build files...\n";
if ($os_flavor eq "fedora_core") {
print `cmake $cmake_options -DEQEMU_BUILD_LOGIN=ON -DEQEMU_BUILD_LUA=ON -DLUA_INCLUDE_DIR=/usr/include/lua-5.1/ -G "Unix Makefiles" ..`;
}
else {
print `cmake $cmake_options -DEQEMU_BUILD_LOGIN=ON -DEQEMU_BUILD_LUA=ON -G "Unix Makefiles" ..`;
}
print "Building EQEmu Server code. This will take a while.";
#::: Build
print `make`;
chdir($current_directory);
print `ln -s -f $source_dir/Server/build/bin/eqlaunch .`;
print `ln -s -f $source_dir/Server/build/bin/export_client_files .`;
print `ln -s -f $source_dir/Server/build/bin/import_client_files .`;
print `ln -s -f $source_dir/Server/build/bin/libcommon.a .`;
print `ln -s -f $source_dir/Server/build/bin/libluabind.a .`;
print `ln -s -f $source_dir/Server/build/bin/queryserv .`;
print `ln -s -f $source_dir/Server/build/bin/shared_memory .`;
print `ln -s -f $source_dir/Server/build/bin/ucs .`;
print `ln -s -f $source_dir/Server/build/bin/world .`;
print `ln -s -f $source_dir/Server/build/bin/zone .`;
print `ln -s -f $source_dir/Server/build/bin/loginserver .`;
}
sub do_installer_routines
{
print "[Install] EQEmu Server Installer... LOADING... PLEASE WAIT...\n";
#::: Make some local server directories...
mkdir('logs');
mkdir('updates_staged');
mkdir('shared');
mkdir('bin');
$bin_dir = "bin/";
do_install_config_json();
read_eqemu_config_json();
get_installation_variables();
$db_name = "peq";
if ($installation_variables{"mysql_eqemu_db_name"}) {
$db_name = $installation_variables{"mysql_eqemu_db_name"};
}
#::: Download assets
if ($OS eq "Windows") {
fetch_latest_windows_appveyor();
}
map_files_fetch_bulk() if !$skip_self_maps_update_check;
opcodes_fetch();
plugins_fetch();
quest_files_fetch();
lua_modules_fetch();
fetch_utility_scripts();
#::: Database Routines
print "[Database] Creating Database '" . $db_name . "'\n";
print `"$path" --host $host --user $user --password="$pass" -N -B -e "DROP DATABASE IF EXISTS $db_name;"`;
print `"$path" --host $host --user $user --password="$pass" -N -B -e "CREATE DATABASE $db_name"`;
my $world_path = "world";
if (-e "bin/world") {
$world_path = "bin/world";
}
elsif (-e "bin/world.exe") {
$world_path = "bin/world.exe";
}
#::: Get Binary DB version
if ($OS eq "Windows") {
@db_version = split(': ', `"$world_path" db_version`);
}
if ($OS eq "Linux") {
@db_version = split(': ', `./$world_path db_version`);
}
$binary_database_version = trim($db_version[1]);
#::: Local DB Version
check_db_version_table();
$local_database_version = trim(get_mysql_result("SELECT version FROM db_version LIMIT 1"));
#::: Download PEQ latest
fetch_peq_db_full();
print "[Database] Fetching and Applying Latest Database Updates...\n";
main_db_management();
remove_duplicate_rule_values();
if ($OS eq "Windows") {
check_windows_firewall_rules();
do_windows_login_server_setup();
}
if ($OS eq "Linux") {
do_linux_login_server_setup();
}
}
sub check_for_input
{
print "[Input] " . $_[0];
$input = <STDIN>;
chomp $input;
}
sub check_for_world_bootup_database_update
{
my $world_path = "world";
if (-e "bin/world") {
$world_path = "bin/world";
}
elsif (-e "bin/world.exe") {
$world_path = "bin/world.exe";
}
$binary_database_version = 0;
$local_database_version = 0;
# Usually hit during installer when world hasn't been installed yet...
if (-e $world_path) {
if ($OS eq "Windows") {
@db_version = split(': ', `"$world_path" db_version`);
}
if ($OS eq "Linux") {
@db_version = split(': ', `./$world_path db_version`);
}
$binary_database_version = trim($db_version[1]);
$local_database_version = get_main_db_version();
}
if ($binary_database_version == $local_database_version && $ARGV[0] eq "ran_from_world") {
print "[Update] Database up to date...\n";
if (trim($db_version[2]) == 0) {
print "[Update] Continuing bootup\n";
exit;
}
}
else {
#::: We ran world - Database needs to update, lets backup and run updates and continue world bootup
if ($local_database_version < $binary_database_version && $ARGV[0] eq "ran_from_world") {
print "[Update] Database not up to date with binaries... Automatically updating...\n";
print "[Update] Issuing database backup first...\n";
database_dump_compress();
$db_already_backed_up = 1;
print "[Update] Updating database...\n";
sleep(1);
main_db_management();
analytics_insertion("auto database upgrade world",
$db . " :: Binary DB Version / Local DB Version :: " . $binary_database_version . " / " . $local_database_version);
}
#::: Make sure that we didn't pass any arugments to the script
else {
if ($local_database_version > $binary_database_version) {
print "[Update] Database version is ahead of current binaries...\n";
}
if (!$db) {print "[eqemu_server.pl] No database connection found... Running without\n";}
show_menu_prompt();
}
}
#::: Bots
$binary_database_version = trim($db_version[2]);
if ($binary_database_version > 0) {
$local_database_version = get_bots_db_version();
#::: We ran world - Database needs to update, lets backup and run updates and continue world bootup
if ($binary_database_version == $local_database_version && $ARGV[0] eq "ran_from_world") {
print "[Update] Bots database up to date...\n";
}
else {
if ($local_database_version < $binary_database_version && $ARGV[0] eq "ran_from_world") {
print "[Update] Bots Database not up to date with binaries... Automatically updating...\n";
if (!$db_already_backed_up) {
print "[Update] Issuing database backup first...\n";
database_dump_compress();
}
print "[Update] Updating bots database...\n";
sleep(1);
bots_db_management();
analytics_insertion("auto database bots upgrade world",
$db . " :: Binary DB Version / Local DB Version :: " . $binary_database_version . " / " . $local_database_version);
}
#::: Make sure that we didn't pass any arugments to the script
else {
if ($local_database_version > $binary_database_version) {
print "[Update] Bots database version is ahead of current binaries...\n";
}
if (!$db) {print "[eqemu_server.pl] No database connection found... Running without\n";}
show_menu_prompt();
}
}
}
print "[Update] Continuing bootup\n";
}
sub check_internet_connection
{
if ($OS eq "Linux") {
$count = "c";
}
if ($OS eq "Windows") {
$count = "n";
}
if (`ping 8.8.8.8 -$count 1 -w 500` =~ /TTL|1 received/i) {
# print "[Update] We have a connection to the internet, continuing...\n";
return 1;
}
elsif (`ping 4.2.2.2 -$count 1 -w 500` =~ /TTL|1 received/i) {
# print "[Update] We have a connection to the internet, continuing...\n";
return 1;
}
else {
print "[Update] No connection to the internet, can't check update\n";
return;
}
}
sub get_perl_version
{
#::: Check Perl version
$perl_version = $^V;
$perl_version =~ s/v//g;
print "[Update] Perl Version is " . $perl_version . "\n" if $debug;
if ($perl_version > 5.12) {
no warnings 'uninitialized';
}
no warnings;
}
sub get_windows_wget {
if (!-e "bin/wget.exe" && $OS eq "Windows") {
if (!-d "bin") {
mkdir("bin");
}
`powershell -Command "(New-Object Net.WebClient).DownloadFile('https://raw.githubusercontent.com/Akkadius/eqemu-install-v2/master/windows/wget.exe', 'bin\\wget.exe') "`
}
}
sub do_self_update_check_routine
{
#::: Check for internet connection before updating
if (!$has_internet_connection) {
print "[Update] Cannot check self-update without internet connection...\n";
return;
}
#::: Check for script changes :: eqemu_server.pl
get_remote_file($eqemu_repository_request_url . "utils/scripts/eqemu_server.pl",
"updates_staged/eqemu_server.pl",
0,
1,
1
);
if (-e "updates_staged/eqemu_server.pl") {
my $remote_script_size = -s "updates_staged/eqemu_server.pl";
my $local_script_size = -s "eqemu_server.pl";
if ($remote_script_size != $local_script_size) {
print "[Update] Script has been updated, updating...\n";
my @files;
my $start_dir = "updates_staged/";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
if ($file =~ /eqemu_server/i) {
$destination_file = $file;
$destination_file =~ s/updates_staged\///g;
print "[Install] Installing [" . $destination_file . "]\n";
unlink($destination_file);
copy_file($file, $destination_file);
if ($OS eq "Linux") {
system("chmod 755 eqemu_server.pl");
}
exec("perl eqemu_server.pl ran_from_world");
}
}
print "[Install] Done\n";
}
else {
print "[Update] No script update necessary...\n";
if (-e "db_update") {
unlink("db_update");
}
if (-e "updates_staged") {
unlink("updates_staged");
}
}
unlink("updates_staged/eqemu_server.pl");
unlink("updates_staged");
}
}
sub get_installation_variables
{
#::: Fetch installation variables before building the config
if ($OS eq "Linux") {
if (-e "../install_variables.txt") {
open(INSTALL_VARS, "../install_variables.txt");
}
elsif (-e "install_variables.txt") {
open(INSTALL_VARS, "./install_variables.txt");
}
}
if ($OS eq "Windows") {
open(INSTALL_VARS, "install_variables.txt");
}
while (<INSTALL_VARS>) {
chomp;
$o = $_;
@data = split(":", $o);
$installation_variables{trim($data[0])} = trim($data[1]);
}
close(INSTALL_VARS);
}
sub do_install_config_json
{
get_installation_variables();
#::: Fetch json template
get_remote_file($install_repository_request_url . "eqemu_config.json", "eqemu_config_template.json");
use JSON;
my $json = new JSON();
my $content;
open(my $fh, '<', "eqemu_config_template.json") or die "cannot open file $filename"; {
local $/;
$content = <$fh>;
}
close($fh);
$config = $json->decode($content);
$long_name = "Akkas " . $OS . " PEQ Installer (" . generate_random_password(5) . ')';
$config->{"server"}{"world"}{"longname"} = $long_name;
$config->{"server"}{"world"}{"key"} = generate_random_password(30);
if ($installation_variables{"mysql_eqemu_db_name"}) {
$db_name = $installation_variables{"mysql_eqemu_db_name"};
}
else {
$db_name = "peq";
}
$config->{"server"}{"database"}{"username"} = $installation_variables{"mysql_eqemu_user"};
$config->{"server"}{"database"}{"password"} = $installation_variables{"mysql_eqemu_password"};
$config->{"server"}{"database"}{"db"} = $db_name;
$config->{"server"}{"qsdatabase"}{"username"} = $installation_variables{"mysql_eqemu_user"};
$config->{"server"}{"qsdatabase"}{"password"} = $installation_variables{"mysql_eqemu_password"};
$config->{"server"}{"qsdatabase"}{"db"} = $db_name;
$json->canonical(1);
open(my $fh, '>', 'eqemu_config.json');
print $fh $json->pretty->utf8->encode($config);
close $fh;
unlink("eqemu_config_template.json");
}
sub do_install_config_login_json
{
get_installation_variables();
#::: Fetch json template
get_remote_file($eqemu_repository_request_url . "loginserver/login_util/login.json", "login_template.json");
use JSON;
my $json = new JSON();
my $content;
open(my $fh, '<', "login_template.json") or die "cannot open file $filename"; {
local $/;
$content = <$fh>;
}
close($fh);
$config = $json->decode($content);
if ($installation_variables{"mysql_eqemu_db_name"}) {
$db_name = $installation_variables{"mysql_eqemu_db_name"};
}
else {
$db_name = "peq";
}
$config->{"database"}{"host"} = "127.0.0.1";
$config->{"database"}{"user"} = $installation_variables{"mysql_eqemu_user"};
$config->{"database"}{"password"} = $installation_variables{"mysql_eqemu_password"};
$config->{"database"}{"db"} = $db_name;
$config->{"client_configuration"}{"titanium_opcodes"} = $opcodes_path . "login_opcodes.conf";
$config->{"client_configuration"}{"sod_opcodes"} = $opcodes_path . "login_opcodes_sod.conf";
$json->canonical(1);
open(my $fh, '>', 'login.json');
print $fh $json->pretty->utf8->encode($config);
close $fh;
unlink("login_template.json");
}
sub fetch_utility_scripts
{
if ($OS eq "Windows") {
opendir(DIR, "bin/");
my @files = grep(/\.exe$/, readdir(DIR));
closedir(DIR);
foreach my $file (@files) {
my $full_file = "bin/" . $file;
if ($file=~/test|launch/i) {
next;
}
print "Creating Symbolic Link for [$file] from [$full_file]\n";
system("del start_$file >nul 2>&1");
system("powershell.exe \"New-Item -ItemType SymbolicLink -Name 'start_$file' -Value '$full_file'\" >nul 2>&1");
}
get_remote_file($install_repository_request_url . "windows/t_database_backup.bat", "t_database_backup.bat");
get_remote_file($install_repository_request_url . "windows/t_start_server.bat", "t_start_server.bat");
get_remote_file($install_repository_request_url . "windows/t_server_update_binaries_no_bots.bat",
"t_server_update_binaries_no_bots.bat");
get_remote_file($install_repository_request_url . "windows/t_start_server_with_login_server.bat",
"t_start_server_with_login_server.bat");
get_remote_file($install_repository_request_url . "windows/t_stop_server.bat", "t_stop_server.bat");
get_remote_file($install_repository_request_url . "windows/t_server_crash_report.pl", "t_server_crash_report.pl");
get_remote_file($install_repository_request_url . "windows/win_server_launcher.pl", "win_server_launcher.pl");
get_remote_file($install_repository_request_url . "windows/t_start_server_with_login_server.bat",
"t_start_server_with_login_server.bat");
get_remote_file(
$install_repository_request_url . "windows/t_set_gm_account.bat",
"t_set_gm_account.bat"
);
get_remote_file(
$install_repository_request_url . "windows/windows_server_readme.html",
"windows_server_readme.html"
);
}
else {
get_remote_file($install_repository_request_url . "linux/server_launcher.pl", "server_launcher.pl");
get_remote_file($install_repository_request_url . "linux/server_start.sh", "server_start.sh");
get_remote_file($install_repository_request_url . "linux/server_start_dev.sh", "server_start_dev.sh");
get_remote_file($install_repository_request_url . "linux/server_status.sh", "server_status.sh");
get_remote_file($install_repository_request_url . "linux/server_stop.sh", "server_stop.sh");
}
}
sub setup_bots
{
if ($OS eq "Windows") {
fetch_latest_windows_appveyor_bots();
}
if ($OS eq "Linux") {
build_linux_source("bots");
}
bots_db_management();
print "Bots should be setup, run your server and the bot command should be available in-game (type '^help')\n";
}
sub show_menu_prompt
{
$dc = 0;
while (1) {
if ($ARGV[0] ne "") {
$input = trim($ARGV[0]);
}
else {
$input = trim($input);
}
$errored_command = 0;
if ($input eq "database") {
print "\n>>> Database Menu\n\n";
print " [backup_database] Back up database to backups/ directory\n";
print " [backup_player_tables] Back up player tables to backups/ directory\n";
print " [backup_database_compressed] Back up database compressed to backups/ directory\n";
print " \n";
print " [check_db_updates] Checks for database updates manually\n";
print " [check_bot_db_updates] Checks for bot database updates\n";
print " \n";
print " [aa_tables] Downloads and installs clean slate AA data from PEQ\n";
print " [remove_duplicate_rules] Removes duplicate rules from rule_values table\n";
print " [drop_bots_db_schema] Removes bot database schema\n";
print " \n> main - go back to main menu\n";
print "Enter a command #> ";
$last_menu = trim($input);
}
elsif ($input eq "conversions") {
print "\n>>> Conversions Menu\n\n";
print " [quest_heading_convert] Converts old heading format in quest scripts to new (live format)\n";
print " [quest_faction_convert] Converts to new faction values imported from client\n";
print " \n> main - go back to main menu\n";
print "Enter a command #> ";
$last_menu = trim($input);
}
elsif ($input eq "assets") {
print "\n>>> Server Assets Menu\n\n";
print " [maps] Download latest maps\n";
print " [opcodes] Download opcodes (Patches for eq clients)\n";
print " [quests] Download latest quests\n";
print " [plugins] Download latest plugins\n";
print " [lua_modules] Download latest lua_modules\n";
print " [utility_scripts] Download utility scripts to run and operate the EQEmu Server\n";
if ($OS eq "Windows") {
print ">>> Windows\n";
print " [windows_server_download] Updates server via latest 'stable' code\n";
print " [windows_server_latest] Updates server via latest commit 'unstable'\n";
print " [windows_server_download_bots] Updates server (bots) via latest 'stable'\n";
print " [windows_server_latest_bots] Updates server (bots) via latest commit 'unstable'\n";
print " [fetch_dlls] Grabs dll's needed to run windows binaries\n";
print " [setup_loginserver] Sets up loginserver for Windows\n";
}
print " \n> main - go back to main menu\n";
print "Enter a command #> ";
$last_menu = trim($input);
}
elsif ($input eq "backup_database") {
database_dump();
$dc = 1;
}
elsif ($input eq "backup_player_tables") {
database_dump_player_tables();
$dc = 1;
}
elsif ($input eq "backup_database_compressed") {
database_dump_compress();
$dc = 1;
}
elsif ($input eq "drop_bots_db_schema") {
do_bots_db_schema_drop();
$dc = 1;
}
elsif ($input eq "aa_tables") {
aa_fetch();
$dc = 1;
}
elsif ($input eq "remove_duplicate_rules") {
remove_duplicate_rule_values();
$dc = 1;
}
elsif ($input eq "maps") {
map_files_fetch_bulk();
$dc = 1;
}
elsif ($input eq "opcodes") {
opcodes_fetch();
$dc = 1;
}
elsif ($input eq "plugins") {
plugins_fetch();
$dc = 1;
}
elsif ($input eq "quests") {
quest_files_fetch();
$dc = 1;
}
elsif ($input eq "lua_modules") {
lua_modules_fetch();
$dc = 1;
}
elsif ($input eq "windows_server_download") {
fetch_latest_windows_binaries();
$dc = 1;
}
elsif ($input eq "windows_server_latest") {
fetch_latest_windows_appveyor();
$dc = 1;
}
elsif ($input eq "windows_server_latest_bots") {
fetch_latest_windows_appveyor_bots();
$dc = 1;
}
elsif ($input eq "fetch_dlls") {
fetch_server_dlls();
$dc = 1;
}
elsif ($input eq "utility_scripts") {
fetch_utility_scripts();
$dc = 1;
}
elsif ($input eq "check_db_updates") {
main_db_management();
$dc = 1;
}
elsif ($input eq "check_bot_db_updates") {
bots_db_management();
$dc = 1;
}
elsif ($input eq "setup_loginserver") {
do_windows_login_server_setup();
$dc = 1;
}
elsif ($input eq "new_server") {
new_server();
$dc = 1;
}
elsif ($input eq "setup_bots") {
setup_bots();
$dc = 1;
}
elsif ($input eq "linux_login_server_setup") {
do_linux_login_server_setup();
$dc = 1;
}
elsif ($input eq "quest_heading_convert") {
quest_heading_convert();
$dc = 1;
}
elsif ($input eq "quest_faction_convert") {
quest_faction_convert();
$dc = 1;
}
elsif ($input eq "source_peq_db") {
fetch_peq_db_full();
$dc = 1;
}
elsif ($input eq "exit") {
exit;
}
elsif ($input eq "main") {
print "Returning to main menu...\n";
print_main_menu();
$last_menu = trim($input);
}
elsif ($input eq "" && $last_menu ne "") {
$errored_command = 1;
}
elsif ($input ne "") {
# print "Invalid command '" . $input . "'\n";
$errored_command = 1;
}
else {
print_main_menu();
}
#::: Errored command checking
if ($errored_command == 1) {
$input = $last_menu;
}
elsif ($dc == 1) {
analytics_insertion("menu", trim($input));
$dc = 0;
$input = "";
}
else {
$input = <>;
}
#::: If we're processing a CLI command, kill the loop
if ($ARGV[0] ne "") {
analytics_insertion("cli", trim($input));
$input = "";
$ARGV[0] = "";
exit;
}
}
}
sub print_main_menu
{
print "\n>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>\n";
print ">>> EQEmu Server Main Menu >>>>>>>>>>>>\n";
print ">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>\n\n";
print " [database] Enter database management menu \n";
print " [assets] Manage server assets \n";
print " [new_server] New folder EQEmu/PEQ install - Assumes MySQL/Perl installed \n";
print " [setup_bots] Enables bots on server - builds code and database requirements \n";
print " [conversions] Routines used for conversion of scripts/data \n";
print "\n";
print " exit \n";
print "\n";
print "Enter a command #> ";
}
sub get_mysql_path
{
if ($OS eq "Windows") {
$has_mysql_path = `echo %PATH%`;
if ($has_mysql_path =~ /MySQL|MariaDB/i) {
@mysql = split(';', $has_mysql_path);
foreach my $v (@mysql) {
if ($v =~ /MySQL|MariaDB/i) {
$v =~ s/\n//g;
$path = trim($v) . "/mysql";
last;
}
}
}
}
if ($OS eq "Linux") {
$path = `which mysql`;
if ($path eq "") {
$path = `which mariadb`;
}
$path =~ s/\n//g;
}
#::: Path not found, error and exit
if ($path eq "") {
print "[Error:eqemu_server.pl] MySQL path not found, please add the path for automatic database upgrading to continue... \n\n";
exit;
}
}
sub check_for_database_dump_script
{
#::: Check for internet connection before updating
if (!$has_internet_connection) {
print "[Update] Cannot check update without internet connection...\n";
return;
}
#::: Check for script changes :: database_dumper.pl
get_remote_file($eqemu_repository_request_url . "utils/scripts/database_dumper.pl",
"updates_staged/database_dumper.pl",
0,
1,
1);
if (-e "updates_staged/database_dumper.pl") {
my $remote_script_size = -s "updates_staged/database_dumper.pl";
my $local_script_size = -s "database_dumper.pl";
if ($remote_script_size != $local_script_size) {
print "[Update] Script has been updated, updating...\n";
my @files;
my $start_dir = "updates_staged/";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
if ($file =~ /database_dumper/i) {
$destination_file = $file;
$destination_file =~ s/updates_staged\///g;
print "[Install] Installing [" . $destination_file . "]\n";
unlink($destination_file);
copy_file($file, $destination_file);
if ($OS eq "Linux") {
system("chmod 755 database_dumper.pl");
}
}
}
print "[Install] Done\n";
}
else {
print "[Update] No script update necessary...\n";
}
unlink("updates_staged/database_dumper.pl");
}
return;
}
sub database_dump
{
check_for_database_dump_script();
print "[Database] Performing database backup....\n";
print `perl database_dumper.pl database="$db" loc="backups"`;
}
sub database_dump_player_tables
{
check_for_database_dump_script();
print "[Database] Performing database backup of player tables....\n";
get_remote_file($eqemu_repository_request_url . "utils/sql/character_table_list.txt",
"backups/character_table_list.txt");
$tables = "";
open(FILE, "backups/character_table_list.txt");
$i = 0;
while (<FILE>) {
chomp;
$o = $_;
$tables .= $o . ",";
}
$tables = substr($tables, 0, -1);
print `perl database_dumper.pl database="$db" loc="backups" tables="$tables" backup_name="player_tables_export" nolock`;
print "[Database] Press any key to continue...\n";
<>; #Read from STDIN
}
sub database_dump_compress
{
check_for_database_dump_script();
print "[Database] Performing database backup....\n";
print `perl database_dumper.pl database="$db" loc="backups" compress`;
}
sub script_exit
{
#::: Cleanup staged folder...
rmtree("updates_staged/");
exit;
}
sub check_db_version_table
{
if (get_mysql_result("SHOW TABLES LIKE 'db_version'") eq "" && $db) {
print get_mysql_result("
CREATE TABLE db_version (
version int(11) DEFAULT '0'
) ENGINE=InnoDB DEFAULT CHARSET=latin1;
INSERT INTO db_version (version) VALUES ('1000');");
print "[Database] Table 'db_version' does not exist.... Creating...\n\n";
}
}
#::: Returns Tab Delimited MySQL Result from Command Line
sub get_mysql_result
{
my $run_query = $_[0];
if (!$db) {return;}
if ($OS eq "Windows") {return `"$path" --host $host --user $user --password="$pass" $db -N -B -e "$run_query"`;}
if ($OS eq "Linux") {
$run_query =~ s/`//g;
return `$path --user="$user" --host $host --password="$pass" $db -N -B -e "$run_query"`;
}
}
sub get_mysql_result_from_file
{
my $update_file = $_[0];
if (!$db) {
return;
}
if ($OS eq "Windows") {
return `"$path" --host $host --user $user --password="$pass" --force $db < $update_file`;
}
if ($OS eq "Linux") {
return `"$path" --host $host --user $user --password="$pass" --force $db < $update_file`;
}
}
#::: Gets Remote File based on request_url (1st Arg), and saves to destination file (2nd Arg)
#::: Example: get_remote_file($eqemu_repository_request_url . "utils/sql/db_update_manifest.txt", "db_update/db_update_manifest.txt");
sub get_remote_file
{
my $request_url = $_[0];
my $destination_file = $_[1];
my $content_type = $_[2];
my $no_retry = $_[3];
my $silent_download = $_[4];
if (!$has_internet_connection) {
print "[Download] Cannot download without internet connection...\n";
return;
}
#::: Build file path of the destination file so that we may check for the folder's existence and make it if necessary
if ($destination_file =~ /\//i) {
my @directory_path = split('/', $destination_file);
$build_path = "";
$directory_index = 0;
while ($directory_path[$directory_index] && $directory_path[$directory_index + 1]) {
$build_path .= $directory_path[$directory_index] . "/";
# print "checking '" . $build_path . "'\n";
#::: If path does not exist, create the directory...
if (!-d $build_path) {
print "[Copy] folder doesn't exist, creating [" . $build_path . "]\n";
mkdir($build_path);
}
if (!$directory_indexr_path[$directory_index + 2] && $directory_indexr_path[$directory_index + 1]) {
# print $actual_path . "\n";
$actual_path = $build_path;
last;
}
$directory_index++;
}
}
#::: wget -O db_update/db_update_manifest.txt https://raw.githubusercontent.com/EQEmu/Server/master/utils/sql/db_update_manifest.txt
if ($OS eq "Linux") {
$wget = `wget -N --no-cache --cache=no --no-check-certificate --quiet -O $destination_file $request_url`;
}
elsif ($OS eq "Windows") {
$wget = `bin\\wget.exe -N --no-cache --cache=no --no-check-certificate --quiet -O $destination_file $request_url`;
}
print "[Download] Saved [" . $destination_file . "] from [" . $request_url . "]\n" if !$silent_download;
if ($wget =~ /unable to resolve/i) {
print "Error, no connection or failed request...\n\n";
#die;
}
}
#::: Trim Whitespaces
sub trim
{
my $string = $_[0];
$string =~ s/^\s+//;
$string =~ s/\s+$//;
return $string;
}
sub read_eqemu_config_xml
{
open(CONFIG, "eqemu_config.xml");
while (<CONFIG>) {
chomp;
$o = $_;
if ($o =~ /\<\!--/i) {
next;
}
if ($o =~ /database/i && $o =~ /\<\//i) {
$in_database_tag = 0;
}
if ($o =~ /<database>/i) {
print "IN DATABASE TAG\n" if $debug;
$in_database_tag = 1;
}
if ($o =~ /<longname>/i) {
($long_name) = $o =~ /<longname>(.*)<\/longname>/;
print "Long Name: '" . $long_name . "'\n" if $debug;
}
if ($in_database_tag == 1) {
@left = split(">", $o);
@right = split("<", $left[1]);
$tag_data = trim($right[0]);
if ($o =~ /<username>/i && $in_database_tag) {
$user = $tag_data;
print "Database User: '" . $user . "'\n" if $debug;
}
if ($o =~ /<password>/i && $in_database_tag) {
$pass = $tag_data;
print "Database Pass: '" . $pass . "'\n" if $debug;
}
if ($o =~ /<db>/i) {
$db = $tag_data;
print "Database Name: '" . $db . "'\n" if $debug;
}
if ($o =~ /<host>/i) {
$host = $tag_data;
print "Database Host: '" . $host . "'\n" if $debug;
}
}
}
close(CONFIG);
}
sub read_eqemu_config_json
{
use JSON;
my $json = new JSON();
my $content;
open(my $fh, '<', "eqemu_config.json") or die "cannot open file $filename"; {
local $/;
$content = <$fh>;
}
close($fh);
$config = $json->decode($content);
$db = $config->{"server"}{"database"}{"db"};
$host = $config->{"server"}{"database"}{"host"};
$user = $config->{"server"}{"database"}{"username"};
$pass = $config->{"server"}{"database"}{"password"};
$opcodes_path = $config->{"server"}{"directories"}{"opcodes"};
$patches_path = $config->{"server"}{"directories"}{"patches"};
}
#::: Fetch Latest PEQ AA's
sub aa_fetch
{
if (!$db) {
print "No database present, check your eqemu_config.json for proper MySQL/MariaDB configuration...\n";
return;
}
print "[Install] Pulling down PEQ AA Tables...\n";
get_remote_file($eqemu_repository_request_url . "utils/sql/peq_aa_tables_post_rework.sql",
"db_update/peq_aa_tables_post_rework.sql");
print "[Install] Installing AA Tables...\n";
print get_mysql_result_from_file("db_update/peq_aa_tables_post_rework.sql");
print "[Install] Done...\n\n";
}
#::: Fetch Latest Opcodes
sub opcodes_fetch
{
print "[Update] Pulling down latest opcodes...\n";
my %opcodes = (
1 => [ "opcodes", $eqemu_repository_request_url . "utils/patches/opcodes.conf" ],
2 => [ "mail_opcodes", $eqemu_repository_request_url . "utils/patches/mail_opcodes.conf" ],
3 => [ "Titanium", $eqemu_repository_request_url . "utils/patches/patch_Titanium.conf" ],
4 => [ "Secrets of Faydwer", $eqemu_repository_request_url . "utils/patches/patch_SoF.conf" ],
5 => [ "Seeds of Destruction", $eqemu_repository_request_url . "utils/patches/patch_SoD.conf" ],
6 => [ "Underfoot", $eqemu_repository_request_url . "utils/patches/patch_UF.conf" ],
7 => [ "Rain of Fear", $eqemu_repository_request_url . "utils/patches/patch_RoF.conf" ],
8 => [ "Rain of Fear 2", $eqemu_repository_request_url . "utils/patches/patch_RoF2.conf" ],
);
my $loop = 1;
while ($opcodes{$loop}[0]) {
#::: Split the request_url by the patches folder to get the file name from request_url
my @real_file = split("patches/", $opcodes{$loop}[1]);
my $find = 0;
while ($real_file[$find]) {
$file_name = $real_file[$find];
$find++;
}
my $file_path = $opcodes_path;
if ($file_name =~ /patch_/i) {
$file_path = $patches_path;
}
get_remote_file($opcodes{$loop}[1], $file_path . $file_name);
$loop++;
}
print "[Update] Done...\n";
}
sub remove_duplicate_rule_values
{
$ruleset_id = trim(get_mysql_result("SELECT `ruleset_id` FROM `rule_sets` WHERE `name` = 'default'"));
print "[Database] Default Ruleset ID: " . $ruleset_id . "\n";
$total_removed = 0;
#::: Store Default values...
$mysql_result = get_mysql_result("SELECT * FROM `rule_values` WHERE `ruleset_id` = " . $ruleset_id);
my @lines = split("\n", $mysql_result);
foreach my $val (@lines) {
my @values = split("\t", $val);
$rule_set_values{$values[1]}[0] = $values[2];
}
#::: Compare default values against other rulesets to check for duplicates...
$mysql_result = get_mysql_result("SELECT * FROM `rule_values` WHERE `ruleset_id` != " . $ruleset_id);
my @lines = split("\n", $mysql_result);
foreach my $val (@lines) {
my @values = split("\t", $val);
if ($values[2] == $rule_set_values{$values[1]}[0]) {
print "[Database] Removing duplicate : " . $values[1] . " (Ruleset (" . $values[0] . ")) matches default value of : " . $values[2] . "\n";
get_mysql_result("DELETE FROM `rule_values` WHERE `ruleset_id` = " . $values[0] . " AND `rule_name` = '" . $values[1] . "'");
$total_removed++;
}
}
print "[Database] Total duplicate rules removed... " . $total_removed . "\n";
}
sub copy_file
{
$l_source_file = $_[0];
$l_destination_file = $_[1];
if ($l_destination_file =~ /\//i) {
my @directory_path = split('/', $l_destination_file);
$build_path = "";
$directory_index = 0;
while ($directory_path[$directory_index]) {
$build_path .= $directory_path[$directory_index] . "/";
#::: If path does not exist, create the directory...
if (!-d $build_path) {
mkdir($build_path);
}
if (!$directory_path[$directory_index + 2] && $directory_path[$directory_index + 1]) {
# print $actual_path . "\n";
$actual_path = $build_path;
last;
}
$directory_index++;
}
}
copy $l_source_file, $l_destination_file;
}
sub fetch_latest_windows_appveyor
{
print "[Update] Fetching Latest Windows Binaries (unstable) from Appveyor... \n";
get_remote_file("https://ci.appveyor.com/api/projects/KimLS/server-pglwk/artifacts/build_x64.zip",
"updates_staged/build_x64.zip",
1
);
print "[Update] Fetched Latest Windows Binaries (unstable) from Appveyor... \n";
print "[Update] Extracting... --- \n";
unzip('updates_staged/build_x64.zip', 'updates_staged/binaries/');
my @files;
my $start_dir = "updates_staged/binaries";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
my $destination_file = $file;
$destination_file =~ s/updates_staged\/binaries\///g;
print "[Update] Installing [" . $bin_dir . $destination_file . "]\n";
copy_file($file, $bin_dir . $destination_file);
}
print "[Update] Done\n";
rmtree('updates_staged');
}
sub fetch_latest_windows_binaries
{
print "[Update] Fetching Latest Windows Binaries... \n";
get_remote_file($install_repository_request_url . "master_windows_build.zip",
"updates_staged/master_windows_build.zip",
1
);
print "[Update] Fetched Latest Windows Binaries... \n";
print "[Update] Extracting... --- \n";
unzip('updates_staged/master_windows_build.zip', 'updates_staged/binaries/');
my @files;
my $start_dir = "updates_staged/binaries";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
my $destination_file = $file;
$destination_file =~ s/updates_staged\/binaries\///g;
print "[Update] Installing [" . $bin_dir . $destination_file . "]\n";
copy_file($file, $bin_dir . $destination_file);
}
print "[Update] Done\n";
rmtree('updates_staged');
}
sub fetch_latest_windows_appveyor_bots
{
print "[Update] Fetching Latest Windows Binaries with Bots (unstable) from Appveyor... \n";
get_remote_file("https://ci.appveyor.com/api/projects/KimLS/server-87crp/artifacts/build_x64.zip",
"updates_staged/eqemu-x64-bots.zip",
1);
print "[Update] Fetched Latest Windows Binaries (unstable) from Appveyor... \n";
print "[Update] Extracting... --- \n";
unzip('updates_staged/eqemu-x64-bots.zip', 'updates_staged/binaries/');
my @files;
my $start_dir = "updates_staged/binaries";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
$destination_file = $file;
$destination_file =~ s/updates_staged\/binaries\///g;
print "[Update] Installing [" . $bin_dir . $destination_file . "]\n";
copy_file($file, $bin_dir . $destination_file);
}
print "[Update] Done\n";
rmtree('updates_staged');
}
sub do_windows_login_server_setup
{
print "[Install] Pulling down Loginserver database tables...\n";
get_remote_file(
$eqemu_repository_request_url . "loginserver/login_util/login_schema.sql",
"db_update/login_schema.sql"
);
get_remote_file(
$eqemu_repository_request_url . "loginserver/login_util/login_opcodes_sod.conf",
$opcodes_path . "login_opcodes_sod.conf"
);
get_remote_file(
$eqemu_repository_request_url . "loginserver/login_util/login_opcodes.conf",
$opcodes_path . "login_opcodes.conf"
);
print "[Install] Installing Loginserver tables...\n";
print get_mysql_result_from_file("db_update/login_schema.sql");
print "[Install] Done...\n";
print "[Install] Pulling and initializing Loginserver configuration files...\n";
do_install_config_login_json();
print "[Install] Done...\n";
add_login_server_firewall_rules();
rmtree('updates_staged');
rmtree('db_update');
print "[Install] Press any key to continue...\n";
<>; #Read from STDIN
}
sub do_linux_login_server_setup
{
build_linux_source();
for my $file (@files) {
$destination_file = $file;
$destination_file =~ s/updates_staged\/login_server\///g;
print "[Install] Installing [" . $destination_file . "]\n";
copy_file($file, $destination_file);
}
print "\n Done... \n";
print "[Install] Pulling down Loginserver database tables...\n";
get_remote_file($eqemu_repository_request_url . "loginserver/login_util/login_schema.sql",
"db_update/login_schema.sql");
print "[Install] Installing Loginserver tables...\n";
print get_mysql_result_from_file("db_update/login_schema.sql");
print "[Install] Done...\n\n";
print "[Install] Pulling and initializing Loginserver configuration files...\n";
do_install_config_login_json();
print "[Install] Done...\n";
rmtree('updates_staged');
rmtree('db_update');
get_remote_file($install_repository_request_url . "linux/login_opcodes.conf", $opcodes_path . "login_opcodes.conf");
get_remote_file($install_repository_request_url . "linux/login_opcodes_sod.conf",
$opcodes_path . "login_opcodes_sod.conf");
get_remote_file($install_repository_request_url . "linux/server_start_with_login.sh", "server_start_with_login.sh");
system("chmod 755 *.sh");
print "[Install] Press any key to continue...\n";
<>; #Read from STDIN
}
sub add_login_server_firewall_rules
{
#::: Check Loginserver Firewall install for Windows
if ($OS eq "Windows") {
$output = `netsh advfirewall firewall show rule name=all`;
@output_buffer = split("\n", $output);
$has_loginserver_rules_titanium = 0;
$has_loginserver_rules_sod = 0;
foreach my $val (@output_buffer) {
if ($val =~ /Rule Name/i) {
$val =~ s/Rule Name://g;
if ($val =~ /EQEmu Loginserver/i && $val =~ /Titanium/i) {
$has_loginserver_rules_titanium = 1;
print "[Install] Found existing rule [" . trim($val) . "]\n";
}
if ($val =~ /EQEmu Loginserver/i && $val =~ /SOD/i) {
$has_loginserver_rules_sod = 1;
print "[Install] Found existing rule [" . trim($val) . "]\n";
}
}
}
if ($has_loginserver_rules_titanium == 0) {
print "[Install] Attempting to add EQEmu Loginserver Firewall Rules (Titanium) (TCP) port 5998 \n";
print `netsh advfirewall firewall add rule name="EQEmu Loginserver (Titanium) (5998) TCP" dir=in action=allow protocol=TCP localport=5998`;
print "[Install] Attempting to add EQEmu Loginserver Firewall Rules (Titanium) (UDP) port 5998 \n";
print `netsh advfirewall firewall add rule name="EQEmu Loginserver (Titanium) (5998) UDP" dir=in action=allow protocol=UDP localport=5998`;
}
if ($has_loginserver_rules_sod == 0) {
print "[Install] Attempting to add EQEmu Loginserver Firewall Rules (SOD+) (TCP) port 5999 \n";
print `netsh advfirewall firewall add rule name="EQEmu Loginserver (SOD+) (5999) TCP" dir=in action=allow protocol=TCP localport=5999`;
print "[Install] Attempting to add EQEmu Loginserver Firewall Rules (SOD+) (UDP) port 5999 \n";
print `netsh advfirewall firewall add rule name="EQEmu Loginserver (SOD+) (5999) UDP" dir=in action=allow protocol=UDP localport=5999`;
}
print "If firewall rules don't add you must run this script (eqemu_server.pl) as administrator\n";
print "\n";
print "[Install] Instructions \n";
print "[Install] In order to connect your server to the loginserver you must point your eqemu_config.json to your local server similar to the following:\n";
print "
\"loginserver1\" : {
\"account\" : \"\",
\"host\" : \"login.eqemulator.net\",
\"password\" : \"\",
\"port\" : \"5998\",
\"legacy\": \"1\"
},
\"loginserver2\" : {
\"account\" : \"\",
\"host\" : \"192.168.197.129\",
\"password\" : \"\",
\"port\" : \"5998\"
},
\"localaddress\" : \"192.168.197.129\",
";
print "[Install] When done, make sure your EverQuest client points to your loginserver's IP (In this case it would be 192.168.197.129) in the eqhosts.txt file\n";
}
}
sub check_windows_firewall_rules
{
$output = `netsh advfirewall firewall show rule name=all`;
@output_buffer = split("\n", $output);
$has_world_rules = 0;
$has_zone_rules = 0;
foreach my $val (@output_buffer) {
if ($val =~ /Rule Name/i) {
$val =~ s/Rule Name://g;
if ($val =~ /EQEmu World/i) {
$has_world_rules = 1;
print "[Install] Found existing rule [" . trim($val) . "]\n";
}
if ($val =~ /EQEmu Zone/i) {
$has_zone_rules = 1;
print "[Install] Found existing rule [" . trim($val) . "]\n";
}
}
}
if ($has_world_rules == 0) {
print "[Install] Attempting to add EQEmu World Firewall Rules (TCP) port 9000 \n";
print `netsh advfirewall firewall add rule name="EQEmu World (9000) TCP" dir=in action=allow protocol=TCP localport=9000`;
print "[Install] Attempting to add EQEmu World Firewall Rules (UDP) port 9000 \n";
print `netsh advfirewall firewall add rule name="EQEmu World (9000) UDP" dir=in action=allow protocol=UDP localport=9000`;
}
if ($has_zone_rules == 0) {
print "[Install] Attempting to add EQEmu Zones (7000-7500) TCP \n";
print `netsh advfirewall firewall add rule name="EQEmu Zones (7000-7500) TCP" dir=in action=allow protocol=TCP localport=7000-7500`;
print "[Install] Attempting to add EQEmu Zones (7000-7500) UDP \n";
print `netsh advfirewall firewall add rule name="EQEmu Zones (7000-7500) UDP" dir=in action=allow protocol=UDP localport=7000-7500`;
}
}
sub fetch_server_dlls
{
# print "[Download] Fetching lua51.dll, zlib1.dll, zlib1.pdb, libmysql.dll...\n";
# get_remote_file($install_repository_request_url . "lua51.dll", "lua51.dll", 1);
# get_remote_file($install_repository_request_url . "zlib1.dll", "zlib1.dll", 1);
# get_remote_file($install_repository_request_url . "zlib1.pdb", "zlib1.pdb", 1);
# get_remote_file($install_repository_request_url . "libmysql.dll", "libmysql.dll", 1);
}
sub fetch_peq_db_full
{
print "[Install] Downloading latest PEQ Database... Please wait...\n";
get_remote_file("http://db.projecteq.net/api/v1/dump/latest", "updates_staged/peq-latest.zip", 1);
print "[Install] Downloaded latest PEQ Database... Extracting...\n";
unzip('updates_staged/peq-latest.zip', 'updates_staged/peq_db/');
my $start_dir = "updates_staged/peq_db/peq-dump";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
$destination_file = $file;
$destination_file =~ s/updates_staged\/peq_db\/peq-dump\///g;
if ($file =~ /create_tables_content|create_tables_login|create_tables_player|create_tables_queryserv|create_tables_state|create_tables_system/i) {
print "[Install] Database sourcing [" . $destination_file . "]\n";
get_mysql_result_from_file($file);
}
}
}
sub map_files_fetch_bulk
{
print "[Install] Fetching Latest Maps... (This could take a few minutes...)\n";
get_remote_file("http://github.com/Akkadius/EQEmuMaps/archive/master.zip", "maps/maps.zip", 1);
unzip('maps/maps.zip', 'maps/');
my @files;
my $start_dir = "maps/EQEmuMaps-master/";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
$destination_file = $file;
$destination_file =~ s/maps\/EQEmuMaps-master\///g;
print "[Install] Installing [" . $destination_file . "]\n";
copy_file($file, "maps/" . $destination_file);
}
print "[Install] Fetched Latest Maps\n";
rmtree('maps/EQEmuMaps-master');
unlink('maps/maps.zip');
}
sub map_files_fetch
{
print "[Install] Fetching Latest Maps --- \n";
get_remote_file("https://raw.githubusercontent.com/Akkadius/EQEmuMaps/master/!eqemu_maps_manifest.txt",
"updates_staged/eqemu_maps_manifest.txt");
#::: Get Data from manifest
open(FILE, "updates_staged/eqemu_maps_manifest.txt");
$i = 0;
while (<FILE>) {
chomp;
$o = $_;
@manifest_map_data = split(',', $o);
if ($manifest_map_data[0] ne "") {
$maps_manifest[$i] = [ $manifest_map_data[0], $manifest_map_data[1] ];
$i++;
}
}
#::: Download
$fc = 0;
for ($m = 0; $m <= $i; $m++) {
my $file_existing = $maps_manifest[$m][0];
my $file_existing_size = (stat $file_existing)[7];
if ($file_existing_size != $maps_manifest[$m][1]) {
print "[Install] Updating: '" . $maps_manifest[$m][0] . "'\n";
get_remote_file("https://raw.githubusercontent.com/Akkadius/EQEmuMaps/master/" . $maps_manifest[$m][0],
$maps_manifest[$m][0],
1);
$fc++;
}
}
if ($fc == 0) {
print "[Install] No Map Updates found... \n\n";
}
}
sub quest_files_fetch
{
if (!-e "updates_staged/projecteqquests-master/") {
print "[Update] Fetching Latest Quests --- \n";
get_remote_file("https://codeload.github.com/ProjectEQ/projecteqquests/zip/master",
"updates_staged/projecteqquests-master.zip",
1);
print "[Install] Fetched latest quests...\n";
mkdir('updates_staged');
unzip('updates_staged/projecteqquests-master.zip', 'updates_staged/');
}
$fc = 0;
use File::Find;
use File::Compare;
my @files;
my $start_dir = "updates_staged/projecteqquests-master/";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
if ($file =~ /\.pl|\.lua|\.ext/i) {
$staged_file = $file;
$destination_file = $file;
$destination_file =~ s/updates_staged\/projecteqquests-master\//quests\//g;
if (!-e $destination_file) {
copy_file($staged_file, $destination_file);
print "[Install] Installing [" . $destination_file . "]\n";
$fc++;
}
else {
$directory_indexff = do_file_diff($destination_file, $staged_file);
if ($directory_indexff ne "") {
$backup_dest = "updates_backups/" . $time_stamp . "/" . $destination_file;
print $directory_indexff . "\n";
print "[Update] File Different [" . $destination_file . "]\n";
print "[Update] Do you wish to update this Quest? '" . $destination_file . "' [Yes (Enter) - No (N)] \nA backup will be found in '" . $backup_dest . "'\n";
my $input = <STDIN>;
if ($input =~ /N/i) {}
else {
#::: Make a backup
copy_file($destination_file, $backup_dest);
#::: Copy staged to running
copy($staged_file, $destination_file);
print "[Install] Installing [" . $destination_file . "]\n\n";
}
$fc++;
}
}
}
}
if ($fc == 0) {
print "[Update] No Quest Updates found... \n\n";
}
rmtree("updates_staged/");
}
sub lua_modules_fetch
{
if (!-e "updates_staged/projecteqquests-master/") {
print "[Update] Fetching Latest lua modules --- \n";
get_remote_file("https://codeload.github.com/ProjectEQ/projecteqquests/zip/master",
"updates_staged/projecteqquests-master.zip",
1);
print "[Install] Fetched latest lua modules...\n";
mkdir('updates_staged');
unzip('updates_staged/projecteqquests-master.zip', 'updates_staged/');
}
$fc = 0;
use File::Find;
use File::Compare;
mkdir('lua_modules');
my @files;
my $start_dir = "updates_staged/projecteqquests-master/lua_modules/";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
if ($file =~ /\.pl|\.lua|\.ext/i) {
$staged_file = $file;
$destination_file = $file;
$destination_file =~ s/updates_staged\/projecteqquests-master\/lua_modules\//lua_modules\//g;
if (!-e $destination_file) {
copy_file($staged_file, $destination_file);
print "[Install] Installing [" . $destination_file . "]\n";
$fc++;
}
else {
$directory_indexff = do_file_diff($destination_file, $staged_file);
if ($directory_indexff ne "") {
$backup_dest = "updates_backups/" . $time_stamp . "/" . $destination_file;
print $directory_indexff . "\n";
print "[Update] File Different [" . $destination_file . "]\n";
print "[Update] Do you wish to update this LUA Module? '" . $destination_file . "' [Yes (Enter) - No (N)] \nA backup will be found in '" . $backup_dest . "'\n";
my $input = <STDIN>;
if ($input =~ /N/i) {}
else {
#::: Make a backup
copy_file($destination_file, $backup_dest);
#::: Copy staged to running
copy($staged_file, $destination_file);
print "[Install] Installing [" . $destination_file . "]\n\n";
}
$fc++;
}
}
}
}
if ($fc == 0) {
print "[Update] No LUA Modules Updates found... \n\n";
}
}
sub plugins_fetch
{
if (!-e "updates_staged/projecteqquests-master/") {
print "[Update] Fetching Latest plugins --- \n";
get_remote_file("https://codeload.github.com/ProjectEQ/projecteqquests/zip/master",
"updates_staged/projecteqquests-master.zip",
1);
print "[Install] Fetched latest plugins...\n";
mkdir('updates_staged');
unzip('updates_staged/projecteqquests-master.zip', 'updates_staged/');
}
$fc = 0;
use File::Find;
use File::Compare;
mkdir('plugins');
my @files;
my $start_dir = "updates_staged/projecteqquests-master/plugins/";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
if ($file =~ /\.pl|\.lua|\.ext/i) {
$staged_file = $file;
$destination_file = $file;
$destination_file =~ s/updates_staged\/projecteqquests-master\///g;
if (!-e $destination_file) {
copy_file($staged_file, $destination_file);
print "[Install] Installing [" . $destination_file . "]\n";
$fc++;
}
else {
$directory_indexff = do_file_diff($destination_file, $staged_file);
if ($directory_indexff ne "") {
$backup_dest = "updates_backups/" . $time_stamp . "/" . $destination_file;
print $directory_indexff . "\n";
print "[Update] File Different [" . $destination_file . "]\n";
print "[Update] Do you wish to update this Plugin? '" . $destination_file . "' [Yes (Enter) - No (N)] \nA backup will be found in '" . $backup_dest . "'\n";
my $input = <STDIN>;
if ($input =~ /N/i) {}
else {
#::: Make a backup
copy_file($destination_file, $backup_dest);
#::: Copy staged to running
copy($staged_file, $destination_file);
print "[Install] Installing [" . $destination_file . "]\n\n";
}
$fc++;
}
}
}
}
if ($fc == 0) {
print "[Update] No Plugin Updates found... \n\n";
}
}
sub do_file_diff
{
$file_1 = $_[0];
$file_2 = $_[1];
if ($OS eq "Windows") {
eval "use Text::Diff";
$directory_indexff = diff($file_1, $file_2, { STYLE => "Unified" });
return $directory_indexff;
}
if ($OS eq "Linux") {
# print 'diff -u "$file_1" "$file_2"' . "\n";
return `diff -u "$file_1" "$file_2"`;
}
}
sub unzip
{
$archive_to_unzip = $_[0];
$dest_folder = $_[1];
if ($OS eq "Windows") {
eval "use Archive::Zip qw( :ERROR_CODES :CONSTANTS )";
my $zip = Archive::Zip->new();
unless ($zip->read($archive_to_unzip) == AZ_OK) {
die 'read error';
}
print "[Unzip] Extracting...\n";
$zip->extractTree('', $dest_folder);
}
if ($OS eq "Linux") {
print `unzip -o -q "$archive_to_unzip" -d "$dest_folder"`;
}
}
sub are_file_sizes_different
{
$file_1 = $_[0];
$file_2 = $_[1];
my $file_1 = (stat $file_1)[7];
my $file_2 = (stat $file_2)[7];
# print $file_1 . " :: " . $file_2 . "\n";
if ($file_1 != $file_2) {
return 1;
}
return;
}
sub do_bots_db_schema_drop
{
#"drop_bots.sql" is run before reverting database back to 'normal'
print "[Database] Fetching drop_bots.sql...\n";
get_remote_file($eqemu_repository_request_url . "utils/sql/git/bots/drop_bots.sql", "db_update/drop_bots.sql");
print get_mysql_result_from_file("db_update/drop_bots.sql");
print "[Database] Removing bot database tables...\n";
if (get_mysql_result("SHOW KEYS FROM `group_id` WHERE `Key_name` LIKE 'PRIMARY'") ne "" && $db) {
print get_mysql_result("ALTER TABLE `group_id` DROP PRIMARY KEY;");
}
print get_mysql_result("ALTER TABLE `group_id` ADD PRIMARY KEY (`groupid`, `charid`, `ismerc`);");
if (get_mysql_result("SHOW KEYS FROM `guild_members` WHERE `Key_name` LIKE 'PRIMARY'") ne "" && $db) {
print get_mysql_result("ALTER TABLE `guild_members` DROP PRIMARY KEY;");
}
print get_mysql_result("ALTER TABLE `guild_members` ADD PRIMARY KEY (`char_id`);");
print get_mysql_result("UPDATE `spawn2` SET `enabled` = 0 WHERE `id` IN (59297,59298);");
if (get_mysql_result("SHOW COLUMNS FROM `db_version` LIKE 'bots_version'") ne "" && $db) {
print get_mysql_result("UPDATE `db_version` SET `bots_version` = 0;");
}
print "[Database] Done...\n";
}
sub modify_db_for_bots
{
#Called after the db bots schema (2015_09_30_bots.sql) has been loaded
print "[Database] Modifying database for bots...\n";
print get_mysql_result("UPDATE `spawn2` SET `enabled` = 1 WHERE `id` IN (59297,59298);");
if (get_mysql_result("SHOW KEYS FROM `guild_members` WHERE `Key_name` LIKE 'PRIMARY'") ne "" && $db) {
print get_mysql_result("ALTER TABLE `guild_members` DROP PRIMARY KEY;");
}
if (get_mysql_result("SHOW KEYS FROM `group_id` WHERE `Key_name` LIKE 'PRIMARY'") ne "" && $db) {
print get_mysql_result("ALTER TABLE `group_id` DROP PRIMARY KEY;");
}
print get_mysql_result("ALTER TABLE `group_id` ADD PRIMARY KEY USING BTREE(`groupid`, `charid`, `name`, `ismerc`);");
convert_existing_bot_data();
}
sub convert_existing_bot_data
{
if (get_mysql_result("SHOW TABLES LIKE 'bots'") ne "" && $db) {
print "[Database] Converting existing bot data...\n";
print get_mysql_result("INSERT INTO `bot_data` (`bot_id`, `owner_id`, `spells_id`, `name`, `last_name`, `zone_id`, `gender`, `race`, `class`, `level`, `creation_day`, `last_spawn`, `time_spawned`, `size`, `face`, `hair_color`, `hair_style`, `beard`, `beard_color`, `eye_color_1`, `eye_color_2`, `drakkin_heritage`, `drakkin_tattoo`, `drakkin_details`, `ac`, `atk`, `hp`, `mana`, `str`, `sta`, `cha`, `dex`, `int`, `agi`, `wis`, `fire`, `cold`, `magic`, `poison`, `disease`, `corruption`) SELECT `BotID`, `BotOwnerCharacterID`, `BotSpellsID`, `Name`, `LastName`, `LastZoneId`, `Gender`, `Race`, `Class`, `BotLevel`, UNIX_TIMESTAMP(`BotCreateDate`), UNIX_TIMESTAMP(`LastSpawnDate`), `TotalPlayTime`, `Size`, `Face`, `LuclinHairColor`, `LuclinHairStyle`, `LuclinBeard`, `LuclinBeardColor`, `LuclinEyeColor`, `LuclinEyeColor2`, `DrakkinHeritage`, `DrakkinTattoo`, `DrakkinDetails`, `AC`, `ATK`, `HP`, `Mana`, `STR`, `STA`, `CHA`, `DEX`, `_INT`, `AGI`, `WIS`, `FR`, `CR`, `MR`, `PR`, `DR`, `Corrup` FROM `bots`;");
print get_mysql_result("INSERT INTO `bot_inspect_messages` (`bot_id`, `inspect_message`) SELECT `BotID`, `BotInspectMessage` FROM `bots`;");
print get_mysql_result("RENAME TABLE `bots` TO `bots_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botstances'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_stances` (`bot_id`, `stance_id`) SELECT bs.`BotID`, bs.`StanceID` FROM `botstances` bs INNER JOIN `bot_data` bd ON bs.`BotID` = bd.`bot_id`;");
print get_mysql_result("RENAME TABLE `botstances` TO `botstances_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'bottimers'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_timers` (`bot_id`, `timer_id`, `timer_value`) SELECT bt.`BotID`, bt.`TimerID`, bt.`Value` FROM `bottimers` bt INNER JOIN `bot_data` bd ON bt.`BotID` = bd.`bot_id`;");
print get_mysql_result("RENAME TABLE `bottimers` TO `bottimers_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botbuffs'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_buffs` (`buffs_index`, `bot_id`, `spell_id`, `caster_level`, `duration_formula`, `tics_remaining`, `poison_counters`, `disease_counters`, `curse_counters`, `corruption_counters`, `numhits`, `melee_rune`, `magic_rune`, `persistent`) SELECT bb.`BotBuffId`, bb.`BotId`, bb.`SpellId`, bb.`CasterLevel`, bb.`DurationFormula`, bb.`TicsRemaining`, bb.`PoisonCounters`, bb.`DiseaseCounters`, bb.`CurseCounters`, bb.`CorruptionCounters`, bb.`HitCount`, bb.`MeleeRune`, bb.`MagicRune`, bb.`Persistent` FROM `botbuffs` bb INNER JOIN `bot_data` bd ON bb.`BotId` = bd.`bot_id`;");
if (get_mysql_result("SHOW COLUMNS FROM `botbuffs` LIKE 'dot_rune'") ne "" && $db) {
print get_mysql_result("UPDATE `bot_buffs` bb INNER JOIN `botbuffs` bbo ON bb.`buffs_index` = bbo.`BotBuffId` SET bb.`dot_rune` = bbo.`dot_rune` WHERE bb.`bot_id` = bbo.`BotID`;");
}
if (get_mysql_result("SHOW COLUMNS FROM `botbuffs` LIKE 'caston_x'") ne "" && $db) {
print get_mysql_result("UPDATE `bot_buffs` bb INNER JOIN `botbuffs` bbo ON bb.`buffs_index` = bbo.`BotBuffId` SET bb.`caston_x` = bbo.`caston_x` WHERE bb.`bot_id` = bbo.`BotID`;");
}
if (get_mysql_result("SHOW COLUMNS FROM `botbuffs` LIKE 'caston_y'") ne "" && $db) {
print get_mysql_result("UPDATE `bot_buffs` bb INNER JOIN `botbuffs` bbo ON bb.`buffs_index` = bbo.`BotBuffId` SET bb.`caston_y` = bbo.`caston_y` WHERE bb.`bot_id` = bbo.`BotID`;");
}
if (get_mysql_result("SHOW COLUMNS FROM `botbuffs` LIKE 'caston_z'") ne "" && $db) {
print get_mysql_result("UPDATE `bot_buffs` bb INNER JOIN `botbuffs` bbo ON bb.`buffs_index` = bbo.`BotBuffId` SET bb.`caston_z` = bbo.`caston_z` WHERE bb.`bot_id` = bbo.`BotID`;");
}
if (get_mysql_result("SHOW COLUMNS FROM `botbuffs` LIKE 'ExtraDIChance'") ne "" && $db) {
print get_mysql_result("UPDATE `bot_buffs` bb INNER JOIN `botbuffs` bbo ON bb.`buffs_index` = bbo.`BotBuffId` SET bb.`extra_di_chance` = bbo.`ExtraDIChance` WHERE bb.`bot_id` = bbo.`BotID`;");
}
print get_mysql_result("RENAME TABLE `botbuffs` TO `botbuffs_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botinventory'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_inventories` (`inventories_index`, `bot_id`, `slot_id`, `item_id`, `inst_charges`, `inst_color`, `inst_no_drop`, `augment_1`, `augment_2`, `augment_3`, `augment_4`, `augment_5`) SELECT bi.`BotInventoryID`, bi.`BotID`, bi.`SlotID`, bi.`ItemID`, bi.`charges`, bi.`color`, bi.`instnodrop`, bi.`augslot1`, bi.`augslot2`, bi.`augslot3`, bi.`augslot4`, bi.`augslot5` FROM `botinventory` bi INNER JOIN `bot_data` bd ON bi.`BotID` = bd.`bot_id`;");
if (get_mysql_result("SHOW COLUMNS FROM `botinventory` LIKE 'augslot6'") ne "" && $db) {
print get_mysql_result("UPDATE `bot_inventories` bi INNER JOIN `botinventory` bio ON bi.`inventories_index` = bio.`BotInventoryID` SET bi.`augment_6` = bio.`augslot6` WHERE bi.`bot_id` = bio.`BotID`;");
}
print get_mysql_result("RENAME TABLE `botinventory` TO `botinventory_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botpets'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_pets` (`pets_index`, `pet_id`, `bot_id`, `name`, `mana`, `hp`) SELECT bp.`BotPetsId`, bp.`PetId`, bp.`BotId`, bp.`Name`, bp.`Mana`, bp.`HitPoints` FROM `botpets` bp INNER JOIN `bot_data` bd ON bp.`BotId` = bd.`bot_id`;");
print get_mysql_result("RENAME TABLE `botpets` TO `botpets_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botpetbuffs'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_pet_buffs` (`pet_buffs_index`, `pets_index`, `spell_id`, `caster_level`, `duration`) SELECT bpb.`BotPetBuffId`, bpb.`BotPetsId`, bpb.`SpellId`, bpb.`CasterLevel`, bpb.`Duration` FROM `botpetbuffs` bpb INNER JOIN `bot_pets` bp ON bpb.`BotPetsId` = bp.`pets_index`;");
print get_mysql_result("RENAME TABLE `botpetbuffs` TO `botpetbuffs_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botpetinventory'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_pet_inventories` (`pet_inventories_index`, `pets_index`, `item_id`) SELECT bpi.`BotPetInventoryId`, bpi.`BotPetsId`, bpi.`ItemId` FROM `botpetinventory` bpi INNER JOIN `bot_pets` bp ON bpi.`BotPetsId` = bp.`pets_index`;");
print get_mysql_result("RENAME TABLE `botpetinventory` TO `botpetinventory_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botgroup'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_groups` (`groups_index`, `group_leader_id`, `group_name`) SELECT bg.`BotGroupId`, bg.`BotGroupLeaderBotId`, bg.`BotGroupName` FROM `botgroup` bg INNER JOIN `bot_data` bd ON bg.`BotGroupLeaderBotId` = bd.`bot_id`;");
print get_mysql_result("RENAME TABLE `botgroup` TO `botgroup_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botgroupmembers'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_group_members` (`group_members_index`, `groups_index`, `bot_id`) SELECT bgm.`BotGroupMemberId`, bgm.`BotGroupId`, bgm.`BotId` FROM `botgroupmembers` bgm INNER JOIN `bot_groups` bg ON bgm.`BotGroupId` = bg.`groups_index` INNER JOIN `bot_data` bd ON bgm.`BotId` = bd.`bot_id`;");
print get_mysql_result("RENAME TABLE `botgroupmembers` TO `botgroupmembers_old`;");
}
if (get_mysql_result("SHOW TABLES LIKE 'botguildmembers'") ne "" && $db) {
print get_mysql_result("INSERT INTO `bot_guild_members` (`bot_id`, `guild_id`, `rank`, `tribute_enable`, `total_tribute`, `last_tribute`, `banker`, `public_note`, `alt`) SELECT bgm.`char_id`, bgm.`guild_id`, bgm.`rank`, bgm.`tribute_enable`, bgm.`total_tribute`, bgm.`last_tribute`, bgm.`banker`, bgm.`public_note`, bgm.`alt` FROM `botguildmembers` bgm INNER JOIN `guilds` g ON bgm.`guild_id` = g.`id` INNER JOIN `bot_data` bd ON bgm.`char_id` = bd.`bot_id`;");
print get_mysql_result("RENAME TABLE `botguildmembers` TO `botguildmembers_old`;");
}
}
sub get_main_db_version
{
$main_local_db_version = trim(get_mysql_result("SELECT version FROM db_version LIMIT 1"));
return $main_local_db_version;
}
sub get_bots_db_version
{
#::: Check if bots_version column exists...
if (get_mysql_result("SHOW COLUMNS FROM db_version LIKE 'bots_version'") eq "" && $db) {
print get_mysql_result("ALTER TABLE db_version ADD bots_version int(11) DEFAULT '0' AFTER version;");
print "[Database] Column 'bots_version' does not exists.... Adding to 'db_version' table...\n\n";
}
$bots_local_db_version = trim(get_mysql_result("SELECT bots_version FROM db_version LIMIT 1"));
return $bots_local_db_version;
}
#::: Safe for call from world startup or menu option
sub bots_db_management
{
#::: If we have stale data from main db run
if ($db_run_stage > 0 && $bots_db_management == 0) {
clear_database_runs();
}
#::: Main Binary Database version
$binary_database_version = trim($db_version[2]);
if ($binary_database_version == 0) {
print "[Database] Your server binaries (world/zone) are not compiled for bots...\n\n";
return;
}
$local_database_version = get_bots_db_version();
#::: Set on flag for running bot updates...
$bots_db_management = 1;
if ($local_database_version > $binary_database_version) {
print "[Update] Bots database version is ahead of current binaries...\n";
return;
}
run_database_check();
}
#::: Safe for call from world startup or menu option
sub main_db_management
{
#::: If we have stale data from bots db run
if ($db_run_stage > 0 && $bots_db_management == 1) {
clear_database_runs();
}
#::: Main Binary Database version
$binary_database_version = trim($db_version[1]);
$local_database_version = get_main_db_version();
$bots_db_management = 0;
if ($local_database_version > $binary_database_version) {
print "[Update] Database version is ahead of current binaries...\n";
return;
}
run_database_check();
}
sub clear_database_runs
{
# print "DEBUG :: clear_database_runs\n\n";
#::: Clear manifest data...
%m_d = ();
#::: Clear updates...
@total_updates = ();
}
#::: Responsible for Database Upgrade Routines
sub run_database_check
{
if (!$db) {
print "No database present, check your eqemu_config.json for proper MySQL/MariaDB configuration...\n";
return;
}
#::: Pull down bots database manifest
if ($bots_db_management == 1) {
print "[Database] Retrieving latest bots database manifest...\n";
get_remote_file($eqemu_repository_request_url . "utils/sql/git/bots/bots_db_update_manifest.txt",
"db_update/db_update_manifest.txt");
}
#::: Pull down mainstream database manifest
else {
print "[Database] Retrieving latest database manifest...\n";
get_remote_file($eqemu_repository_request_url . "utils/sql/db_update_manifest.txt",
"db_update/db_update_manifest.txt");
}
#::: Parse manifest
print "[Database] Reading manifest...\n";
use Data::Dumper;
open(FILE, "db_update/db_update_manifest.txt");
while (<FILE>) {
chomp;
$o = $_;
if ($o =~ /#/i) {
next;
}
@manifest = split('\|', $o);
$m_d{$manifest[0]} = [ @manifest ];
}
#::: This is where we set checkpoints for where a database might be so we don't check so far back in the manifest...
if ($local_database_version >= 9000) {
$revision_check = $local_database_version + 1;
}
else {
#::: This does not negatively affect bots
$revision_check = 1000;
if (get_mysql_result("SHOW TABLES LIKE 'character_data'") ne "") {
$revision_check = 8999;
}
}
@total_updates = ();
#::: Fetch and register sqls for this database update cycle
for ($i = $revision_check; $i <= $binary_database_version; $i++) {
if (!defined($m_d{$i}[0])) {
next;
}
$file_name = trim($m_d{$i}[1]);
print "[Database] fetching update: " . $i . " '" . $file_name . "' \n";
fetch_missing_db_update($i, $file_name);
push(@total_updates, $i);
}
if (scalar(@total_updates) == 0) {
print "[Database] No updates need to be run...\n";
if ($bots_db_management == 1) {
print "[Database] Setting Database to Bots Binary Version (" . $binary_database_version . ") if not already...\n\n";
get_mysql_result("UPDATE db_version SET bots_version = $binary_database_version ");
}
else {
print "[Database] Setting Database to Binary Version (" . $binary_database_version . ") if not already...\n\n";
get_mysql_result("UPDATE db_version SET version = $binary_database_version ");
}
clear_database_runs();
return;
}
#::: Execute pending updates
@total_updates = sort @total_updates;
foreach my $val (@total_updates) {
$file_name = trim($m_d{$val}[1]);
$query_check = trim($m_d{$val}[2]);
$match_type = trim($m_d{$val}[3]);
$match_text = trim($m_d{$val}[4]);
#::: Match type update
if ($match_type eq "contains") {
if (trim(get_mysql_result($query_check)) =~ /$match_text/i) {
print "[Database] Applying update [" . $val . "]:[" . $file_name . "]\n";
print get_mysql_result_from_file("db_update/$file_name");
}
else {
print "[Database] Has update [" . $val . "]:[" . $file_name . "]\n";
}
print_match_debug();
print_break();
}
if ($match_type eq "missing") {
if (get_mysql_result($query_check) =~ /$match_text/i) {
print "[Database] Has update [" . $val . "]:[" . $file_name . "]\n";
}
else {
print "[Database] Applying update [" . $val . "]:[" . $file_name . "]\n";
print get_mysql_result_from_file("db_update/$file_name");
}
print_match_debug();
print_break();
}
if ($match_type eq "empty") {
if (get_mysql_result($query_check) eq "") {
print "[Database] Applying update [" . $val . "]:[" . $file_name . "]\n";
print get_mysql_result_from_file("db_update/$file_name");
}
else {
print "[Database] Has update [" . $val . "]:[" . $file_name . "' \n";
}
print_match_debug();
print_break();
}
if ($match_type eq "not_empty") {
if (get_mysql_result($query_check) ne "") {
print "[Database] Applying update [" . $val . "]:[" . $file_name . "]\n";
print get_mysql_result_from_file("db_update/$file_name");
}
else {
print "[Database] Has update [" . $val . "]:[" . $file_name . "]\n";
}
print_match_debug();
print_break();
}
if ($bots_db_management == 1) {
print get_mysql_result("UPDATE db_version SET bots_version = $val WHERE bots_version < $val");
if ($val == 9000) {
modify_db_for_bots();
}
}
else {
print get_mysql_result("UPDATE db_version SET version = $val WHERE version < $val");
if ($val == 9138) {
fix_quest_factions();
}
}
}
if ($bots_db_management == 1) {
print "[Database] Bots database update cycle complete at version [" . get_bots_db_version() . "]\n";
}
else {
print "[Database] Mainstream database update cycle complete at version [" . get_main_db_version() . "]\n";
}
}
sub fetch_missing_db_update
{
$db_update = $_[0];
$update_file = $_[1];
if ($bots_db_management == 1) {
if ($db_update >= 9000) {
get_remote_file($eqemu_repository_request_url . "utils/sql/git/bots/required/" . $update_file,
"db_update/" . $update_file . "");
}
}
else {
if ($db_update >= 9000) {
get_remote_file($eqemu_repository_request_url . "utils/sql/git/required/" . $update_file,
"db_update/" . $update_file . "");
}
elsif ($db_update >= 5000 && $db_update <= 9000) {
get_remote_file($eqemu_repository_request_url . "utils/sql/svn/" . $update_file,
"db_update/" . $update_file . "");
}
}
}
sub print_match_debug
{
if (!$debug) {return;}
print " Match Type: '" . $match_type . "'\n";
print " Match Text: '" . $match_text . "'\n";
print " Query Check: '" . $query_check . "'\n";
print " Result: '" . trim(get_mysql_result($query_check)) . "'\n";
}
sub print_break
{
if (!$debug) {return;}
print "\n==============================================\n";
}
sub generate_random_password
{
my $passwordsize = shift;
my @alphanumeric = ('a' .. 'z', 'A' .. 'Z', 0 .. 9);
my $randpassword = join '',
map $alphanumeric[rand @alphanumeric], 0 .. $passwordsize;
return $randpassword;
}
sub quest_heading_convert
{
if (trim(get_mysql_result("SELECT value FROM variables WHERE varname = 'new_heading_conversion'")) eq "true") {
print "Conversion script has already ran... doing this again would skew proper heading values in function calls...\n";
exit;
}
%matches = (
0 => [ "quest::spawn2", 6 ],
1 => [ "eq.spawn2", 6 ],
2 => [ "eq.unique_spawn", 6 ],
3 => [ "quest::unique_spawn", 6 ],
4 => [ "GMMove", 3 ],
5 => [ "MovePCInstance", 5 ],
6 => [ "MovePC", 4 ],
7 => [ "moveto", 3 ],
);
$total_matches = 0;
use Scalar::Util qw(looks_like_number);
my @files;
my $start_dir = "quests/.";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
#::: Skip non script files
if ($file !~ /lua|pl/i) {next;}
if ($file =~ /lua|pl/i) {
$print_buffer = "";
$changes_made = 0;
#::: Open and read line by line
open(FILE, $file);
while (<FILE>) {
chomp;
$line = $_;
#::: Loop through matches
foreach my $key (sort (keys %matches)) {
$argument_position = $matches{$key}[1];
$match = $matches{$key}[0];
if ($line =~ /$match/i) {
$line_temp = $line;
$line_temp =~ s/$match\(//g;
$line_temp =~ s/\(.*?\)//gs;
$line_temp =~ s/\);.*//;
$line_temp =~ s/\).*//;
$line_temp =~ s/\):.*//;
$line_temp =~ s/\);//g;
@line_data = split(",", $line_temp);
# use Data::Dumper;
# print Dumper(\@line_data);
$heading_value = $line_data[$argument_position];
$heading_value_clean = trim($heading_value);
$heading_value_raw = $line_data[$argument_position];
$heading_value_before = $line_data[$argument_position - 1];
if (looks_like_number($heading_value) && $heading_value != 0 && ($heading_value * 2) <= 512) {
$heading_value_new = $heading_value * 2;
$heading_value =~ s/$heading_value_clean/$heading_value_new/g;
$heading_value_search = quotemeta($heading_value_before . "," . $heading_value_raw);
$heading_value_replace = $heading_value_before . "," . $heading_value;
print $file . "\n";
print $line . "\n";
$line =~ s/$heading_value_search/$heading_value_replace/g;
print $line . "\n";
print "\n";
$changes_made = 1;
}
elsif ($heading_value == 0) {} #::: Do nothing
elsif ($heading_value =~ /GetHeading|heading|\$h/i) {} #::: Do nothing
else {
if ($file =~ /\.pl/i) {
if ($line_temp =~ /#/i) {
$line .= " - needs_heading_validation";
}
else {
$line .= " # needs_heading_validation";
}
}
elsif ($file =~ /\.lua/i) {
if ($line_temp =~ /--/i) {
$line .= " - needs_heading_validation";
}
else {
$line .= " -- needs_heading_validation";
}
}
$changes_made = 1;
print $line . "\n";
}
$total_matches++;
}
}
$print_buffer .= $line . "\n";
}
close(FILE);
if ($changes_made == 1) {
#::: Write changes
open(NEW_FILE, '>', $file);
print NEW_FILE $print_buffer;
close NEW_FILE;
}
}
}
#::: Mark conversion as ran
print get_mysql_result("INSERT INTO `variables` (varname, value, information, ts) VALUES ('new_heading_conversion', 'true', 'Script ran against quests folder to convert new heading values', NOW())");
print "Total matches: " . $total_matches . "\n";
}
sub quest_faction_convert
{
if (trim(get_mysql_result("SELECT value FROM variables WHERE varname = 'new_faction_conversion'")) eq "true") {
print "Conversion script has already ran... doing this again would skew proper faction values in function calls...\n";
exit;
}
%matches = (
0 => [ "GetCharacterFactionLevel", 0 ],
1 => [ "GetModCharacterFactionLevel", 0 ],
2 => [ "SetFactionLevel2", 1 ],
3 => [ "GetFactionLevel", 5 ],
4 => [ "CheckNPCFactionAlly", 0 ],
5 => [ ":Faction", 0 ],
);
$total_matches = 0;
use Scalar::Util qw(looks_like_number);
my @files;
my $start_dir = "quests/.";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
#::: Skip non script files
if ($file !~ /lua|pl/i) {
next;
}
if ($file =~ /lua|pl/i) {
$print_buffer = "";
$changes_made = 0;
#::: Open and read line by line
open(FILE, $file);
while (<FILE>) {
chomp;
$line = $_;
#::: Loop through matches
foreach my $key (sort (keys %matches)) {
$argument_position = $matches{$key}[1];
$match = $matches{$key}[0];
if ($line =~ /$match\(/i || $line =~ /$match \(/i) {
$line_temp = $line;
$line_temp =~ s/^.*$match\(//gi;
$line_temp =~ s/^.*$match \(//gi;
$line_temp =~ s/"//g;
$line_temp =~ s/\);.*//;
@line_data = split(",", $line_temp);
$faction_value = $line_data[$argument_position];
$faction_value_clean = trim($faction_value);
if (looks_like_number($faction_value_clean)) {
$new_faction =
get_mysql_result("select clientid from client_server_faction_map where serverid = $faction_value_clean");
chomp $new_faction;
if ($new_faction == 0) {
$new_faction =
get_mysql_result("select new_faction from custom_faction_mappings where old_faction = $faction_value_clean");
chomp $new_faction;
}
if ($new_faction > 0) {
print "BEFORE: " . $line . "\n";
$line =~ s/$faction_value_clean/$new_faction/g;
print "AFTER: " . $line . "\n";
$changes_made = 1;
}
else {
print "Unknown Faction: '$match' FACTION VALUE: '" . $faction_value_clean . "'\n";
}
}
$total_matches++;
}
}
$print_buffer .= $line . "\n";
}
close(FILE);
#::: Write changes
if ($changes_made == 1) {
open(NEW_FILE, '>', $file);
print NEW_FILE $print_buffer;
close NEW_FILE;
}
}
}
#::: Mark conversion as ran
print get_mysql_result("INSERT INTO `variables` (varname, value, information, ts) VALUES ('new_faction_conversion', 'true', 'Script ran against quests folder to convert new faction values', NOW())");
print "Total matches: " . $total_matches . "\n";
}
sub fix_quest_factions
{
# Backup the quests
mkdir('backups');
my @files;
my $start_dir = "quests/";
find(
sub {push @files, $File::Find::name unless -d;},
$start_dir
);
for my $file (@files) {
$destination_file = $file;
my $date = strftime "%m-%d-%Y", localtime;
$destination_file =~ s/quests/quests-$date/;
print "Backing up :: " . $destination_file . "\n";
# unlink($destination_file);
copy_file($file, 'backups/' . $destination_file);
}
# Fix the factions
quest_faction_convert();
}