use axum::extract::{Json, Path, State};
use futures::stream::{self, StreamExt as _};

use crate::{
    conversation,
    event::Sequenced,
    message::app::SendError,
    test::fixtures::{self, future::Expect as _},
};

#[tokio::test]
async fn messages_in_order() {
    // Set up the environment

    let app = fixtures::scratch_app().await;
    let sender = fixtures::identity::create(&app, &fixtures::now()).await;
    let conversation = fixtures::conversation::create(&app, &fixtures::now()).await;
    let resume_point = fixtures::boot::resume_point(&app).await;

    // Call the endpoint (twice)

    let requests = vec![
        (fixtures::now(), fixtures::message::propose()),
        (fixtures::now(), fixtures::message::propose()),
    ];

    for (sent_at, body) in &requests {
        let request = super::Request { body: body.clone() };

        let _ = super::handler(
            State(app.clone()),
            Path(conversation.id.clone()),
            sent_at.clone(),
            sender.clone(),
            Json(request),
        )
        .await
        .expect("sending to a valid conversation succeeds");
    }

    // Verify the semantics

    let mut events = app
        .events()
        .subscribe(resume_point)
        .await
        .expect("subscribing always succeeds")
        .filter_map(fixtures::event::stream::message)
        .filter_map(fixtures::event::stream::message::sent)
        .zip(stream::iter(requests));

    while let Some((event, (sent_at, body))) = events
        .next()
        .expect_ready("an event should be ready for each message")
        .await
    {
        assert_eq!(*sent_at, event.at());
        assert_eq!(sender.user.id, event.message.sender);
        assert_eq!(body, event.message.body);
    }
}

#[tokio::test]
async fn nonexistent_conversation() {
    // Set up the environment

    let app = fixtures::scratch_app().await;
    let sender = fixtures::identity::create(&app, &fixtures::now()).await;

    // Call the endpoint

    let sent_at = fixtures::now();
    let conversation = conversation::Id::generate();
    let request = super::Request {
        body: fixtures::message::propose(),
    };
    let super::Error(error) = super::handler(
        State(app),
        Path(conversation.clone()),
        sent_at,
        sender,
        Json(request),
    )
    .await
    .expect_err("sending to a nonexistent conversation fails");

    // Verify the structure of the response

    assert!(matches!(
        error,
        SendError::ConversationNotFound(error_conversation) if conversation == error_conversation
    ));
}

#[tokio::test]
async fn deleted_conversation() {
    // Set up the environment

    let app = fixtures::scratch_app().await;
    let sender = fixtures::identity::create(&app, &fixtures::now()).await;
    let conversation = fixtures::conversation::create(&app, &fixtures::now()).await;

    app.conversations()
        .delete(&conversation.id, &fixtures::now())
        .await
        .expect("deleting a new conversation succeeds");

    // Call the endpoint

    let sent_at = fixtures::now();
    let request = super::Request {
        body: fixtures::message::propose(),
    };
    let super::Error(error) = super::handler(
        State(app),
        Path(conversation.id.clone()),
        sent_at,
        sender,
        Json(request),
    )
    .await
    .expect_err("sending to a deleted conversation fails");

    // Verify the structure of the response

    assert!(matches!(
        error,
        SendError::ConversationDeleted(error_conversation) if conversation.id == error_conversation
    ));
}