vector_core/

rumor.rs

//! Rumor Processing Module
//!
//! Unified processing for the inner decrypted events of NIP-17 DMs. "Rumors" are
//! the inner events; only the gift-wrap unwrapping happens before this.
//!
//! ## Architecture
//!
//! ```text
//! Event → Protocol Handler (unwrap) → RumorEvent
//!                                       ↓
//!                             process_rumor() [SHARED]
//!                                       ↓
//!                             RumorProcessingResult
//!                                       ↓
//!                     Storage Handler (protocol-specific)
//!                                       ↓
//!                             Emit to UI [SHARED]
//! ```
//!
//! ## Supported Rumor Types
//!
//! - **Text Messages**: `Kind::PrivateDirectMessage` - Plain text with optional replies
//! - **File Attachments**: `Kind::from_u16(15)` - Encrypted files with metadata
//! - **Reactions**: `Kind::Reaction` - Emoji reactions to messages
//! - **Typing Indicators**: `Kind::ApplicationSpecificData` - Real-time typing status

use crate::tags::TagsExt;
use std::path::Path;
use nostr_sdk::prelude::*;
use crate::types::{Message, Attachment, ImageMetadata, Reaction};
use crate::stored_event::{StoredEvent, StoredEventBuilder, event_kind};
use crate::crypto::{extension_from_mime, sanitize_filename};

/// Decrypted NIP-17 rumor event representation.
#[derive(Debug, Clone)]
pub struct RumorEvent {
    pub id: EventId,
    pub kind: Kind,
    pub content: String,
    pub tags: Tags,
    pub created_at: Timestamp,
    pub pubkey: PublicKey,
}

/// Context for processing a rumor
///
/// Provides the necessary context to process a rumor correctly,
/// including who sent it and what conversation it belongs to.
#[derive(Debug, Clone)]
pub struct RumorContext {
    /// The sender's public key
    pub sender: PublicKey,
    /// Whether this rumor is from ourselves
    pub is_mine: bool,
    /// The conversation ID (npub for DMs)
    pub conversation_id: String,
    /// The type of conversation
    pub conversation_type: ConversationType,
}

/// Type of conversation — the transport-specific dimension the shared parser keys off (e.g. who the
/// author is). `conversation_id` carries the address: an npub for a DM, a channel id for a Community.
#[derive(Debug, Clone, PartialEq)]
pub enum ConversationType {
    /// Direct message (NIP-17) — 1:1, so the author is implied by the chat.
    DirectMessage,
    /// Concord community channel — a group, so each message records its real author.
    Community,
}

impl RumorContext {
    /// The author npub to stamp on a parsed message. A DM is 1:1 so the author is implied by the
    /// chat (`None`); a Community message records its real author so the group can attribute it.
    pub fn author_npub(&self, author: &PublicKey) -> Option<String> {
        match self.conversation_type {
            ConversationType::Community => author.to_bech32().ok(),
            ConversationType::DirectMessage => None,
        }
    }
}

/// Result of processing a rumor
///
/// Represents the different types of events that can result from
/// processing a rumor. The caller is responsible for storing these
/// results appropriately based on the conversation type.
#[derive(Debug, Clone)]
pub enum RumorProcessingResult {
    /// A text message (with optional reply reference)
    TextMessage(Message),
    /// A file attachment message
    FileAttachment(Message),
    /// An emoji reaction to a message
    Reaction(Reaction),
    /// A typing indicator update
    TypingIndicator {
        profile_id: String,
        until: u64,
    },
    /// A leave request from a group member (admin should auto-remove them)
    LeaveRequest {
        /// The event ID of the leave request (for deduplication)
        event_id: String,
        /// The pubkey of the member requesting to leave (npub)
        member_pubkey: String,
    },
    /// A WebXDC peer advertisement for realtime channels
    WebxdcPeerAdvertisement {
        event_id: String,
        topic_id: String,
        node_addr: String,
        sender_npub: String,
        created_at: u64,
    },
    /// A WebXDC peer left signal (peer closed their Mini App)
    WebxdcPeerLeft {
        event_id: String,
        topic_id: String,
        sender_npub: String,
        created_at: u64,
    },
    /// Unknown event type - stored for future compatibility
    /// The frontend will render this as "Unknown Event" placeholder
    UnknownEvent(StoredEvent),
    /// A PIVX payment promo code sent in chat
    PivxPayment {
        /// The promo code (5-char Base58)
        gift_code: String,
        /// Amount in PIV
        amount_piv: f64,
        /// The PIVX address for balance checking (optional for older events)
        address: Option<String>,
        /// The message ID for this payment event
        message_id: String,
        /// The stored event for persistence
        event: StoredEvent,
    },
    /// A per-DM wallpaper change. The encrypted Blossom file is referenced
    /// by URL + decryption key in the tags; the caller is responsible for
    /// the timestamp comparison (latest-write-wins against
    /// `chat.wallpaper_ts`) and the download + decrypt step.
    WallpaperChanged {
        /// Sender's npub (whoever set the wallpaper).
        sender_npub: String,
        /// Rumor `created_at` (Unix seconds) — drives latest-write-wins.
        created_at: u64,
        /// Encrypted file URL on Blossom.
        url: String,
        /// Hex-encoded AES key.
        decryption_key: String,
        /// Hex-encoded AES nonce.
        decryption_nonce: String,
        /// Optional plaintext SHA-256 (for caller integrity check).
        plaintext_hash: Option<String>,
        /// Optional MIME hint (e.g. "image/png") — informs cache extension.
        mime: Option<String>,
        /// Blur (px, 0..=30). `None` falls back to the receiver's default.
        blur: Option<u8>,
        /// Brightness percent (0..=100). `None` falls back to default.
        dim: Option<u8>,
        /// The rumor ID, used as the system-event row id.
        event_id: String,
    },
    /// Event was ignored (invalid, expired, or should not be stored)
    Ignored,
    /// A NIP-09 deletion request — sender asks live clients to drop a
    /// previously-received message from local storage. Cooperative
    /// delete-for-everyone signal that pairs with Vector's gift-wrap
    /// nuke at the relay layer (see `vector_core::deletion`).
    DeletionRequest {
        /// Hex id of the rumor being deleted (target's `["e", ...]` tag).
        target_event_id: String,
    },
    /// A message edit event
    Edit {
        /// The ID of the message being edited
        message_id: String,
        /// The new content
        new_content: String,
        /// Timestamp of the edit (milliseconds)
        edited_at: u64,
        /// NIP-30 custom-emoji tags resolved from the new content
        emoji_tags: Vec<crate::types::EmojiTag>,
        /// The stored event for persistence
        event: StoredEvent,
    },
}

