feature(services): check before moving task and before move itself

selfprivacy_api/actions/services.py

@@ -0,0 +1,36 @@
+from selfprivacy_api.utils.block_devices import BlockDevices
+from selfprivacy_api.jobs import Jobs, Job
+
+from selfprivacy_api.services import get_service_by_id
+from selfprivacy_api.services.tasks import move_service as move_service_task
+
+
+class ServiceNotFoundError(Exception):
+    pass
+
+
+class VolumeNotFoundError(Exception):
+    pass
+
+
+def move_service(service_id: str, volume_name: str) -> Job:
+    service = get_service_by_id(service_id)
+    if service is None:
+        raise ServiceNotFoundError(f"No such service:{service_id}")
+
+    volume = BlockDevices().get_block_device(volume_name)
+    if volume is None:
+        raise VolumeNotFoundError(f"No such volume:{volume_name}")
+
+    service.assert_can_move(volume)
+
+    job = Jobs.add(
+        type_id=f"services.{service.get_id()}.move",
+        name=f"Move {service.get_display_name()}",
+        description=f"Moving {service.get_display_name()} data to {volume.name}",
+    )
+
+    handle = move_service_task(service, volume, job)
+    # Nonblocking
+    handle()
+    return job

selfprivacy_api/graphql/mutations/services_mutations.py

@@ -5,18 +5,25 @@ import strawberry
 from selfprivacy_api.graphql import IsAuthenticated
 from selfprivacy_api.graphql.common_types.jobs import job_to_api_job
 from selfprivacy_api.jobs import JobStatus
+from selfprivacy_api.utils.block_devices import BlockDevices
 
-from selfprivacy_api.graphql.common_types.service import (
-    Service,
-    service_to_graphql_service,
-)
 from selfprivacy_api.graphql.mutations.mutation_interface import (
     GenericJobMutationReturn,
     GenericMutationReturn,
 )
+from selfprivacy_api.graphql.common_types.service import (
+    Service,
+    service_to_graphql_service,
+)
+
+from selfprivacy_api.actions.services import (
+    move_service,
+    ServiceNotFoundError,
+    VolumeNotFoundError,
+)
+from selfprivacy_api.services.moving import MoveError
 
 from selfprivacy_api.services import get_service_by_id
-from selfprivacy_api.utils.block_devices import BlockDevices
 
 
 @strawberry.type
@@ -60,7 +67,7 @@ class ServicesMutations:
         except Exception as e:
             return ServiceMutationReturn(
                 success=False,
-                message=format_error(e),
+                message=pretty_error(e),
                 code=400,
             )
 
