Function sync_developer_notifications

core/developer_notifications.py:236–382

Sync developer notifications from JSON file to database. - Adds new notifications that don't exist in the DB - Removes DB notifications that are no longer in the JSON file - Updates existing notifications if they've changed Returns a dict with counts of added, updated, and rem

()

def sync_developer_notifications() -> dict[str, int]:
    """
    Sync developer notifications from JSON file to database.

    - Adds new notifications that don't exist in the DB
    - Removes DB notifications that are no longer in the JSON file
    - Updates existing notifications if they've changed

    Returns a dict with counts of added, updated, and removed notifications.
    """
    from core.models import SystemNotification

    results = {'added': 0, 'updated': 0, 'removed': 0, 'skipped': 0}

    notifications = load_developer_notifications()
    json_notification_keys = set()
    notifications_to_remove = set()  # Track notifications to remove (out of range or expired)

    for notif_data in notifications:
        notification_id = notif_data.get('id')
        if not notification_id:
            logger.warning("Notification missing 'id' field, skipping")
            results['skipped'] += 1
            continue

        json_notification_keys.add(notification_id)

        # Check version constraints (only add if current version is in range)
        if not is_version_in_range(
            __version__,
            notif_data.get('min_version'),
            notif_data.get('max_version')
        ):
            logger.debug(f"Notification {notification_id} not in version range, marking for removal")
            results['skipped'] += 1
            notifications_to_remove.add(notification_id)
            continue

        # Parse expires_at if provided
        expires_at = None
        if notif_data.get('expires_at'):
            try:
                expires_at = datetime.fromisoformat(
                    notif_data['expires_at'].replace('Z', '+00:00')
                )
                # Skip if already expired and mark for removal
                if expires_at < timezone.now():
                    logger.debug(f"Notification {notification_id} has expired, marking for removal")
                    results['skipped'] += 1
                    notifications_to_remove.add(notification_id)
                    continue
            except (ValueError, TypeError) as e:
                logger.warning(f"Invalid expires_at for {notification_id}: {e}")

        # Map notification_type from JSON to model choices
        type_mapping = {
            'version_update': SystemNotification.NotificationType.VERSION_UPDATE,
            'setting_recommendation': SystemNotification.NotificationType.SETTING_RECOMMENDATION,