/// Main rumor processor - protocol agnostic
///
/// This is the single entry point for processing all rumor types.
/// It handles text messages, file attachments, reactions, and typing indicators
/// in a unified way, regardless of the underlying protocol.
///
/// # Arguments
///
/// * `rumor` - The rumor event to process
/// * `context` - Context about the rumor (sender, conversation, etc.)
/// * `download_dir` - Directory for file attachment paths
///
/// # Returns
///
/// A `RumorProcessingResult` indicating what type of event was processed,
/// or an error if processing failed.
pub fn process_rumor(
    rumor: RumorEvent,
    context: RumorContext,
    download_dir: &Path,
) -> Result<RumorProcessingResult, String> {
    match rumor.kind {
        // Text messages — Kind 14 (NIP-17 DM chat message).
        Kind::PrivateDirectMessage => {
            process_text_message(rumor, context)
        }
        // File attachments
        k if k.as_u16() == 15 => {
            process_file_attachment(rumor, context, download_dir)
        }
        // Message edits
        k if k.as_u16() == event_kind::MESSAGE_EDIT => {
            process_edit_event(rumor, context)
        }
        // Emoji reactions
        Kind::Reaction => {
            process_reaction(rumor, context)
        }
        // Application-specific data (typing indicators, etc.)
        Kind::ApplicationSpecificData => {
            process_app_specific(rumor, context)
        }
        // NIP-09 cooperative deletion (Layer 2 of Vector's delete flow).
        // The relay-layer wrap nuke happens via the retained ephemeral
        // key in `vector_core::deletion`; this rumor tells live clients
        // that already decrypted the original to drop it from local
        // storage. Authorization (sender == original author) is
        // verified at commit time, not parse time.
        Kind::EventDeletion => {
            process_deletion(rumor, context)
        }
        // Unknown or unsupported kind - store for future compatibility
        _ => {
            process_unknown_event(rumor, context)
        }
    }
}

/// Process an unknown event type
///
/// Creates a StoredEvent for unknown kinds so they can be stored
/// and potentially displayed/processed in future versions.
fn process_unknown_event(
    rumor: RumorEvent,
    context: RumorContext,
) -> Result<RumorProcessingResult, String> {
    // Convert tags to Vec<Vec<String>> format
    let tags: Vec<Vec<String>> = rumor.tags.iter()
        .map(|tag| {
            tag.as_slice().iter().map(|s| s.to_string()).collect()
        })
        .collect();

    // Extract reference_id from e-tag if present
    let reference_id = rumor.tags
        .find_kind("e")
        .and_then(|tag| tag.content())
        .map(|s| s.to_string());

    let event = StoredEventBuilder::new()
        .id(rumor.id.to_hex())
        .kind(rumor.kind.as_u16())
        .content(rumor.content)
        .tags(tags)
        .reference_id(reference_id)
        .created_at(rumor.created_at.as_secs())
        .mine(context.is_mine)
        .npub(rumor.pubkey.to_bech32().ok())
        .build();

    Ok(RumorProcessingResult::UnknownEvent(event))
}

/// Process a text message rumor
///
/// Extracts text content, reply references, and millisecond-precision timestamps.
fn process_text_message(
    rumor: RumorEvent,
    context: RumorContext,
) -> Result<RumorProcessingResult, String> {
    // Extract reply reference if present
    let replied_to = extract_reply_reference(&rumor);

    // Extract millisecond-precision timestamp
    let ms_timestamp = extract_millisecond_timestamp(&rumor);

    let emoji_tags = crate::types::EmojiTag::extract_from_tags(rumor.tags.iter());
    let addressed_bots = crate::bot_interface::addressed_bots(rumor.tags.iter());
    // DM → None (1:1, implied by chat); Community → the real author.
    let npub = context.author_npub(&rumor.pubkey);

    // Create the message
    let expiration = extract_nip40_expiration(&rumor);
    // NIP-40: an event arriving already expired is dropped on receipt — it
    // must never render or persist.
    if already_expired(expiration) {
        return Ok(RumorProcessingResult::Ignored);
    }
    let msg = Message {
        expiration,
        id: rumor.id.to_hex(),
        content: rumor.content,
        replied_to,
        replied_to_content: None, // Populated by get_message_views
        replied_to_npub: None,
        replied_to_has_attachment: None,
        replied_to_attachment_extension: None,
        preview_metadata: None,
        at: ms_timestamp,
        attachments: Vec::new(),
        reactions: Vec::new(),
        mine: context.is_mine,
        pending: false,
        failed: false,
        npub,
        wrapper_event_id: None, // Set by caller after processing
        edited: false,
        edit_history: None,
        emoji_tags,
        addressed_bots,
    };

    Ok(RumorProcessingResult::TextMessage(msg))
}

/// Extract SHA256 hash from a Blossom URL
///
/// Blossom URLs typically follow the format: https://server.com/<sha256hash>[.ext]
pub fn extract_hash_from_blossom_url(url: &str) -> Option<String> {
    let path = url.split('/').last()?;
    let hash_part = path.split('.').next()?;
    if hash_part.len() == 64 && hash_part.chars().all(|c| c.is_ascii_hexdigit()) {
        Some(hash_part.to_string())
    } else {
        None
    }
}

