buzz/mobile/lib/features/profile/user_status_provider.dart

import 'dart:async';

import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:nostr/nostr.dart' as nostr;

import '../../shared/relay/relay.dart';
import 'user_status.dart';
import 'user_status_cache_provider.dart';
import 'package:buzz/shared/crypto/event_signing.dart';

/// Manages the current user's own NIP-38 status (kind:30315, d=general).
///
/// Fetches the existing status on build and provides [setStatus] / [clearStatus]
/// for publishing. Publishes via WebSocket (triggers fan-out). No heartbeat
/// needed — user status events are parameterised replaceable, not ephemeral.
class UserStatusNotifier extends AsyncNotifier<UserStatus?> {
  Timer? _expirationTimer;

  @override
  Future<UserStatus?> build() async {
    ref.watch(relayClientProvider);
    ref.watch(relaySessionProvider);
    ref.onDispose(() {
      _expirationTimer?.cancel();
      _expirationTimer = null;
    });

    final status = await _fetch();
    _scheduleExpiration(status);
    return status;
  }

  Future<UserStatus?> _fetch() async {
    final config = ref.read(relayConfigProvider);
    final nsec = config.nsec;
    if (nsec == null || nsec.isEmpty) return null;

    String pubkey;
    try {
      final privkeyHex = nostr.Nip19.decode(payload: nsec).data;
      pubkey = derivePublicKeyHex(privkeyHex);
    } catch (_) {
      return null;
    }

    final sessionState = ref.read(relaySessionProvider);
    if (sessionState.status != SessionStatus.connected) return null;

    try {
      final session = ref.read(relaySessionProvider.notifier);
      final events = await session.fetchHistory(
        NostrFilter(
          kinds: const [EventKind.userStatus],
          authors: [pubkey],
          tags: const {
            '#d': ['general'],
          },
          limit: 1,
        ),
      );

      if (events.isEmpty) return null;

      // Pick the most recent event.
      final latest = events.reduce(
        (a, b) => a.createdAt >= b.createdAt ? a : b,
      );
      final status = UserStatus.fromEvent(latest);
      final now = DateTime.now().millisecondsSinceEpoch ~/ 1000;
      return status.isEmpty || status.isExpiredAt(now) ? null : status;
    } catch (_) {
      return null;
    }
  }

  Future<void> setStatus(
    String text,
    String emoji, {
    DateTime? expiresAt,
  }) async {
    final trimmed = text.trim();
    final config = ref.read(relayConfigProvider);
    final nsec = config.nsec;
    if (nsec == null || nsec.isEmpty) return;

    final tags = <List<String>>[
      ['d', 'general'],
    ];
    if (emoji.isNotEmpty) {
      tags.add(['emoji', emoji]);
    }
    if (expiresAt != null) {
      tags.add(['expiration', '${expiresAt.millisecondsSinceEpoch ~/ 1000}']);
    }

    final privkeyHex = nostr.Nip19.decode(payload: nsec).data;
    final event = signNostrEvent(
      kind: EventKind.userStatus,
      content: trimmed,
      tags: tags,
      secretKey: privkeyHex,
    );

    final session = ref.read(relaySessionProvider.notifier);
    await session.publish(NostrEvent.fromJson(event.toMap()));

    // Optimistic update: update own state immediately.
    final newStatus = (trimmed.isNotEmpty || emoji.isNotEmpty)
        ? UserStatus(
            text: trimmed,
            emoji: emoji,
            updatedAt: DateTime.now().millisecondsSinceEpoch ~/ 1000,
            expiresAt: expiresAt == null
                ? null
                : expiresAt.millisecondsSinceEpoch ~/ 1000,
          )
        : null;
    state = AsyncValue.data(newStatus);
    _scheduleExpiration(newStatus);

    // Also update the shared cache so other UI reads stay consistent.
    final pubkey = derivePublicKeyHex(privkeyHex);
    ref.read(userStatusCacheProvider.notifier).updateStatus(pubkey, newStatus);
  }

  Future<void> clearStatus() => setStatus('', '');

  void _scheduleExpiration(UserStatus? status) {
    _expirationTimer?.cancel();
    _expirationTimer = null;
    final deadline = status?.expirationDateTime;
    if (deadline == null) return;

    final remaining = deadline.difference(DateTime.now());
    _expirationTimer = Timer(
      remaining.isNegative ? Duration.zero : remaining,
      _expireCurrentStatus,
    );
  }

  void _expireCurrentStatus() {
    final current = state.asData?.value;
    if (current == null) return;
    final now = DateTime.now().millisecondsSinceEpoch ~/ 1000;
    if (!current.isExpiredAt(now)) {
      // Timer callbacks can land just before the Unix-second boundary.
      _expirationTimer = Timer(
        const Duration(milliseconds: 50),
        _expireCurrentStatus,
      );
      return;
    }

    state = const AsyncValue.data(null);
    final pubkey = _currentPubkey();
    if (pubkey != null) {
      ref.read(userStatusCacheProvider.notifier).updateStatus(pubkey, null);
    }
  }

  String? _currentPubkey() {
    final nsec = ref.read(relayConfigProvider).nsec;
    if (nsec == null || nsec.isEmpty) return null;
    try {
      final privkeyHex = nostr.Nip19.decode(payload: nsec).data;
      return derivePublicKeyHex(privkeyHex);
    } catch (_) {
      return null;
    }
  }
}

final userStatusProvider =
    AsyncNotifierProvider<UserStatusNotifier, UserStatus?>(
      UserStatusNotifier.new,
    );