Add: keep stats about the openttd-version used for listing (#56)

This allows us to see how quickly people migrate to a newer version of OpenTTD.
OpenTTD · Aug 28, 2021 · d5d69ce · d5d69ce
1 parent 0b11a1f
commit d5d69ce
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/game_coordinator/application/coordinator.py b/game_coordinator/application/coordinator.py
@@ -277,7 +277,7 @@ async def receive_PACKET_COORDINATOR_CLIENT_LISTING(
         await source.protocol.send_PACKET_COORDINATOR_GC_LISTING(
             protocol_version, game_info_version, servers_match + servers_other, self._newgrf_lookup_table
         )
-        await self.database.stats_listing(game_info_version)
+        await self.database.stats_listing(game_info_version, openttd_version)
 
     async def receive_PACKET_COORDINATOR_CLIENT_CONNECT(self, source, protocol_version, invite_code):
         if not invite_code or invite_code[0] != "+" or invite_code not in self._servers:

diff --git a/game_coordinator/database/redis.py b/game_coordinator/database/redis.py
@@ -338,8 +338,9 @@ async def stats_connect(self, method_name, result, final=True):
 
         await self._stats(key, method_name)
 
-    async def stats_listing(self, game_info_version):
+    async def stats_listing(self, game_info_version, openttd_version):
         await self._stats("listing", game_info_version)
+        await self._stats("listing-version", openttd_version)
 
     async def stats_turn(self, side):
         await self._stats("turn", side)

diff --git a/game_coordinator/web.py b/game_coordinator/web.py
@@ -20,6 +20,7 @@ async def stats_handler(request):
         {
             "verify": await DB_INSTANCE.get_stats("verify"),
             "listing": await DB_INSTANCE.get_stats("listing"),
+            "listing-version": await DB_INSTANCE.get_stats("listing-version"),
             "connect": await DB_INSTANCE.get_stats("connect"),
             "connect-failed": await DB_INSTANCE.get_stats("connect-failed"),
             "connect-method-failed": await DB_INSTANCE.get_stats("connect-method-failed"),