diff --git a/android/app/build.gradle b/android/app/build.gradle
index 87c532b9d3..f360f667e5 100644
--- a/android/app/build.gradle
+++ b/android/app/build.gradle
@@ -27,13 +27,6 @@ android {
     compileOptions {
         sourceCompatibility JavaVersion.VERSION_1_8
         targetCompatibility JavaVersion.VERSION_1_8
-
-        // The use of desugar_jdk_libs causes warning noise at build time:
-        //   https://github.com/zulip/zulip-flutter/pull/887#issuecomment-2287653388
-        //   https://issuetracker.google.com/issues/294273986
-        // TODO(#351): Try removing core-library desugaring once we've
-        //   removed flutter_local_notifications.
-        coreLibraryDesugaringEnabled true
     }
 
     kotlinOptions {
@@ -103,5 +96,4 @@ flutter {
 
 dependencies {
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlinVersion"
-    coreLibraryDesugaring "com.android.tools:desugar_jdk_libs:2.0.4"
 }
diff --git a/android/app/src/main/kotlin/com/zulip/flutter/Notifications.g.kt b/android/app/src/main/kotlin/com/zulip/flutter/Notifications.g.kt
index 5b64bead48..490c367beb 100644
--- a/android/app/src/main/kotlin/com/zulip/flutter/Notifications.g.kt
+++ b/android/app/src/main/kotlin/com/zulip/flutter/Notifications.g.kt
@@ -87,6 +87,40 @@ data class NotificationChannel (
   }
 }
 
+/**
+ * Corresponds to `android.content.Intent`
+ *
+ * See:
+ *   https://developer.android.com/reference/android/content/Intent
+ *   https://developer.android.com/reference/android/content/Intent#Intent(java.lang.String,%20android.net.Uri,%20android.content.Context,%20java.lang.Class%3C?%3E)
+ *
+ * Generated class from Pigeon that represents data sent in messages.
+ */
+data class AndroidIntent (
+  val action: String,
+  val dataUrl: String,
+  /** A combination of flags from [IntentFlag]. */
+  val flags: Long
+
+) {
+  companion object {
+    @Suppress("LocalVariableName")
+    fun fromList(__pigeon_list: List<Any?>): AndroidIntent {
+      val action = __pigeon_list[0] as String
+      val dataUrl = __pigeon_list[1] as String
+      val flags = __pigeon_list[2].let { num -> if (num is Int) num.toLong() else num as Long }
+      return AndroidIntent(action, dataUrl, flags)
+    }
+  }
+  fun toList(): List<Any?> {
+    return listOf(
+      action,
+      dataUrl,
+      flags,
+    )
+  }
+}
+
 /**
  * Corresponds to `android.app.PendingIntent`.
  *
@@ -96,11 +130,7 @@ data class NotificationChannel (
  */
 data class PendingIntent (
   val requestCode: Long,
-  /**
-   * A value set on an extra on the Intent, and passed to
-   * the on-notification-opened callback.
-   */
-  val intentPayload: String,
+  val intent: AndroidIntent,
   /**
    * A combination of flags from [PendingIntent.flags], and others associated
    * with `Intent`; see Android docs for `PendingIntent.getActivity`.
@@ -112,15 +142,15 @@ data class PendingIntent (
     @Suppress("LocalVariableName")
     fun fromList(__pigeon_list: List<Any?>): PendingIntent {
       val requestCode = __pigeon_list[0].let { num -> if (num is Int) num.toLong() else num as Long }
-      val intentPayload = __pigeon_list[1] as String
+      val intent = __pigeon_list[1] as AndroidIntent
       val flags = __pigeon_list[2].let { num -> if (num is Int) num.toLong() else num as Long }
-      return PendingIntent(requestCode, intentPayload, flags)
+      return PendingIntent(requestCode, intent, flags)
     }
   }
   fun toList(): List<Any?> {
     return listOf(
       requestCode,
-      intentPayload,
+      intent,
       flags,
     )
   }
@@ -325,35 +355,40 @@ private object NotificationsPigeonCodec : StandardMessageCodec() {
       }
       130.toByte() -> {
         return (readValue(buffer) as? List<Any?>)?.let {
-          PendingIntent.fromList(it)
+          AndroidIntent.fromList(it)
         }
       }
       131.toByte() -> {
         return (readValue(buffer) as? List<Any?>)?.let {
-          InboxStyle.fromList(it)
+          PendingIntent.fromList(it)
         }
       }
       132.toByte() -> {
         return (readValue(buffer) as? List<Any?>)?.let {
-          Person.fromList(it)
+          InboxStyle.fromList(it)
         }
       }
       133.toByte() -> {
         return (readValue(buffer) as? List<Any?>)?.let {
-          MessagingStyleMessage.fromList(it)
+          Person.fromList(it)
         }
       }
       134.toByte() -> {
         return (readValue(buffer) as? List<Any?>)?.let {
-          MessagingStyle.fromList(it)
+          MessagingStyleMessage.fromList(it)
         }
       }
       135.toByte() -> {
         return (readValue(buffer) as? List<Any?>)?.let {
-          Notification.fromList(it)
+          MessagingStyle.fromList(it)
         }
       }
       136.toByte() -> {
+        return (readValue(buffer) as? List<Any?>)?.let {
+          Notification.fromList(it)
+        }
+      }
+      137.toByte() -> {
         return (readValue(buffer) as? List<Any?>)?.let {
           StatusBarNotification.fromList(it)
         }
@@ -367,34 +402,38 @@ private object NotificationsPigeonCodec : StandardMessageCodec() {
         stream.write(129)
         writeValue(stream, value.toList())
       }
-      is PendingIntent -> {
+      is AndroidIntent -> {
         stream.write(130)
         writeValue(stream, value.toList())
       }
-      is InboxStyle -> {
+      is PendingIntent -> {
         stream.write(131)
         writeValue(stream, value.toList())
       }
-      is Person -> {
+      is InboxStyle -> {
         stream.write(132)
         writeValue(stream, value.toList())
       }
-      is MessagingStyleMessage -> {
+      is Person -> {
         stream.write(133)
         writeValue(stream, value.toList())
       }
-      is MessagingStyle -> {
+      is MessagingStyleMessage -> {
         stream.write(134)
         writeValue(stream, value.toList())
       }
-      is Notification -> {
+      is MessagingStyle -> {
         stream.write(135)
         writeValue(stream, value.toList())
       }
-      is StatusBarNotification -> {
+      is Notification -> {
         stream.write(136)
         writeValue(stream, value.toList())
       }
+      is StatusBarNotification -> {
+        stream.write(137)
+        writeValue(stream, value.toList())
+      }
       else -> super.writeValue(stream, value)
     }
   }
diff --git a/android/app/src/main/kotlin/com/zulip/flutter/ZulipPlugin.kt b/android/app/src/main/kotlin/com/zulip/flutter/ZulipPlugin.kt
index 4146e26e36..c0104153f4 100644
--- a/android/app/src/main/kotlin/com/zulip/flutter/ZulipPlugin.kt
+++ b/android/app/src/main/kotlin/com/zulip/flutter/ZulipPlugin.kt
@@ -3,6 +3,7 @@ package com.zulip.flutter
 import android.annotation.SuppressLint
 import android.content.Context
 import android.content.Intent
+import android.net.Uri
 import android.os.Bundle
 import android.util.Log
 import androidx.annotation.Keep
@@ -97,13 +98,14 @@ private class AndroidNotificationHost(val context: Context)
             contentIntent?.let { setContentIntent(
                 android.app.PendingIntent.getActivity(context,
                     it.requestCode.toInt(),
-                    Intent(context, MainActivity::class.java).apply {
-                        // This action name and extra name are special to
-                        // FlutterLocalNotificationsPlugin, which handles receiving the Intent.
-                        // TODO take care of receiving the notification-opened Intent ourselves
-                        action = "SELECT_NOTIFICATION"
-                        putExtra("payload", it.intentPayload)
-                    },
+                    it.intent.let { intent -> Intent(
+                        intent.action,
+                        Uri.parse(intent.dataUrl),
+                        context,
+                        MainActivity::class.java
+                    ).apply {
+                        flags = intent.flags.toInt()
+                    } },
                     it.flags.toInt())
             ) }
             contentText?.let { setContentText(it) }
diff --git a/android/app/src/main/res/raw/keep.xml b/android/app/src/main/res/raw/keep.xml
index a88c32b2f7..2a75152d2e 100644
--- a/android/app/src/main/res/raw/keep.xml
+++ b/android/app/src/main/res/raw/keep.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <!-- This file is necessary for notifications to work in release builds.
 
-     The issue is that the package:flutter_local_notifications API has us
+     The issue is that the Pigeon bindings for notifications API has us
      identify which icon we want to use via a string name, in Dart code,
      and that's invisible to the resource shrinker:
        https://developer.android.com/build/shrink-code#keep-resources
diff --git a/assets/l10n/app_en.arb b/assets/l10n/app_en.arb
index 0ae6984e41..aea0c83d38 100644
--- a/assets/l10n/app_en.arb
+++ b/assets/l10n/app_en.arb
@@ -558,5 +558,13 @@
   "pollWidgetOptionsMissing": "This poll has no options yet.",
   "@pollWidgetOptionsMissing": {
     "description": "Text to display for a poll when it has no options"
+  },
+  "errorNotificationOpenTitle": "Failed to open notification",
+  "@errorNotificationOpenTitle": {
+    "description": "Error title when notification opening fails"
+  },
+  "errorNotificationOpenAccountMissing": "The account associated with this notification no longer exists.",
+  "@errorNotificationOpenAccountMissing": {
+    "description": "Error message when the account associated with the notification is not found"
   }
 }
diff --git a/ios/Podfile.lock b/ios/Podfile.lock
index 2e6b2ba73e..451100d4b7 100644
--- a/ios/Podfile.lock
+++ b/ios/Podfile.lock
@@ -70,8 +70,6 @@ PODS:
     - GoogleUtilities/UserDefaults (~> 7.8)
     - nanopb (< 2.30911.0, >= 2.30908.0)
   - Flutter (1.0.0)
-  - flutter_local_notifications (0.0.1):
-    - Flutter
   - GoogleDataTransport (9.4.1):
     - GoogleUtilities/Environment (~> 7.7)
     - nanopb (< 2.30911.0, >= 2.30908.0)
@@ -155,7 +153,6 @@ DEPENDENCIES:
   - firebase_core (from `.symlinks/plugins/firebase_core/ios`)
   - firebase_messaging (from `.symlinks/plugins/firebase_messaging/ios`)
   - Flutter (from `Flutter`)
-  - flutter_local_notifications (from `.symlinks/plugins/flutter_local_notifications/ios`)
   - image_picker_ios (from `.symlinks/plugins/image_picker_ios/ios`)
   - integration_test (from `.symlinks/plugins/integration_test/ios`)
   - package_info_plus (from `.symlinks/plugins/package_info_plus/ios`)
@@ -196,8 +193,6 @@ EXTERNAL SOURCES:
     :path: ".symlinks/plugins/firebase_messaging/ios"
   Flutter:
     :path: Flutter
-  flutter_local_notifications:
-    :path: ".symlinks/plugins/flutter_local_notifications/ios"
   image_picker_ios:
     :path: ".symlinks/plugins/image_picker_ios/ios"
   integration_test:
@@ -231,7 +226,6 @@ SPEC CHECKSUMS:
   FirebaseInstallations: 913cf60d0400ebd5d6b63a28b290372ab44590dd
   FirebaseMessaging: 7b5d8033e183ab59eb5b852a53201559e976d366
   Flutter: e0871f40cf51350855a761d2e70bf5af5b9b5de7
-  flutter_local_notifications: 4cde75091f6327eb8517fa068a0a5950212d2086
   GoogleDataTransport: 6c09b596d841063d76d4288cc2d2f42cc36e1e2a
   GoogleUtilities: ea963c370a38a8069cc5f7ba4ca849a60b6d7d15
   image_picker_ios: c560581cceedb403a6ff17f2f816d7fea1421fc1
diff --git a/lib/api/notifications.dart b/lib/api/notifications.dart
index 0717f5afe9..2337c0456e 100644
--- a/lib/api/notifications.dart
+++ b/lib/api/notifications.dart
@@ -64,7 +64,8 @@ sealed class FcmMessageWithIdentity extends FcmMessage {
   ///
   /// This is a real, absolute URL which is the base for all URLs a client uses
   /// with this realm.  It corresponds to [GetServerSettingsResult.realmUri].
-  final Uri realmUri;
+  @JsonKey(readValue: _readRealmUrl) // TODO(server-9)
+  final Uri realmUrl;
 
   /// This user's ID within the server.
   ///
@@ -75,9 +76,14 @@ sealed class FcmMessageWithIdentity extends FcmMessage {
   FcmMessageWithIdentity({
     required this.server,
     required this.realmId,
-    required this.realmUri,
+    required this.realmUrl,
     required this.userId,
   });
+
+  // TODO(server-9): FL 257 deprecated 'realm_uri' in favor of 'realm_url'.
+  static String _readRealmUrl(Map<dynamic, dynamic> json, String key) {
+    return (json['realm_url'] ?? json['realm_uri']) as String;
+  }
 }
 
 /// Parsed version of an FCM message of type `message`.
@@ -117,7 +123,7 @@ class MessageFcmMessage extends FcmMessageWithIdentity {
   MessageFcmMessage({
     required super.server,
     required super.realmId,
-    required super.realmUri,
+    required super.realmUrl,
     required super.userId,
     required this.senderId,
     required this.senderAvatarUrl,
@@ -147,6 +153,7 @@ class MessageFcmMessage extends FcmMessageWithIdentity {
         if (recipient.streamName != null) result['stream'] = recipient.streamName;
         result['topic'] = recipient.topic;
     }
+    result['realm_uri'] = realmUrl.toString(); // TODO(server-9): deprecated in FL 257
     return result;
   }
 }
@@ -236,7 +243,7 @@ class RemoveFcmMessage extends FcmMessageWithIdentity {
   RemoveFcmMessage({
     required super.server,
     required super.realmId,
-    required super.realmUri,
+    required super.realmUrl,
     required super.userId,
     required this.zulipMessageIds,
   });
@@ -247,7 +254,11 @@ class RemoveFcmMessage extends FcmMessageWithIdentity {
   }
 
   @override
-  Map<String, dynamic> toJson() => _$RemoveFcmMessageToJson(this);
+  Map<String, dynamic> toJson() {
+    final result = _$RemoveFcmMessageToJson(this);
+    result['realm_uri'] = realmUrl.toString(); // TODO(server-9): deprecated in FL 257
+    return result;
+  }
 }
 
 class _IntListConverter extends JsonConverter<List<int>, String> {
diff --git a/lib/api/notifications.g.dart b/lib/api/notifications.g.dart
index 8dda549b90..4a9752a9af 100644
--- a/lib/api/notifications.g.dart
+++ b/lib/api/notifications.g.dart
@@ -12,7 +12,8 @@ MessageFcmMessage _$MessageFcmMessageFromJson(Map<String, dynamic> json) =>
     MessageFcmMessage(
       server: json['server'] as String,
       realmId: const _IntConverter().fromJson(json['realm_id'] as String),
-      realmUri: Uri.parse(json['realm_uri'] as String),
+      realmUrl: Uri.parse(
+          FcmMessageWithIdentity._readRealmUrl(json, 'realm_url') as String),
       userId: const _IntConverter().fromJson(json['user_id'] as String),
       senderId: const _IntConverter().fromJson(json['sender_id'] as String),
       senderAvatarUrl: Uri.parse(json['sender_avatar_url'] as String),
@@ -30,7 +31,7 @@ Map<String, dynamic> _$MessageFcmMessageToJson(MessageFcmMessage instance) =>
     <String, dynamic>{
       'server': instance.server,
       'realm_id': const _IntConverter().toJson(instance.realmId),
-      'realm_uri': instance.realmUri.toString(),
+      'realm_url': instance.realmUrl.toString(),
       'user_id': const _IntConverter().toJson(instance.userId),
       'event': instance.type,
       'sender_id': const _IntConverter().toJson(instance.senderId),
@@ -53,7 +54,8 @@ RemoveFcmMessage _$RemoveFcmMessageFromJson(Map<String, dynamic> json) =>
     RemoveFcmMessage(
       server: json['server'] as String,
       realmId: const _IntConverter().fromJson(json['realm_id'] as String),
-      realmUri: Uri.parse(json['realm_uri'] as String),
+      realmUrl: Uri.parse(
+          FcmMessageWithIdentity._readRealmUrl(json, 'realm_url') as String),
       userId: const _IntConverter().fromJson(json['user_id'] as String),
       zulipMessageIds: const _IntListConverter()
           .fromJson(json['zulip_message_ids'] as String),
@@ -63,7 +65,7 @@ Map<String, dynamic> _$RemoveFcmMessageToJson(RemoveFcmMessage instance) =>
     <String, dynamic>{
       'server': instance.server,
       'realm_id': const _IntConverter().toJson(instance.realmId),
-      'realm_uri': instance.realmUri.toString(),
+      'realm_url': instance.realmUrl.toString(),
       'user_id': const _IntConverter().toJson(instance.userId),
       'event': instance.type,
       'zulip_message_ids':
diff --git a/lib/host/android_notifications.dart b/lib/host/android_notifications.dart
index e7b998de18..a06b0b137d 100644
--- a/lib/host/android_notifications.dart
+++ b/lib/host/android_notifications.dart
@@ -60,3 +60,22 @@ abstract class PendingIntentFlag {
   /// Corresponds to `FLAG_ALLOW_UNSAFE_IMPLICIT_INTENT`.
   static const allowUnsafeImplicitIntent = 1 << 24;
 }
+
+/// For use in [AndroidIntent.action].
+///
+/// See: https://developer.android.com/reference/android/content/Intent#constants_1
+abstract class IntentAction {
+  /// Corresponds to `ACTION_VIEW`.
+  static const view = 'android.intent.action.VIEW';
+}
+
+/// For use in [AndroidIntent.flags].
+///
+/// See: https://developer.android.com/reference/android/content/Intent#FLAG_ACTIVITY_BROUGHT_TO_FRONT
+abstract class IntentFlag {
+  /// Corresponds to `FLAG_ACTIVITY_CLEAR_TOP`.
+  static const activityClearTop = 1 << 26;
+
+  /// Corresponds to `FLAG_ACTIVITY_NEW_TASK`.
+  static const activityNewTask = 1 << 28;
+}
diff --git a/lib/host/android_notifications.g.dart b/lib/host/android_notifications.g.dart
index 6ed36ffda1..ed3800ce69 100644
--- a/lib/host/android_notifications.g.dart
+++ b/lib/host/android_notifications.g.dart
@@ -63,21 +63,56 @@ class NotificationChannel {
   }
 }
 
+/// Corresponds to `android.content.Intent`
+///
+/// See:
+///   https://developer.android.com/reference/android/content/Intent
+///   https://developer.android.com/reference/android/content/Intent#Intent(java.lang.String,%20android.net.Uri,%20android.content.Context,%20java.lang.Class%3C?%3E)
+class AndroidIntent {
+  AndroidIntent({
+    required this.action,
+    required this.dataUrl,
+    this.flags = 0,
+  });
+
+  String action;
+
+  String dataUrl;
+
+  /// A combination of flags from [IntentFlag].
+  int flags;
+
+  Object encode() {
+    return <Object?>[
+      action,
+      dataUrl,
+      flags,
+    ];
+  }
+
+  static AndroidIntent decode(Object result) {
+    result as List<Object?>;
+    return AndroidIntent(
+      action: result[0]! as String,
+      dataUrl: result[1]! as String,
+      flags: result[2]! as int,
+    );
+  }
+}
+
 /// Corresponds to `android.app.PendingIntent`.
 ///
 /// See: https://developer.android.com/reference/android/app/PendingIntent
 class PendingIntent {
   PendingIntent({
     required this.requestCode,
-    required this.intentPayload,
+    required this.intent,
     required this.flags,
   });
 
   int requestCode;
 
-  /// A value set on an extra on the Intent, and passed to
-  /// the on-notification-opened callback.
-  String intentPayload;
+  AndroidIntent intent;
 
   /// A combination of flags from [PendingIntent.flags], and others associated
   /// with `Intent`; see Android docs for `PendingIntent.getActivity`.
@@ -86,7 +121,7 @@ class PendingIntent {
   Object encode() {
     return <Object?>[
       requestCode,
-      intentPayload,
+      intent,
       flags,
     ];
   }
@@ -95,7 +130,7 @@ class PendingIntent {
     result as List<Object?>;
     return PendingIntent(
       requestCode: result[0]! as int,
-      intentPayload: result[1]! as String,
+      intent: result[1]! as AndroidIntent,
       flags: result[2]! as int,
     );
   }
@@ -311,27 +346,30 @@ class _PigeonCodec extends StandardMessageCodec {
     if (value is NotificationChannel) {
       buffer.putUint8(129);
       writeValue(buffer, value.encode());
-    } else     if (value is PendingIntent) {
+    } else     if (value is AndroidIntent) {
       buffer.putUint8(130);
       writeValue(buffer, value.encode());
-    } else     if (value is InboxStyle) {
+    } else     if (value is PendingIntent) {
       buffer.putUint8(131);
       writeValue(buffer, value.encode());
-    } else     if (value is Person) {
+    } else     if (value is InboxStyle) {
       buffer.putUint8(132);
       writeValue(buffer, value.encode());
-    } else     if (value is MessagingStyleMessage) {
+    } else     if (value is Person) {
       buffer.putUint8(133);
       writeValue(buffer, value.encode());
-    } else     if (value is MessagingStyle) {
+    } else     if (value is MessagingStyleMessage) {
       buffer.putUint8(134);
       writeValue(buffer, value.encode());
-    } else     if (value is Notification) {
+    } else     if (value is MessagingStyle) {
       buffer.putUint8(135);
       writeValue(buffer, value.encode());
-    } else     if (value is StatusBarNotification) {
+    } else     if (value is Notification) {
       buffer.putUint8(136);
       writeValue(buffer, value.encode());
+    } else     if (value is StatusBarNotification) {
+      buffer.putUint8(137);
+      writeValue(buffer, value.encode());
     } else {
       super.writeValue(buffer, value);
     }
@@ -343,18 +381,20 @@ class _PigeonCodec extends StandardMessageCodec {
       case 129: 
         return NotificationChannel.decode(readValue(buffer)!);
       case 130: 
-        return PendingIntent.decode(readValue(buffer)!);
+        return AndroidIntent.decode(readValue(buffer)!);
       case 131: 
-        return InboxStyle.decode(readValue(buffer)!);
+        return PendingIntent.decode(readValue(buffer)!);
       case 132: 
-        return Person.decode(readValue(buffer)!);
+        return InboxStyle.decode(readValue(buffer)!);
       case 133: 
-        return MessagingStyleMessage.decode(readValue(buffer)!);
+        return Person.decode(readValue(buffer)!);
       case 134: 
-        return MessagingStyle.decode(readValue(buffer)!);
+        return MessagingStyleMessage.decode(readValue(buffer)!);
       case 135: 
-        return Notification.decode(readValue(buffer)!);
+        return MessagingStyle.decode(readValue(buffer)!);
       case 136: 
+        return Notification.decode(readValue(buffer)!);
+      case 137: 
         return StatusBarNotification.decode(readValue(buffer)!);
       default:
         return super.readValueOfType(type, buffer);
diff --git a/lib/model/binding.dart b/lib/model/binding.dart
index 7f014e1a5a..bb49fe1334 100644
--- a/lib/model/binding.dart
+++ b/lib/model/binding.dart
@@ -5,7 +5,6 @@ import 'package:file_picker/file_picker.dart' as file_picker;
 import 'package:firebase_core/firebase_core.dart' as firebase_core;
 import 'package:firebase_messaging/firebase_messaging.dart' as firebase_messaging;
 import 'package:flutter/foundation.dart';
-import 'package:flutter_local_notifications/flutter_local_notifications.dart';
 import 'package:image_picker/image_picker.dart' as image_picker;
 import 'package:package_info_plus/package_info_plus.dart' as package_info_plus;
 import 'package:url_launcher/url_launcher.dart' as url_launcher;
@@ -161,9 +160,6 @@ abstract class ZulipBinding {
   /// Wraps [firebase_messaging.FirebaseMessaging.onBackgroundMessage].
   void firebaseMessagingOnBackgroundMessage(firebase_messaging.BackgroundMessageHandler handler);
 
-  /// Wraps the [FlutterLocalNotificationsPlugin] singleton constructor.
-  FlutterLocalNotificationsPlugin get notifications;
-
   /// Wraps the [AndroidNotificationHostApi] constructor.
   AndroidNotificationHostApi get androidNotificationHost;
 
@@ -435,9 +431,6 @@ class LiveZulipBinding extends ZulipBinding {
     firebase_messaging.FirebaseMessaging.onBackgroundMessage(handler);
   }
 
-  @override
-  FlutterLocalNotificationsPlugin get notifications => FlutterLocalNotificationsPlugin();
-
   @override
   AndroidNotificationHostApi get androidNotificationHost => AndroidNotificationHostApi();
 
diff --git a/lib/notifications/display.dart b/lib/notifications/display.dart
index 28fe5be646..64b183e6dd 100644
--- a/lib/notifications/display.dart
+++ b/lib/notifications/display.dart
@@ -1,13 +1,11 @@
 import 'dart:async';
-import 'dart:convert';
 import 'dart:io';
 
 import 'package:http/http.dart' as http;
 import 'package:collection/collection.dart';
-import 'package:crypto/crypto.dart';
+import 'package:flutter_gen/gen_l10n/zulip_localizations.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter/widgets.dart' hide Notification;
-import 'package:flutter_local_notifications/flutter_local_notifications.dart' hide Person;
 
 import '../api/notifications.dart';
 import '../host/android_notifications.dart';
@@ -17,6 +15,7 @@ import '../model/localizations.dart';
 import '../model/narrow.dart';
 import '../widgets/app.dart';
 import '../widgets/color.dart';
+import '../widgets/dialog.dart';
 import '../widgets/message_list.dart';
 import '../widgets/page.dart';
 import '../widgets/store.dart';
@@ -95,16 +94,6 @@ class NotificationChannelManager {
 /// Service for managing the notifications shown to the user.
 class NotificationDisplayManager {
   static Future<void> init() async {
-    await ZulipBinding.instance.notifications.initialize(
-      const InitializationSettings(
-        android: AndroidInitializationSettings('zulip_notification'),
-      ),
-      onDidReceiveNotificationResponse: _onNotificationOpened,
-    );
-    final launchDetails = await ZulipBinding.instance.notifications.getNotificationAppLaunchDetails();
-    if (launchDetails?.didNotificationLaunchApp ?? false) {
-      _handleNotificationAppLaunch(launchDetails!.notificationResponse);
-    }
     await NotificationChannelManager.ensureChannel();
   }
 
@@ -133,7 +122,7 @@ class NotificationDisplayManager {
     } else {
       messagingStyle = MessagingStyle(
         user: Person(
-          key: _personKey(data.realmUri, data.userId),
+          key: _personKey(data.realmUrl, data.userId),
           name: zulipLocalizations.notifSelfUser),
         messages: [],
         isGroupConversation: switch (data.recipient) {
@@ -164,14 +153,22 @@ class NotificationDisplayManager {
       text: data.content,
       timestampMs: data.time * 1000,
       person: Person(
-        key: _personKey(data.realmUri, data.senderId),
+        key: _personKey(data.realmUrl, data.senderId),
         name: data.senderFullName,
         iconBitmap: await _fetchBitmap(data.senderAvatarUrl))));
 
+    final intentDataUrl = NotificationOpenPayload(
+      realmUrl: data.realmUrl,
+      userId: data.userId,
+      narrow: switch (data.recipient) {
+        FcmMessageChannelRecipient(:var streamId, :var topic) =>
+          TopicNarrow(streamId, topic),
+        FcmMessageDmRecipient(:var allRecipientIds) =>
+          DmNarrow(allRecipientIds: allRecipientIds, selfUserId: data.userId),
+      }).buildUrl();
+
     await _androidHost.notify(
-      // TODO the notification ID can be constant, instead of matching requestCode
-      //   (This is a legacy of `flutter_local_notifications`.)
-      id: notificationIdAsHashOf(conversationKey),
+      id: kNotificationId,
       tag: conversationKey,
       channelId: NotificationChannelManager.kChannelId,
       groupKey: groupKey,
@@ -188,31 +185,33 @@ class NotificationDisplayManager {
       },
 
       contentIntent: PendingIntent(
-        // TODO make intent URLs distinct, instead of requestCode
-        //   (This way is a legacy of flutter_local_notifications.)
-        //   The Intent objects we make for different conversations look the same.
-        //   They differ in their extras, but that doesn't count:
-        //     https://developer.android.com/reference/android/app/PendingIntent
-        //
-        //   This leaves only PendingIntent.requestCode to distinguish one
-        //   PendingIntent from another; the plugin sets that to the notification ID.
-        //   We need a distinct PendingIntent for each conversation, so that the
-        //   notifications can lead to the right conversations when opened.
-        //   So, use a hash of the conversation key.
-        requestCode: notificationIdAsHashOf(conversationKey),
-
-        // TODO is setting PendingIntentFlag.updateCurrent OK?
-        //   (That's a legacy of `flutter_local_notifications`.)
-        flags: PendingIntentFlag.immutable | PendingIntentFlag.updateCurrent,
-        intentPayload: jsonEncode(dataJson),
-        // TODO this doesn't set the Intent flags we set in zulip-mobile; is that OK?
-        //   (This is a legacy of `flutter_local_notifications`.)
-        ),
+        // The intent data URL is distinct for each conversation, so this value
+        // doesn't matter.
+        requestCode: 0,
+        flags: PendingIntentFlag.immutable,
+        intent: AndroidIntent(
+          action: IntentAction.view,
+          dataUrl: intentDataUrl.toString(),
+          // See these sections in the Android docs:
+          //   https://developer.android.com/guide/components/activities/tasks-and-back-stack#TaskLaunchModes
+          //   https://developer.android.com/reference/android/content/Intent#FLAG_ACTIVITY_CLEAR_TOP
+          //
+          // * From the doc on `PendingIntent.getActivity` at
+          //     https://developer.android.com/reference/android/app/PendingIntent#getActivity(android.content.Context,%20int,%20android.content.Intent,%20int)
+          //   > Note that the activity will be started outside of the context of an
+          //   > existing activity, so you must use the Intent.FLAG_ACTIVITY_NEW_TASK
+          //   > launch flag in the Intent.
+          //
+          // * The flag FLAG_ACTIVITY_CLEAR_TOP is mentioned as being what the
+          //   notification manager does; so use that.  It has no effect as long
+          //   as we only have one activity; but if we add more, it will destroy
+          //   all the activities on top of the target one.
+          flags: IntentFlag.activityClearTop | IntentFlag.activityNewTask)),
       autoCancel: true,
     );
 
     await _androidHost.notify(
-      id: notificationIdAsHashOf(groupKey),
+      id: kNotificationId,
       tag: groupKey,
       channelId: NotificationChannelManager.kChannelId,
       groupKey: groupKey,
@@ -223,7 +222,7 @@ class NotificationDisplayManager {
       smallIconResourceName: 'zulip_notification', // This name must appear in keep.xml too: https://github.com/zulip/zulip-flutter/issues/528
       inboxStyle: InboxStyle(
         // TODO(#570) Show organization name, not URL
-        summaryText: data.realmUri.toString()),
+        summaryText: data.realmUrl.toString()),
 
       // On Android 11 and lower, if autoCancel is not specified,
       // the summary notification may linger even after all child
@@ -297,11 +296,18 @@ class NotificationDisplayManager {
       // Even though we enable the `autoCancel` flag for summary notification
       // during creation, the summary notification doesn't get auto canceled if
       // child notifications are canceled programatically as done above.
-      await _androidHost.cancel(
-        tag: groupKey, id: notificationIdAsHashOf(groupKey));
+      await _androidHost.cancel(tag: groupKey, id: kNotificationId);
     }
   }
 
+  /// The constant numeric "ID" we use for all non-test notifications,
+  /// along with unique tags.
+  ///
+  /// Because we construct a unique string "tag" for each distinct
+  /// notification, and Android notifications are identified by the
+  /// pair (tag, ID), it's simplest to leave these numeric IDs all the same.
+  static const kNotificationId = 0x00C0FFEE;
+
   /// A key we use in [Notification.extras] for the [Message.id] of the
   /// latest Zulip message in the notification's conversation.
   ///
@@ -310,21 +316,6 @@ class NotificationDisplayManager {
   @visibleForTesting
   static const kExtraLastZulipMessageId = 'lastZulipMessageId';
 
-  /// A notification ID, derived as a hash of the given string key.
-  ///
-  /// The result fits in 31 bits, the size of a nonnegative Java `int`,
-  /// so that it can be used as an Android notification ID.  (It's possible
-  /// negative values would work too, which would add one bit.)
-  ///
-  /// This is a cryptographic hash, meaning that collisions are about as
-  /// unlikely as one could hope for given the size of the hash.
-  @visibleForTesting
-  static int notificationIdAsHashOf(String key) {
-    final bytes = sha256.convert(utf8.encode(key)).bytes;
-    return bytes[0] | (bytes[1] << 8) | (bytes[2] << 16)
-      | ((bytes[3] & 0x7f) << 24);
-  }
-
   static String _conversationKey(MessageFcmMessage data, String groupKey) {
     final conversation = switch (data.recipient) {
       FcmMessageChannelRecipient(:var streamId, :var topic) => 'stream:$streamId:$topic',
@@ -336,51 +327,41 @@ class NotificationDisplayManager {
   static String _groupKey(FcmMessageWithIdentity data) {
     // The realm URL can't contain a `|`, because `|` is not a URL code point:
     //   https://url.spec.whatwg.org/#url-code-points
-    return "${data.realmUri}|${data.userId}";
+    return "${data.realmUrl}|${data.userId}";
   }
 
-  static String _personKey(Uri realmUri, int userId) => "$realmUri|$userId";
+  static String _personKey(Uri realmUrl, int userId) => "$realmUrl|$userId";
 
-  static void _onNotificationOpened(NotificationResponse response) async {
-    final payload = jsonDecode(response.payload!) as Map<String, dynamic>;
-    final data = MessageFcmMessage.fromJson(payload);
-    assert(debugLog('opened notif: message ${data.zulipMessageId}, content ${data.content}'));
-    _navigateForNotification(data);
-  }
+  /// Navigates to the [MessageListPage] of the specific conversation
+  /// given the `zulip://notification/…` Android intent data URL,
+  /// generated with [NotificationOpenPayload.buildUrl] while creating
+  /// the notification.
+  static Future<void> navigateForNotification(Uri url) async {
+    assert(debugLog('opened notif: url: $url'));
 
-  static void _handleNotificationAppLaunch(NotificationResponse? response) async {
-    assert(response != null);
-    if (response == null) return; // TODO(log) seems like a bug in flutter_local_notifications if this can happen
+    assert(url.scheme == 'zulip' && url.host == 'notification');
+    final payload = NotificationOpenPayload.parseUrl(url);
 
-    final payload = jsonDecode(response.payload!) as Map<String, dynamic>;
-    final data = MessageFcmMessage.fromJson(payload);
-    assert(debugLog('launched from notif: message ${data.zulipMessageId}, content ${data.content}'));
-    _navigateForNotification(data);
-  }
-
-  static void _navigateForNotification(MessageFcmMessage data) async {
     NavigatorState navigator = await ZulipApp.navigator;
     final context = navigator.context;
     assert(context.mounted);
     if (!context.mounted) return; // TODO(linter): this is impossible as there's no actual async gap, but the use_build_context_synchronously lint doesn't see that
 
+    final zulipLocalizations = ZulipLocalizations.of(context);
     final globalStore = GlobalStoreWidget.of(context);
     final account = globalStore.accounts.firstWhereOrNull((account) =>
-      account.realmUrl == data.realmUri && account.userId == data.userId);
-    if (account == null) return; // TODO(log)
-
-    final narrow = switch (data.recipient) {
-      FcmMessageChannelRecipient(:var streamId, :var topic) =>
-        TopicNarrow(streamId, topic),
-      FcmMessageDmRecipient(:var allRecipientIds) =>
-        DmNarrow(allRecipientIds: allRecipientIds, selfUserId: account.userId),
-    };
+      account.realmUrl == payload.realmUrl && account.userId == payload.userId);
+    if (account == null) { // TODO(log)
+      showErrorDialog(context: context,
+        title: zulipLocalizations.errorNotificationOpenTitle,
+        message: zulipLocalizations.errorNotificationOpenAccountMissing);
+      return;
+    }
 
-    assert(debugLog('  account: $account, narrow: $narrow'));
     // TODO(nav): Better interact with existing nav stack on notif open
     unawaited(navigator.push(MaterialAccountWidgetRoute<void>(accountId: account.id,
       // TODO(#82): Open at specific message, not just conversation
-      page: MessageListPage(initNarrow: narrow))));
+      page: MessageListPage(initNarrow: payload.narrow))));
   }
 
   static Future<Uint8List?> _fetchBitmap(Uri url) async {
@@ -396,3 +377,86 @@ class NotificationDisplayManager {
     return null;
   }
 }
+
+/// The information contained in 'zulip://notification/…' internal
+/// Android intent data URL, used for notification-open flow.
+class NotificationOpenPayload {
+  final Uri realmUrl;
+  final int userId;
+  final Narrow narrow;
+
+  NotificationOpenPayload({
+    required this.realmUrl,
+    required this.userId,
+    required this.narrow,
+  });
+
+  factory NotificationOpenPayload.parseUrl(Uri url) {
+    if (url case Uri(
+      scheme: 'zulip',
+      host: 'notification',
+      queryParameters: {
+        'realm_url': var realmUrlStr,
+        'user_id': var userIdStr,
+        'narrow_type': var narrowType,
+        // In case of narrowType == 'topic':
+        // 'channel_id' and 'topic' handled below.
+
+        // In case of narrowType == 'dm':
+        // 'all_recipient_ids' handled below.
+      },
+    )) {
+      final realmUrl = Uri.parse(realmUrlStr);
+      final userId = int.parse(userIdStr, radix: 10);
+
+      final Narrow narrow;
+      switch (narrowType) {
+        case 'topic':
+          final channelIdStr = url.queryParameters['channel_id']!;
+          final channelId = int.parse(channelIdStr, radix: 10);
+          final topic = url.queryParameters['topic']!;
+          narrow = TopicNarrow(channelId, topic);
+        case 'dm':
+          final allRecipientIdsStr = url.queryParameters['all_recipient_ids']!;
+          final allRecipientIds = allRecipientIdsStr.split(',')
+            .map((idStr) => int.parse(idStr, radix: 10))
+            .toList(growable: false);
+          narrow = DmNarrow(allRecipientIds: allRecipientIds, selfUserId: userId);
+        default:
+          throw const FormatException();
+      }
+
+      return NotificationOpenPayload(
+        realmUrl: realmUrl,
+        userId: userId,
+        narrow: narrow,
+      );
+    } else {
+      // TODO(dart): simplify after https://github.com/dart-lang/language/issues/2537
+      throw const FormatException();
+    }
+  }
+
+  Uri buildUrl() {
+    return Uri(
+      scheme: 'zulip',
+      host: 'notification',
+      queryParameters: <String, String>{
+        'realm_url': realmUrl.toString(),
+        'user_id': userId.toString(),
+        ...(switch (narrow) {
+          TopicNarrow(streamId: var channelId, :var topic) => {
+            'narrow_type': 'topic',
+            'channel_id': channelId.toString(),
+            'topic': topic,
+          },
+          DmNarrow(:var allRecipientIds) => {
+            'narrow_type': 'dm',
+            'all_recipient_ids': allRecipientIds.join(','),
+          },
+          _ => throw UnsupportedError('Found an unexpected Narrow of type ${narrow.runtimeType}.'),
+        })
+      },
+    );
+  }
+}
diff --git a/lib/widgets/app.dart b/lib/widgets/app.dart
index fac501da4b..7091a2a927 100644
--- a/lib/widgets/app.dart
+++ b/lib/widgets/app.dart
@@ -8,6 +8,7 @@ import 'package:flutter_gen/gen_l10n/zulip_localizations.dart';
 import '../log.dart';
 import '../model/localizations.dart';
 import '../model/narrow.dart';
+import '../notifications/display.dart';
 import 'about_zulip.dart';
 import 'app_bar.dart';
 import 'dialog.dart';
@@ -144,19 +145,29 @@ class ZulipApp extends StatefulWidget {
 class _ZulipAppState extends State<ZulipApp> with WidgetsBindingObserver {
   @override
   Future<bool> didPushRouteInformation(routeInformation) async {
-    if (routeInformation case RouteInformation(
-      uri: Uri(scheme: 'zulip', host: 'login') && var url)
-    ) {
-      await LoginPage.handleWebAuthUrl(url);
-      return true;
+    switch (routeInformation.uri) {
+      case Uri(scheme: 'zulip', host: 'login') && var url:
+        await LoginPage.handleWebAuthUrl(url);
+        return true;
+      case Uri(scheme: 'zulip', host: 'notification') && var url:
+        await NotificationDisplayManager.navigateForNotification(url);
+        return true;
     }
     return super.didPushRouteInformation(routeInformation);
   }
 
+  Future<void> _handleInitialRoute() async {
+    final initialRouteUrl = Uri.parse(WidgetsBinding.instance.platformDispatcher.defaultRouteName);
+    if (initialRouteUrl case Uri(scheme: 'zulip', host: 'notification')) {
+      await NotificationDisplayManager.navigateForNotification(initialRouteUrl);
+    }
+  }
+
   @override
   void initState() {
     super.initState();
     WidgetsBinding.instance.addObserver(this);
+    _handleInitialRoute();
   }
 
   @override
diff --git a/macos/Flutter/GeneratedPluginRegistrant.swift b/macos/Flutter/GeneratedPluginRegistrant.swift
index 09964a2e6e..83889555f8 100644
--- a/macos/Flutter/GeneratedPluginRegistrant.swift
+++ b/macos/Flutter/GeneratedPluginRegistrant.swift
@@ -9,7 +9,6 @@ import device_info_plus
 import file_selector_macos
 import firebase_core
 import firebase_messaging
-import flutter_local_notifications
 import package_info_plus
 import path_provider_foundation
 import share_plus
@@ -23,7 +22,6 @@ func RegisterGeneratedPlugins(registry: FlutterPluginRegistry) {
   FileSelectorPlugin.register(with: registry.registrar(forPlugin: "FileSelectorPlugin"))
   FLTFirebaseCorePlugin.register(with: registry.registrar(forPlugin: "FLTFirebaseCorePlugin"))
   FLTFirebaseMessagingPlugin.register(with: registry.registrar(forPlugin: "FLTFirebaseMessagingPlugin"))
-  FlutterLocalNotificationsPlugin.register(with: registry.registrar(forPlugin: "FlutterLocalNotificationsPlugin"))
   FPPPackageInfoPlusPlugin.register(with: registry.registrar(forPlugin: "FPPPackageInfoPlusPlugin"))
   PathProviderPlugin.register(with: registry.registrar(forPlugin: "PathProviderPlugin"))
   SharePlusMacosPlugin.register(with: registry.registrar(forPlugin: "SharePlusMacosPlugin"))
diff --git a/macos/Podfile.lock b/macos/Podfile.lock
index 80f09379b2..fc34acf4c9 100644
--- a/macos/Podfile.lock
+++ b/macos/Podfile.lock
@@ -36,8 +36,6 @@ PODS:
     - GoogleUtilities/Reachability (~> 7.8)
     - GoogleUtilities/UserDefaults (~> 7.8)
     - nanopb (< 2.30911.0, >= 2.30908.0)
-  - flutter_local_notifications (0.0.1):
-    - FlutterMacOS
   - FlutterMacOS (1.0.0)
   - GoogleDataTransport (9.4.1):
     - GoogleUtilities/Environment (~> 7.7)
@@ -112,7 +110,6 @@ DEPENDENCIES:
   - file_selector_macos (from `Flutter/ephemeral/.symlinks/plugins/file_selector_macos/macos`)
   - firebase_core (from `Flutter/ephemeral/.symlinks/plugins/firebase_core/macos`)
   - firebase_messaging (from `Flutter/ephemeral/.symlinks/plugins/firebase_messaging/macos`)
-  - flutter_local_notifications (from `Flutter/ephemeral/.symlinks/plugins/flutter_local_notifications/macos`)
   - FlutterMacOS (from `Flutter/ephemeral`)
   - package_info_plus (from `Flutter/ephemeral/.symlinks/plugins/package_info_plus/macos`)
   - path_provider_foundation (from `Flutter/ephemeral/.symlinks/plugins/path_provider_foundation/darwin`)
@@ -144,8 +141,6 @@ EXTERNAL SOURCES:
     :path: Flutter/ephemeral/.symlinks/plugins/firebase_core/macos
   firebase_messaging:
     :path: Flutter/ephemeral/.symlinks/plugins/firebase_messaging/macos
-  flutter_local_notifications:
-    :path: Flutter/ephemeral/.symlinks/plugins/flutter_local_notifications/macos
   FlutterMacOS:
     :path: Flutter/ephemeral
   package_info_plus:
@@ -173,7 +168,6 @@ SPEC CHECKSUMS:
   FirebaseCoreInternal: df84dd300b561c27d5571684f389bf60b0a5c934
   FirebaseInstallations: 913cf60d0400ebd5d6b63a28b290372ab44590dd
   FirebaseMessaging: 7b5d8033e183ab59eb5b852a53201559e976d366
-  flutter_local_notifications: 3805ca215b2fb7f397d78b66db91f6a747af52e4
   FlutterMacOS: 8f6f14fa908a6fb3fba0cd85dbd81ec4b251fb24
   GoogleDataTransport: 6c09b596d841063d76d4288cc2d2f42cc36e1e2a
   GoogleUtilities: ea963c370a38a8069cc5f7ba4ca849a60b6d7d15
diff --git a/pigeon/notifications.dart b/pigeon/notifications.dart
index 8d2b56e125..55eec1b986 100644
--- a/pigeon/notifications.dart
+++ b/pigeon/notifications.dart
@@ -36,19 +36,30 @@ class NotificationChannel {
   final Int64List? vibrationPattern;
 }
 
+/// Corresponds to `android.content.Intent`
+///
+/// See:
+///   https://developer.android.com/reference/android/content/Intent
+///   https://developer.android.com/reference/android/content/Intent#Intent(java.lang.String,%20android.net.Uri,%20android.content.Context,%20java.lang.Class%3C?%3E)
+class AndroidIntent {
+  AndroidIntent({required this.action, required this.dataUrl, this.flags = 0});
+
+  final String action;
+  final String dataUrl;
+
+  /// A combination of flags from [IntentFlag].
+  final int flags;
+}
+
 /// Corresponds to `android.app.PendingIntent`.
 ///
 /// See: https://developer.android.com/reference/android/app/PendingIntent
 class PendingIntent {
   /// Corresponds to `PendingIntent.getActivity`.
-  PendingIntent({required this.requestCode, required this.intentPayload, required this.flags});
+  PendingIntent({required this.requestCode, required this.intent, required this.flags});
 
   final int requestCode;
-
-  /// A value set on an extra on the Intent, and passed to
-  /// the on-notification-opened callback.
-  // TODO replace intentPayload with a more direct wrapping of the underlying API
-  final String intentPayload;
+  final AndroidIntent intent;
 
   /// A combination of flags from [PendingIntent.flags], and others associated
   /// with `Intent`; see Android docs for `PendingIntent.getActivity`.
diff --git a/pubspec.lock b/pubspec.lock
index a04d594dc0..dfee6863bf 100644
--- a/pubspec.lock
+++ b/pubspec.lock
@@ -450,30 +450,6 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "4.0.0"
-  flutter_local_notifications:
-    dependency: "direct main"
-    description:
-      name: flutter_local_notifications
-      sha256: c500d5d9e7e553f06b61877ca6b9c8b92c570a4c8db371038702e8ce57f8a50f
-      url: "https://pub.dev"
-    source: hosted
-    version: "17.2.2"
-  flutter_local_notifications_linux:
-    dependency: transitive
-    description:
-      name: flutter_local_notifications_linux
-      sha256: c49bd06165cad9beeb79090b18cd1eb0296f4bf4b23b84426e37dd7c027fc3af
-      url: "https://pub.dev"
-    source: hosted
-    version: "4.0.1"
-  flutter_local_notifications_platform_interface:
-    dependency: "direct main"
-    description:
-      name: flutter_local_notifications_platform_interface
-      sha256: "85f8d07fe708c1bdcf45037f2c0109753b26ae077e9d9e899d55971711a4ea66"
-      url: "https://pub.dev"
-    source: hosted
-    version: "7.2.0"
   flutter_localizations:
     dependency: "direct main"
     description: flutter
@@ -1136,14 +1112,6 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "0.6.5"
-  timezone:
-    dependency: transitive
-    description:
-      name: timezone
-      sha256: "2236ec079a174ce07434e89fcd3fcda430025eb7692244139a9cf54fdcf1fc7d"
-      url: "https://pub.dev"
-    source: hosted
-    version: "0.9.4"
   timing:
     dependency: transitive
     description:
diff --git a/pubspec.yaml b/pubspec.yaml
index 540ad1b65d..e0833cc216 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -45,8 +45,6 @@ dependencies:
   firebase_core: ^3.1.0
   firebase_messaging: ^15.0.1
   flutter_color_models: ^1.3.3+2
-  flutter_local_notifications: ^17.2.1
-  flutter_local_notifications_platform_interface: ^7.2.0
   html: ^0.15.1
   http: ^1.0.0
   http_parser: ^4.0.2
diff --git a/test/api/notifications_test.dart b/test/api/notifications_test.dart
index af041cdc46..fd4465f33a 100644
--- a/test/api/notifications_test.dart
+++ b/test/api/notifications_test.dart
@@ -8,7 +8,8 @@ void main() {
   final baseBaseJson = {
     "server": "zulip.example.cloud",
     "realm_id": "4",
-    "realm_uri": "https://zulip.example.com/",
+    "realm_uri": "https://zulip.example.com/",  // TODO(server-9)
+    "realm_url": "https://zulip.example.com/",
     "user_id": "234",
   };
 
@@ -70,7 +71,8 @@ void main() {
       check(parse(streamJson))
         ..server.equals(baseJson['server']!)
         ..realmId.equals(4)
-        ..realmUri.equals(Uri.parse(baseJson['realm_uri']!))
+        ..realmUrl.equals(Uri.parse(baseJson['realm_url']!))
+        ..realmUrl.equals(Uri.parse(baseJson['realm_uri']!)) // TODO(server-9)
         ..userId.equals(234)
         ..senderId.equals(123)
         ..senderAvatarUrl.equals(Uri.parse(streamJson['sender_avatar_url']!))
@@ -137,17 +139,28 @@ void main() {
       checkInert({ 'awesome_feature': 'enabled' });
     });
 
+    test('uses deprecated fields when newer fields are missing', () {
+      final baseline = parse(dmJson);
+
+      // FL 257 deprecated 'realm_uri' in favor of 'realm_url'.
+      final jsonSansRealm =
+        { ...dmJson }..remove('realm_url')..remove('realm_uri');
+      check(parse({ ...jsonSansRealm, 'realm_url': 'https://zulip.example.com/' })).jsonEquals(baseline);
+    });
+
     group("parse failures on malformed 'message'", () {
       int n = 1;
       test("${n++}", () => checkParseFails({ ...dmJson }..remove('server')));
       test("${n++}", () => checkParseFails({ ...dmJson }..remove('realm_id')));
       test("${n++}", () => checkParseFails({ ...dmJson, 'realm_id': '12,34' }));
       test("${n++}", () => checkParseFails({ ...dmJson, 'realm_id': 'abc' }));
-      test("${n++}", () => checkParseFails({ ...dmJson }..remove('realm_uri')));
+      test("${n++}", () => checkParseFails({ ...dmJson }
+                                            ..remove('realm_url')
+                                            ..remove('realm_uri'))); // TODO(server-9)
       test(skip: true, // Dart's Uri.parse is lax in what it accepts.
-           "${n++}", () => checkParseFails({ ...dmJson, 'realm_uri': 'zulip.example.com' }));
+           "${n++}", () => checkParseFails({ ...dmJson, 'realm_url': 'zulip.example.com' }));
       test(skip: true, // Dart's Uri.parse is lax in what it accepts.
-           "${n++}", () => checkParseFails({ ...dmJson, 'realm_uri': '/examplecorp' }));
+           "${n++}", () => checkParseFails({ ...dmJson, 'realm_url': '/examplecorp' }));
 
       test("${n++}", () => checkParseFails({ ...streamJson, 'stream_id': '12,34' }));
       test("${n++}", () => checkParseFails({ ...streamJson, 'stream_id': 'abc' }));
@@ -190,7 +203,8 @@ void main() {
       check(parse(baseJson))
         ..server.equals(baseJson['server']!)
         ..realmId.equals(4)
-        ..realmUri.equals(Uri.parse(baseJson['realm_uri']!))
+        ..realmUrl.equals(Uri.parse(baseJson['realm_url']!))
+        ..realmUrl.equals(Uri.parse(baseJson['realm_uri']!)) // TODO(server-9)
         ..userId.equals(234)
         ..zulipMessageIds.deepEquals([123, 234]);
     });
@@ -210,6 +224,15 @@ void main() {
       check(parse({ ...baseJson, 'awesome_feature': 'enabled' })).jsonEquals(baseline);
     });
 
+    test('uses deprecated fields when newer fields are missing', () {
+      final baseline = parse(baseJson);
+
+      // FL 257 deprecated 'realm_uri' in favor of 'realm_url'.
+      final jsonSansRealm =
+        { ...baseJson }..remove('realm_url')..remove('realm_uri');
+      check(parse({ ...jsonSansRealm, 'realm_url': 'https://zulip.example.com/' })).jsonEquals(baseline);
+    });
+
     group('parse failures on malformed data', () {
       int n = 1;
 
@@ -217,11 +240,13 @@ void main() {
       test("${n++}", () => checkParseFails({ ...baseJson }..remove('realm_id')));
       test("${n++}", () => checkParseFails({ ...baseJson, 'realm_id': 'abc' }));
       test("${n++}", () => checkParseFails({ ...baseJson, 'realm_id': '12,34' }));
-      test("${n++}", () => checkParseFails({ ...baseJson }..remove('realm_uri')));
+      test("${n++}", () => checkParseFails({ ...baseJson }
+                                            ..remove('realm_url')
+                                            ..remove('realm_uri'))); // TODO(server-9)
       test(skip: true, // Dart's Uri.parse is lax in what it accepts.
-           "${n++}", () => checkParseFails({ ...baseJson, 'realm_uri': 'zulip.example.com' }));
+           "${n++}", () => checkParseFails({ ...baseJson, 'realm_url': 'zulip.example.com' }));
       test(skip: true, // Dart's Uri.parse is lax in what it accepts.
-           "${n++}", () => checkParseFails({ ...baseJson, 'realm_uri': '/examplecorp' }));
+           "${n++}", () => checkParseFails({ ...baseJson, 'realm_url': '/examplecorp' }));
 
       for (final badIntList in ["abc,34", "12,abc", "12,", ""]) {
         test("${n++}", () => checkParseFails({ ...baseJson, 'zulip_message_ids': badIntList }));
@@ -237,7 +262,7 @@ extension UnexpectedFcmMessageChecks on Subject<UnexpectedFcmMessage> {
 extension FcmMessageWithIdentityChecks on Subject<FcmMessageWithIdentity> {
   Subject<String> get server => has((x) => x.server, 'server');
   Subject<int> get realmId => has((x) => x.realmId, 'realmId');
-  Subject<Uri> get realmUri => has((x) => x.realmUri, 'realmUri');
+  Subject<Uri> get realmUrl => has((x) => x.realmUrl, 'realmUrl');
   Subject<int> get userId => has((x) => x.userId, 'userId');
 }
 
diff --git a/test/model/binding.dart b/test/model/binding.dart
index b968566dc5..7616effb8e 100644
--- a/test/model/binding.dart
+++ b/test/model/binding.dart
@@ -3,7 +3,6 @@ import 'dart:async';
 import 'package:firebase_core/firebase_core.dart';
 import 'package:firebase_messaging/firebase_messaging.dart';
 import 'package:flutter/foundation.dart';
-import 'package:flutter_local_notifications/flutter_local_notifications.dart' hide Person;
 import 'package:test/fake.dart';
 import 'package:url_launcher/url_launcher.dart' as url_launcher;
 import 'package:zulip/host/android_notifications.dart';
@@ -273,17 +272,9 @@ class TestZulipBinding extends ZulipBinding {
   }
 
   void _resetNotifications() {
-    _notificationsPlugin = null;
     _androidNotificationHostApi = null;
   }
 
-  FakeFlutterLocalNotificationsPlugin? _notificationsPlugin;
-
-  @override
-  FakeFlutterLocalNotificationsPlugin get notifications {
-    return (_notificationsPlugin ??= FakeFlutterLocalNotificationsPlugin());
-  }
-
   FakeAndroidNotificationHostApi? _androidNotificationHostApi;
 
   @override
@@ -512,39 +503,6 @@ typedef FirebaseMessagingRequestPermissionCall = ({
   bool sound,
 });
 
-class FakeFlutterLocalNotificationsPlugin extends Fake implements FlutterLocalNotificationsPlugin {
-  InitializationSettings? initializationSettings;
-  DidReceiveNotificationResponseCallback? onDidReceiveNotificationResponse;
-  DidReceiveBackgroundNotificationResponseCallback? onDidReceiveBackgroundNotificationResponse;
-
-  @override
-  Future<bool?> initialize(
-    InitializationSettings initializationSettings, {
-    DidReceiveNotificationResponseCallback? onDidReceiveNotificationResponse,
-    DidReceiveBackgroundNotificationResponseCallback? onDidReceiveBackgroundNotificationResponse,
-  }) async {
-    assert(this.initializationSettings == null);
-    this.initializationSettings = initializationSettings;
-    this.onDidReceiveNotificationResponse = onDidReceiveNotificationResponse;
-    this.onDidReceiveBackgroundNotificationResponse = onDidReceiveBackgroundNotificationResponse;
-    return true;
-  }
-
-  /// The value to be returned by [getNotificationAppLaunchDetails].
-  NotificationAppLaunchDetails? appLaunchDetails;
-
-  @override
-  Future<NotificationAppLaunchDetails?> getNotificationAppLaunchDetails() {
-    return Future.value(appLaunchDetails);
-  }
-
-  void receiveNotificationResponse(NotificationResponse details) {
-    if (onDidReceiveNotificationResponse != null) {
-      onDidReceiveNotificationResponse!(details);
-    }
-  }
-}
-
 class FakeAndroidNotificationHostApi implements AndroidNotificationHostApi {
   /// Lists currently active channels, result is aggregated from calls made to
   /// [createNotificationChannel] and [deleteNotificationChannel],
diff --git a/test/model/narrow_checks.dart b/test/model/narrow_checks.dart
index 9d299a8a27..241547d782 100644
--- a/test/model/narrow_checks.dart
+++ b/test/model/narrow_checks.dart
@@ -11,3 +11,8 @@ extension DmNarrowChecks on Subject<DmNarrow> {
   Subject<List<int>> get allRecipientIds => has((x) => x.allRecipientIds, 'allRecipientIds');
   Subject<List<int>> get otherRecipientIds => has((x) => x.otherRecipientIds, 'otherRecipientIds');
 }
+
+extension TopicNarrowChecks on Subject<TopicNarrow> {
+  Subject<int> get streamId => has((x) => x.streamId, 'streamId');
+  Subject<String> get topic => has((x) => x.topic, 'topic');
+}
diff --git a/test/notifications/display_test.dart b/test/notifications/display_test.dart
index cc7552877d..bd39e78ac9 100644
--- a/test/notifications/display_test.dart
+++ b/test/notifications/display_test.dart
@@ -1,4 +1,4 @@
-import 'dart:convert';
+import 'dart:async';
 import 'dart:io';
 import 'dart:typed_data';
 
@@ -6,8 +6,7 @@ import 'package:checks/checks.dart';
 import 'package:collection/collection.dart';
 import 'package:fake_async/fake_async.dart';
 import 'package:firebase_messaging/firebase_messaging.dart';
-import 'package:flutter/widgets.dart' hide Notification;
-import 'package:flutter_local_notifications/flutter_local_notifications.dart' hide Message, Person;
+import 'package:flutter/material.dart' hide Notification;
 import 'package:flutter_test/flutter_test.dart';
 import 'package:http/http.dart' as http;
 import 'package:http/testing.dart' as http_testing;
@@ -29,8 +28,11 @@ import 'package:zulip/widgets/theme.dart';
 import '../fake_async.dart';
 import '../model/binding.dart';
 import '../example_data.dart' as eg;
+import '../model/narrow_checks.dart';
+import '../stdlib_checks.dart';
 import '../test_images.dart';
 import '../test_navigation.dart';
+import '../widgets/dialog_checks.dart';
 import '../widgets/message_list_checks.dart';
 import '../widgets/page_checks.dart';
 
@@ -217,20 +219,27 @@ void main() {
       List<int>? expectedIconBitmap = kSolidBlueAvatar,
     }) {
       assert(messageStyleMessages.every((e) => e.userId == data.userId));
-      assert(messageStyleMessages.every((e) => e.realmUri == data.realmUri));
-
-      final expectedTag = '${data.realmUri}|${data.userId}|$expectedTagComponent';
-      final expectedGroupKey = '${data.realmUri}|${data.userId}';
-      final expectedId =
-        NotificationDisplayManager.notificationIdAsHashOf(expectedTag);
-      const expectedIntentFlags =
-        PendingIntentFlag.immutable | PendingIntentFlag.updateCurrent;
-      final expectedSelfUserKey = '${data.realmUri}|${data.userId}';
+      assert(messageStyleMessages.every((e) => e.realmUrl == data.realmUrl));
+
+      final expectedTag = '${data.realmUrl}|${data.userId}|$expectedTagComponent';
+      final expectedGroupKey = '${data.realmUrl}|${data.userId}';
+      const expectedPendingIntentFlags = PendingIntentFlag.immutable;
+      const expectedIntentFlags = IntentFlag.activityClearTop | IntentFlag.activityNewTask;
+      final expectedSelfUserKey = '${data.realmUrl}|${data.userId}';
+      final expectedIntentDataUrl = NotificationOpenPayload(
+        realmUrl: data.realmUrl,
+        userId: data.userId,
+        narrow: switch (data.recipient) {
+        FcmMessageChannelRecipient(:var streamId, :var topic) =>
+          TopicNarrow(streamId, topic),
+        FcmMessageDmRecipient(:var allRecipientIds) =>
+          DmNarrow(allRecipientIds: allRecipientIds, selfUserId: data.userId),
+      }).buildUrl();
 
       final messageStyleMessagesChecks =
         messageStyleMessages.mapIndexed((i, messageData) {
           final expectedSenderKey =
-            '${messageData.realmUri}|${messageData.senderId}';
+            '${messageData.realmUrl}|${messageData.senderId}';
           final isLast = i == (messageStyleMessages.length - 1);
           return (Subject<Object?> it) => it.isA<MessagingStyleMessage>()
             ..text.equals(messageData.content)
@@ -245,7 +254,7 @@ void main() {
       check(testBinding.androidNotificationHost.takeNotifyCalls())
         .deepEquals(<Condition<Object?>>[
           (it) => it.isA<AndroidNotificationHostApiNotifyCall>()
-            ..id.equals(expectedId)
+            ..id.equals(NotificationDisplayManager.kNotificationId)
             ..tag.equals(expectedTag)
             ..channelId.equals(NotificationChannelManager.kChannelId)
             ..contentTitle.isNull()
@@ -270,11 +279,14 @@ void main() {
             ..inboxStyle.isNull()
             ..autoCancel.equals(true)
             ..contentIntent.which((it) => it.isNotNull()
-              ..requestCode.equals(expectedId)
-              ..flags.equals(expectedIntentFlags)
-              ..intentPayload.equals(jsonEncode(data.toJson()))),
+              ..requestCode.equals(0)
+              ..flags.equals(expectedPendingIntentFlags)
+              ..intent.which((it) => it
+                ..action.equals(IntentAction.view)
+                ..dataUrl.equals(expectedIntentDataUrl.toString())
+                ..flags.equals(expectedIntentFlags))),
           (it) => it.isA<AndroidNotificationHostApiNotifyCall>()
-            ..id.equals(NotificationDisplayManager.notificationIdAsHashOf(expectedGroupKey))
+            ..id.equals(NotificationDisplayManager.kNotificationId)
             ..tag.equals(expectedGroupKey)
             ..channelId.equals(NotificationChannelManager.kChannelId)
             ..contentTitle.isNull()
@@ -285,7 +297,7 @@ void main() {
             ..groupKey.equals(expectedGroupKey)
             ..isGroupSummary.equals(true)
             ..inboxStyle.which((it) => it.isNotNull()
-              ..summaryText.equals(data.realmUri.toString()))
+              ..summaryText.equals(data.realmUrl.toString()))
             ..autoCancel.equals(true)
             ..contentIntent.isNull(),
         ]);
@@ -327,10 +339,10 @@ void main() {
     }
 
     Condition<Object?> conditionActiveNotif(MessageFcmMessage data, String tagComponent) {
-      final expectedGroupKey = '${data.realmUri}|${data.userId}';
+      final expectedGroupKey = '${data.realmUrl}|${data.userId}';
       final expectedTag = '$expectedGroupKey|$tagComponent';
       return (it) => it.isA<StatusBarNotification>()
-        ..id.equals(NotificationDisplayManager.notificationIdAsHashOf(expectedTag))
+        ..id.equals(NotificationDisplayManager.kNotificationId)
         ..notification.which((it) => it
           ..group.equals(expectedGroupKey)
           ..extras.deepEquals(<String, String>{
@@ -341,7 +353,7 @@ void main() {
 
     Condition<Object?> conditionSummaryActiveNotif(String expectedGroupKey) {
       return (it) => it.isA<StatusBarNotification>()
-        ..id.equals(NotificationDisplayManager.notificationIdAsHashOf(expectedGroupKey))
+        ..id.equals(NotificationDisplayManager.kNotificationId)
         ..notification.which((it) => it
           ..group.equals(expectedGroupKey)
           ..extras.isEmpty())
@@ -615,7 +627,7 @@ void main() {
       await init();
       final message = eg.streamMessage();
       final data = messageFcmMessage(message);
-      final expectedGroupKey = '${data.realmUri}|${data.userId}';
+      final expectedGroupKey = '${data.realmUrl}|${data.userId}';
 
       check(testBinding.androidNotificationHost.activeNotifications).isEmpty();
 
@@ -652,7 +664,7 @@ void main() {
       final data2 = messageFcmMessage(message2, streamName: stream.name);
       final message3 = eg.streamMessage(stream: stream, topic: topicA);
       final data3 = messageFcmMessage(message3, streamName: stream.name);
-      final expectedGroupKey = '${data1.realmUri}|${data1.userId}';
+      final expectedGroupKey = '${data1.realmUrl}|${data1.userId}';
 
       check(testBinding.androidNotificationHost.activeNotifications).isEmpty();
 
@@ -685,7 +697,7 @@ void main() {
       const topicB = 'Topic B';
       final message2 = eg.streamMessage(stream: stream, topic: topicB);
       final data2 = messageFcmMessage(message2, streamName: stream.name);
-      final expectedGroupKey = '${data1.realmUri}|${data1.userId}';
+      final expectedGroupKey = '${data1.realmUrl}|${data1.userId}';
 
       check(testBinding.androidNotificationHost.activeNotifications).isEmpty();
 
@@ -711,7 +723,6 @@ void main() {
       check(testBinding.androidNotificationHost.activeNotifications).isEmpty();
     })));
 
-
     test('remove: different realm URLs but same user-ids and same message-ids', () => runWithHttpClient(() => awaitFakeAsync((async) async {
       await init();
       final stream = eg.stream();
@@ -728,7 +739,7 @@ void main() {
 
       final account2 = eg.account(
         realmUrl: Uri.parse('https://2.chat.example'),
-        id: 1001,
+        id: 1002,
         user: eg.user(userId: 1001));
       final message2 = eg.streamMessage(id: 1000, stream: stream, topic: topic);
       final data2 =
@@ -834,11 +845,19 @@ void main() {
     }
 
     Future<void> openNotification(WidgetTester tester, Account account, Message message) async {
-      final fcmMessage = messageFcmMessage(message, account: account);
-      testBinding.notifications.receiveNotificationResponse(NotificationResponse(
-        notificationResponseType: NotificationResponseType.selectedNotification,
-        payload: jsonEncode(fcmMessage)));
-      await tester.idle(); // let _navigateForNotification find navigator
+      final data = messageFcmMessage(message, account: account);
+      final intentDataUrl = NotificationOpenPayload(
+        realmUrl: data.realmUrl,
+        userId: data.userId,
+        narrow: switch (data.recipient) {
+        FcmMessageChannelRecipient(:var streamId, :var topic) =>
+          TopicNarrow(streamId, topic),
+        FcmMessageDmRecipient(:var allRecipientIds) =>
+          DmNarrow(allRecipientIds: allRecipientIds, selfUserId: data.userId),
+      }).buildUrl();
+      unawaited(
+        WidgetsBinding.instance.handlePushRoute(intentDataUrl.toString()));
+      await tester.idle(); // let navigateForNotification find navigator
     }
 
     void matchesNavigation(Subject<Route<void>> route, Account account, Message message) {
@@ -873,7 +892,11 @@ void main() {
     testWidgets('no accounts', (tester) async {
       await prepare(tester, withAccount: false);
       await openNotification(tester, eg.selfAccount, eg.streamMessage());
-      check(pushedRoutes).isEmpty();
+      await tester.pump();
+      check(pushedRoutes.single).isA<DialogRoute<void>>();
+      await tester.tap(find.byWidget(checkErrorDialog(tester,
+        expectedTitle: zulipLocalizations.errorNotificationOpenTitle,
+        expectedMessage: zulipLocalizations.errorNotificationOpenAccountMissing)));
     });
 
     testWidgets('mismatching account', (tester) async {
@@ -881,7 +904,11 @@ void main() {
       await testBinding.globalStore.add(eg.selfAccount, eg.initialSnapshot());
       await prepare(tester);
       await openNotification(tester, eg.otherAccount, eg.streamMessage());
-      check(pushedRoutes).isEmpty();
+      await tester.pump();
+      check(pushedRoutes.single).isA<DialogRoute<void>>();
+      await tester.tap(find.byWidget(checkErrorDialog(tester,
+        expectedTitle: zulipLocalizations.errorNotificationOpenTitle,
+        expectedMessage: zulipLocalizations.errorNotificationOpenAccountMissing)));
     });
 
     testWidgets('find account among several', (tester) async {
@@ -929,14 +956,21 @@ void main() {
 
     testWidgets('at app launch', (tester) async {
       addTearDown(testBinding.reset);
-      // Set up a value for `getNotificationLaunchDetails` to return.
+      // Set up a value for `PlatformDispatcher.defaultRouteName` to return,
+      // for determining the intial route.
       final account = eg.selfAccount;
       final message = eg.streamMessage();
-      final response = NotificationResponse(
-        notificationResponseType: NotificationResponseType.selectedNotification,
-        payload: jsonEncode(messageFcmMessage(message, account: account)));
-      testBinding.notifications.appLaunchDetails =
-        NotificationAppLaunchDetails(true, notificationResponse: response);
+      final data = messageFcmMessage(message, account: account);
+      final intentDataUrl = NotificationOpenPayload(
+        realmUrl: data.realmUrl,
+        userId: data.userId,
+        narrow: switch (data.recipient) {
+        FcmMessageChannelRecipient(:var streamId, :var topic) =>
+          TopicNarrow(streamId, topic),
+        FcmMessageDmRecipient(:var allRecipientIds) =>
+          DmNarrow(allRecipientIds: allRecipientIds, selfUserId: data.userId),
+      }).buildUrl();
+      tester.binding.platformDispatcher.defaultRouteNameTestValue = intentDataUrl.toString();
 
       // Now start the app.
       await testBinding.globalStore.add(account, eg.initialSnapshot());
@@ -949,6 +983,202 @@ void main() {
       matchesNavigation(check(pushedRoutes).single, account, message);
     });
   });
+
+  group('NotificationOpenPayload', () {
+    test('smoke round-trip', () {
+      // DM narrow
+      var payload = NotificationOpenPayload(
+        realmUrl: Uri.parse('http://chat.example'),
+        userId: 1001,
+        narrow: DmNarrow(allRecipientIds: [1001, 1002], selfUserId: 1001),
+      );
+      var url = payload.buildUrl();
+      check(NotificationOpenPayload.parseUrl(url))
+        ..realmUrl.equals(payload.realmUrl)
+        ..userId.equals(payload.userId)
+        ..narrow.equals(payload.narrow);
+
+      // Topic narrow
+      payload = NotificationOpenPayload(
+        realmUrl: Uri.parse('http://chat.example'),
+        userId: 1001,
+        narrow: const TopicNarrow(1, 'topic A'),
+      );
+      url = payload.buildUrl();
+      check(NotificationOpenPayload.parseUrl(url))
+        ..realmUrl.equals(payload.realmUrl)
+        ..userId.equals(payload.userId)
+        ..narrow.equals(payload.narrow);
+    });
+
+    test('buildUrl: smoke DM', () {
+      final url = NotificationOpenPayload(
+        realmUrl: Uri.parse('http://chat.example'),
+        userId: 1001,
+        narrow: DmNarrow(allRecipientIds: [1001, 1002], selfUserId: 1001),
+      ).buildUrl();
+      check(url)
+        ..scheme.equals('zulip')
+        ..host.equals('notification')
+        ..queryParameters.deepEquals({
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'dm',
+          'all_recipient_ids': '1001,1002',
+        });
+    });
+
+    test('buildUrl: smoke topic', () {
+      final url = NotificationOpenPayload(
+        realmUrl: Uri.parse('http://chat.example'),
+        userId: 1001,
+        narrow: const TopicNarrow(1, 'topic A'),
+      ).buildUrl();
+      check(url)
+        ..scheme.equals('zulip')
+        ..host.equals('notification')
+        ..queryParameters.deepEquals({
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'topic',
+          'channel_id': '1',
+          'topic': 'topic A',
+        });
+    });
+
+    test('parse: smoke DM', () {
+      final url = Uri(
+        scheme: 'zulip',
+        host: 'notification',
+        queryParameters: <String, String>{
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'dm',
+          'all_recipient_ids': '1001,1002',
+        });
+      check(NotificationOpenPayload.parseUrl(url))
+        ..realmUrl.equals(Uri.parse('http://chat.example'))
+        ..userId.equals(1001)
+        ..narrow.which((it) => it.isA<DmNarrow>()
+          ..allRecipientIds.deepEquals([1001, 1002])
+          ..otherRecipientIds.deepEquals([1002]));
+    });
+
+    test('parse: smoke topic', () {
+      final url = Uri(
+        scheme: 'zulip',
+        host: 'notification',
+        queryParameters: <String, String>{
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'topic',
+          'channel_id': '1',
+          'topic': 'topic A',
+        });
+      check(NotificationOpenPayload.parseUrl(url))
+        ..realmUrl.equals(Uri.parse('http://chat.example'))
+        ..userId.equals(1001)
+        ..narrow.which((it) => it.isA<TopicNarrow>()
+          ..streamId.equals(1)
+          ..topic.equals('topic A'));
+    });
+
+    test('parse: fails when missing any expected query parameters', () {
+      final testCases = <Map<String, String>>[
+        {
+          // 'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'topic',
+          'channel_id': '1',
+          'topic': 'topic A',
+        },
+        {
+          'realm_url': 'http://chat.example',
+          // 'user_id': '1001',
+          'narrow_type': 'topic',
+          'channel_id': '1',
+          'topic': 'topic A',
+        },
+        {
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          // 'narrow_type': 'topic',
+          'channel_id': '1',
+          'topic': 'topic A',
+        },
+        {
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'topic',
+          // 'channel_id': '1',
+          'topic': 'topic A',
+        },
+        {
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'topic',
+          'channel_id': '1',
+          // 'topic': 'topic A',
+        },
+        {
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          // 'narrow_type': 'dm',
+          'all_recipient_ids': '1001,1002',
+        },
+        {
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'dm',
+          // 'all_recipient_ids': '1001,1002',
+        },
+      ];
+      for (final params in testCases) {
+        check(() => NotificationOpenPayload.parseUrl(Uri(
+          scheme: 'zulip',
+          host: 'notification',
+          queryParameters: params,
+        )))
+          // Missing 'realm_url', 'user_id' and 'narrow_type'
+          // throws 'FormatException'.
+          // Missing 'channel_id', 'topic', when narrow_type == 'topic'
+          // throws 'TypeError'.
+          // Missing 'all_recipient_ids', when narrow_type == 'dm'
+          // throws 'TypeError'.
+          .throws<Object>();
+      }
+    });
+
+    test('parse: fails when scheme is not "zulip"', () {
+      final url = Uri(
+        scheme: 'http',
+        host: 'notification',
+        queryParameters: <String, String>{
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'topic',
+          'channel_id': '1',
+          'topic': 'topic A',
+        });
+      check(() => NotificationOpenPayload.parseUrl(url))
+        .throws<FormatException>();
+    });
+
+    test('parse: fails when host is not "notification"', () {
+      final url = Uri(
+        scheme: 'zulip',
+        host: 'example',
+        queryParameters: <String, String>{
+          'realm_url': 'http://chat.example',
+          'user_id': '1001',
+          'narrow_type': 'topic',
+          'channel_id': '1',
+          'topic': 'topic A',
+        });
+      check(() => NotificationOpenPayload.parseUrl(url))
+        .throws<FormatException>();
+    });
+  });
 }
 
 extension NotificationChannelChecks on Subject<NotificationChannel> {
@@ -979,7 +1209,13 @@ extension on Subject<AndroidNotificationHostApiNotifyCall> {
 
 extension on Subject<PendingIntent> {
   Subject<int> get requestCode => has((x) => x.requestCode, 'requestCode');
-  Subject<String> get intentPayload => has((x) => x.intentPayload, 'intentPayload');
+  Subject<AndroidIntent> get intent => has((x) => x.intent, 'intent');
+  Subject<int> get flags => has((x) => x.flags, 'flags');
+}
+
+extension on Subject<AndroidIntent> {
+  Subject<String> get action => has((x) => x.action, 'action');
+  Subject<String> get dataUrl => has((x) => x.dataUrl, 'dataUrl');
   Subject<int> get flags => has((x) => x.flags, 'flags');
 }
 
@@ -1016,3 +1252,9 @@ extension on Subject<StatusBarNotification> {
   Subject<Notification> get notification => has((x) => x.notification, 'notification');
   Subject<String> get tag => has((x) => x.tag, 'tag');
 }
+
+extension on Subject<NotificationOpenPayload> {
+  Subject<Uri> get realmUrl => has((x) => x.realmUrl, 'realmUrl');
+  Subject<int> get userId => has((x) => x.userId, 'userId');
+  Subject<Narrow> get narrow => has((x) => x.narrow, 'narrow');
+}