Message queue

let tokens = cx.theme().semantic_tokens();
let status: SharedString = self
    .last_queue_event
    .clone()
    .unwrap_or_else(|| "Reorder, edit, send now, or remove a waiting prompt".into());
v_flex()
    .gap(tokens.spacing.md)
    .child(
        MessageQueue::new("queue")
            .items(self.queued.iter().cloned())
            .editable(true)
            .on_event(cx.listener(|this, event: &QueueEvent, _, cx| {
                match event {
                    QueueEvent::Removed { id } | QueueEvent::SentNow { id } => {
                        this.queued.retain(|item| item.id() != id);
                    }
                    QueueEvent::MovedUp { id } => {
                        if let Some(index) =
                            this.queued.iter().position(|item| item.id() == id)
                            && index > 0
                        {
                            this.queued.swap(index, index - 1);
                        }
                    }
                    QueueEvent::MovedDown { id } => {
                        if let Some(index) =
                            this.queued.iter().position(|item| item.id() == id)
                            && index + 1 < this.queued.len()
                        {
                            this.queued.swap(index, index + 1);
                        }
                    }
                    QueueEvent::EditRequested { .. } => {}
                    QueueEvent::Cleared => this.queued.clear(),
                }
                this.last_queue_event = Some(format!("{event:?}").into());
                cx.notify();
            })),
    )
    .when(self.queued.is_empty(), |this| {
        this.child(
            Button::new("queue-refill")
                .outline()
                .small()
                .text_label("Queue the demo prompts again")
                .on_click(cx.listener(|this, _, _, cx| {
                    this.queued = demo_queue();
                    this.last_queue_event = Some("Refilled".into());
                    cx.notify();
                })),
        )
    })
    .child(
        div()
            .id("queue-story-status")
            .role(Role::Status)
            .aria_label(status.clone())
            .text_xs()
            .text_color(cx.theme().muted_foreground)
            .child(status),
    )