Masterserver update

diff --git a/src/server.cpp b/src/server.cpp
index c144be1ba13d541cc8e16d7e4b09d83241aacc8c..8350b7013a9cefe1bc600c3eae843b5d04608bb7 100644 (file)
--- a/src/server.cpp
+++ b/src/server.cpp
@@ -673,7 +673,6 @@ Server::Server(
        m_objectdata_timer = 0.0;
        m_emergethread_trigger_timer = 0.0;
        m_savemap_timer = 0.0;
-       m_clients_number = 0;
 
        m_env_mutex.Init();
        m_con_mutex.Init();
@@ -1244,7 +1243,7 @@ void Server::AsyncRunStep()
                        counter = 0.0;
 
                        JMutexAutoLock lock2(m_con_mutex);
-                       m_clients_number = 0;
+                       m_clients_names.clear();
                        if(m_clients.size() != 0)
                                infostream<<"Players:"<<std::endl;
                        for(std::map<u16, RemoteClient*>::iterator
@@ -1258,7 +1257,7 @@ void Server::AsyncRunStep()
                                        continue;
                                infostream<<"* "<<player->getName()<<"\t";
                                client->PrintInfo(infostream);
-                               ++m_clients_number;
+                               m_clients_names.push_back(player->getName());
                        }
                }
        }
@@ -1270,7 +1269,7 @@ void Server::AsyncRunStep()
                float &counter = m_masterserver_timer;
                if(!isSingleplayer() && (!counter || counter >= 300.0) && g_settings->getBool("server_announce") == true)
                {
-                       ServerList::sendAnnounce(!counter ? "start" : "update", m_clients_number, m_uptime.get(), m_gamespec.id, m_mods);
+                       ServerList::sendAnnounce(!counter ? "start" : "update", m_clients_names, m_uptime.get(), m_env->getGameTime(), m_gamespec.id, m_mods);
                        counter = 0.01;
                }
                counter += dtime;

diff --git a/src/server.h b/src/server.h
index bc7829f748cafcda5bf29d35b382a4b1a85615c7..b52ae02dcf19b90ebe6a98ef54e33c314d247f9a 100644 (file)
--- a/src/server.h
+++ b/src/server.h
@@ -685,7 +685,7 @@ private:
        JMutex m_con_mutex;
        // Connected clients (behind the con mutex)
        std::map<u16, RemoteClient*> m_clients;
-       u16 m_clients_number; //for announcing masterserver
+       std::vector<std::string> m_clients_names; //for announcing masterserver
 
        // Ban checking
        BanManager *m_banmanager;

diff --git a/src/serverlist.cpp b/src/serverlist.cpp
index 908f048cb5624d422347a030fd81a5dbe569a750..fb5bc9c87d6b21e32cd7a6a089561b40020cc8eb 100644 (file)
--- a/src/serverlist.cpp
+++ b/src/serverlist.cpp
@@ -194,11 +194,11 @@ static size_t ServerAnnounceCallback(void *contents, size_t size, size_t nmemb,
     //((std::string*)userp)->append((char*)contents, size * nmemb);
     return size * nmemb;
 }
