class ActivityItem {
  final String id;
  final String type;     // new_user / achievement / milestone / share / level_up
  final String userName;
  final String action;
  final DateTime timestamp;

  factory ActivityItem.fromJson(Map<String, dynamic> json) {
    return ActivityItem(
      id: json['id'].toString(),
      type: json['type'] as String? ?? 'general',
      userName: json['user_name'] ?? 'anonymous',
      action: json['action'] as String? ?? '',
      timestamp: DateTime.parse(json['timestamp'] as String),
    );
  }
}

class _ActivityFeedPageState extends State<ActivityFeedPage> {
  final _supabase = Supabase.instance.client;
  StreamSubscription<List<Map<String, dynamic>>>? _activitySubscription;

  void _startRealTimeSubscription() {
    _activitySubscription = _supabase
        .from('activities')
        .stream(primaryKey: ['id'])
        .order('timestamp', ascending: false)
        .limit(30)
        .listen(
          (data) {
            if (mounted) {
              setState(() => _activities = data.map(ActivityItem.fromJson).toList());
            }
          },
          onError: (_) => _loadActivities(), // fallback to HTTP on WS error
        );
  }

  @override
  void dispose() {
    _activitySubscription?.cancel(); // critical — prevents memory leaks
    super.dispose();
  }
}

Future<void> _loadActivities() async {
  final response = await _supabase
      .from('activities')
      .select('id, type, user_name, action, timestamp')
      .order('timestamp', ascending: false)
      .limit(30);

  if (mounted) {
    setState(() => _activities = (response as List)
        .map((j) => ActivityItem.fromJson(j as Map<String, dynamic>))
        .toList());
  }
}

ALTER PUBLICATION supabase_realtime ADD TABLE activities;