Rename StateSyncer -> StateManager

Author: Peter-Sh

src/redis_release/bht/tree.py

@@ -20,7 +20,7 @@
 
 from ..config import Config
 from ..github_client_async import GitHubClientAsync
-from ..state_manager import S3StateStorage, StateStorage, StateSyncer
+from ..state_manager import S3StateStorage, StateManager, StateStorage
 from .args import ReleaseArgs
 from .backchain import latch_chains
 from .behaviours import NeedToPublishRelease
@@ -102,14 +102,14 @@ def initialize_tree_and_state(
     args: ReleaseArgs,
     storage: Optional[StateStorage] = None,
     read_only: bool = False,
-) -> Iterator[Tuple[BehaviourTree, StateSyncer]]:
+) -> Iterator[Tuple[BehaviourTree, StateManager]]:
     github_client = GitHubClientAsync(token=os.getenv("GITHUB_TOKEN") or "")
 
     if storage is None:
         storage = S3StateStorage()
 
     # Create state syncer with storage backend and acquire lock
-    with StateSyncer(
+    with StateManager(
         storage=storage,
         config=config,
         args=args,

src/redis_release/cli.py

@@ -13,7 +13,7 @@
 from redis_release.state_manager import (
     InMemoryStateStorage,
     S3StateStorage,
-    StateSyncer,
+    StateManager,
 )
 
 from .bht.tree import TreeInspector, async_tick_tock, initialize_tree_and_state
@@ -137,7 +137,7 @@ def status(
         force_rebuild=[],
     )
 
-    with StateSyncer(
+    with StateManager(
         storage=S3StateStorage(),
         config=config,
         args=args,

src/redis_release/state_manager.py

@@ -145,7 +145,7 @@ def release_lock(self, tag: str) -> bool:
         ...
 
 
-class StateSyncer:
+class StateManager:
     """Syncs ReleaseState to storage backend only when changed.
 
     Can be used as a context manager to automatically acquire and release locks.
@@ -167,7 +167,7 @@ def __init__(
         self._lock_acquired = False
         self.read_only = read_only
 
-    def __enter__(self) -> "StateSyncer":
+    def __enter__(self) -> "StateManager":
         if self.read_only:
             return self
         """Acquire lock when entering context."""

src/tests/test_state.py

@@ -9,7 +9,7 @@
 from redis_release.bht.state import ReleaseState, Workflow
 from redis_release.config import Config, PackageConfig
 from redis_release.models import PackageType
-from redis_release.state_manager import InMemoryStateStorage, StateSyncer
+from redis_release.state_manager import InMemoryStateStorage, StateManager
 
 
 class TestReleaseStateFromConfig:
@@ -492,7 +492,7 @@ def test_state_syncer_sets_tag_from_args(self) -> None:
 
         args = ReleaseArgs(release_tag="8.4-m01", force_rebuild=[])
         storage = InMemoryStateStorage()
-        syncer = StateSyncer(storage=storage, config=config, args=args)
+        syncer = StateManager(storage=storage, config=config, args=args)
 
         assert syncer.state.meta.tag == "8.4-m01"
 
@@ -518,7 +518,7 @@ def test_state_syncer_sets_force_rebuild_from_args(self) -> None:
 
         args = ReleaseArgs(release_tag="8.4-m01", force_rebuild=["docker"])
         storage = InMemoryStateStorage()
-        syncer = StateSyncer(storage=storage, config=config, args=args)
+        syncer = StateManager(storage=storage, config=config, args=args)
 
         assert syncer.state.packages["docker"].meta.ephemeral.force_rebuild is True
         assert syncer.state.packages["redis"].meta.ephemeral.force_rebuild is False
@@ -551,7 +551,7 @@ def test_state_syncer_sets_multiple_force_rebuild_from_args(self) -> None:
 
         args = ReleaseArgs(release_tag="8.4-m01", force_rebuild=["docker", "snap"])
         storage = InMemoryStateStorage()
-        syncer = StateSyncer(storage=storage, config=config, args=args)
+        syncer = StateManager(storage=storage, config=config, args=args)
 
         assert syncer.state.packages["docker"].meta.ephemeral.force_rebuild is True
         assert syncer.state.packages["redis"].meta.ephemeral.force_rebuild is False
@@ -573,7 +573,7 @@ def test_state_syncer_without_args(self) -> None:
 
         args = ReleaseArgs(release_tag="test-tag", force_rebuild=[])
         storage = InMemoryStateStorage()
-        syncer = StateSyncer(storage=storage, config=config, args=args)
+        syncer = StateManager(storage=storage, config=config, args=args)
 
         assert syncer.state.meta.tag == "test-tag"
         assert (
@@ -608,7 +608,7 @@ def test_state_syncer_force_rebuild_all(self) -> None:
 
         args = ReleaseArgs(release_tag="8.4-m01", force_rebuild=["all"])
         storage = InMemoryStateStorage()
-        syncer = StateSyncer(storage=storage, config=config, args=args)
+        syncer = StateManager(storage=storage, config=config, args=args)
 
         # All packages should have force_rebuild set to True
         assert syncer.state.packages["docker"].meta.ephemeral.force_rebuild is True
@@ -637,7 +637,7 @@ def test_state_syncer_force_rebuild_all_with_other_values(self) -> None:
 
         args = ReleaseArgs(release_tag="8.4-m01", force_rebuild=["docker", "all"])
         storage = InMemoryStateStorage()
-        syncer = StateSyncer(storage=storage, config=config, args=args)
+        syncer = StateManager(storage=storage, config=config, args=args)
 
         # All packages should have force_rebuild set to True
         assert syncer.state.packages["docker"].meta.ephemeral.force_rebuild is True