@@ -86,7 +93,7 @@ class ServicesMutations:
         except Exception as e:
             return ServiceMutationReturn(
                 success=False,
-                message=format_error(e),
+                message=pretty_error(e),
                 code=400,
             )
         return ServiceMutationReturn(
@@ -153,31 +160,31 @@ class ServicesMutations:
     @strawberry.mutation(permission_classes=[IsAuthenticated])
     def move_service(self, input: MoveServiceInput) -> ServiceJobMutationReturn:
         """Move service."""
+        # We need a service instance for a reply later
         service = get_service_by_id(input.service_id)
         if service is None:
             return ServiceJobMutationReturn(
                 success=False,
-                message=f"Service not found: {input.service_id}",
+                message=f"Service does not exist: {input.service_id}",
                 code=404,
             )
-        # TODO: make serviceImmovable and BlockdeviceNotFound exceptions
+
-        # in the move_to_volume() function and handle them here
+        try:
-        if not service.is_movable():
+            job = move_service(input.service_id, input.location)
+        except (ServiceNotFoundError, VolumeNotFoundError) as e:
             return ServiceJobMutationReturn(
                 success=False,
-                message=f"Service is not movable: {service.get_display_name()}",
+                message=pretty_error(e),
+                code=404,
+            )
+        except Exception as e:
+            return ServiceJobMutationReturn(
+                success=False,
+                message=pretty_error(e),
                 code=400,
                 service=service_to_graphql_service(service),
             )
-        volume = BlockDevices().get_block_device(input.location)
+
-        if volume is None:
-            return ServiceJobMutationReturn(
-                success=False,
-                message=f"Volume not found: {input.location}",
-                code=404,
-                service=service_to_graphql_service(service),
-            )
-        job = service.move_to_volume(volume)
         if job.status in [JobStatus.CREATED, JobStatus.RUNNING]:
             return ServiceJobMutationReturn(
                 success=True,
@@ -204,5 +211,5 @@ class ServicesMutations:
             )
 
 
-def format_error(e: Exception) -> str:
+def pretty_error(e: Exception) -> str:
     return type(e).__name__ + ": " + str(e)

selfprivacy_api/services/bitwarden/__init__.py

@@ -3,12 +3,10 @@ import base64
 import subprocess
 from typing import Optional, List
 
-from selfprivacy_api.jobs import Job, Jobs
+from selfprivacy_api.utils import get_domain
-from selfprivacy_api.services.generic_service_mover import FolderMoveNames, move_service
+
 from selfprivacy_api.utils.systemd import get_service_status
 from selfprivacy_api.services.service import Service, ServiceStatus
-from selfprivacy_api.utils import get_domain
-from selfprivacy_api.utils.block_devices import BlockDevice
 from selfprivacy_api.services.bitwarden.icon import BITWARDEN_ICON
 
 
@@ -101,20 +99,3 @@ class Bitwarden(Service):
     @staticmethod
     def get_folders() -> List[str]:
         return ["/var/lib/bitwarden", "/var/lib/bitwarden_rs"]
-
-    def move_to_volume(self, volume: BlockDevice) -> Job:
-        job = Jobs.add(
-            type_id="services.bitwarden.move",
-            name="Move Bitwarden",
-            description=f"Moving Bitwarden data to {volume.name}",
-        )
-
-        move_service(
-            self,
-            volume,
-            job,
-            FolderMoveNames.default_foldermoves(self),
-            "bitwarden",
-        )
-
-        return job

selfprivacy_api/services/gitea/__init__.py

@@ -3,12 +3,10 @@ import base64
 import subprocess
 from typing import Optional, List
 
-from selfprivacy_api.jobs import Job, Jobs
+from selfprivacy_api.utils import get_domain
-from selfprivacy_api.services.generic_service_mover import FolderMoveNames, move_service
+
 from selfprivacy_api.utils.systemd import get_service_status
 from selfprivacy_api.services.service import Service, ServiceStatus
-from selfprivacy_api.utils import get_domain
-from selfprivacy_api.utils.block_devices import BlockDevice
 from selfprivacy_api.services.gitea.icon import GITEA_ICON
 
 
@@ -96,20 +94,3 @@ class Gitea(Service):
     @staticmethod
     def get_folders() -> List[str]:
         return ["/var/lib/gitea"]
-
-    def move_to_volume(self, volume: BlockDevice) -> Job:
-        job = Jobs.add(
-            type_id="services.gitea.move",
-            name="Move Gitea",
-            description=f"Moving Gitea data to {volume.name}",
-        )
-
-        move_service(
-            self,
-            volume,
-            job,
-            FolderMoveNames.default_foldermoves(self),
-            "gitea",
-        )
-
-        return job

selfprivacy_api/services/mailserver/__init__.py

@@ -4,14 +4,11 @@ import base64
 import subprocess
 from typing import Optional, List
 
-from selfprivacy_api.jobs import Job, Jobs
-from selfprivacy_api.services.generic_service_mover import FolderMoveNames, move_service
 from selfprivacy_api.utils.systemd import (
     get_service_status_from_several_units,
 )
 from selfprivacy_api.services.service import Service, ServiceDnsRecord, ServiceStatus
 from selfprivacy_api import utils
-from selfprivacy_api.utils.block_devices import BlockDevice
 from selfprivacy_api.services.mailserver.icon import MAILSERVER_ICON
 
 
@@ -166,20 +163,3 @@ class MailServer(Service):
                 ),
             )
         return dns_records
-
-    def move_to_volume(self, volume: BlockDevice) -> Job:
-        job = Jobs.add(
-            type_id="services.email.move",
-            name="Move Mail Server",
-            description=f"Moving mailserver data to {volume.name}",
-        )
-
-        move_service(
-            self,
-            volume,
-            job,
-            FolderMoveNames.default_foldermoves(self),
-            "simple-nixos-mailserver",
-        )
-
-        return job

selfprivacy_api/services/moving.py

@@ -14,10 +14,9 @@ from selfprivacy_api.services.owned_path import OwnedPath
 class MoveError(Exception):
     """Move failed"""
 
-def get_foldername(path: str) -> str:
-    return path.split("/")[-1]
-
 
+def get_foldername(p: OwnedPath) -> str:
+    return p.path.split("/")[-1]
 
 
 def check_volume(volume: BlockDevice, space_needed: int) -> bool:
@@ -26,10 +25,7 @@ def check_volume(volume: BlockDevice, space_needed: int) -> bool:
         raise MoveError("Not enough space on the new volume.")
 
     # Make sure the volume is mounted
-    if (
+    if not volume.is_root() and f"/volumes/{volume.name}" not in volume.mountpoints:
-        not volume.is_root()
-        and f"/volumes/{volume.name}" not in volume.mountpoints
-    ):
         raise MoveError("Volume is not mounted.")
 
 
@@ -39,11 +35,11 @@ def check_folders(current_volume: BlockDevice, folders: List[OwnedPath]) -> None
         path = pathlib.Path(f"/volumes/{current_volume}/{get_foldername(folder)}")
 
         if not path.exists():
-            raise MoveError(f"{path} is not found.")
+            raise MoveError(f"directory {path} is not found.")
         if not path.is_dir():
             raise MoveError(f"{path} is not a directory.")
         if path.owner() != folder.owner:
-            raise MoveError(f"{path} owner is not {folder.owner}.")
+            raise MoveError(f"{path} is not owned by {folder.owner}.")
 
 
 def unbind_folders(owned_folders: List[OwnedPath]) -> None:
