Compare commits

..

7 Commits

11 changed files with 126 additions and 35 deletions

View File

@ -84,7 +84,6 @@ class Controller(GObject.GObject):
self.emitter = Emitter() self.emitter = Emitter()
self.emitter.connect("map_selection_changed", self._on_map_selection_changed) self.emitter.connect("map_selection_changed", self._on_map_selection_changed)
self.emitter.connect("check_toggled", self._on_check_toggled) self.emitter.connect("check_toggled", self._on_check_toggled)
self.emitter.connect("servers_loaded_init", self._on_servers_loaded_init)
# NOTE: suppress requests until entire UI is loaded # NOTE: suppress requests until entire UI is loaded
self.loaded = False self.loaded = False
@ -321,6 +320,7 @@ class Controller(GObject.GObject):
self.mediator.filters.button_grid.block_toggles(True) self.mediator.filters.button_grid.block_toggles(True)
self.populate_filter_prefs() self.populate_filter_prefs()
self.mediator.filters.button_grid.block_toggles(False) self.mediator.filters.button_grid.block_toggles(False)
self.emitter.emit("lan_page_initialized")
ServerModelManager(self, tv).load() ServerModelManager(self, tv).load()
def populate_filter_prefs(self) -> None: def populate_filter_prefs(self) -> None:
@ -347,16 +347,7 @@ class Controller(GObject.GObject):
filter_man = self.get_filter_man() filter_man = self.get_filter_man()
return filter_man.get_filters() return filter_man.get_filters()
# TODO: rename # FIXME: wipe maps store when changing tabs if model is none
def _on_servers_loaded_init(self, emitter: "Emitter") -> None:
"""Triggered after servers load but prior to maps loading"""
# FIXME: wipe maps store when changing tabs if model is none
# e.g. select recent, toggle map, then select lan -> not wiped
tv = self.get_active_treeview()
if tv.loaded is False:
return
store = self.get_map_store()
self.emitter.emit("load_maps", store)
def has_server_model(self) -> bool: def has_server_model(self) -> bool:
treeview = self.get_active_treeview() treeview = self.get_active_treeview()

View File

@ -17,17 +17,28 @@ def has_new_config(config: Path) -> bool:
return config.exists() return config.exists()
def migrate_cols_file(res: Path) -> None: def convert_cols_file(res: Path) -> dict[str, int] | None:
# NOTE: dzg.columns.json is API 7 spec j = read_json(res)
old_res = Path.home() / LEGACY_COLS_PATH cols = j["cols"]
if old_res.is_file(): # NOTE: implies prior conversion
j = read_json(old_res) if "View" in cols:
cols = j["cols"] return None
if "View" in cols: # NOTE: user may not have changed these widths in API 6
return try:
cols["View"] = cols.pop("Perspective") cols["View"] = cols.pop("Perspective")
cols["Max"] = cols.pop("Maximum") cols["Max"] = cols.pop("Maximum")
write_json(j, res) except Exception:
pass
return j
def migrate_cols_file(res: Path) -> None:
# NOTE: filename "dzg.columns.json" is API 7 spec
old_res = Path.home() / LEGACY_COLS_PATH
if old_res.is_file():
j = convert_cols_file(old_res)
if j is not None:
write_json(j, res)
def copy_state_files(state_path: Path) -> None: def copy_state_files(state_path: Path) -> None:

View File

