51 lines
1.3 KiB
Python
51 lines
1.3 KiB
Python
import json
|
|
import stat
|
|
import time
|
|
|
|
from fenrirscreenreader.core import remoteInstanceRegistry
|
|
|
|
|
|
def test_write_instance_creates_shared_sticky_registry_directory(
|
|
tmp_path, monkeypatch
|
|
):
|
|
registry_dir = tmp_path / "instances"
|
|
monkeypatch.setattr(
|
|
remoteInstanceRegistry, "get_registry_dir", lambda: str(registry_dir)
|
|
)
|
|
|
|
remoteInstanceRegistry.write_instance({"pid": 456})
|
|
|
|
mode = stat.S_IMODE(registry_dir.stat().st_mode)
|
|
assert mode == 0o1777
|
|
|
|
|
|
def test_write_instance_prunes_stale_registry_files(tmp_path, monkeypatch):
|
|
monkeypatch.setattr(
|
|
remoteInstanceRegistry, "get_registry_dir", lambda: str(tmp_path)
|
|
)
|
|
monkeypatch.setattr(
|
|
remoteInstanceRegistry,
|
|
"process_exists",
|
|
lambda pid: pid == 456,
|
|
)
|
|
|
|
stale_instance = tmp_path / "123.json"
|
|
stale_instance.write_text(
|
|
json.dumps(
|
|
{
|
|
"pid": 123,
|
|
"updated_at": time.time(),
|
|
}
|
|
)
|
|
+ "\n",
|
|
encoding="utf-8",
|
|
)
|
|
invalid_instance = tmp_path / "invalid.json"
|
|
invalid_instance.write_text("not json\n", encoding="utf-8")
|
|
|
|
remoteInstanceRegistry.write_instance({"pid": 456})
|
|
|
|
assert not stale_instance.exists()
|
|
assert not invalid_instance.exists()
|
|
assert (tmp_path / "456.json").exists()
|