/// Process a file attachment rumor
///
/// Handles encrypted file metadata including:
/// - Decryption keys and nonces
/// - Original file hashes (for deduplication)
/// - Image metadata (thumbhash, dimensions)
/// - File extensions and mime types
fn process_file_attachment(
    rumor: RumorEvent,
    context: RumorContext,
    download_dir: &Path,
) -> Result<RumorProcessingResult, String> {
    // Extract decryption parameters
    let decryption_key = rumor.tags
        .find_kind("decryption-key")
        .and_then(|tag| tag.content())
        .ok_or("Missing decryption-key tag")?
        .to_string();

    let decryption_nonce = rumor.tags
        .find_kind("decryption-nonce")
        .and_then(|tag| tag.content())
        .ok_or("Missing decryption-nonce tag")?
        .to_string();

    // Extract original file hash (ox tag) if present
    let original_file_hash = rumor.tags
        .find_kind("ox")
        .and_then(|tag| tag.content())
        .map(|s| s.to_string());

    // Extract content storage URL
    let content_url = rumor.content.clone();

    // Skip attachments with empty file hash - these are corrupted uploads
    const EMPTY_FILE_HASH: &str = "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855";
    if content_url.contains(EMPTY_FILE_HASH) {
        eprintln!("Skipping attachment with empty file hash in URL: {}", content_url);
        return Err("Attachment contains empty file hash - skipping".to_string());
    }

    // Extract image metadata if provided
    let img_meta: Option<ImageMetadata> = {
        // Read BOTH tag names: current senders emit `thumbhash` (see sending.rs),
        // while older ones emit `thumb`. The two must never diverge or img_meta
        // silently drops and the image renders as a generic file box with no
        // preview — the bug this belt-and-braces read exists to prevent.
        let thumbhash_opt = rumor.tags
            .find_kind("thumbhash")
            .or_else(|| rumor.tags.find_kind("thumb"))
            .and_then(|tag| tag.content())
            .map(|s| s.to_string());

        let dimensions_opt = rumor.tags
            .find_kind("dim")
            .and_then(|tag| tag.content())
            .and_then(|s| {
                let parts: Vec<&str> = s.split('x').collect();
                if parts.len() == 2 {
                    let width = parts[0].parse::<u32>().ok()?;
                    let height = parts[1].parse::<u32>().ok()?;
                    Some((width, height))
                } else {
                    None
                }
            });

        match (thumbhash_opt, dimensions_opt) {
            (Some(thumbhash), Some((width, height))) => {
                Some(ImageMetadata {
                    thumbhash,
                    width,
                    height,
                })
            },
            _ => None
        }
    };

    // Figure out the file extension: prefer the name tag's extension, fall back to MIME-derived
    let mime_type = rumor.tags
        .find_kind("file-type")
        .and_then(|tag| tag.content())
        .ok_or("Missing file-type tag")?;
    let mime_extension = extension_from_mime(mime_type);

    // Extract filename from name tag (used for extension override and display name)
    let file_name = rumor.tags
        .find_kind("name")
        .and_then(|tag| tag.content())
        .map(|s| sanitize_filename(s))
        .unwrap_or_default();

    // Use the extension from the original filename when available (more accurate than MIME for
    // uncommon types like .sh, .toml, .rs, etc. which all map to application/octet-stream)
    let extension = if !file_name.is_empty() {
        file_name.rsplit('.').next()
            .filter(|e| !e.is_empty() && *e != file_name)
            .map(|e| e.to_lowercase())
            .unwrap_or(mime_extension)
    } else {
        mime_extension
    };

    // Grab the reported file size
    let reported_size = rumor.tags
        .find_kind("size")
        .and_then(|tag| tag.content())
        .and_then(|s| s.parse::<u64>().ok())
        .unwrap_or(0);

    // Determine identity, file path and download status via the shared basis
    // rules (ox for dedup when present, else a nonce+url digest — see
    // `attachment_identity_basis`). The basis is author-controlled and
    // becomes an on-disk filename — require bounded plain hex before joining
    // it into a path, mirroring the Community parser, so a crafted tag can't
    // smuggle `../` traversal into `path`.
    let valid_path_basis =
        |s: &str| !s.is_empty() && s.len() <= 128 && s.bytes().all(|b| b.is_ascii_hexdigit());
    let original_file_hash = original_file_hash.filter(|h| valid_path_basis(h));
    if !valid_path_basis(&decryption_nonce) {
        return Err("Invalid decryption-nonce tag".to_string());
    }
    let file_hash = crate::crypto::attachment_identity_basis(
        original_file_hash.as_deref(),
        &decryption_nonce,
        &content_url,
    );
    let hash_file_path = download_dir.join(format!("{}.{}", file_hash, extension));
    // Arrival never claims downloaded: an ox-named file proves nothing about
    // content (the download path re-verifies by hash before reuse), and the
    // honest pipeline never writes digest-named files at all — a file found
    // under one could only be a foreign plant.
    let downloaded = false;
    let file_path = hash_file_path.to_string_lossy().to_string();

    // Extract reply reference if present
    let replied_to = extract_reply_reference(&rumor);

    // Extract millisecond-precision timestamp
    let ms_timestamp = extract_millisecond_timestamp(&rumor);

    // Extract webxdc-topic for Mini Apps (realtime channel isolation).
    // Bounded sanity (mirrors the Community parser): base32 alphabet only,
    // 32-byte payload (52 chars); anything else is dropped, not propagated.
    let webxdc_topic = rumor.tags
        .find_kind("webxdc-topic")
        .and_then(|tag| tag.content())
        .filter(|t| t.len() == 52 && t.bytes().all(|b| b.is_ascii_uppercase() || (b'2'..=b'7').contains(&b)))
        .map(|s| s.to_string());

    // NIP-17 `fallback` mirrors: the same ciphertext on other hosts, tried in
    // order when the primary URL dies. Sender-controlled data — https-only,
    // deduped against the primary and each other, capped.
    let mut fallback_urls: Vec<String> = Vec::new();
    for tag in rumor.tags.iter() {
        let parts = tag.as_slice();
        if parts.first().map(String::as_str) != Some("fallback") {
            continue;
        }
        let Some(u) = parts.get(1) else { continue };
        if !u.starts_with("https://")
            || u.contains(char::is_whitespace)
            || *u == content_url
            || fallback_urls.contains(u)
        {
            continue;
        }
        fallback_urls.push(u.clone());
        if fallback_urls.len() >= 4 {
            break;
        }
    }

    // Create the attachment
    let attachment = Attachment {
        id: file_hash.clone(),
        key: decryption_key,
        nonce: decryption_nonce,
        extension: extension.to_string(),
        name: file_name,
        url: content_url,
        path: file_path,
        size: reported_size,
        img_meta,
        downloading: false,
        downloaded,
        webxdc_topic,
        group_id: None,       // Kind 15 attachments use explicit key/nonce
        original_hash: original_file_hash, // ox tag value (original file hash)
        fallback_urls,
    };

    let emoji_tags = crate::types::EmojiTag::extract_from_tags(rumor.tags.iter());
    // DM → None (1:1, implied by chat); Community → the real author.
    let npub = context.author_npub(&rumor.pubkey);

    // Create the message with attachment
    let expiration = extract_nip40_expiration(&rumor);
    // NIP-40: an event arriving already expired is dropped on receipt.
    if already_expired(expiration) {
        return Ok(RumorProcessingResult::Ignored);
    }
    let msg = Message {
        expiration,
        id: rumor.id.to_hex(),
        content: String::new(),
        replied_to,
        replied_to_content: None, // Populated by get_message_views
        replied_to_npub: None,
        replied_to_has_attachment: None,
        replied_to_attachment_extension: None,
        preview_metadata: None,
        at: ms_timestamp,
        attachments: vec![attachment],
        reactions: Vec::new(),
        mine: context.is_mine,
        pending: false,
        failed: false,
        npub,
        wrapper_event_id: None, // Set by caller after processing
        edited: false,
        edit_history: None,
        emoji_tags,
        addressed_bots: crate::bot_interface::addressed_bots(rumor.tags.iter()),
    };

    Ok(RumorProcessingResult::FileAttachment(msg))
}

/// Process a NIP-09 deletion rumor (Layer 2 cooperative hide).
///
/// Extracts the target event id from the `["e", ...]` tag. Authorization
/// (sender pubkey == original message author) is verified at commit
/// time so callers can short-circuit without an extra DB hit at parse.
/// The single `e`-tag target id, or `None` if absent OR ambiguous (multiple `e` tags). A reaction,
/// edit, and deletion each act on ONE specific message, so a first-of-many match could route to the
/// wrong target — reject ambiguity for every transport (shared hardening; honest senders emit exactly
/// one `e` tag). This mirrors Concord's `unique_tag` discipline and extends it to DMs.
fn unique_event_ref(rumor: &RumorEvent) -> Option<String> {
    let mut matches = rumor.tags.iter().filter(|t| t.kind() == "e");
    let first = matches.next()?;
    if matches.next().is_some() {
        return None;
    }
    first.content().map(|s| s.to_string())
}

/// Parse the NIP-40 `["expiration", <unix secs>]` tag off an inbound rumor.
/// Present on Self-Destruct Timer messages; drives the local countdown + purge.
fn extract_nip40_expiration(rumor: &RumorEvent) -> Option<u64> {
    rumor.tags.iter().find_map(|tag| {
        let s = tag.as_slice();
        if s.len() >= 2 && s[0] == "expiration" {
            s[1].parse::<u64>().ok()
        } else {
            None
        }
    })
}

/// NIP-40: true when the tag's expiry already lies in the past at receipt.
fn already_expired(expiration: Option<u64>) -> bool {
    match expiration {
        Some(exp) => std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .map(|d| exp <= d.as_secs())
            .unwrap_or(false),
        None => false,
    }
}

fn process_deletion(
    rumor: RumorEvent,
    _context: RumorContext,
) -> Result<RumorProcessingResult, String> {
    let target_event_id = unique_event_ref(&rumor)
        .ok_or("Deletion target tag missing or ambiguous")?;
    Ok(RumorProcessingResult::DeletionRequest { target_event_id })
}

/// Whether a reaction's content is something Vector can render as a clean chip.
/// Everything else (a `:code:URL`, prose, a jammed-in URL, anything long or with
/// whitespace) is dropped at ingest instead of shown as an overflowing/garbled
/// reaction — the wrapper is still recorded, but no reaction is stored.
fn is_renderable_reaction(content: &str) -> bool {
    // NIP-25 like / dislike / implicit-like.
    if content.is_empty() || content == "+" || content == "-" {
        return true;
    }
    // A clean NIP-30 custom-emoji shortcode `:name:` (resolves to an image, or is
    // shown verbatim). Bounded so a giant shortcode can't slip through either.
    if let Some(inner) = content.strip_prefix(':').and_then(|s| s.strip_suffix(':')) {
        if !inner.is_empty()
            && inner.len() <= 48
            && inner.chars().all(|c| c.is_ascii_alphanumeric() || matches!(c, '_' | '~' | '-' | '+'))
        {
            return true;
        }
    }
    // Otherwise keep only a short, single-token glyph. Reject anything that would
    // stretch or break the row: long content, whitespace/newlines, or an embedded
    // URL (the `:code:https://…` fuzz). Short odd content is harmless.
    content.chars().count() <= 12
        && !content.chars().any(char::is_whitespace)
        && !content.contains("://")
}

/// Process a reaction rumor
///
/// Extracts emoji reactions to messages.
fn process_reaction(
    rumor: RumorEvent,
    _context: RumorContext,
) -> Result<RumorProcessingResult, String> {
    let reference_id = unique_event_ref(&rumor)
        .ok_or("Reaction reference tag missing or ambiguous")?;

    // Unrenderable / junk content: record the wrapper (Ignored) so it isn't
    // re-synced, but store nothing — as if the reaction never arrived.
    if !is_renderable_reaction(&rumor.content) {
        return Ok(RumorProcessingResult::Ignored);
    }

    // NIP-30: pull the first `["emoji", shortcode, url]` tag whose
    // shortcode matches the reaction content (`:shortcode:` form).
    let emoji_url = if rumor.content.starts_with(':') && rumor.content.ends_with(':')
        && rumor.content.len() >= 3
    {
        let sc = &rumor.content[1..rumor.content.len() - 1];
        rumor.tags.iter().find_map(|tag| {
            let parts: Vec<&str> = tag.as_slice().iter().map(|s| s.as_str()).collect();
            if parts.len() >= 3 && parts[0] == "emoji" && parts[1] == sc {
                Some(parts[2].to_string())
            } else {
                None
            }
        })
    } else {
        None
    };

    let reaction = Reaction {
        id: rumor.id.to_hex(),
        reference_id,
        author_id: rumor.pubkey.to_bech32().unwrap_or_else(|_| rumor.pubkey.to_hex()),
        emoji: rumor.content,
        emoji_url,
    };

    Ok(RumorProcessingResult::Reaction(reaction))
}

/// Process a message edit rumor
///
/// Extracts the edited content and references the original message.
fn process_edit_event(
    rumor: RumorEvent,
    context: RumorContext,
) -> Result<RumorProcessingResult, String> {
    let message_id = unique_event_ref(&rumor)
        .ok_or("Edit reference tag missing or ambiguous")?;

    let edited_at = extract_millisecond_timestamp(&rumor);

    // NIP-30 custom-emoji tags ride the edit so a `:shortcode:` introduced (or
    // kept) by the edit renders as its image rather than literal text.
    let emoji_tags = crate::types::EmojiTag::extract_from_tags(rumor.tags.iter());

    let tags: Vec<Vec<String>> = rumor.tags.iter()
        .map(|tag| {
            tag.as_slice().iter().map(|s| s.to_string()).collect()
        })
        .collect();

    let event = StoredEventBuilder::new()
        .id(rumor.id.to_hex())
        .kind(event_kind::MESSAGE_EDIT)
        .content(rumor.content.clone())
        .tags(tags)
        .reference_id(Some(message_id.clone()))
        .created_at(rumor.created_at.as_secs())
        .mine(context.is_mine)
        .npub(rumor.pubkey.to_bech32().ok())
        .build();

    Ok(RumorProcessingResult::Edit {
        message_id,
        new_content: rumor.content,
        edited_at,
        emoji_tags,
        event,
    })
}

/// Process application-specific data (typing indicators, etc.)
fn process_app_specific(
    rumor: RumorEvent,
    context: RumorContext,
) -> Result<RumorProcessingResult, String> {
    // Check if this is a typing indicator
    if is_typing_indicator(&rumor) {
        let expiry_tag = rumor.tags
            .find_kind("expiration")
            .ok_or("Typing indicator missing expiration tag")?;

        let expiry_timestamp: u64 = expiry_tag.content()
            .ok_or("Expiration tag has no content")?
            .parse()
            .map_err(|_| "Invalid expiration timestamp")?;

        let current_timestamp = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .map_err(|e| format!("System time error: {}", e))?
            .as_secs();

        if expiry_timestamp <= current_timestamp || expiry_timestamp > current_timestamp + 30 {
            return Ok(RumorProcessingResult::Ignored);
        }

        let profile_id = rumor.pubkey.to_bech32()
            .map_err(|e| format!("Failed to convert pubkey to bech32: {}", e))?;

        return Ok(RumorProcessingResult::TypingIndicator {
            profile_id,
            until: expiry_timestamp,
        });
    }

    // Check if this is a leave request
    if is_leave_request(&rumor) {
        let member_pubkey = rumor.pubkey.to_bech32()
            .map_err(|e| format!("Failed to convert pubkey to bech32: {}", e))?;

        return Ok(RumorProcessingResult::LeaveRequest {
            event_id: rumor.id.to_hex(),
            member_pubkey,
        });
    }

    // Check if this is a PIVX payment
    if is_pivx_payment(&rumor) {
        let gift_code = rumor.tags
            .find_kind("gift-code")
            .and_then(|tag| tag.content())
            .ok_or("PIVX payment missing gift-code tag")?
            .to_string();

        let amount_str = rumor.tags
            .find_kind("amount")
            .and_then(|tag| tag.content())
            .unwrap_or("0");
        let amount_piv = amount_str.parse::<u64>().unwrap_or(0) as f64 / 100_000_000.0;

        let address = rumor.tags
            .find_kind("address")
            .and_then(|tag| tag.content())
            .map(|s| s.to_string());

        let message_id = rumor.id.to_hex();

        let tags: Vec<Vec<String>> = rumor.tags.iter()
            .map(|tag| tag.as_slice().iter().map(|s| s.to_string()).collect())
            .collect();

        let event = StoredEventBuilder::new()
            .id(&message_id)
            .kind(event_kind::APPLICATION_SPECIFIC)
            .chat_id(0) // Will be set by caller
            .content(&rumor.content)
            .tags(tags)
            .created_at(rumor.created_at.as_secs())
            .mine(context.is_mine)
            .npub(Some(rumor.pubkey.to_bech32().unwrap_or_default()))
            .build();

        return Ok(RumorProcessingResult::PivxPayment {
            gift_code,
            amount_piv,
            address,
            message_id,
            event,
        });
    }

    // Check if this is a wallpaper change. Tags carry the encrypted file
    // ref; the caller decides whether this beats the chat's current
    // `wallpaper_ts` and runs the download+decrypt step.
    if is_wallpaper_change(&rumor) {
        // A wallpaper rumor with no `url` is a removal tombstone — the sender
        // cleared their wallpaper. The url/key/nonce are absent in that case,
        // so they're optional here; the apply step treats an empty url as
        // "revert to default theme".
        let url = rumor.tags
            .find_kind("url")
            .and_then(|tag| tag.content())
            .unwrap_or_default()
            .to_string();
        let decryption_key = rumor.tags
            .find_kind("decryption-key")
            .and_then(|tag| tag.content())
            .unwrap_or_default()
            .to_string();
        let decryption_nonce = rumor.tags
            .find_kind("decryption-nonce")
            .and_then(|tag| tag.content())
            .unwrap_or_default()
            .to_string();
        let plaintext_hash = rumor.tags
            .find_kind("x")
            .and_then(|tag| tag.content())
            .map(|s| s.to_string());
        let mime = rumor.tags
            .find_kind("m")
            .and_then(|tag| tag.content())
            .map(|s| s.to_string());
        let blur = rumor.tags
            .find_kind("blur")
            .and_then(|tag| tag.content())
            .and_then(|s| s.parse::<u32>().ok())
            .map(|n| n.min(30) as u8);
        let dim = rumor.tags
            .find_kind("dim")
            .and_then(|tag| tag.content())
            .and_then(|s| s.parse::<u32>().ok())
            .map(|n| n.min(100) as u8);

        return Ok(RumorProcessingResult::WallpaperChanged {
            sender_npub: rumor.pubkey.to_bech32().unwrap_or_default(),
            created_at: rumor.created_at.as_secs(),
            url,
            decryption_key,
            decryption_nonce,
            plaintext_hash,
            mime,
            blur,
            dim,
            event_id: rumor.id.to_hex(),
        });
    }

    // Check if this is a WebXDC peer advertisement
    if is_webxdc_peer_advertisement(&rumor) {
        log_info!("[WEBXDC] Found peer advertisement rumor, is_mine={}, sender={}",
            context.is_mine,
            rumor.pubkey.to_bech32().unwrap_or_else(|_| "unknown".to_string()));

        if context.is_mine {
            log_info!("[WEBXDC] Ignoring our own peer advertisement");
            return Ok(RumorProcessingResult::Ignored);
        }

        log_info!("[WEBXDC] Detected peer advertisement in rumor from another device");

        let topic_id = rumor.tags
            .find_kind("webxdc-topic")
            .and_then(|tag| tag.content())
            .ok_or("Peer advertisement missing webxdc-topic tag")?
            .to_string();

        let node_addr = rumor.tags
            .find_kind("webxdc-node-addr")
            .and_then(|tag| tag.content())
            .ok_or("Peer advertisement missing webxdc-node-addr tag")?
            .to_string();

        let sender_npub = rumor.pubkey.to_bech32().unwrap_or_default();
        return Ok(RumorProcessingResult::WebxdcPeerAdvertisement {
            event_id: rumor.id.to_hex(),
            topic_id,
            node_addr,
            sender_npub,
            created_at: rumor.created_at.as_secs(),
        });
    }

    // Check if this is a WebXDC peer-left signal
    if is_webxdc_peer_left(&rumor) {
        if context.is_mine {
            return Ok(RumorProcessingResult::Ignored);
        }

        log_info!("[WEBXDC] Detected peer-left signal from another device");

        let topic_id = rumor.tags
            .find_kind("webxdc-topic")
            .and_then(|tag| tag.content())
            .ok_or("Peer-left missing webxdc-topic tag")?
            .to_string();

        let sender_npub = rumor.pubkey.to_bech32().unwrap_or_default();
        return Ok(RumorProcessingResult::WebxdcPeerLeft {
            event_id: rumor.id.to_hex(),
            topic_id,
            sender_npub,
            created_at: rumor.created_at.as_secs(),
        });
    }

    // Unknown application-specific data
    Ok(RumorProcessingResult::Ignored)
}

