SelfPrivacy
/
selfprivacy-rest-api
mirror of https://git.selfprivacy.org/SelfPrivacy/selfprivacy-rest-api.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

test(service): do not call bash needlessly (it screwed up with fp)

This commit is contained in:
Houkime 2024-03-13 12:50:41 +00:00
parent 8c8c9a51cc
commit 12b2153b7c
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
selfprivacy_api/services/test_service/__init__.py
View File

@ -8,10 +8,9 @@ from os import path
# from enum import Enum # from enum import Enum
from selfprivacy_api.jobs import Job, Jobs, JobStatus from selfprivacy_api.jobs import Job
from selfprivacy_api.services.service import Service, ServiceDnsRecord, ServiceStatus from selfprivacy_api.services.service import Service, ServiceStatus
from selfprivacy_api.utils.block_devices import BlockDevice from selfprivacy_api.utils.block_devices import BlockDevice
import selfprivacy_api.utils.network as network_utils
from selfprivacy_api.services.test_service.icon import BITWARDEN_ICON from selfprivacy_api.services.test_service.icon import BITWARDEN_ICON
@ -89,7 +88,7 @@ class DummyService(Service):
@classmethod @classmethod
def set_status(cls, status: ServiceStatus): def set_status(cls, status: ServiceStatus):
with open(cls.status_file(), "w") as file: with open(cls.status_file(), "w") as file:
status_string = file.write(status.value) file.write(status.value)
@classmethod @classmethod
def get_status(cls) -> ServiceStatus: def get_status(cls) -> ServiceStatus:
@ -102,16 +101,17 @@ class DummyService(Service):
cls, new_status: ServiceStatus, delay_sec: float cls, new_status: ServiceStatus, delay_sec: float
): ):
"""simulating a delay on systemd side""" """simulating a delay on systemd side"""
status_file = cls.status_file() if delay_sec == 0:
cls.set_status(new_status)
return
status_file = cls.status_file()
command = [ command = [
"bash", "bash",
"-c", "-c",
f" sleep {delay_sec} && echo {new_status.value} > {status_file}", f" sleep {delay_sec} && echo {new_status.value} > {status_file}",
] ]
handle = subprocess.Popen(command) subprocess.Popen(command)
if delay_sec == 0:
handle.communicate()
@classmethod @classmethod
def set_backuppable(cls, new_value: bool) -> None: def set_backuppable(cls, new_value: bool) -> None: