diff --git a/lib/src/core/moderation/moderation.dart b/lib/src/core/moderation/moderation.dart
--- a/lib/src/core/moderation/moderation.dart
+++ b/lib/src/core/moderation/moderation.dart
@@ -1,5 +1,6 @@
 export 'moderation_definitions.dart';
 export 'moderation_engine.dart';
+export 'moderation_label_events.dart';
 export 'moderation_label_localizations.dart';
 export 'moderation_models.dart';
 export 'moderation_presentation.dart';
diff --git a/lib/src/core/moderation/moderation_engine.dart b/lib/src/core/moderation/moderation_engine.dart
--- a/lib/src/core/moderation/moderation_engine.dart
+++ b/lib/src/core/moderation/moderation_engine.dart
@@ -1,5 +1,6 @@
 import 'package:poptart_lex/com/atproto/label/defs.dart';
 import 'package:spark/src/core/moderation/moderation_definitions.dart';
+import 'package:spark/src/core/moderation/moderation_label_events.dart';
 import 'package:spark/src/core/moderation/moderation_models.dart';
 
 final class ModerationEngine {
@@ -28,8 +29,7 @@
     final causes = <ModerationCause>[];
 
     for (final label in labels) {
-      if (label.neg ?? false) continue;
-      if (label.exp?.toUtc().isAfter(evaluationTime) == false) continue;
+      if (!isLabelActiveAt(label, now: evaluationTime)) continue;
 
       final isSelfLabel = subjectDid != null && label.src == subjectDid;
       final definition = isSelfLabel
diff --git a/lib/src/core/moderation/moderation_label_events.dart b/lib/src/core/moderation/moderation_label_events.dart
new file mode 100644
--- /dev/null
+++ b/lib/src/core/moderation/moderation_label_events.dart
@@ -0,0 +1,46 @@
+import 'package:poptart_lex/com/atproto/label/defs.dart';
+
+/// Merges label event streams to the latest event for each label identity.
+List<Label> mergeLatestLabelEvents({
+  required Iterable<Label> existing,
+  required Iterable<Label> incoming,
+  required DateTime now,
+}) {
+  final evaluationTime = now.toUtc();
+  final latestByIdentity = <({String src, String uri, String val}), Label>{};
+  for (final event in existing.followedBy(incoming)) {
+    final identity = (src: event.src, uri: event.uri, val: event.val);
+    final current = latestByIdentity[identity];
+    if (current == null ||
+        _labelShouldReplace(event, current, evaluationTime)) {
+      latestByIdentity[identity] = event;
+    }
+  }
+  return latestByIdentity.values.toList(growable: false);
+}
+
+/// Selects asserted, unexpired labels from a reconciled event snapshot.
+List<Label> activeLabelsFromEvents(
+  Iterable<Label> events, {
+  required DateTime now,
+}) {
+  final evaluationTime = now.toUtc();
+  return events
+      .where((label) => isLabelActiveAt(label, now: evaluationTime))
+      .toList(growable: false);
+}
+
+/// Whether a label assertion applies at [now].
+bool isLabelActiveAt(Label label, {required DateTime now}) {
+  final evaluationTime = now.toUtc();
+  return !label.isNeg && (label.exp?.toUtc().isAfter(evaluationTime) ?? true);
+}
+
+bool _labelShouldReplace(Label candidate, Label existing, DateTime now) {
+  final comparison = candidate.cts.toUtc().compareTo(existing.cts.toUtc());
+  if (comparison != 0) return comparison > 0;
+
+  final candidateInactive = !isLabelActiveAt(candidate, now: now);
+  final existingInactive = !isLabelActiveAt(existing, now: now);
+  return candidateInactive || !existingInactive;
+}
diff --git a/test/src/core/moderation/moderation_label_events_test.dart b/test/src/core/moderation/moderation_label_events_test.dart
new file mode 100644
--- /dev/null
+++ b/test/src/core/moderation/moderation_label_events_test.dart
@@ -0,0 +1,96 @@
+import 'package:flutter_test/flutter_test.dart';
+import 'package:poptart_lex/com/atproto/label/defs.dart';
+import 'package:spark/src/core/moderation/moderation_label_events.dart';
+
+void main() {
+  final now = DateTime.utc(2026, 8, 20, 12);
+
+  Label label({
+    required String value,
+    required DateTime createdAt,
+    String source = 'did:plc:moderator',
+    String uri = 'at://did:plc:author/app.bsky.feed.post/record',
+    bool? negated,
+    DateTime? expiresAt,
+  }) {
+    return Label(
+      src: source,
+      uri: uri,
+      val: value,
+      neg: negated,
+      cts: createdAt,
+      exp: expiresAt,
+    );
+  }
+
+  group('mergeLatestLabelEvents', () {
+    test('reconciles each identity while preserving identity order', () {
+      final original = label(
+        value: 'sexual',
+        createdAt: now.subtract(const Duration(minutes: 3)),
+      );
+      final otherValue = label(
+        value: 'gore',
+        createdAt: now.subtract(const Duration(minutes: 2)),
+      );
+      final replacement = label(
+        value: 'sexual',
+        createdAt: now.subtract(const Duration(minutes: 1)),
+      );
+      final otherSource = label(
+        value: 'sexual',
+        source: 'did:plc:other-moderator',
+        createdAt: now,
+      );
+
+      final result = mergeLatestLabelEvents(
+        existing: [original, otherValue],
+        incoming: [replacement, otherSource],
+        now: now,
+      );
+
+      expect(result, [replacement, otherValue, otherSource]);
+    });
+
+    test('keeps an inactive event over an equal-time assertion', () {
+      final assertion = label(value: 'sexual', createdAt: now);
+      final negation = label(value: 'sexual', createdAt: now, negated: true);
+
+      expect(
+        mergeLatestLabelEvents(
+          existing: [assertion],
+          incoming: [negation],
+          now: now,
+        ),
+        [negation],
+      );
+      expect(
+        mergeLatestLabelEvents(
+          existing: [negation],
+          incoming: [assertion],
+          now: now,
+        ),
+        [negation],
+      );
+    });
+  });
+
+  group('label activity', () {
+    test('uses one negation and expiry boundary', () {
+      final active = label(
+        value: 'active',
+        createdAt: now,
+        expiresAt: now.add(const Duration(seconds: 1)),
+      );
+      final negated = label(value: 'negated', createdAt: now, negated: true);
+      final expired = label(value: 'expired', createdAt: now, expiresAt: now);
+
+      expect(isLabelActiveAt(active, now: now), isTrue);
+      expect(isLabelActiveAt(negated, now: now), isFalse);
+      expect(isLabelActiveAt(expired, now: now), isFalse);
+      expect(activeLabelsFromEvents([active, negated, expired], now: now), [
+        active,
+      ]);
+    });
+  });
+}
diff --git a/lib/src/features/feed/providers/feed_provider.dart b/lib/src/features/feed/providers/feed_provider.dart
--- a/lib/src/features/feed/providers/feed_provider.dart
+++ b/lib/src/features/feed/providers/feed_provider.dart
@@ -236,30 +236,12 @@
           }
         }
 
-        final latestLabels = <Label>[...?extraInfo[post.uri]?.postLabels];
-        for (final incoming in incomingLabels) {
-          final existingIndex = latestLabels.indexWhere(
-            (label) =>
-                label.src == incoming.src &&
-                label.uri == incoming.uri &&
-                label.val == incoming.val,
-          );
-          if (existingIndex == -1) {
-            latestLabels.add(incoming);
-          } else if (_labelShouldReplace(
-            incoming,
-            latestLabels[existingIndex],
-            now,
-          )) {
-            latestLabels[existingIndex] = incoming;
-          }
-        }
-        final activeLabels = latestLabels
-            .where(
-              (label) =>
-                  !label.isNeg && (label.exp?.toUtc().isAfter(now) ?? true),
-            )
-            .toList();
+        final latestLabels = mergeLatestLabelEvents(
+          existing: extraInfo[post.uri]?.postLabels ?? const [],
+          incoming: incomingLabels,
+          now: now,
+        );
+        final activeLabels = activeLabelsFromEvents(latestLabels, now: now);
         extraInfo[post.uri] = (postLabels: latestLabels);
         postsWithMergedLabels.add(post.copyWith(labels: activeLabels));
       }
@@ -579,15 +561,4 @@
       return posts;
     }
   }
-}
-
-bool _labelShouldReplace(Label candidate, Label existing, DateTime now) {
-  final comparison = candidate.cts.toUtc().compareTo(existing.cts.toUtc());
-  if (comparison != 0) return comparison > 0;
-
-  final candidateInactive =
-      candidate.isNeg || candidate.exp?.toUtc().isAfter(now) == false;
-  final existingInactive =
-      existing.isNeg || existing.exp?.toUtc().isAfter(now) == false;
-  return candidateInactive || !existingInactive;
 }
