9dfa06ffee
Docker image / Build (linux/amd64) (push) Has been cancelled
Docker image / Build (linux/arm64) (push) Has been cancelled
Docker image / Merge release multi-arch manifest (push) Has been cancelled
Docker image / Merge debug multi-arch manifest (push) Has been cancelled
Docker image / Build public push gateway (linux/amd64) (push) Has been cancelled
Docker image / Build public push gateway (linux/arm64) (push) Has been cancelled
Docker image / Publish public push gateway image (push) Has been cancelled
Sprig image / Build (linux/amd64) (push) Has been cancelled
Sprig image / Build (linux/arm64) (push) Has been cancelled
Sprig image / Merge multi-arch manifest (push) Has been cancelled
Harbor Buzz Orchestra / Python tests and lint (push) Has been cancelled
CI / Detect Changed Paths (push) Has been cancelled
CI / Rust Lint (push) Has been cancelled
CI / Unit Tests (push) Has been cancelled
CI / Desktop Core (push) Has been cancelled
CI / Desktop Smoke E2E (1) (push) Has been cancelled
CI / Desktop Smoke E2E (2) (push) Has been cancelled
CI / Desktop Smoke E2E (3) (push) Has been cancelled
CI / Desktop Smoke E2E (4) (push) Has been cancelled
CI / Desktop (push) Has been cancelled
CI / Desktop E2E Relay (push) Has been cancelled
CI / Desktop E2E Integration (1/2) (push) Has been cancelled
CI / Desktop E2E Integration (2/2) (push) Has been cancelled
CI / Desktop E2E Integration (push) Has been cancelled
CI / Backend Integration (relay e2e) (push) Has been cancelled
CI / Relay E2E (push) Has been cancelled
CI / Web (push) Has been cancelled
CI / Mobile (push) Has been cancelled
CI / Security (push) Has been cancelled
CI / Dead Token Reference Guard (push) Has been cancelled
CI / Server Cross-Compile (aarch64-unknown-linux-musl) (push) Has been cancelled
CI / Server Cross-Compile (x86_64-unknown-linux-musl) (push) Has been cancelled
CI / Windows Rust (x86_64-pc-windows-msvc) (push) Has been cancelled
CI / Desktop Build (macOS) (push) Has been cancelled
helm chart / lint + unittest + render matrix (push) Has been cancelled
helm chart / install on kind (gated) (push) Has been cancelled
helm chart / publish chart to GHCR (push) Has been cancelled
Mesh Lifecycle / Relay-Driven Mesh Lifecycle Smoke (push) Has been cancelled
Sprig / Build (aarch64-unknown-linux-musl) (push) Has been cancelled
Sprig / Build (x86_64-unknown-linux-musl) (push) Has been cancelled
Sprig / Publish rolling release (push) Has been cancelled
Sprig / Publish tagged release (push) Has been cancelled
Signed-off-by: cls_宁波本机 <908705107@qq.com>
61 lines
2.0 KiB
Dart
61 lines
2.0 KiB
Dart
import 'package:hooks_riverpod/hooks_riverpod.dart';
|
|
|
|
import '../relay/relay.dart';
|
|
import 'custom_emoji.dart';
|
|
|
|
/// Community custom-emoji palette (NIP-30, per-user kind:30030 sets unioned).
|
|
///
|
|
/// On build, fetches every member's set and collapses to one entry per
|
|
/// shortcode (see [unionCustomEmoji]). Re-fetches when the relay session
|
|
/// reconnects. The palette is the single source of truth consumed by the
|
|
/// renderer, picker, autocomplete, and reaction/send tag plumbing.
|
|
class CustomEmojiPaletteNotifier extends AsyncNotifier<List<CustomEmoji>> {
|
|
@override
|
|
Future<List<CustomEmoji>> build() {
|
|
ref.watch(relayClientProvider);
|
|
ref.watch(relaySessionProvider);
|
|
return _fetch();
|
|
}
|
|
|
|
Future<List<CustomEmoji>> _fetch() async {
|
|
final sessionState = ref.read(relaySessionProvider);
|
|
if (sessionState.status != SessionStatus.connected) return [];
|
|
|
|
try {
|
|
final session = ref.read(relaySessionProvider.notifier);
|
|
final events = await session.fetchHistory(
|
|
const NostrFilter(
|
|
kinds: [kindEmojiSet],
|
|
tags: {
|
|
'#d': [customEmojiSetDTag],
|
|
},
|
|
// One 30030 per member; the relay keeps only the latest per
|
|
// (pubkey, d_tag), so this bounds member count, not history.
|
|
limit: 500,
|
|
),
|
|
);
|
|
return unionCustomEmoji(events);
|
|
} catch (_) {
|
|
return [];
|
|
}
|
|
}
|
|
|
|
/// Force a re-fetch of the community palette.
|
|
Future<void> refresh() async {
|
|
state = const AsyncValue.loading();
|
|
state = await AsyncValue.guard(_fetch);
|
|
}
|
|
}
|
|
|
|
final customEmojiPaletteProvider =
|
|
AsyncNotifierProvider<CustomEmojiPaletteNotifier, List<CustomEmoji>>(
|
|
CustomEmojiPaletteNotifier.new,
|
|
);
|
|
|
|
/// Synchronous read of the current palette (empty while loading/error).
|
|
/// Convenience for widgets that only need the resolved list, not the async
|
|
/// state — renderer, autocomplete, reaction resolution.
|
|
final customEmojiListProvider = Provider<List<CustomEmoji>>((ref) {
|
|
return ref.watch(customEmojiPaletteProvider).value ?? const [];
|
|
});
|