Merge branch 'dev' into experimental/lukas-cleanup

app/classes/models/servers.py

@@ -1,13 +1,11 @@
 import logging
 import datetime
 from peewee import (
-    ForeignKeyField,
     CharField,
     AutoField,
     DateTimeField,
     BooleanField,
     IntegerField,
-    FloatField,
 )
 
 from app.classes.shared.main_models import DatabaseShortcuts
@@ -42,37 +40,6 @@ class Servers(BaseModel):
         table_name = "servers"
 
 
-# **********************************************************************************
-#                                   Servers Stats Class
-# **********************************************************************************
-class ServerStats(BaseModel):
-    stats_id = AutoField()
-    created = DateTimeField(default=datetime.datetime.now)
-    server_id = ForeignKeyField(Servers, backref="server", index=True)
-    started = CharField(default="")
-    running = BooleanField(default=False)
-    cpu = FloatField(default=0)
-    mem = FloatField(default=0)
-    mem_percent = FloatField(default=0)
-    world_name = CharField(default="")
-    world_size = CharField(default="")
-    server_port = IntegerField(default=25565)
-    int_ping_results = CharField(default="")
-    online = IntegerField(default=0)
-    max = IntegerField(default=0)
-    players = CharField(default="")
-    desc = CharField(default="Unable to Connect")
-    version = CharField(default="")
-    updating = BooleanField(default=False)
-    waiting_start = BooleanField(default=False)
-    first_run = BooleanField(default=True)
-    crashed = BooleanField(default=False)
-    downloading = BooleanField(default=False)
-
-    class Meta:
-        table_name = "server_stats"
-
-
 # **********************************************************************************
 #                                   Servers Class
 # **********************************************************************************
@@ -146,31 +113,6 @@ class HelperServers:
         query = Servers.select()
         return DatabaseShortcuts.return_rows(query)
 
-    @staticmethod
-    def get_all_servers_stats():
-        servers = HelperServers.get_all_defined_servers()
-        server_data = []
-        try:
-            for s in servers:
-                latest = (
-                    ServerStats.select()
-                    .where(ServerStats.server_id == s.get("server_id"))
-                    .order_by(ServerStats.created.desc())
-                    .limit(1)
-                )
-                server_data.append(
-                    {
-                        "server_data": s,
-                        "stats": DatabaseShortcuts.return_rows(latest)[0],
-                        "user_command_permission": True,
-                    }
-                )
-        except IndexError as ex:
-            logger.error(
-                f"Stats collection failed with error: {ex}. Was a server just created?"
-            )
-        return server_data
-
     @staticmethod
     def get_server_friendly_name(server_id):
         server_data = HelperServers.get_server_data_by_id(server_id)
@@ -179,147 +121,3 @@ class HelperServers:
             f"with ID: {server_data.get('server_id', 0)}"
         )
         return friendly_name
-
-    # **********************************************************************************
-    #                                    Servers_Stats Methods
-    # **********************************************************************************
-    @staticmethod
-    def get_latest_server_stats(server_id):
-        return (
-            ServerStats.select()
-            .where(ServerStats.server_id == server_id)
-            .order_by(ServerStats.created.desc())
-            .limit(1)
-        )
-
-    @staticmethod
-    def get_server_stats_by_id(server_id):
-        stats = (
-            ServerStats.select()
-            .where(ServerStats.server_id == server_id)
-            .order_by(ServerStats.created.desc())
-            .limit(1)
-        )
-        return DatabaseShortcuts.return_rows(stats)[0]
-
-    @staticmethod
-    def server_id_exists(server_id):
-        return Servers.select().where(Servers.server_id == server_id).count() != 0
-
-    @staticmethod
-    def sever_crashed(server_id):
-        ServerStats.update(crashed=True).where(
-            ServerStats.server_id == server_id
-        ).execute()
-
-    @staticmethod
-    def set_download(server_id):
-        ServerStats.update(downloading=True).where(
-            ServerStats.server_id == server_id
-        ).execute()
-
-    @staticmethod
-    def finish_download(server_id):
-        ServerStats.update(downloading=False).where(
-            ServerStats.server_id == server_id
-        ).execute()
-
-    @staticmethod
-    def get_download_status(server_id):
-        download_status = (
-            ServerStats.select().where(ServerStats.server_id == server_id).get()
-        )
-        return download_status.downloading
-
-    @staticmethod
-    def server_crash_reset(server_id):
-        ServerStats.update(crashed=False).where(
-            ServerStats.server_id == server_id
-        ).execute()
-
-    @staticmethod
-    def is_crashed(server_id):
-        svr = ServerStats.select().where(ServerStats.server_id == server_id).get()
-        if svr.crashed is True:
-            return True
-        else:
-            return False
-
-    @staticmethod
-    def set_update(server_id, value):
-        try:
-            # Checks if server even exists
-            ServerStats.select().where(ServerStats.server_id == server_id)
-        except Exception as ex:
-            logger.error(f"Database entry not found! {ex}")
-        ServerStats.update(updating=value).where(
-            ServerStats.server_id == server_id
-        ).execute()
-
-    @staticmethod
-    def get_update_status(server_id):
-        update_status = (
-            ServerStats.select().where(ServerStats.server_id == server_id).get()
-        )
-        return update_status.updating
-
-    @staticmethod
-    def set_first_run(server_id):
-        # Sets first run to false
-        try:
-            # Checks if server even exists
-            ServerStats.select().where(ServerStats.server_id == server_id)
-        except Exception as ex:
-            logger.error(f"Database entry not found! {ex}")
-            return
-        ServerStats.update(first_run=False).where(
-            ServerStats.server_id == server_id
-        ).execute()
-
-    @staticmethod
-    def get_first_run(server_id):
-        first_run = ServerStats.select().where(ServerStats.server_id == server_id).get()
-        return first_run.first_run
-
-    @staticmethod
-    def get_ttl_without_player(server_id):
-        last_stat = (
-            ServerStats.select()
-            .where(ServerStats.server_id == server_id)
-            .order_by(ServerStats.created.desc())
-            .first()
-        )
-        last_stat_with_player = (
-            ServerStats.select()
-            .where(ServerStats.server_id == server_id)
-            .where(ServerStats.online > 0)
-            .order_by(ServerStats.created.desc())
-            .first()
-        )
-        return last_stat.created - last_stat_with_player.created
-
-    @staticmethod
-    def can_stop_no_players(server_id, time_limit):
-        can = False
-        ttl_no_players = HelperServers.get_ttl_without_player(server_id)
-        if (time_limit == -1) or (ttl_no_players > time_limit):
-            can = True
-        return can
-
-    @staticmethod
-    def set_waiting_start(server_id, value):
-        try:
-            # Checks if server even exists
-            ServerStats.select().where(ServerStats.server_id == server_id)
-        except Exception as ex:
-            logger.error(f"Database entry not found! {ex}")
-        ServerStats.update(waiting_start=value).where(
-            ServerStats.server_id == server_id
-        ).execute()
-
-    @staticmethod
-    def get_waiting_start(server_id):
-        waiting_start = (
-            ServerStats.select().where(ServerStats.server_id == server_id).get()
-        )
-        return waiting_start.waiting_start