@@ -66,7 +62,7 @@ def move_folders_to_volume(
     current_progress = job.progress
     folder_percentage = 50 // len(folders)
     for folder in folders:
-        folder_name = get_foldername(folder.path)
+        folder_name = get_foldername(folder)
         shutil.move(
             f"/volumes/{old_volume}/{folder_name}",
             f"/volumes/{new_volume.name}/{folder_name}",
@@ -75,11 +71,9 @@ def move_folders_to_volume(
         report_progress(progress, job, "Moving data to new volume...")
 
 
-def ensure_folder_ownership(
+def ensure_folder_ownership(folders: List[OwnedPath], volume: BlockDevice) -> None:
-    folders: List[OwnedPath], volume: BlockDevice
-) -> None:
     for folder in folders:
-        true_location = f"/volumes/{volume.name}/{get_foldername(folder.path)}"
+        true_location = f"/volumes/{volume.name}/{get_foldername(folder)}"
         try:
             subprocess.run(
                 [
@@ -87,12 +81,14 @@ def ensure_folder_ownership(
                     "-R",
                     f"{folder.owner}:{folder.group}",
                     # Could we just chown the binded location instead?
-                    true_location
+                    true_location,
                 ],
                 check=True,
             )
         except subprocess.CalledProcessError as error:
-            error_message = f"Unable to set ownership of {true_location} :{error.output}"
+            error_message = (
+                f"Unable to set ownership of {true_location} :{error.output}"
+            )
             print(error.output)
             raise MoveError(error_message)
 
@@ -104,7 +100,7 @@ def bind_folders(folders: List[OwnedPath], volume: BlockDevice) -> None:
                 [
                     "mount",
                     "--bind",
-                    f"/volumes/{volume.name}/{get_foldername(folder.path)}",
+                    f"/volumes/{volume.name}/{get_foldername(folder)}",
                     folder.path,
                 ],
                 check=True,

selfprivacy_api/services/nextcloud/__init__.py

@@ -2,12 +2,13 @@
 import base64
 import subprocess
 from typing import Optional, List
+
+from selfprivacy_api.utils import get_domain
 from selfprivacy_api.jobs import Job, Jobs
-from selfprivacy_api.services.generic_service_mover import FolderMoveNames, move_service
+
 from selfprivacy_api.utils.systemd import get_service_status
 from selfprivacy_api.services.service import Service, ServiceStatus
-from selfprivacy_api.utils import get_domain
+
-from selfprivacy_api.utils.block_devices import BlockDevice
 from selfprivacy_api.services.nextcloud.icon import NEXTCLOUD_ICON
 
 
@@ -101,18 +102,3 @@ class Nextcloud(Service):
     @staticmethod
     def get_folders() -> List[str]:
         return ["/var/lib/nextcloud"]
-
-    def move_to_volume(self, volume: BlockDevice) -> Job:
-        job = Jobs.add(
-            type_id="services.nextcloud.move",
-            name="Move Nextcloud",
-            description=f"Moving Nextcloud to volume {volume.name}",
-        )
-        move_service(
-            self,
-            volume,
-            job,
-            FolderMoveNames.default_foldermoves(self),
-            "nextcloud",
-        )
-        return job

selfprivacy_api/services/pleroma/__init__.py

@@ -2,13 +2,13 @@
 import base64
 import subprocess
 from typing import Optional, List
-from selfprivacy_api.jobs import Job, Jobs
+
-from selfprivacy_api.services.generic_service_mover import FolderMoveNames, move_service
+from selfprivacy_api.utils import get_domain
+
+from selfprivacy_api.services.owned_path import OwnedPath
 from selfprivacy_api.utils.systemd import get_service_status
 from selfprivacy_api.services.service import Service, ServiceStatus
-from selfprivacy_api.services.owned_path import OwnedPath
+
-from selfprivacy_api.utils import get_domain
-from selfprivacy_api.utils.block_devices import BlockDevice
 from selfprivacy_api.services.pleroma.icon import PLEROMA_ICON
 
 
@@ -88,7 +88,7 @@ class Pleroma(Service):
     def get_owned_folders() -> List[OwnedPath]:
         """
         Get a list of occupied directories with ownership info
-        pleroma has folders that are owned by different users
+        Pleroma has folders that are owned by different users
         """
         return [
             OwnedPath(
@@ -102,18 +102,3 @@ class Pleroma(Service):
                 group="postgres",
             ),
         ]
-
-    def move_to_volume(self, volume: BlockDevice) -> Job:
-        job = Jobs.add(
-            type_id="services.pleroma.move",
-            name="Move Pleroma",
-            description=f"Moving Pleroma to volume {volume.name}",
-        )
-        move_service(
-            self,
-            volume,
-            job,
-            FolderMoveNames.default_foldermoves(self),
-            "pleroma",
-        )
-        return job

selfprivacy_api/services/service.py

@@ -10,7 +10,15 @@ from selfprivacy_api.utils.block_devices import BlockDevice, BlockDevices
 
 from selfprivacy_api.services.generic_size_counter import get_storage_usage
 from selfprivacy_api.services.owned_path import OwnedPath
-from selfprivacy_api.services.moving import check_folders, check_volume, unbind_folders, bind_folders, ensure_folder_ownership, MoveError, move_folders_to_volume
+from selfprivacy_api.services.moving import (
+    check_folders,
+    check_volume,
+    unbind_folders,
+    bind_folders,
+    ensure_folder_ownership,
+    MoveError,
+    move_folders_to_volume,
+)
 
 from selfprivacy_api import utils
 from selfprivacy_api.utils.waitloop import wait_until_true
@@ -300,7 +308,7 @@ class Service(ABC):
     @classmethod
     def set_location(cls, volume: BlockDevice):
         """
-            Only changes userdata
+        Only changes userdata
         """
 
         with WriteUserData() as user_data:
@@ -313,15 +321,18 @@ class Service(ABC):
 
     def assert_can_move(self, new_volume):
         """
-            Checks if the service can be moved to new volume
+        Checks if the service can be moved to new volume
-            Raises errors if it cannot
+        Raises errors if it cannot
         """
+        service_name = self.get_display_name()
+        if not self.is_movable():
+            raise MoveError(f"{service_name} is not movable")
+
         with ReadUserData() as user_data:
             if not user_data.get("useBinds", False):
                 raise MoveError("Server is not using binds.")
 
         current_volume_name = self.get_drive()
-        service_name = self.get_display_name()
         if current_volume_name == new_volume.name:
             raise MoveError(f"{service_name} is already on volume {new_volume}")
 
@@ -333,7 +344,6 @@ class Service(ABC):
 
         check_folders(current_volume_name, owned_folders)
 
-
     def do_move_to_volume(
         self,
         new_volume: BlockDevice,
@@ -341,59 +351,57 @@ class Service(ABC):
     ):
         """
         Move a service to another volume.
-        Is not allowed to raise errors because it is a task.
         """
         service_name = self.get_display_name()
         old_volume_name = self.get_drive()
         owned_folders = self.get_owned_folders()
 
-        report_progress(0, job, "Performing pre-move checks...")
+        report_progress(10, job, "Unmounting folders from old volume...")
+        unbind_folders(owned_folders)
 
-        # TODO: move trying to the task
+        report_progress(20, job, "Moving data to new volume...")
+        move_folders_to_volume(owned_folders, old_volume_name, new_volume, job)
+
+        report_progress(70, job, f"Making sure {service_name} owns its files...")
         try:
-            report_progress(5, job, f"Stopping {service_name}...")
+            ensure_folder_ownership(owned_folders, new_volume, job, self)
-
+        except Exception as error:
-            with StoppedService(self):
+            # We have logged it via print and we additionally log it here in the error field
-                report_progress(10, job, "Unmounting folders from old volume...")
+            # We are continuing anyway but Job has no warning field
-                unbind_folders(owned_folders)
-
-                report_progress(20, job, "Moving data to new volume...")
-                move_folders_to_volume(owned_folders, old_volume_name, new_volume, job)
-
-                report_progress(70, job, f"Making sure {service_name} owns its files...")
-                try:
-                    ensure_folder_ownership(owned_folders, new_volume, job, self)
-                except Exception as error:
-                    # We have logged it via print and we additionally log it here in the error field
-                    # We are continuing anyway but Job has no warning field
-                    Jobs.update(job, JobStatus.RUNNING, error=f"Service {service_name} will not be able to write files: " + str(error))
-
-                report_progress(90, job, f"Mounting {service_name} data...")
-                bind_folders(owned_folders, new_volume)
-
-                report_progress(95, job, f"Finishing moving {service_name}...")
-                self.set_location(self, new_volume)
-
-                Jobs.update(
-                    job=job,
-                    status=JobStatus.FINISHED,
-                    result=f"{service_name} moved successfully.",
-                    status_text=f"Starting {service_name}...",
-                    progress=100,
-                )
-        except Exception as e:
             Jobs.update(
-                job=job,
+                job,
-                status=JobStatus.ERROR,
+                JobStatus.RUNNING,
-                error=type(e).__name__ + " " + str(e),
+                error=f"Service {service_name} will not be able to write files: "
+                + str(error),
             )
 
+        report_progress(90, job, f"Mounting {service_name} data...")
+        bind_folders(owned_folders, new_volume)
 
-    @abstractmethod
+        report_progress(95, job, f"Finishing moving {service_name}...")
-    def move_to_volume(self, volume: BlockDevice) -> Job:
+        self.set_location(new_volume)
-        """Cannot raise errors.
+
-        Returns errors as an errored out Job instead."""
+        Jobs.update(
-        pass
+            job=job,
+            status=JobStatus.FINISHED,
+            result=f"{service_name} moved successfully.",
+            status_text=f"Starting {service_name}...",
+            progress=100,
+        )
+
+    def move_to_volume(self, volume: BlockDevice, job: Job) -> Job:
+        service_name = self.get_display_name()
+
+        report_progress(0, job, "Performing pre-move checks...")
+        self.assert_can_move(volume)
+
+        report_progress(5, job, f"Stopping {service_name}...")
+        assert self is not None
+        with StoppedService(self):
+            report_progress(9, job, f"Stopped server, starting the move...")
+            self.do_move_to_volume(volume, job)
+
+        return job
 
     @classmethod
     def owned_path(cls, path: str):

selfprivacy_api/services/tasks.py

@@ -1,11 +1,22 @@
 from selfprivacy_api.services import Service
 from selfprivacy_api.utils.block_devices import BlockDevice
 from selfprivacy_api.utils.huey import huey
+from selfprivacy_api.jobs import Job, Jobs, JobStatus
 
 
 @huey.task()
-def move_service(
+def move_service(service: Service, new_volume: BlockDevice, job: Job) -> bool:
-    service: Service,
+    """
-    new_volume: BlockDevice,
+    Move service's folders to new physical volume
-):
+    Does not raise exceptions (we cannot handle exceptions from tasks).
-    service.move_to_volume(new_volume)
+    Reports all errors via job.
+    """
+    try:
+        service.move_to_volume(new_volume, job)
+    except Exception as e:
+        Jobs.update(
+            job=job,
+            status=JobStatus.ERROR,
+            error=type(e).__name__ + " " + str(e),
+        )
+    return True

selfprivacy_api/services/test_service/__init__.py

@@ -11,7 +11,6 @@ from os import path
 from selfprivacy_api.jobs import Job, Jobs, JobStatus
 from selfprivacy_api.services.service import Service, ServiceDnsRecord, ServiceStatus
 from selfprivacy_api.utils.block_devices import BlockDevice
-from selfprivacy_api.services.generic_service_mover import move_service, FolderMoveNames
 import selfprivacy_api.utils.network as network_utils
 
 from selfprivacy_api.services.test_service.icon import BITWARDEN_ICON
@@ -189,23 +188,10 @@ class DummyService(Service):
     def get_folders(cls) -> List[str]:
         return cls.folders
 
-    def move_to_volume(self, volume: BlockDevice) -> Job:
+    def do_move_to_volume(self, volume: BlockDevice, job: Job) -> Job:
-        job = Jobs.add(
-            type_id=f"services.{self.get_id()}.move",
-            name=f"Move {self.get_display_name()}",
-            description=f"Moving {self.get_display_name()} data to {volume.name}",
-        )
         if self.simulate_moving is False:
-            # completely generic code, TODO: make it the default impl.
+            return super(DummyService, self).do_move_to_volume(volume, job)
-            move_service(
-                self,
-                volume,
-                job,
-                FolderMoveNames.default_foldermoves(self),
-                self.get_id(),
-            )
         else:
             Jobs.update(job, status=JobStatus.FINISHED)
-
+            self.set_drive(volume.name)
-        self.set_drive(volume.name)
+            return job
-        return job

tests/test_graphql/test_services.py

@@ -8,6 +8,8 @@ from selfprivacy_api.services import get_service_by_id
 from selfprivacy_api.services.service import Service, ServiceStatus
 from selfprivacy_api.services.test_service import DummyService
 
+# from selfprivacy_api.services.moving import check_folders
+
 from tests.common import generate_service_query
 from tests.test_graphql.common import assert_empty, assert_ok, get_data
 from tests.test_block_device_utils import lsblk_singular_mock
@@ -32,7 +34,7 @@ MOVER_MOCK_PROCESS = CompletedProcess(["ls"], returncode=0)
 @pytest.fixture()
 def mock_check_service_mover_folders(mocker):
     mock = mocker.patch(
-        "selfprivacy_api.services.generic_service_mover.check_folders",
+        "selfprivacy_api.services.service.check_folders",
         autospec=True,
         return_value=None,
     )
@@ -495,9 +497,14 @@ def test_disable_enable(authorized_client, only_dummy_service):
 def test_move_immovable(authorized_client, only_dummy_service):
     dummy_service = only_dummy_service
     dummy_service.set_movable(False)
-    mutation_response = api_move(authorized_client, dummy_service, "sda1")
+    root = BlockDevices().get_root_block_device()
+    mutation_response = api_move(authorized_client, dummy_service, root.name)
     data = get_data(mutation_response)["services"]["moveService"]
     assert_errorcode(data, 400)
+    try:
+        assert "not movable" in data["message"]
+    except AssertionError:
+        raise ValueError("wrong type of error?: ", data["message"])
 
     # is there a meaning in returning the service in this?
     assert data["service"] is not None
@@ -519,8 +526,7 @@ def test_move_no_such_volume(authorized_client, only_dummy_service):
     data = get_data(mutation_response)["services"]["moveService"]
     assert_notfound(data)
 
-    # is there a meaning in returning the service in this?
+    assert data["service"] is None
-    assert data["service"] is not None
     assert data["job"] is None
 
 
@@ -538,7 +544,8 @@ def test_move_same_volume(authorized_client, dummy_service):
 
     # is there a meaning in returning the service in this?
     assert data["service"] is not None
-    assert data["job"] is not None
+    # We do not create a job if task is not created
+    assert data["job"] is None
 
 
 def test_graphql_move_service_without_folders_on_old_volume(

tests/test_services.py

@@ -13,7 +13,6 @@ from selfprivacy_api.services.bitwarden import Bitwarden
 from selfprivacy_api.services.pleroma import Pleroma
 from selfprivacy_api.services.mailserver import MailServer
 from selfprivacy_api.services.owned_path import OwnedPath
-from selfprivacy_api.services.generic_service_mover import FolderMoveNames
 
 from selfprivacy_api.services.test_service import DummyService
 from selfprivacy_api.services.service import Service, ServiceStatus, StoppedService
@@ -81,19 +80,19 @@ def test_paths_from_owned_paths():
     ]
 
 
-def test_foldermoves_from_ownedpaths():
+# def test_foldermoves_from_ownedpaths():
-    owned = OwnedPath(
+#     owned = OwnedPath(
-        path="var/lib/bitwarden",
+#         path="var/lib/bitwarden",
-        group="vaultwarden",
+#         group="vaultwarden",
-        owner="vaultwarden",
+#         owner="vaultwarden",
-    )
+#     )
 
-    assert FolderMoveNames.from_owned_path(owned) == FolderMoveNames(
+#     assert FolderMoveNames.from_owned_path(owned) == FolderMoveNames(
-        name="bitwarden",
+#         name="bitwarden",
-        bind_location="var/lib/bitwarden",
+#         bind_location="var/lib/bitwarden",
-        group="vaultwarden",
+#         group="vaultwarden",
-        owner="vaultwarden",
+#         owner="vaultwarden",
-    )
+#     )
 
 
 def test_enabling_disabling_reads_json(dummy_service: DummyService):