/// Check if a rumor is a WebXDC peer advertisement
fn is_webxdc_peer_advertisement(rumor: &RumorEvent) -> bool {
    rumor.content == "peer-advertisement"
        && rumor.tags.find_kind("webxdc-topic").is_some()
        && rumor.tags.find_kind("webxdc-node-addr").is_some()
}

/// Check if a rumor is a WebXDC peer-left signal
fn is_webxdc_peer_left(rumor: &RumorEvent) -> bool {
    rumor.content == "peer-left"
        && rumor.tags.find_kind("webxdc-topic").is_some()
}

/// Check if a rumor is a PIVX payment
fn is_pivx_payment(rumor: &RumorEvent) -> bool {
    rumor.tags
        .find_kind("d")
        .and_then(|tag| tag.content())
        .map(|content| content == "pivx-payment")
        .unwrap_or(false)
        && rumor.tags.find_kind("gift-code").is_some()
}

// ============================================================================
// Helper Functions
// ============================================================================

/// Extract millisecond-precision timestamp from rumor
///
/// Combines the rumor's created_at (seconds) with a custom "ms" tag
/// to provide millisecond precision for accurate message ordering.
fn extract_millisecond_timestamp(rumor: &RumorEvent) -> u64 {
    let ms_tag = rumor.tags
        .find_kind("ms")
        .and_then(|t| t.content());
    resolve_message_timestamp(rumor.created_at.as_secs(), ms_tag)
}

/// Resolve a message's ordering timestamp (epoch ms) from its second-resolution `created_at` and an
/// optional `ms` sub-second offset tag. ONE implementation for every transport — DMs and Concord share
/// the exact ms convention AND the anti-abuse clamp.
///
/// - The `ms` tag is a 0..=999 sub-second offset (senders decompose `created_at = ms/1000`,
///   `tag = ms%1000`); an out-of-range or unparseable tag is ignored, falling back to whole seconds.
/// - The inner event escapes relay far-future clamping (DM rumors and Concord inners are both
///   encrypted and never published bare), so a hostile sender could stamp `created_at` year-9999 to
///   pin a message to the top forever. Clamp an implausible-future result back to receipt time; a few
///   minutes' grace absorbs clock skew.
pub fn resolve_message_timestamp(created_at_secs: u64, ms_tag: Option<&str>) -> u64 {
    const FUTURE_GRACE_MS: u64 = 5 * 60 * 1000;
    let base = created_at_secs.saturating_mul(1000);
    let at = match ms_tag.and_then(|s| s.parse::<u64>().ok()) {
        Some(offset) if offset <= 999 => base.saturating_add(offset),
        _ => base,
    };
    let now_ms = std::time::SystemTime::now()
        .duration_since(std::time::UNIX_EPOCH)
        .map(|d| d.as_millis() as u64)
        .unwrap_or(u64::MAX);
    if at > now_ms.saturating_add(FUTURE_GRACE_MS) { now_ms } else { at }
}

/// Extract reply reference from rumor tags
///
/// Looks for an "e" tag with the "reply" marker to identify
/// which message this rumor is replying to.
fn extract_reply_reference(rumor: &RumorEvent) -> String {
    match rumor.tags.find_kind("e") {
        // Marker sits at index 3 of the raw tag (`["e", id, relay, "reply"]`).
        Some(tag) if tag.as_slice().get(3).is_some_and(|s| s == "reply") => {
            tag.content().unwrap_or("").to_string()
        }
        _ => String::new(),
    }
}

/// Check if rumor is a typing indicator
fn is_typing_indicator(rumor: &RumorEvent) -> bool {
    let has_vector_tag = rumor.tags
        .find_kind("d")
        .and_then(|tag| tag.content())
        .map(|content| content == "vector")
        .unwrap_or(false);

    let is_typing_content = rumor.content == "typing";

    has_vector_tag && is_typing_content
}

/// Check if rumor is a wallpaper-change application-data event.
fn is_wallpaper_change(rumor: &RumorEvent) -> bool {
    rumor.tags
        .find_kind("d")
        .and_then(|tag| tag.content())
        .map(|content| content == "vector-wallpaper")
        .unwrap_or(false)
}

