mirror of
https://github.com/pacnpal/thrillwiki_django_no_react.git
synced 2025-12-21 22:11:07 -05:00
b860e332cb
Extend state machine module with callback infrastructure including: - Pre/post/error transition callbacks with registry - Signal-based transition notifications - Callback configuration and monitoring support - Helper functions for callback registration - Improved park ride count updates with FSM integration
74 lines
2.2 KiB
Python
74 lines
2.2 KiB
Python
import logging
|
|
|
|
from django.apps import AppConfig
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class ParksConfig(AppConfig):
|
|
default_auto_field = "django.db.models.BigAutoField"
|
|
name = "apps.parks"
|
|
|
|
def ready(self):
|
|
import apps.parks.signals # noqa: F401 - Register signals
|
|
import apps.parks.choices # noqa: F401 - Register choices
|
|
|
|
self._apply_state_machines()
|
|
self._register_callbacks()
|
|
|
|
def _apply_state_machines(self):
|
|
"""Apply FSM to park models."""
|
|
from apps.core.state_machine import apply_state_machine
|
|
from apps.parks.models import Park
|
|
|
|
# Register FSM transitions for Park
|
|
apply_state_machine(
|
|
Park, field_name="status", choice_group="statuses", domain="parks"
|
|
)
|
|
|
|
def _register_callbacks(self):
|
|
"""Register FSM transition callbacks for park models."""
|
|
from apps.core.state_machine.registry import register_callback
|
|
from apps.core.state_machine.callbacks.cache import (
|
|
ParkCacheInvalidation,
|
|
APICacheInvalidation,
|
|
)
|
|
from apps.core.state_machine.callbacks.notifications import (
|
|
StatusChangeNotification,
|
|
)
|
|
from apps.core.state_machine.callbacks.related_updates import (
|
|
SearchTextUpdateCallback,
|
|
)
|
|
from apps.parks.models import Park
|
|
|
|
# Cache invalidation for all park status changes
|
|
register_callback(
|
|
Park, 'status', '*', '*',
|
|
ParkCacheInvalidation()
|
|
)
|
|
|
|
# API cache invalidation
|
|
register_callback(
|
|
Park, 'status', '*', '*',
|
|
APICacheInvalidation(include_geo_cache=True)
|
|
)
|
|
|
|
# Search text update
|
|
register_callback(
|
|
Park, 'status', '*', '*',
|
|
SearchTextUpdateCallback()
|
|
)
|
|
|
|
# Notification for significant status changes
|
|
register_callback(
|
|
Park, 'status', '*', 'CLOSED_PERM',
|
|
StatusChangeNotification(notify_admins=True)
|
|
)
|
|
register_callback(
|
|
Park, 'status', '*', 'DEMOLISHED',
|
|
StatusChangeNotification(notify_admins=True)
|
|
)
|
|
|
|
logger.debug("Registered park transition callbacks")
|