Cross-Platform Push Notifications

flowchart TD
  subgraph Ingest["Event Ingestion"]
    RL["Relay Messages"]
    RA["remote_api.rs"]
    NDB["nostrdb LMDB"]
  end

  subgraph DesktopPoll["Desktop Poll Model"]
    POLL["poll_notifications"]
    NDBh["ndb_helpers.rs"]
    FMT["manager.rs format"]
    CH["mpsc channel"]
  end

  subgraph Worker["Worker Thread"]
    DD["Dedup LRU"]
    WRK["worker.rs"]
  end

  subgraph Desktop["Desktop Backends"]
    LIN["DesktopBackend\nnotify-rust / libnotify"]
    MAC["MacOSBackend\nUNUserNotificationCenter"]
    IMG["image_cache.rs\nProfile pictures"]
  end

  subgraph Android["Android Path"]
    JNI["JNI Bridge\nchrome/notifications.rs"]
    ANDB["ndb ingest and poll"]
    FCM["FCM Mode\nFirebase via notepush"]
    NAT["Native Mode\nForeground Service"]
  end

  subgraph Kotlin["Kotlin Services"]
    MA["MainActivity.kt"]
    NFS["NotedeckFirebaseMessagingService"]
    NPC["NotepushClient"]
    NS["NotificationsService"]
    NH["NotificationHelper"]
  end

  subgraph Settings["Settings"]
    UI["settings.rs UI"]
    PER["SettingsHandler"]
    PLAT["platform/mod.rs"]
  end

  RL --> RA
  RA --> NDB
  NDB --> POLL
  POLL --> NDBh
  NDBh --> FMT
  FMT --> CH
  CH --> DD
  DD --> WRK
  WRK --> LIN
  WRK --> MAC
  MAC --> IMG

  JNI --> FCM
  JNI --> NAT
  NAT --> NS
  NS --> ANDB
  ANDB --> NDBh
  ANDB -.-> NH
  FCM --> NFS
  NFS --> NPC
  NFS --> NH

  UI --> PER
  UI --> PLAT
  PLAT --> JNI
  PLAT --> WRK
      

sequenceDiagram
  participant R as Relay
  participant RA as remote_api
  participant NDB as nostrdb (LMDB)
  participant NM as NotificationManager
  participant W as Worker Thread
  participant B as Backend

  R->>RA: RelayMessage Event
  RA->>NDB: ingest event
  Note over NM: poll_notifications() called each frame
  NM->>NDB: poll_for_notes(sub, 50)
  NDB-->>NM: Note keys
  NM->>NDB: get_note_by_key (Note API)
  NM->>NM: Kind check + p-tag match via ndb_helpers
  NM->>NM: Self-suppress check (all accounts)
  NM->>NDB: get_profile_by_pubkey
  NM->>NM: Format title and body
  NM->>W: mpsc send NotificationData
  W->>W: Dedup check via LRU
  W->>B: display notification
  Note over B: Linux: notify-rust
  Note over B: macOS: UNUserNotificationCenter
      

sequenceDiagram
  participant U as User
  participant MA as MainActivity.kt
  participant NPC as NotepushClient
  participant NP as Notepush Server
  participant FCM as Firebase
  participant FMS as FirebaseMessagingService
  participant JNI as Rust JNI Bridge
  participant NH as NotificationHelper

  U->>MA: Enable FCM mode
  MA->>MA: Iterate all account pubkeys
  MA->>NPC: registerDevice per account (NIP-98 auth)
  NPC->>NP: POST register
  NP-->>NPC: OK

  Note over NP: Later, event arrives
  NP->>FCM: Push notification
  FCM->>FMS: onMessageReceived
  FMS->>JNI: nativeProcessNostrEvent
  JNI-->>FMS: Parsed event data
  FMS->>NH: showNotification
  NH->>U: System notification with deep link
      

sequenceDiagram
  participant U as User
  participant MA as MainActivity.kt
  participant NS as NotificationsService
  participant JNI as Rust JNI Bridge
  participant RP as Relay Pool
  participant NDB as nostrdb (LMDB)
  participant NH as NotificationHelper

  U->>MA: Enable Native mode
  MA->>MA: Store active_pubkeys JSON
  MA->>NS: Start foreground service
  NS->>NS: Acquire wake lock
  NS->>JNI: nativeStartSubscriptions(pubkeysJson, relaysJson)
  JNI->>RP: Connect to relays
  JNI->>RP: Subscribe with all pubkey filters
  Note over JNI: Worker loop: drain → ingest → poll
  RP-->>JNI: Relay message (raw JSON)
  JNI->>NDB: process_event_with (ingest)
  Note over JNI: Sleep 200ms for LMDB write
  JNI->>NDB: poll_for_notes(sub, 50)
  NDB-->>JNI: Note via Note API
  JNI->>JNI: Self-suppress + ndb_helpers
  JNI->>NDB: get_profile_by_pubkey
  JNI-->>NS: onNostrEvent callback
  NS->>NH: showNotification
  NH->>U: System notification with deep link