allow to return cleaned up values

This commit is contained in:
2025-05-15 09:55:12 +02:00
parent 4d515f0784
commit 58bbbf3cbd
2 changed files with 11 additions and 9 deletions
+3 -2
View File
@@ -57,7 +57,8 @@ class Server:
@self.app.get("/cleanup")
def cleanup():
self._cleanup_database()
results = self._cleanup_database()
return jsonify(data=json.loads(results), status=200)
def run(self, host:str="0.0.0.0", port:str="8000", debug:bool=False):
logging.getLogger("werkzeug").setLevel(logging.ERROR)
@@ -159,4 +160,4 @@ class Server:
def _cleanup_database(self):
storage = StorageLoader.build(self.storage_type)()
return jsonify(storage.cleanup())
return storage.cleanup()
+8 -7
View File
@@ -1,7 +1,7 @@
from server.GameBoard import GameBoard
from datetime import datetime
import edgedb, json, time
import gel, json, time
class EdgeDB:
def __init__(self, database:str=None, tls_security:str='insecure', **kwargs):
@@ -10,7 +10,7 @@ class EdgeDB:
self._connect()
def _connect(self):
self.client = edgedb.create_client(
self.client = gel.create_client(
tls_security=self.tls_security,
database=self.database
)
@@ -19,7 +19,7 @@ class EdgeDB:
while True:
try:
return function(*args, **kwargs)
except edgedb.errors.ClientConnectionFailedError:
except gel.errors.ClientConnectionFailedError:
self._connect()
time.sleep(0.5)
@@ -112,11 +112,12 @@ class EdgeDB:
def cleanup(self):
return self.run_query_with_reconnection(
self.client.query,
self.client.query_json,
"""
delete default::GameBoard { }
filter .turns < <std::int32>"200" or .is_winner_me = <std::bool>"false";
delete Moves { };
with gameboard := (delete GameBoard filter .turns < <std::int32>"200" or .is_winner_me = <std::bool>"false")
select gameboard {id, url, winner, turns, type: { is_ladder, name } };
delete default::Moves { }
"""
)