feat: reauth after delegation available (#680)

## Description
Reauth relays after user delegation is send.

## Type of Change
- [ ] Bug fix
- [x] New feature
- [ ] Breaking change
- [ ] Refactoring
- [ ] Documentation
- [ ] Chore

lib/app/features/ion_connect/providers/ion_connect_notifier.c.dart

@@ -17,6 +17,7 @@ import 'package:ion/app/features/ion_connect/providers/ion_connect_cache.c.dart'
 import 'package:ion/app/features/ion_connect/providers/ion_connect_event_parser.c.dart';
 import 'package:ion/app/features/ion_connect/providers/ion_connect_event_signer_provider.c.dart';
 import 'package:ion/app/features/ion_connect/providers/relay_creation_provider.c.dart';
+import 'package:ion/app/features/user/providers/user_delegation_provider.c.dart';
 import 'package:ion/app/services/ion_identity/ion_identity_provider.c.dart';
 import 'package:ion/app/services/logger/logger.dart';
 import 'package:ion/app/utils/retry.dart';
@@ -45,7 +46,7 @@ class IonConnectNotifier extends _$IonConnectNotifier {
             .getRelay(actionSource, dislikedUrls: dislikedRelaysUrls);
 
         if (_isAuthRequired(error)) {
-          await sendAuthEvent(relay!);
+          await _sendAuthEvent(relay!);
         }
 
         await relay!.sendEvents(events);
@@ -78,7 +79,20 @@ class IonConnectNotifier extends _$IonConnectNotifier {
     return result?.elementAtOrNull(0);
   }
 
-  Future<void> sendAuthEvent(IonConnectRelay relay) async {
+  Future<void> initRelayAuth(IonConnectRelay relay) async {
+    final signedAuthEvent = await createAuthEvent(
+      challenge: 'init',
+      relayUrl: Uri.parse(relay.url).toString(),
+    );
+
+    await sendEvent(
+      signedAuthEvent,
+      relay: relay,
+      cache: false,
+    );
+  }
+
+  Future<void> _sendAuthEvent(IonConnectRelay relay) async {
     final challenge = ref.read(authChallengeProvider(relay.url));
     if (challenge == null || challenge.isEmpty) throw AuthChallengeIsEmptyException();
 
@@ -113,7 +127,8 @@ class IonConnectNotifier extends _$IonConnectNotifier {
       relay: relayUrl,
     );
 
-    return sign(authEvent);
+    final delegation = await ref.read(currentUserCachedDelegationProvider.future);
+    return sign(authEvent, includeMasterPubkey: delegation != null);
   }
 
   Future<List<IonConnectEntity>?> sendEntitiesData(
@@ -151,8 +166,7 @@ class IonConnectNotifier extends _$IonConnectNotifier {
 
         if (_isAuthRequired(error)) {
           try {
-            // TODO: handle multiple auth requests to one connectoon properly
-            await sendAuthEvent(relay!);
+            await _sendAuthEvent(relay!);
           } catch (error, stackTrace) {
             Logger.log('Send auth exception', error: error, stackTrace: stackTrace);
           }

lib/app/features/ion_connect/providers/mixins/relay_delegation_mixin.dart

@@ -0,0 +1,37 @@
+// SPDX-License-Identifier: ice License 1.0
+
+import 'package:hooks_riverpod/hooks_riverpod.dart';
+import 'package:ion/app/features/ion_connect/ion_connect.dart';
+import 'package:ion/app/features/ion_connect/providers/ion_connect_event_signer_provider.c.dart';
+import 'package:ion/app/features/ion_connect/providers/ion_connect_notifier.c.dart';
+import 'package:ion/app/features/user/model/user_delegation.c.dart';
+import 'package:ion/app/features/user/providers/user_delegation_provider.c.dart';
+
+mixin RelayDelegationMixin {
+  void initializeDelegationListener(IonConnectRelay relay, Ref ref) {
+    ref.listen(
+      currentUserCachedDelegationProvider,
+      (previous, next) => _handleDelegationChange(previous, next, relay, ref),
+    );
+  }
+
+  void _handleDelegationChange(
+    AsyncValue<UserDelegationEntity?>? previous,
+    AsyncValue<UserDelegationEntity?> next,
+    IonConnectRelay relay,
+    Ref ref,
+  ) {
+    if (previous?.value == null && next.value != null) {
+      ref.read(currentUserIonConnectEventSignerProvider.future).then((eventSigner) {
+        if (eventSigner != null) {
+          final hasDelegate =
+              next.value?.data.hasDelegateFor(pubkey: eventSigner.publicKey) ?? false;
+
+          if (hasDelegate) {
+            ref.read(ionConnectNotifierProvider.notifier).initRelayAuth(relay);
+          }
+        }
+      });
+    }
+  }
+}

lib/app/features/ion_connect/providers/mixins/relay_init_mixin.dart

@@ -21,16 +21,7 @@ mixin RelayInitMixin {
     _initCompleters[relay.url] = completer;
 
     try {
-      final signedAuthEvent = await ref.read(ionConnectNotifierProvider.notifier).createAuthEvent(
-            challenge: 'init',
-            relayUrl: Uri.parse(relay.url).toString(),
-          );
-
-      await ref.read(ionConnectNotifierProvider.notifier).sendEvent(
-            signedAuthEvent,
-            relay: relay,
-            cache: false,
-          );
+      await ref.read(ionConnectNotifierProvider.notifier).initRelayAuth(relay);
 
       _subscriptions[relay.url] = relay.onClose.listen(
         (url) {

lib/app/features/ion_connect/providers/relays_provider.c.dart

@@ -2,6 +2,7 @@
 
 import 'package:ion/app/features/ion_connect/ion_connect.dart';
 import 'package:ion/app/features/ion_connect/providers/mixins/relay_auth_mixin.dart';
+import 'package:ion/app/features/ion_connect/providers/mixins/relay_delegation_mixin.dart';
 import 'package:ion/app/features/ion_connect/providers/mixins/relay_init_mixin.dart';
 import 'package:ion/app/features/ion_connect/providers/mixins/relay_timer_mixin.dart';
 import 'package:riverpod_annotation/riverpod_annotation.dart';
@@ -11,13 +12,16 @@ part 'relays_provider.c.g.dart';
 typedef RelaysState = Map<String, IonConnectRelay>;
 
 @Riverpod(keepAlive: true)
-class Relay extends _$Relay with RelayTimerMixin, RelayAuthMixin, RelayInitMixin {
+class Relay extends _$Relay
+    with RelayTimerMixin, RelayAuthMixin, RelayInitMixin, RelayDelegationMixin {
   @override
   Future<IonConnectRelay> build(String url, {bool anonymous = false}) async {
     final relay = await IonConnectRelay.connect(url);
 
     initializeRelayTimer(relay, ref);
+
     if (!anonymous) {
+      initializeDelegationListener(relay, ref);
       initializeAuthMessageListener(relay, ref);
       await initRelay(relay, ref);
     }

lib/app/features/user/providers/user_delegation_provider.c.dart

@@ -15,16 +15,10 @@ part 'user_delegation_provider.c.g.dart';
 
 @Riverpod(keepAlive: true)
 Future<UserDelegationEntity?> userDelegation(Ref ref, String pubkey) async {
-  final userDelegation = ref.watch(
-    ionConnectCacheProvider.select(
-      cacheSelector<UserDelegationEntity>(
-        CacheableEntity.cacheKeyBuilder(
-          eventReference:
-              ReplaceableEventReference(pubkey: pubkey, kind: UserDelegationEntity.kind),
-        ),
-      ),
-    ),
+  final userDelegation = await ref.watch(
+    cachedUserDelegationProvider(pubkey).future,
   );
+
   if (userDelegation != null) {
     return userDelegation;
   }
@@ -40,6 +34,24 @@ Future<UserDelegationEntity?> userDelegation(Ref ref, String pubkey) async {
       );
 }
 
+@Riverpod(keepAlive: true)
+Future<UserDelegationEntity?> cachedUserDelegation(Ref ref, String pubkey) async {
+  final userDelegation = ref.watch(
+    ionConnectCacheProvider.select(
+      cacheSelector<UserDelegationEntity>(
+        CacheableEntity.cacheKeyBuilder(
+          eventReference: ReplaceableEventReference(
+            pubkey: pubkey,
+            kind: UserDelegationEntity.kind,
+          ),
+        ),
+      ),
+    ),
+  );
+
+  return userDelegation;
+}
+
 @Riverpod(keepAlive: true)
 Future<UserDelegationEntity?> currentUserDelegation(Ref ref) async {
   final mainWallet = await ref.watch(mainWalletProvider.future);
@@ -51,6 +63,17 @@ Future<UserDelegationEntity?> currentUserDelegation(Ref ref) async {
   }
 }
 
+@Riverpod(keepAlive: true)
+Future<UserDelegationEntity?> currentUserCachedDelegation(Ref ref) async {
+  final mainWallet = await ref.watch(mainWalletProvider.future);
+
+  try {
+    return await ref.watch(cachedUserDelegationProvider(mainWallet.signingKey.publicKey).future);
+  } on UserRelaysNotFoundException catch (_) {
+    return null;
+  }
+}
+
 @riverpod
 class UserDelegationManager extends _$UserDelegationManager {
   @override