diff --git a/lib/src/core/network/atproto/data/repositories/story_repository_impl.dart b/lib/src/core/network/atproto/data/repositories/story_repository_impl.dart
--- a/lib/src/core/network/atproto/data/repositories/story_repository_impl.dart
+++ b/lib/src/core/network/atproto/data/repositories/story_repository_impl.dart
@@ -3,6 +3,7 @@
     as repo_list_records;
 import 'package:poptart_lex/com/atproto/repo/strong_ref.dart';
 import 'package:poptart/poptart.dart';
+import 'package:spark/src/core/moderation/moderation_label_events.dart';
 import 'package:spark/src/core/network/atproto/data/models/feed_models.dart';
 import 'package:spark/src/core/network/atproto/data/models/models.dart';
 import 'package:spark/src/core/network/atproto/data/models/moderated_story_view.dart';
@@ -262,9 +263,15 @@
     Map<String, List<Label>> labelsByUri,
     StoryView story,
   ) {
-    return (labelsByUri[story.uri.toString()] ?? const []).where(
-      (label) => label.cid == null || label.cid == story.cid,
+    final now = _now().toUtc();
+    final latest = mergeLatestLabelEvents(
+      existing: const [],
+      incoming: (labelsByUri[story.uri.toString()] ?? const []).where(
+        (label) => label.cid == null || label.cid == story.cid,
+      ),
+      now: now,
     );
+    return activeLabelsFromEvents(latest, now: now);
   }
 
   @override
diff --git a/test/src/core/network/atproto/data/repositories/story_repository_impl_test.dart b/test/src/core/network/atproto/data/repositories/story_repository_impl_test.dart
--- a/test/src/core/network/atproto/data/repositories/story_repository_impl_test.dart
+++ b/test/src/core/network/atproto/data/repositories/story_repository_impl_test.dart
@@ -113,6 +113,81 @@
       },
     );
 
+    test(
+      'getStoryViews reconciles paged negations and newer assertions',
+      () async {
+        final story = StoryView(
+          uri: AtUri('at://did:plc:author/so.sprk.story.post/story'),
+          cid: 'story-cid',
+          author: const ProfileViewBasic(
+            did: 'did:plc:author',
+            handle: 'author.sprk.so',
+          ),
+          record: const <String, dynamic>{},
+          indexedAt: fixedNow,
+        );
+        Label label(String value, Duration age, {bool? neg, String? cid}) =>
+            Label(
+              src: 'did:plc:moderator',
+              uri: story.uri.toString(),
+              cid: cid ?? story.cid,
+              val: value,
+              neg: neg,
+              cts: fixedNow.subtract(age),
+            );
+
+        final sexualAssertion = label('sexual', const Duration(minutes: 3));
+        final sexualNegation = label(
+          'sexual',
+          const Duration(minutes: 2),
+          neg: true,
+        );
+        final staleSexualAssertion = label(
+          'sexual',
+          const Duration(minutes: 4),
+        );
+        final goreAssertion = label('gore', const Duration(minutes: 3));
+        final goreNegation = label(
+          'gore',
+          const Duration(minutes: 2),
+          neg: true,
+        );
+        final reappliedGore = label('gore', const Duration(minutes: 1));
+        final oldVersionGore = label(
+          'gore',
+          Duration.zero,
+          cid: 'old-story-cid',
+        );
+        final feed = _LabelFeedRepository([
+          (labels: [sexualAssertion, goreAssertion], cursor: 'negations'),
+          (labels: [sexualNegation, goreNegation], cursor: 'updates'),
+          (
+            labels: [staleSexualAssertion, reappliedGore, oldVersionGore],
+            cursor: null,
+          ),
+        ]);
+        final harness = RepositoryHarness(
+          getResponse: {
+            'stories': [story.toJson()],
+          },
+          feedRepository: feed,
+        );
+        final repository = StoryRepositoryImpl(
+          harness.sprk,
+          now: () => fixedNow,
+        );
+
+        final result = await repository.getStoryViews([story.uri]);
+
+        expect(result.single.moderationLabels, [reappliedGore]);
+        expect(feed.calls.map((call) => call.cursor), [
+          null,
+          'negations',
+          'updates',
+        ]);
+      },
+    );
+
     test('listStoryRecords owns record paging parameters', () async {
       final harness = RepositoryHarness(
         getResponse: const {'records': <dynamic>[], 'cursor': 'next-page'},