-void sendAnnounce(std::string action, u16 clients, double uptime, std::string gameid, std::vector<ModSpec> m_mods) {
+void sendAnnounce(std::string action, const std::vector<std::string> & clients_names, double uptime, u32 game_time, std::string gameid, std::vector<ModSpec> mods) {
        Json::Value server;
        if (action.size())
                server["action"]        = action;
-       server["port"] = g_settings->get("port");
+       server["port"]          = g_settings->get("port");
        server["address"]       = g_settings->get("server_address");
        if (action != "delete") {
                server["name"]          = g_settings->get("server_name");
@@ -209,10 +209,15 @@ void sendAnnounce(std::string action, u16 clients, double uptime, std::string ga
                server["damage"]        = g_settings->get("enable_damage");
                server["password"]      = g_settings->getBool("disallow_empty_password");
                server["pvp"]           = g_settings->getBool("enable_pvp");
-               server["clients"]       = clients;
+               server["clients"]       = (int)clients_names.size();
                server["clients_max"]   = g_settings->get("max_users");
-               if (uptime >=1) server["uptime"] = (int)uptime;
-               if (gameid!="") server["gameid"] = gameid;
+               server["clients_list"]  = Json::Value(Json::arrayValue);
+               for(u32 i = 0; i < clients_names.size(); ++i) {
+                       server["clients_list"].append(clients_names[i]);
+               }
+               if (uptime >= 1)        server["uptime"]        = (int)uptime;
+               if (gameid != "")       server["gameid"]        = gameid;
+               if (game_time >= 1)     server["game_time"]     = game_time;
        }
 
        if(server["action"] == "start") {
@@ -220,8 +225,8 @@ void sendAnnounce(std::string action, u16 clients, double uptime, std::string ga
                server["rollback"]      = g_settings->getBool("enable_rollback_recording");
                server["liquid_finite"] = g_settings->getBool("liquid_finite");
                server["mapgen"]        = g_settings->get("mg_name");
-               server["mods"] = Json::Value(Json::arrayValue);
-               for(std::vector<ModSpec>::iterator m = m_mods.begin(); m != m_mods.end(); m++) {
+               server["mods"]          = Json::Value(Json::arrayValue);
+               for(std::vector<ModSpec>::iterator m = mods.begin(); m != mods.end(); m++) {
                        server["mods"].append(m->name);
                }
                actionstream << "announcing to " << g_settings->get("serverlist_url") << std::endl;

diff --git a/src/serverlist.h b/src/serverlist.h
index 365e86beb6e4242ba2110fc40429c6e8ccb34a50..77eb29b14a09a7fff19509ad401c1a044662cbba 100644 (file)
--- a/src/serverlist.h
+++ b/src/serverlist.h
@@ -40,7 +40,9 @@ namespace ServerList
        std::vector<ServerListSpec> deSerializeJson(std::string liststring);
        std::string serializeJson(std::vector<ServerListSpec>);
        #if USE_CURL
-       void sendAnnounce(std::string action = "", u16 clients = 0, double uptime = 0, std::string gameid = "", std::vector<ModSpec> m_mods = std::vector<ModSpec>());
+       void sendAnnounce(std::string action = "", const std::vector<std::string> & clients_names = std::vector<std::string>(), 
+                               double uptime = 0, u32 game_time = 0,std::string gameid = "", 
+                               std::vector<ModSpec> mods = std::vector<ModSpec>());
        #endif
 } //ServerList namespace
 

diff --git a/util/master/index.html b/util/master/index.html
index 328dd893424f3908a1779fe494a47c16ca106b06..ad908fca8937559d2ce41c1245104ef750738ab0 100644 (file)
--- a/util/master/index.html
+++ b/util/master/index.html
@@ -8,4 +8,5 @@
     <body><div id="servers_table"></div></body>
 </html>
 <script src="//ajax.googleapis.com/ajax/libs/jquery/1.9.1/jquery.min.js"></script>
+<script>//var master = {root: 'http://servers.minetest.net/', limit:10, clients_min:1, no_flags:1, no_ping:1, no_uptime:1};</script>
 <script src="list.js"></script>

diff --git a/util/master/list.js b/util/master/list.js
index a17458fb480844784ef13fa478a38e25fad7b7cd..b5974619a56b25a48074101e6fb9d3ef3b07158e 100644 (file)
--- a/util/master/list.js
+++ b/util/master/list.js
@@ -1,7 +1,13 @@
 var master_root, output_to;
+var master;
+if (!master) master = {
+    root: master_root,
+    output: output_to
+};
 
 function e(s) {
     if (typeof s === "undefined") s = '';
+    if (typeof s === "number") return s;
     return s.replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;').replace(/"/g, '&quot;'); //mc"
 }
 
@@ -41,55 +47,88 @@ function human_time(t, abs) {
 
 function success(r) {
     if (!r || !r.list) return;
-    var h = '<table class="mts_table"><tr class="mts_head"><th>ip[:port]</th><th>clients/max</th><th>version gameid mapgen</th><th>name</th><th>description</th><th>flags</th><th>uptime</th><th>ping</th></tr>';
+    var h = '';
+    if (!master.no_total && r.total)
+        h += '<div class="mts_total">Now players: ' + r.total.clients + ' servers: ' + r.total.servers + '</div>';
+    if (!master.no_total_max && r.total_max)
+        h += '<div class="mts_total_max">Max players: ' + r.total_max.clients + ' servers: ' + r.total_max.servers + '</div>';
+    h += '<table class="mts_table">';
+    if (r.list.length) {
+        h += '<tr class="mts_head">';
+        if (!master.no_address) h += '<th>ip[:port]</th>';
+        if (!master.no_clients) h += '<th>players/max</th>';
+        if (!master.no_version) h += '<th>version gameid mapgen</th>';
+        if (!master.no_name) h += '<th>name</th>';
+        if (!master.no_description) h += '<th>description</th>';
+        if (!master.no_flags) h += '<th>flags</th>';
+        if (!master.no_uptime) h += '<th>uptime age</th>';
+        if (!master.no_ping) h += '<th>ping</th>';
+        h += '</tr>';
+    }
+    var count = 0;
     for (var i = 0; i < r.list.length; ++i) {
+        if (++count > master.limit && master.limit) break;
         var s = r.list[i];
         if (!s) continue;
+        if (master.clients_min && s.clients < master.clients_min) continue;
         if (/:/.test(s.address)) s.address = '[' + s.address + ']';
         h += '<tr class="mts_row">';
-        h += '<td class="mts_address">' + e(s.address) + (s.port != 30000 ? (':' + e(s.port)) : '') + '</td>';
-        h += '<td class="mts_clients">' + e(s.clients) + (s.clients_max ? '/' + e(s.clients_max) : '') + (s.clients_top ? ', ' + e(s.clients_top) : '') + '</td>';
+        if (!master.no_address) h += '<td class="mts_address">' + e(s.address) + (s.port != 30000 ? (':' + e(s.port)) : '') + '</td>';
+        if (!master.no_clients) {
+            h += '<td class="mts_clients' + (s.clients && s.clients_list ? ' mts_is_clients' : '') + '">';
+            if (!master.no_clients_list && s.clients && s.clients_list) {
+                h += '<div class="mts_clients_list">Players (' + e(s.clients) + '):<br/>';
+                for (var ii in s.clients_list)
+                    h += e(s.clients_list[ii]) + '<br/>';
+                h += '</div>';
+            }
+            h += e(s.clients) + (s.clients_max ? '/' + e(s.clients_max) : '') + (s.clients_top ? ', ' + e(s.clients_top) : '') + '</td>';
+        }
         var mods = 0;
-        if (s.mods && jQuery.isArray(s.mods)) {
+        if (s.mods && jQuery.isArray(s.mods))
             mods = s.mods.length;
-        }
-        h += '<td class="mts_version' + (mods ? ' mts_ismods' : '') + '">' + e(s.version) + ' ' + e(s.gameid) + ' ' + e(s.mapgen);
-        if (mods) {
-            h += '<div class="mts_mods">Mods ('+mods+'):<br/>';
-            for (m in s.mods) {
-                h += s.mods[m] + '<br/>';
+        if (!master.no_version) {
+            h += '<td class="mts_version' + (mods ? ' mts_is_mods' : '') + '">' + e(s.version) + ' ' + e(s.gameid) + ' ' + e(s.mapgen);
+            if (!master.no_mods && mods) {
+                h += '<div class="mts_mods">Mods (' + mods + '):<br/>';
+                for (var ii in s.mods)
+                    h += e(s.mods[ii]) + '<br/>';
+                h += '</div>';
             }
-            h += '</div>';
+            h += '</td>';
+        }
+        if (!master.no_name) {
+            h += '<td class="mts_url">';
+            if (s.url) h += '<a href="' + e(s.url) + '">';
+            h += e(s.name || s.url);
+            if (s.url) h += '</a>';
+            h += '</td>';
+        }
+        if (!master.no_description) h += '<td class="mts_description">' + e(s.description) + '</td>';
+        if (!master.no_flags) {
+            h += '<td class="mts_flags">' +
+                (s.password ? 'Pwd ' : '') +
+                (s.creative ? 'Cre ' : '') +
+                (s.damage ? 'Dmg ' : '') +
+                (s.pvp ? 'Pvp ' : '') +
+                (s.dedicated ? 'Ded ' : '') +
+                (s.rollback ? 'Rol ' : '') +
+                (s.liquid_finite ? 'Liq ' : '') +
+                '</td>';
         }
-
-        h += '</td>';
-
-        h += '<td class="mts_url">';
-        if (s.url) h += '<a href="' + e(s.url) + '">';
-        h += e(s.name || s.url);
-        if (s.url) h += '</a>';
-        h += '</td>';
-        h += '<td class="mts_description">' + e(s.description) + '</td>';
-        h += '<td class="mts_flags">' +
-             (s.password ? 'Pwd ' : '') +
-             (s.creative ? 'Cre ' : '') +
-             (s.damage ? 'Dmg ' : '') +
-             (s.pvp ? 'Pvp ' : '') +
-             (s.dedicated ? 'Ded ' : '') +
-             (s.rollback ? 'Rol ' : '') +
-             (s.liquid_finite ? 'Liq ' : '') +
-             '</td>';
         if (!s.start || s.start < 0) s.start = 0;
-        h += '<td class="mts_time">' + (s.uptime ? human_time(s.uptime, 1) : s.start ? human_time(s.start) : '') + '</td>';
-        h += '<td class="mts_ping">' + (s.ping ? parseFloat(s.ping).toFixed(3) * 1000 : '') + '</td>';
+        if (!master.no_uptime) h += '<td class="mts_uptime">' + (s.uptime ? human_time(s.uptime, 1) : s.start ? human_time(s.start) : '') + (s.game_time ? ' ' + human_time(s.game_time, 1) : '') + '</td>';
+        if (!master.no_ping) h += '<td class="mts_ping">' + (s.ping ? parseFloat(s.ping).toFixed(3) * 1000 : '') + '</td>';
         h += '</tr>';
     }
-    h += '</table>'
-    jQuery(output_to || '#servers_table').html(h);
+    h += '</table>';
+    if (master.clients_min || master.limit)
+        h += '<a href="#" onclick="delete master.limit;delete master.clients_min; get(1);">more...</a>';
+    jQuery(master.output || '#servers_table').html(h);
 }
 
-function get() {
-    jQuery.getJSON((master_root || '') + 'list', success);
-    setTimeout(get, 60000);
+function get(refresh) {
+    jQuery.getJSON((master.root || '') + 'list', success);
+    if (!refresh && !master.no_refresh) setTimeout(get, 60000);
 }
 get();

diff --git a/util/master/master.cgi b/util/master/master.cgi
index bf627a989963125eccc0a310384932123d280c0d..a916827fea874d41ceef71552f81ef77ca1efa08 100755 (executable)
--- a/util/master/master.cgi
+++ b/util/master/master.cgi
@@ -3,7 +3,7 @@
 =info
 install:
  cpan JSON JSON::XS
- touch list_full list
+ touch list_full list log.log
  chmod a+rw list_full list log.log
 
 freebsd:
@@ -48,6 +48,7 @@ use strict;
 no strict qw(refs);
 use warnings "NONFATAL" => "all";
 no warnings qw(uninitialized);
+no if $] >= 5.017011, warnings => 'experimental::smartmatch';
 use utf8;
 use Socket;
 BEGIN {
@@ -72,7 +73,7 @@ our %config = (
     list_full    => $root_path . 'list_full',
     list_pub     => $root_path . 'list',
     log          => $root_path . 'log.log',
-    time_purge   => 86400 * 30,
+    time_purge   => 86400 * 1,
     time_alive   => 650,
     source_check => 1,
     ping_timeout => 3,
@@ -190,11 +191,13 @@ sub request (;$) {
             $param->{$_} = $j->{$_} for keys %$j;
             delete $param->{json};
         }
+        #printlog 'recv', Dumper $param;
         if (%$param) {
             s/^false$// for values %$param;
             $param->{ip} = $r->{REMOTE_ADDR};
             $param->{ip} =~ s/^::ffff://;
             for (@{$config{blacklist}}) {
+                #printlog("blacklist", $param->{ip} ~~ $_) if $config{debug};
                 return if $param->{ip} ~~ $_;
             }
             $param->{address} ||= $param->{ip};
@@ -223,6 +226,7 @@ sub request (;$) {
                     $param->{ping} = $duration if $pingret;
                     printlog " PING t=$config{ping_timeout}, $param->{address}:$param->{port} = ( $pingret, $duration, $ip )" if $config{debug};
                 }
+                return if !$param->{ping};
             }
             my $list = read_json($config{list_full}) || {};
             printlog "readed[$config{list_full}] list size=", scalar @{$list->{list}};
@@ -232,6 +236,7 @@ sub request (;$) {
             $param->{time} ||= int time;
             $param->{start} = $param->{action} ~~ 'start' ? $param->{time} : $old->{start} || $param->{time};
             delete $param->{start} if $param->{off};
+            $param->{clients} ||= scalar @{$param->{clients_list}} if ref $param->{clients_list} eq 'ARRAY';
             $param->{first} ||= $old->{first} || $old->{time} || $param->{time};
             $param->{clients_top} = $old->{clients_top} if $old->{clients_top} > $param->{clients};
             $param->{clients_top} ||= $param->{clients} || 0;
@@ -239,9 +244,12 @@ sub request (;$) {
             for (qw(dedicated rollback liquid_finite mapgen mods)) {
                 $param->{$_} ||= $old->{$_} if $old->{$_} and !($param->{action} ~~ 'start');
             }
+            $param->{pop_n} = $old->{pop_n} + 1;
+            $param->{pop_c} = $old->{pop_c} + $param->{clients};
+            $param->{pop_v} = $param->{pop_c} / $param->{pop_n};
             delete $param->{action};
             $listk->{$param->{key}} = $param;
-            #printlog Dumper $param;
+            #printlog 'write', Dumper $param if $config{debug};
             $list->{list} = [grep { $_->{time} > time - $config{time_purge} } values %$listk];
             file_rewrite($config{list_full}, JSON->new->encode($list));
             printlog "writed[$config{list_full}] list size=", scalar @{$list->{list}} if $config{debug};
@@ -250,6 +258,13 @@ sub request (;$) {
                   grep { $_->{time} > time - $config{time_alive} and !$_->{off} and (!$config{ping} or !$config{pingable} or $_->{ping}) }
                   @{$list->{list}}
             ];
+            $list->{total} = {clients => 0, servers => 0};
+            for (@{$list->{list}}) {
+                $list->{total}{clients} += $_->{clients};
+                ++$list->{total}{servers};
+            }
+            $list->{total_max}{clients} = $list->{total}{clients} if $list->{total_max}{clients} < $list->{total}{clients};
+            $list->{total_max}{servers} = $list->{total}{servers} if $list->{total_max}{servers} < $list->{total}{servers};
             file_rewrite($config{list_pub}, JSON->new->encode($list));
             printlog "writed[$config{list_pub}] list size=", scalar @{$list->{list}} if $config{debug};
         }

diff --git a/util/master/style.css b/util/master/style.css
index c92c56f6ef54cb51418ac61e0ffd86f4f7585ed1..cff041216e4c29428832411de5d8789fed088d7a 100644 (file)
--- a/util/master/style.css
+++ b/util/master/style.css
@@ -13,7 +13,7 @@ div#table table {
   width: 100%;
 }
 
-.mts_mods {
+.mts_mods, .mts_clients_list {
   visibility: hidden; 
   border:gray solid 1px; 
   position:absolute; 
@@ -22,11 +22,11 @@ div#table table {
   padding:.5em;
 }
 
-.mts_version:hover .mts_mods {
+.mts_version:hover .mts_mods, .mts_clients:hover .mts_clients_list {
   visibility: visible;
 }
 
-.mts_version.mts_ismods {
+.mts_version.mts_is_mods, .mts_clients.mts_is_clients  {
   text-decoration:underline; 
   text-decoration-style:dashed;
 }