@ -243,9 +243,11 @@ class ServerModelManager:
filter_man = self.tv.get_filter_man() filter_man = self.tv.get_filter_man()
maps = self._get_new_maps() maps = self._get_new_maps()
filter_man.set_unique_maps(maps) filter_man.set_unique_maps(maps)
store = filter_man.get_map_store()
self.first_iteration = False self.first_iteration = False
self.emitter.emit("servers_loaded_init") self.emitter.emit("load_maps", store)
# self.emitter.emit("servers_loaded_init")
def add_to_history(self, record: dict[str, Any]) -> None: def add_to_history(self, record: dict[str, Any]) -> None:
proxy_man = self._get_proxy_man() proxy_man = self._get_proxy_man()
@ -378,24 +380,24 @@ class ServerModelManager:
# NOTE: maps are set outside of thread because it triggers map changed signals # NOTE: maps are set outside of thread because it triggers map changed signals
maps = self._get_new_maps() maps = self._get_new_maps()
filter_man.set_unique_maps(maps) filter_man.set_unique_maps(maps)
store = filter_man.get_map_store()
self.emitter.emit("load_maps", store)
self.first_iteration = False self.first_iteration = False
self.emitter.emit("servers_loaded_init")
self.emitter.emit("saved_servers_changed") self.emitter.emit("saved_servers_changed")
def _update_maps(self) -> None: def _update_maps(self) -> None:
filter_man = self.tv.get_filter_man() filter_man = self.tv.get_filter_man()
filter_man.set_unique_maps(self._get_new_maps()) filter_man.set_unique_maps(self._get_new_maps())
self.emitter.emit("servers_loaded_init") store = filter_man.get_map_store()
self.emitter.emit("load_maps", store)
self.first_iteration = False self.first_iteration = False
def _cleanup_on_success(self) -> None: def _cleanup_on_success(self) -> None:
proxy = self._get_proxy_man().get_proxy_model() proxy = self._get_proxy_man().get_proxy_model()
self.tv.set_model(proxy) self.tv.set_model(proxy)
# TODO: servers_loaded vs servers_reloaded
self.emitter.emit("servers_loaded", self.enum) self.emitter.emit("servers_loaded", self.enum)
if self.first_iteration: if self.first_iteration:
self._update_maps() self._update_maps()

View File

@ -94,9 +94,11 @@ class RefreshButton(IconTextButton):
icon=REFRESH_ICON, icon=REFRESH_ICON,
label=atomic_buttons.refresh, label=atomic_buttons.refresh,
) )
self.controller = controller self.controller = controller
emitter = self.controller.get_emitter() emitter = self.controller.get_emitter()
self.loading = False self.loading = False
self.is_clicked = False
self.time = 30 self.time = 30
@ -110,17 +112,21 @@ class RefreshButton(IconTextButton):
def _on_refresh_clicked(self, button: Self) -> None: def _on_refresh_clicked(self, button: Self) -> None:
"""Spawned in a thread""" """Spawned in a thread"""
self.loading = True self.is_clicked = True
self.controller.refresh_tree() self.controller.refresh_tree()
# TODO: get server tab enum # TODO: get server tab enum
# if LAN tab, reload existing entries in place # if LAN tab, reload existing entries in place
def start_decrement(self, emitter: "Emitter", tab: "ServerTab") -> None: def start_decrement(self, emitter: "Emitter", tab: "ServerTab") -> None:
if self.is_clicked is False:
return
if self.loading: if self.loading:
self.set_sensitive(False) return
self.loading = False self.set_sensitive(False)
self.show_time(True) self.loading = True
GLib.timeout_add_seconds(1, self.decrement) self.is_clicked = False
self.show_time(True)
GLib.timeout_add_seconds(1, self.decrement)
def decrement(self) -> bool: def decrement(self) -> bool:
self.time -= 1 self.time -= 1
@ -128,6 +134,7 @@ class RefreshButton(IconTextButton):
self.time = 30 self.time = 30
self.show_time(False) self.show_time(False)
self.set_sensitive(True) self.set_sensitive(True)
self.loading = False
return False return False
self.show_time(True) self.show_time(True)
return True return True

View File

