feat: Init RDS package

packages/syft-bg/pyproject.toml

@@ -17,13 +17,15 @@ dependencies = [
     "pydantic>=2.0.0",
     "google-cloud-pubsub>=2.18.0",
     "syft-job==0.1.39",
+    "syft-rds",
 ]
 
 [project.scripts]
 syft-bg = "syft_bg.cli:main"
 
 [tool.uv.sources]
 "syft-job" = { workspace = true }
+"syft-rds" = { workspace = true }
 
 [build-system]
 requires = ["hatchling"]

packages/syft-bg/src/syft_bg/approve/handlers/job.py

@@ -18,7 +18,7 @@
 )
 
 if TYPE_CHECKING:
-    from syft_client.sync.syftbox_manager import SyftboxManager
+    from syft_rds import SyftRDSClient
 
 
 class StateManager(Protocol):
@@ -33,7 +33,7 @@ class JobApprovalHandler:
 
     def __init__(
         self,
-        client: SyftboxManager,
+        client: SyftRDSClient,
         config_path: Optional[Path] = None,
         state: Optional[StateManager] = None,
         on_approve: Optional[Callable[[JobInfo], None]] = None,

packages/syft-bg/src/syft_bg/approve/handlers/peer.py

@@ -7,7 +7,7 @@
 from syft_bg.approve.config import PeerApprovalConfig
 
 if TYPE_CHECKING:
-    from syft_client.sync.syftbox_manager import SyftboxManager
+    from syft_rds import SyftRDSClient
 
 
 class StateManager(Protocol):
@@ -22,7 +22,7 @@ class PeerApprovalHandler:
 
     def __init__(
         self,
-        client: SyftboxManager,
+        client: SyftRDSClient,
         config: PeerApprovalConfig,
         state: Optional[StateManager] = None,
         on_approve: Optional[Callable[[str], None]] = None,

packages/syft-bg/src/syft_bg/approve/monitors/job.py

@@ -10,15 +10,15 @@
 
 if TYPE_CHECKING:
     from syft_job.job import JobInfo
-    from syft_client.sync.syftbox_manager import SyftboxManager
+    from syft_rds import SyftRDSClient
 
 
 class JobMonitor(Monitor):
     """Monitors for jobs to auto-approve."""
 
     def __init__(
         self,
-        client: SyftboxManager,
+        client: SyftRDSClient,
         config_path: Optional[Path] = None,
         state: Optional[StateManager] = None,
         on_approve: Optional[Callable[[JobInfo], None]] = None,

packages/syft-bg/src/syft_bg/approve/monitors/peer.py

@@ -9,15 +9,15 @@
 
 if TYPE_CHECKING:
     from syft_bg.approve.config import PeerApprovalConfig
-    from syft_client.sync.syftbox_manager import SyftboxManager
+    from syft_rds import SyftRDSClient
 
 
 class PeerMonitor(Monitor):
     """Monitors for peers to auto-approve."""
 
     def __init__(
         self,
-        client: SyftboxManager,
+        client: SyftRDSClient,
         config: PeerApprovalConfig,
         state: Optional[StateManager] = None,
         on_approve: Optional[Callable[[str], None]] = None,

packages/syft-bg/src/syft_bg/approve/orchestrator.py

@@ -12,15 +12,15 @@
 from syft_bg.common.state import JsonStateManager
 
 if TYPE_CHECKING:
-    from syft_client.sync.syftbox_manager import SyftboxManager
+    from syft_rds import SyftRDSClient
 
 
 class ApprovalOrchestrator(BaseOrchestrator):
     """Orchestrator for job and peer auto-approval service."""
 
     def __init__(
         self,
-        client: SyftboxManager,
+        client: SyftRDSClient,
         config: AutoApproveConfig,
         config_path: Optional[Path] = None,
     ):
@@ -40,10 +40,10 @@ def setup(self) -> None:
     @classmethod
     def from_client(
         cls,
-        client: SyftboxManager,
+        client: SyftRDSClient,
         interval: int = 5,
     ) -> ApprovalOrchestrator:
-        """Create orchestrator from a SyftboxManager client."""
+        """Create orchestrator from a SyftRDSClient."""
         if not client.has_do_role:
             raise ValueError(
                 "ApprovalOrchestrator should only run on Data Owner (DO) side."
@@ -67,31 +67,35 @@ def from_config(
         if not config.syftbox_root:
             raise ValueError("Config missing 'syftbox_root' field")
 
-        # Wait for sync to seed the cache before building SyftboxManager —
-        # SyftboxManager.from_config triggers _load_file_hashes_from_disk,
-        # which races sync's identical replay if both run cold-start.
+        # Wait for sync to seed the cache before building the RDS client —
+        # its nested SyftboxManager.from_config triggers
+        # _load_file_hashes_from_disk, which races sync's identical replay if
+        # both run cold-start.
         cls._wait_for_sync_ready(label="Approve")
 
-        from syft_client.sync.environments.environment import Environment
-        from syft_client.sync.syftbox_manager import SyftboxManager
-        from syft_client.sync.utils.syftbox_utils import check_env
+        from syft_rds import (
+            Environment,
+            SyftRDSClient,
+            SyftRDSClientConfig,
+            check_env,
+        )
 
-        env = check_env()
-        if env == Environment.COLAB:
-            client = SyftboxManager.for_colab(
+        if check_env() == Environment.COLAB:
+            rds_config = SyftRDSClientConfig.for_colab(
                 email=config.do_email,
                 has_do_role=True,
                 skip_peer_on_patch_version_diff=config.skip_peer_on_patch_version_diff,
                 force_ignore_peer_version=config.force_ignore_peer_version,
             )
         else:
-            client = SyftboxManager.for_jupyter(
+            rds_config = SyftRDSClientConfig.for_jupyter(
                 email=config.do_email,
                 has_do_role=True,
                 token_path=config.drive_token_path,
                 skip_peer_on_patch_version_diff=config.skip_peer_on_patch_version_diff,
                 force_ignore_peer_version=config.force_ignore_peer_version,
             )
+        client = SyftRDSClient.from_config(rds_config)
 
         return cls(client=client, config=config)
 

packages/syft-bg/src/syft_bg/cli/init/flow.py

@@ -100,7 +100,7 @@ def _resolve_common_settings(config: UserPassedConfig, result: SyftBgConfig) ->
             "Data Owner email address", default=default_email or None
         )
 
-    from syft_client.sync.syftbox_manager import get_jupyter_default_syftbox_folder
+    from syft_rds import get_jupyter_default_syftbox_folder
 
     default_syftbox = result.syftbox_root or str(
         get_jupyter_default_syftbox_folder(result.do_email)

packages/syft-bg/src/syft_bg/common/syft_bg_config.py

@@ -38,9 +38,7 @@ def _set_default_syftbox_root(cls, data: dict) -> dict:
         if not isinstance(data, dict):
             return data
         if not data.get("syftbox_root") and data.get("do_email"):
-            from syft_client.sync.syftbox_manager import (
-                get_jupyter_default_syftbox_folder,
-            )
+            from syft_rds import get_jupyter_default_syftbox_folder
 
             data = dict(data)
             data["syftbox_root"] = str(

packages/syft-bg/src/syft_bg/notify/handlers/job.py

@@ -5,7 +5,7 @@
 
 from syft_bg.common.state import JsonStateManager
 from syft_bg.notify.gmail.sender import GmailSender
-from syft_client.sync.utils.path_filters import is_normal_syncable_path
+from syft_rds import is_normal_syncable_path
 
 if TYPE_CHECKING:
     from syft_job.client import JobClient

packages/syft-bg/src/syft_bg/sync/orchestrator.py

@@ -13,7 +13,7 @@
 from syft_bg.sync.snapshot import PeerVersionInfo, SyncSnapshot
 
 if TYPE_CHECKING:
-    from syft_client.sync.syftbox_manager import SyftboxManager
+    from syft_rds import SyftRDSClient
 
 
 def sync_ready_path() -> Path:
@@ -24,7 +24,7 @@ def sync_ready_path() -> Path:
 class SyncOrchestrator(BaseOrchestrator):
     def __init__(
         self,
-        client: SyftboxManager,
+        client: SyftRDSClient,
         state: JsonStateManager,
         config: SyncConfig,
     ):
@@ -42,26 +42,29 @@ def from_config(cls, config: SyncConfig) -> SyncOrchestrator:
         if not config.syftbox_root:
             raise ValueError("SyncConfig missing 'syftbox_root'")
 
-        from syft_client.sync.environments.environment import Environment
-        from syft_client.sync.syftbox_manager import SyftboxManager
-        from syft_client.sync.utils.syftbox_utils import check_env
+        from syft_rds import (
+            Environment,
+            SyftRDSClient,
+            SyftRDSClientConfig,
+            check_env,
+        )
 
-        env = check_env()
-        if env == Environment.COLAB:
-            client = SyftboxManager.for_colab(
+        if check_env() == Environment.COLAB:
+            rds_config = SyftRDSClientConfig.for_colab(
                 email=config.do_email,
                 has_do_role=True,
                 skip_peer_on_patch_version_diff=config.skip_peer_on_patch_version_diff,
                 force_ignore_peer_version=config.force_ignore_peer_version,
             )
         else:
-            client = SyftboxManager.for_jupyter(
+            rds_config = SyftRDSClientConfig.for_jupyter(
                 email=config.do_email,
                 has_do_role=True,
                 token_path=config.drive_token_path,
                 skip_peer_on_patch_version_diff=config.skip_peer_on_patch_version_diff,
                 force_ignore_peer_version=config.force_ignore_peer_version,
             )
+        client = SyftRDSClient.from_config(rds_config)
 
         state = JsonStateManager(state_file=config.sync_state_path)
 

packages/syft-enclave/pyproject.toml

@@ -8,6 +8,7 @@ requires-python = ">=3.10"
 
 dependencies = [
     "syft-client",
+    "syft-rds",
     "pydantic-settings>=2.11.0",
     "requests>=2.32.0",
     "google-auth[pyjwt]>=2.22.0",
@@ -19,6 +20,7 @@ build-backend = "hatchling.build"
 
 [tool.uv.sources]
 "syft-client" = { workspace = true }
+"syft-rds" = { workspace = true }
 
 [tool.hatch.build.targets.wheel]
 packages = ["src/syft_enclaves"]