/// Check if rumor is a leave request
fn is_leave_request(rumor: &RumorEvent) -> bool {
    let has_vector_tag = rumor.tags
        .find_kind("d")
        .and_then(|tag| tag.content())
        .map(|content| content == "vector")
        .unwrap_or(false);

    let is_leave_content = rumor.content == "leave";

    has_vector_tag && is_leave_content
}

#[cfg(test)]
mod tests {
    use super::*;

    /// One ms resolver for every transport: sub-second offset convention + future-clamp.
    /// Without the clamp a year-9999 `created_at` would pin a message to the top forever — the shared
    /// resolver enforces it for DMs too.
    #[test]
    fn ms_resolver_applies_offset_enforces_sub_second_and_clamps_future() {
        // created_at seconds + a valid 0..=999 offset.
        assert_eq!(resolve_message_timestamp(1500, Some("242")), 1_500_242);
        // No tag → whole-second resolution.
        assert_eq!(resolve_message_timestamp(1500, None), 1_500_000);
        // Out-of-range offset (>999) or junk is ignored, never added.
        assert_eq!(resolve_message_timestamp(1500, Some("4242")), 1_500_000);
        assert_eq!(resolve_message_timestamp(1500, Some("nope")), 1_500_000);
        // Far-future created_at (year ~9999) is clamped back to ~now — can't dominate ordering.
        let now = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH).unwrap().as_secs();
        let clamped = resolve_message_timestamp(253_402_300_800, Some("5"));
        assert!(clamped <= (now + 3600) * 1000, "implausible-future ms must clamp to ~now");
    }

    /// The dup-`e` target reject moved from Concord's `open_message` into the SHARED parser, so it now
    /// guards BOTH transports: a reaction/edit/delete naming TWO targets is ambiguous and rejected
    /// (a single, unambiguous target parses fine).
    #[test]
    fn ambiguous_target_is_rejected_for_reaction_edit_delete() {
        let keys = test_keypair();
        let two_e = || tags(vec![
            Tag::custom("e", ["aa".repeat(32)]),
            Tag::custom("e", ["bb".repeat(32)]),
        ]);
        assert!(process_rumor(make_rumor(&keys, Kind::Reaction, "🔥", two_e()), dm_context(&keys), &temp_dir()).is_err());
        assert!(process_rumor(make_rumor(&keys, Kind::EventDeletion, "", two_e()), dm_context(&keys), &temp_dir()).is_err());
        assert!(process_rumor(make_rumor(&keys, Kind::from(event_kind::MESSAGE_EDIT), "edited", two_e()), dm_context(&keys), &temp_dir()).is_err());
        let one_e = tags(vec![Tag::custom("e", ["aa".repeat(32)])]);
        assert!(process_rumor(make_rumor(&keys, Kind::Reaction, "🔥", one_e), dm_context(&keys), &temp_dir()).is_ok());
    }

    fn test_keypair() -> Keys {
        Keys::generate()
    }

    /// Build a Tags collection from Tag items
    fn tags(items: Vec<Tag>) -> Tags {
        let mut t = Tags::new();
        for item in items {
            t.push(item);
        }
        t
    }

    /// Create a custom tag (e.g., ["ms", "456"])
    fn custom_tag(key: &str, values: &[&str]) -> Tag {
        let owned: Vec<String> = values.iter().map(|s| s.to_string()).collect();
        Tag::custom(key.to_string(), owned)
    }

    fn make_rumor(keys: &Keys, kind: Kind, content: &str, t: Tags) -> RumorEvent {
        RumorEvent {
            id: EventId::from_byte_array([0u8; 32]),
            kind,
            content: content.to_string(),
            tags: t,
            created_at: Timestamp::from_secs(1700000000),
            pubkey: keys.public_key(),
        }
    }

    fn dm_context(keys: &Keys) -> RumorContext {
        RumorContext {
            sender: keys.public_key(),
            is_mine: false,
            conversation_id: "npub1test".to_string(),
            conversation_type: ConversationType::DirectMessage,
        }
    }

    fn temp_dir() -> std::path::PathBuf {
        std::env::temp_dir().join("vector-rumor-test")
    }

    // ========================================================================
    // Text Message Tests
    // ========================================================================

    #[test]
    fn test_text_message_dm() {
        let keys = test_keypair();
        let rumor = make_rumor(&keys, Kind::PrivateDirectMessage, "Hello world!", Tags::new());
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::TextMessage(msg) => {
                assert_eq!(msg.content, "Hello world!");
                assert!(!msg.mine);
                assert!(msg.npub.is_none());
                assert!(msg.attachments.is_empty());
            }
            _ => panic!("Expected TextMessage"),
        }
    }

    #[test]
    fn test_text_message_mine() {
        let keys = test_keypair();
        let rumor = make_rumor(&keys, Kind::PrivateDirectMessage, "My own message", Tags::new());
        let ctx = RumorContext {
            sender: keys.public_key(),
            is_mine: true,
            conversation_id: "npub1test".to_string(),
            conversation_type: ConversationType::DirectMessage,
        };
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::TextMessage(msg) => {
                assert!(msg.mine);
            }
            _ => panic!("Expected TextMessage"),
        }
    }

    #[test]
    fn test_text_message_with_reply() {
        let keys = test_keypair();
        let t = tags(vec![
            Tag::custom("e", ["abc123def456".to_string(), String::new(), "reply".to_string()]),
        ]);
        let rumor = make_rumor(&keys, Kind::PrivateDirectMessage, "Reply text", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::TextMessage(msg) => {
                assert_eq!(msg.replied_to, "abc123def456");
            }
            _ => panic!("Expected TextMessage"),
        }
    }

    #[test]
    fn test_text_message_with_ms_timestamp() {
        let keys = test_keypair();
        let t = tags(vec![custom_tag("ms", &["456"])]);
        let rumor = make_rumor(&keys, Kind::PrivateDirectMessage, "Precise time", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::TextMessage(msg) => {
                assert_eq!(msg.at, 1700000000 * 1000 + 456);
            }
            _ => panic!("Expected TextMessage"),
        }
    }

    // ========================================================================
    // Reaction Tests
    // ========================================================================

    #[test]
    fn test_reaction() {
        let keys = test_keypair();
        let t = tags(vec![custom_tag("e", &["target_msg_id_hex"])]);
        let rumor = make_rumor(&keys, Kind::Reaction, "👍", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::Reaction(reaction) => {
                assert_eq!(reaction.emoji, "👍");
                assert_eq!(reaction.reference_id, "target_msg_id_hex");
            }
            _ => panic!("Expected Reaction"),
        }
    }

    #[test]
    fn test_reaction_missing_e_tag() {
        let keys = test_keypair();
        let rumor = make_rumor(&keys, Kind::Reaction, "👍", Tags::new());
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir());
        assert!(result.is_err());
    }

    #[test]
    fn junk_reaction_content_is_dropped_clean_ones_kept() {
        // Renderable glyphs / shortcodes survive.
        for ok in ["👍", "+", "-", "", "👨\u{200d}👩\u{200d}👧\u{200d}👦", ":thugamy:"] {
            assert!(is_renderable_reaction(ok), "{ok:?} should be renderable");
        }
        // Junk (a shortcode+URL, a bare URL, prose, anything long) is dropped.
        for junk in [
            ":thugamy:https://image.nostr.build/ccc22.png",
            "https://example.com/x.png",
            "lorem ipsum dolor",
        ] {
            assert!(!is_renderable_reaction(junk), "{junk:?} should be dropped");
        }
        assert!(!is_renderable_reaction(&"x".repeat(64)));

        // End-to-end: the reported junk reaction resolves to Ignored, not Reaction.
        let keys = test_keypair();
        let t = tags(vec![custom_tag("e", &["target"])]);
        let rumor = make_rumor(&keys, Kind::Reaction, ":thugamy:https://image.nostr.build/ccc22.png", t);
        let result = process_rumor(rumor, dm_context(&keys), &temp_dir()).unwrap();
        assert!(matches!(result, RumorProcessingResult::Ignored), "junk reaction should be Ignored");
    }

    // ========================================================================
    // Edit Tests
    // ========================================================================

    #[test]
    fn test_edit_event() {
        let keys = test_keypair();
        let t = tags(vec![custom_tag("e", &["original_msg_id"])]);
        let rumor = make_rumor(&keys, Kind::from_u16(16), "Edited content", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::Edit { message_id, new_content, event, .. } => {
                assert_eq!(message_id, "original_msg_id");
                assert_eq!(new_content, "Edited content");
                assert_eq!(event.kind, event_kind::MESSAGE_EDIT);
            }
            _ => panic!("Expected Edit"),
        }
    }

    // ========================================================================
    // Typing Indicator Tests
    // ========================================================================

    #[test]
    fn test_typing_indicator_valid() {
        let keys = test_keypair();
        let future_ts = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH).unwrap()
            .as_secs() + 10;
        let t = tags(vec![
            Tag::identifier("vector"),
            Tag::expiration(Timestamp::from_secs(future_ts)),
        ]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "typing", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::TypingIndicator { until, .. } => {
                assert_eq!(until, future_ts);
            }
            _ => panic!("Expected TypingIndicator"),
        }
    }

    #[test]
    fn test_typing_indicator_expired() {
        let keys = test_keypair();
        let t = tags(vec![
            Tag::identifier("vector"),
            Tag::expiration(Timestamp::from_secs(1000000000)),
        ]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "typing", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        assert!(matches!(result, RumorProcessingResult::Ignored));
    }

    // ========================================================================
    // NIP-40 receipt-drop tests
    // ========================================================================

    #[test]
    fn test_expired_text_message_is_dropped_on_receipt() {
        let keys = test_keypair();
        let t = tags(vec![Tag::expiration(Timestamp::from_secs(1000000000))]);
        let rumor = make_rumor(&keys, Kind::PrivateDirectMessage, "too late", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();
        assert!(matches!(result, RumorProcessingResult::Ignored));
    }

    #[test]
    fn test_expired_file_message_is_dropped_on_receipt() {
        let keys = test_keypair();
        let ox_hash = "deadbeef".repeat(8);
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["11223344"]),
            custom_tag("ox", &[&ox_hash]),
            custom_tag("file-type", &["image/jpeg"]),
            Tag::expiration(Timestamp::from_secs(1000000000)),
        ]);
        let rumor = make_rumor(&keys, Kind::from_u16(15), "https://blossom.example/deadbeef.jpg", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();
        assert!(matches!(result, RumorProcessingResult::Ignored));
    }

    #[test]
    fn test_future_expiration_still_processes() {
        let keys = test_keypair();
        let future_ts = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH).unwrap()
            .as_secs() + 600;
        let t = tags(vec![Tag::expiration(Timestamp::from_secs(future_ts))]);
        let rumor = make_rumor(&keys, Kind::PrivateDirectMessage, "still alive", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();
        match result {
            RumorProcessingResult::TextMessage(msg) => {
                assert_eq!(msg.expiration, Some(future_ts));
            }
            _ => panic!("Expected TextMessage"),
        }
    }

    // ========================================================================
    // Leave Request Tests
    // ========================================================================

    #[test]
    fn test_leave_request() {
        let keys = test_keypair();
        let t = tags(vec![Tag::identifier("vector")]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "leave", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::LeaveRequest { member_pubkey, .. } => {
                assert!(!member_pubkey.is_empty());
                assert!(member_pubkey.starts_with("npub1"));
            }
            _ => panic!("Expected LeaveRequest"),
        }
    }

    // ========================================================================
    // PIVX Payment Tests
    // ========================================================================

    #[test]
    fn test_pivx_payment() {
        let keys = test_keypair();
        let t = tags(vec![
            Tag::identifier("pivx-payment"),
            custom_tag("gift-code", &["ABC12"]),
            custom_tag("amount", &["100000000"]),
            custom_tag("address", &["DTest123"]),
        ]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "pivx-payment", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::PivxPayment { gift_code, amount_piv, address, .. } => {
                assert_eq!(gift_code, "ABC12");
                assert!((amount_piv - 1.0).abs() < f64::EPSILON);
                assert_eq!(address, Some("DTest123".to_string()));
            }
            _ => panic!("Expected PivxPayment"),
        }
    }

    // ========================================================================
    // WebXDC Tests
    // ========================================================================

    #[test]
    fn test_webxdc_peer_advertisement() {
        let keys = test_keypair();
        let t = tags(vec![
            custom_tag("webxdc-topic", &["topic123"]),
            custom_tag("webxdc-node-addr", &["addr456"]),
        ]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "peer-advertisement", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::WebxdcPeerAdvertisement { topic_id, node_addr, .. } => {
                assert_eq!(topic_id, "topic123");
                assert_eq!(node_addr, "addr456");
            }
            _ => panic!("Expected WebxdcPeerAdvertisement"),
        }
    }

    #[test]
    fn test_webxdc_peer_advertisement_own_ignored() {
        let keys = test_keypair();
        let t = tags(vec![
            custom_tag("webxdc-topic", &["topic123"]),
            custom_tag("webxdc-node-addr", &["addr456"]),
        ]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "peer-advertisement", t);
        let ctx = RumorContext {
            sender: keys.public_key(),
            is_mine: true,
            conversation_id: "npub1test".to_string(),
            conversation_type: ConversationType::DirectMessage,
        };
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();
        assert!(matches!(result, RumorProcessingResult::Ignored));
    }

    #[test]
    fn test_webxdc_peer_left() {
        let keys = test_keypair();
        let t = tags(vec![custom_tag("webxdc-topic", &["topic123"])]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "peer-left", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::WebxdcPeerLeft { topic_id, .. } => {
                assert_eq!(topic_id, "topic123");
            }
            _ => panic!("Expected WebxdcPeerLeft"),
        }
    }

    // ========================================================================
    // Unknown Event Tests
    // ========================================================================

    #[test]
    fn test_unknown_kind() {
        let keys = test_keypair();
        let rumor = make_rumor(&keys, Kind::from_u16(65535), "Mystery event", Tags::new());
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::UnknownEvent(event) => {
                assert_eq!(event.kind, 65535);
                assert_eq!(event.content, "Mystery event");
            }
            _ => panic!("Expected UnknownEvent"),
        }
    }

    // ========================================================================
    // File Attachment Tests
    // ========================================================================

    #[test]
    fn test_file_attachment() {
        let keys = test_keypair();
        let ox_hash = "deadbeef".repeat(8); // 64 hex chars
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["11223344"]),
            custom_tag("ox", &[&ox_hash]),
            custom_tag("file-type", &["image/jpeg"]),
            custom_tag("name", &["photo.jpg"]),
            custom_tag("size", &["12345"]),
        ]);
        let rumor = make_rumor(&keys, Kind::from_u16(15), "https://blossom.example/deadbeef.jpg", t);
        let ctx = dm_context(&keys);
        let dir = temp_dir();
        let result = process_rumor(rumor, ctx, &dir).unwrap();

        match result {
            RumorProcessingResult::FileAttachment(msg) => {
                assert_eq!(msg.attachments.len(), 1);
                let att = &msg.attachments[0];
                assert_eq!(att.key, "aabbccdd");
                assert_eq!(att.nonce, "11223344");
                assert_eq!(att.extension, "jpg");
                assert_eq!(att.name, "photo.jpg");
                assert_eq!(att.size, 12345);
                assert!(!att.downloaded);
            }
            _ => panic!("Expected FileAttachment"),
        }
    }

    #[test]
    fn test_file_attachment_fallback_mirrors() {
        let keys = test_keypair();
        let ox_hash = "deadbeef".repeat(8);
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["11223344"]),
            custom_tag("ox", &[&ox_hash]),
            custom_tag("file-type", &["image/jpeg"]),
            custom_tag("fallback", &["https://mirror-one.example/deadbeef.jpg"]),
            // Junk a sender could stuff in: primary dup, plain http,
            // whitespace smuggle, mirror dup.
            custom_tag("fallback", &["https://blossom.example/deadbeef.jpg"]),
            custom_tag("fallback", &["http://insecure.example/deadbeef.jpg"]),
            custom_tag("fallback", &["https://sneaky.example/a b.jpg"]),
            custom_tag("fallback", &["https://mirror-one.example/deadbeef.jpg"]),
            custom_tag("fallback", &["https://mirror-two.example/deadbeef.jpg"]),
        ]);
        let rumor = make_rumor(&keys, Kind::from_u16(15), "https://blossom.example/deadbeef.jpg", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::FileAttachment(msg) => {
                let att = &msg.attachments[0];
                assert_eq!(att.fallback_urls, vec![
                    "https://mirror-one.example/deadbeef.jpg".to_string(),
                    "https://mirror-two.example/deadbeef.jpg".to_string(),
                ]);
            }
            _ => panic!("Expected FileAttachment"),
        }
    }

    #[test]
    fn test_file_attachment_hostile_path_basis_rejected() {
        let keys = test_keypair();
        let dir = temp_dir();
        let ctx = || dm_context(&keys);

        // Traversal via ox: non-hex basis is ignored → the identity falls back
        // to the nonce+url digest (always clean hex) and never leaves the
        // download dir.
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["11223344"]),
            custom_tag("ox", &["../../../etc/passwd"]),
            custom_tag("file-type", &["image/jpeg"]),
            custom_tag("name", &["x.jpg"]),
        ]);
        let rumor = make_rumor(&keys, Kind::from_u16(15), "https://blossom.example/x.jpg", t);
        let expected_id = crate::crypto::attachment_identity_basis(None, "11223344", "https://blossom.example/x.jpg");
        match process_rumor(rumor, ctx(), &dir).unwrap() {
            RumorProcessingResult::FileAttachment(msg) => {
                let att = &msg.attachments[0];
                assert!(!att.path.contains(".."), "traversal basis must not reach the path: {}", att.path);
                assert_eq!(att.id, expected_id, "id falls back to the nonce+url digest");
            }
            _ => panic!("Expected FileAttachment"),
        }

        // Traversal via the nonce (no ox): hard reject, nothing to fall back to.
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["../../../etc/cron.d/evil"]),
            custom_tag("file-type", &["image/jpeg"]),
        ]);
        let rumor = make_rumor(&keys, Kind::from_u16(15), "https://blossom.example/y.jpg", t);
        assert!(process_rumor(rumor, ctx(), &dir).is_err());
    }

    #[test]
    fn test_file_attachment_empty_hash_rejected() {
        let keys = test_keypair();
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["11223344"]),
            custom_tag("file-type", &["image/jpeg"]),
        ]);
        let empty_hash = "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855";
        let rumor = make_rumor(&keys, Kind::from_u16(15), &format!("https://blossom.example/{}", empty_hash), t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir());
        assert!(result.is_err());
    }

    #[test]
    fn test_file_attachment_with_image_meta() {
        let keys = test_keypair();
        let ox_hash = "a".repeat(64);
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["11223344"]),
            custom_tag("ox", &[&ox_hash]),
            custom_tag("file-type", &["image/png"]),
            custom_tag("thumbhash", &["base64data"]),
            custom_tag("dim", &["1920x1080"]),
            custom_tag("size", &["5000"]),
        ]);
        let rumor = make_rumor(&keys, Kind::from_u16(15), "https://blossom.example/aaa.png", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::FileAttachment(msg) => {
                let att = &msg.attachments[0];
                let meta = att.img_meta.as_ref().unwrap();
                assert_eq!(meta.width, 1920);
                assert_eq!(meta.height, 1080);
                assert_eq!(meta.thumbhash, "base64data");
            }
            _ => panic!("Expected FileAttachment"),
        }
    }

    /// Guards the send/receive tag-name contract: the sender emits the
    /// thumbhash under `thumb` (sending.rs), so the receiver MUST read it from
    /// `thumb`. These had diverged (`thumb` vs `thumbhash`), silently dropping
    /// img_meta on every received image. The test above uses the `thumbhash`
    /// alias; this one uses the real wire tag.
    #[test]
    fn test_file_attachment_thumb_tag_is_read() {
        let keys = test_keypair();
        let ox_hash = "b".repeat(64);
        let t = tags(vec![
            custom_tag("decryption-key", &["aabbccdd"]),
            custom_tag("decryption-nonce", &["11223344"]),
            custom_tag("ox", &[&ox_hash]),
            custom_tag("file-type", &["image/png"]),
            custom_tag("thumb", &["realwiretag"]),
            custom_tag("dim", &["800x600"]),
            custom_tag("size", &["5000"]),
        ]);
        let rumor = make_rumor(&keys, Kind::from_u16(15), "https://blossom.example/bbb.png", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();

        match result {
            RumorProcessingResult::FileAttachment(msg) => {
                let meta = msg.attachments[0].img_meta.as_ref()
                    .expect("img_meta must be populated from the `thumb` tag");
                assert_eq!(meta.thumbhash, "realwiretag");
                assert_eq!(meta.width, 800);
                assert_eq!(meta.height, 600);
            }
            _ => panic!("Expected FileAttachment"),
        }
    }

    // ========================================================================
    // Helper Function Tests
    // ========================================================================

    #[test]
    fn test_extract_hash_from_blossom_url() {
        let hash = "a".repeat(64);
        let url = format!("https://blossom.example/{}.jpg", hash);
        assert_eq!(extract_hash_from_blossom_url(&url), Some(hash));

        assert_eq!(extract_hash_from_blossom_url("https://example.com/short"), None);
        assert_eq!(extract_hash_from_blossom_url("https://example.com/not-hex-at-all-but-exactly-sixty-four-characters-long-string-here!"), None);
    }

    #[test]
    fn test_unknown_app_specific_ignored() {
        let keys = test_keypair();
        let t = tags(vec![Tag::identifier("some-other-app")]);
        let rumor = make_rumor(&keys, Kind::ApplicationSpecificData, "unknown-content", t);
        let ctx = dm_context(&keys);
        let result = process_rumor(rumor, ctx, &temp_dir()).unwrap();
        assert!(matches!(result, RumorProcessingResult::Ignored));
    }
}