Invalidate subscription cache on unsync and resync (#977)

Author: tjeerddie

orchestrator/workflows/steps.py

@@ -23,6 +23,7 @@
 from orchestrator.targets import Target
 from orchestrator.types import SubscriptionLifecycle
 from orchestrator.utils.json import to_serializable
+from orchestrator.websocket import sync_invalidate_subscription_cache
 from orchestrator.workflow import Step, step
 from pydantic_forms.types import State, UUIDstr
 
@@ -33,6 +34,7 @@
 def resync(subscription: SubscriptionModel) -> State:
     """Transition a subscription to in sync."""
     subscription.insync = True
+    sync_invalidate_subscription_cache(subscription.subscription_id)
     return {"subscription": subscription}
 
 
@@ -93,6 +95,7 @@ def unsync(subscription_id: UUIDstr, __old_subscriptions__: dict | None = None)
     if not subscription.insync:
         raise ValueError("Subscription is already out of sync, cannot continue!")
     subscription.insync = False
+    sync_invalidate_subscription_cache(subscription.subscription_id)
 
     return {"subscription": subscription, "__old_subscriptions__": subscription_backup}