@ -107,16 +107,16 @@ class RightPanel(Gtk.Box):
if page.loaded is True: if page.loaded is True:
return return
self.filters_vbox.set_sensitive(False) self.filters_vbox.set_sensitive(False)
# TODO: unless it is lan page
#self.refresh_button.set_sensitive(False)
def _on_lan_page_init(self, emitter: "Emitter") -> None: def _on_lan_page_init(self, emitter: "Emitter") -> None:
self.filters_vbox.set_sensitive(False) self.filters_vbox.set_sensitive(False)
self.refresh_button.set_sensitive(False)
def _on_servers_loaded(self, emitter: "Emitter", context: "ServerTab") -> None: def _on_servers_loaded(self, emitter: "Emitter", context: "ServerTab") -> None:
# TODO: similar logic on notebook page change # TODO: similar logic on notebook page change
state = self.controller.has_server_model() state = self.controller.has_server_model()
for el in self.filters_vbox, self.refresh_button: self.filters_vbox.set_sensitive(state)
el.set_sensitive(state)
def _on_version_clicked(self, widget: Gtk.EventBox, event: Gdk.EventButton) -> None: def _on_version_clicked(self, widget: Gtk.EventBox, event: Gdk.EventButton) -> None:
def revert() -> Literal[False]: def revert() -> Literal[False]:

View File

@ -72,6 +72,7 @@ class ServerTreeView(ContextMixin, TreeView): # type: ignore
logger.critical(e) logger.critical(e)
valid_json = False valid_json = False
# NOTE: reasonable defaults for long columns
width_map = { width_map = {
"Name": 800, "Name": 800,
"Map": 300, "Map": 300,
@ -96,8 +97,9 @@ class ServerTreeView(ContextMixin, TreeView): # type: ignore
column.set_fixed_width(saved_size) column.set_fixed_width(saved_size)
column.set_expand(True) column.set_expand(True)
else: else:
w = width_map[column_title] if column_title in width_map:
column.set_fixed_width(w) w = width_map[column_title]
column.set_fixed_width(w)
if column_title == "Ping": if column_title == "Ping":
column.set_cell_data_func(renderer, self._get_ping) column.set_cell_data_func(renderer, self._get_ping)

View File

@ -45,3 +45,9 @@ if proc.returncode == 0:
with tarfile.open(tarpath, "w:gz") as tar: with tarfile.open(tarpath, "w:gz") as tar:
tar.add(release_exe, arcname=appname) tar.add(release_exe, arcname=appname)
print(f"Wrote tarfile to '{tarpath}'") print(f"Wrote tarfile to '{tarpath}'")
proc = subprocess.run([release_exe, "-v"], capture_output=True, text=True)
assert proc.stdout.rstrip() == version
release_exe.unlink()
Path(wheel).unlink()

14
tests/fixtures/columns_1 vendored Normal file
View File

@ -0,0 +1,14 @@
{
"cols": {
"Name": 1,
"Map": 1,
"Gametime": 1,
"Players": 1,
"Queue": 1,
"IP": 1,
"Qport": 1,
"Ping": 1,
"Maximum": 1,
"Perspective": 1
}
}

12
tests/fixtures/columns_2 vendored Normal file
View File

@ -0,0 +1,12 @@
{
"cols": {
"Name": 398,
"Map": 181,
"Gametime": 151,
"Players": 119,
"Queue": 96,
"IP": 247,
"Qport": 94,
"Ping": 253
}
}

13
tests/fixtures/columns_3 vendored Normal file
View File

@ -0,0 +1,13 @@
{
"cols": {
"Name": 1,
"Map": 1,
"Gametime": 1,
"Players": 1,
"Queue": 1,
"IP": 1,
"Qport": 1,
"Ping": 1,
"View": 1
}
}

33
tests/test_columns.py Normal file
View File

@ -0,0 +1,33 @@
import pytest
from dzgui.init.migrate import convert_cols_file
from tests.fixtures import fixture_path
@pytest.fixture
def columns_with_perspective():
return fixture_path("columns_1")
@pytest.fixture
def columns_without_perspective():
return fixture_path("columns_2")
@pytest.fixture
def columns_with_view():
return fixture_path("columns_3")
@pytest.mark.config
def test_columns_with_perspective(columns_with_perspective):
j = convert_cols_file(columns_with_perspective)
assert "View" in j["cols"]
assert "Max" in j["cols"]
@pytest.mark.config
def test_columns_without_perspective(columns_without_perspective):
j = convert_cols_file(columns_without_perspective)
assert "View" not in j["cols"]
assert "Max" not in j["cols"]
@pytest.mark.config
def test_columns_with_view(columns_with_view):
j = convert_cols_file(columns_with_view)
assert j is None