blooio 0.2.1

//! Mock-server integration tests for the blocking client (httpmock).

#![cfg(feature = "sync")]
#![allow(
    clippy::unwrap_used,
    clippy::expect_used,
    clippy::panic,
    clippy::print_stdout,
    clippy::unreadable_literal
)]

use std::time::Duration;

use blooio::resources::contacts::CreateContact;
use blooio::resources::groups::CreateGroup;
use blooio::resources::webhooks::CreateWebhook;
use blooio::{BlockingClient, ClientConfig, RetryPolicy};
use httpmock::prelude::*;

fn client(server: &MockServer) -> BlockingClient {
    BlockingClient::from_config(ClientConfig::new("test-key").with_base_url(server.base_url()))
        .unwrap()
}

#[test]
fn retries_transient_5xx_until_budget_exhausted() {
    let server = MockServer::start();
    // Always 503 with a zero Retry-After so the loop runs without real delay.
    let m = server.mock(|when, then| {
        when.method(POST).path("/contacts");
        then.status(503).header("retry-after", "0");
    });

    let client = BlockingClient::from_config(
        ClientConfig::new("test-key")
            .with_base_url(server.base_url())
            .with_retry(
                RetryPolicy::default()
                    .with_max_retries(2)
                    .with_base_delay(Duration::from_millis(1))
                    .with_jitter(false),
            ),
    )
    .unwrap();

    let err = client
        .contacts()
        .create(CreateContact::new("+15550002222"))
        .unwrap_err();
    // max_retries = 2 → 3 total attempts.
    m.assert_hits(3);
    assert_eq!(err.status(), Some(503));
    assert_eq!(err.retry_after(), Some(Duration::from_secs(0)));
}

#[test]
fn does_not_retry_when_policy_is_none() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST).path("/contacts");
        then.status(503);
    });

    let client = BlockingClient::from_config(
        ClientConfig::new("test-key")
            .with_base_url(server.base_url())
            .with_retry(RetryPolicy::none()),
    )
    .unwrap();

    let err = client
        .contacts()
        .create(CreateContact::new("+15550003333"))
        .unwrap_err();
    m.assert_hits(1);
    assert_eq!(err.status(), Some(503));
}

#[test]
fn get_sends_bearer_auth() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(GET)
            .path("/me")
            .header("Authorization", "Bearer test-key");
        then.status(200)
            .json_body(serde_json::json!({ "valid": true, "user_id": "u1" }));
    });

    let me = client(&server).account().get().unwrap();
    m.assert();
    assert_eq!(me.user_id.as_deref(), Some("u1"));
}

#[test]
fn post_sends_json_body_and_content_type() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST)
            .path("/contacts")
            .header("content-type", "application/json")
            .json_body(serde_json::json!({ "identifier": "+15551234567" }));
        then.status(201)
            .json_body(serde_json::json!({ "id": "c2", "identifier": "+15551234567" }));
    });

    let c = client(&server)
        .contacts()
        .create(CreateContact::new("+15551234567"))
        .unwrap();
    m.assert();
    assert_eq!(c.id.as_deref(), Some("c2"));
}

#[test]
fn send_message_includes_idempotency_key() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST)
            .path("/chats/chat1/messages")
            .header_exists("idempotency-key")
            .json_body(serde_json::json!({ "text": "hi" }));
        then.status(200)
            .json_body(serde_json::json!({ "message_id": "m1", "status": "sent" }));
    });

    let resp = client(&server).chat("chat1").send_text("hi").unwrap();
    m.assert();
    assert_eq!(resp.ids(), vec!["m1"]);
}

#[test]
fn delete_returns_deletion() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(DELETE).path("/contacts/c9");
        then.status(200)
            .json_body(serde_json::json!({ "success": true, "deleted_at": 1700000000_i64 }));
    });

    let resp = client(&server).contacts().delete("c9").unwrap();
    m.assert();
    assert_eq!(resp.success, Some(true));
}

#[test]
fn list_all_iterator_fetches_successive_pages() {
    // Drives the blocking paginator through its `Iterator` impl: a full page
    // keeps it live, a short page terminates it. `total` is null throughout.
    let server = MockServer::start();
    let full: Vec<_> = (0..50)
        .map(|i| serde_json::json!({ "id": format!("c{i}"), "name": "x" }))
        .collect();

    let p1 = server.mock(|when, then| {
        when.method(GET)
            .path("/contacts")
            .query_param("offset", "0")
            .query_param("limit", "50");
        then.status(200).json_body(serde_json::json!({
            "contacts": full,
            "pagination": { "limit": 50, "offset": 0, "total": null }
        }));
    });
    let p2 = server.mock(|when, then| {
        when.method(GET)
            .path("/contacts")
            .query_param("offset", "50");
        then.status(200).json_body(serde_json::json!({
            "contacts": [{ "id": "c50", "name": "x" }],
            "pagination": { "limit": 50, "offset": 50, "total": null }
        }));
    });

    let c = client(&server);
    let mut total = 0usize;
    for page in c.contacts().list_all() {
        total += page.unwrap().len();
    }
    p1.assert();
    p2.assert();
    assert_eq!(total, 51);
}

#[test]
fn malformed_body_maps_to_decode_error() {
    let server = MockServer::start();
    server.mock(|when, then| {
        when.method(GET).path("/me");
        then.status(200).body("not json");
    });

    let err = client(&server).account().get().unwrap_err();
    assert!(matches!(err, blooio::Error::Decode(_)));
    assert_eq!(err.code(), None);
    assert_eq!(err.status(), None);
}

#[test]
fn connection_refused_maps_to_transport_error() {
    let client = BlockingClient::from_config(
        ClientConfig::new("test-key")
            .with_base_url("http://127.0.0.1:1")
            .with_timeout(std::time::Duration::from_secs(2)),
    )
    .unwrap();

    let err = client.account().get().unwrap_err();
    assert!(matches!(err, blooio::Error::Transport(_)));
    assert_eq!(err.code(), None);
    assert_eq!(err.status(), None);
}

#[test]
fn error_response_maps_to_api_error() {
    let server = MockServer::start();
    server.mock(|when, then| {
        when.method(POST).path("/chats/chat1/messages");
        then.status(429).json_body(serde_json::json!({
            "error": "rate_limited",
            "message": "slow down",
            "status": 429,
            "code": "outbound_limit_reached"
        }));
    });

    let err = client(&server).chat("chat1").send_text("hi").unwrap_err();
    assert_eq!(err.status(), Some(429));
    assert_eq!(err.code(), Some("outbound_limit_reached"));
}

// ---------------------------------------------------------------------------
// Groups
// ---------------------------------------------------------------------------

#[test]
fn groups_create_posts_to_groups() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST)
            .path("/groups")
            .header("content-type", "application/json")
            .json_body(serde_json::json!({ "name": "Test Group" }));
        then.status(201)
            .json_body(serde_json::json!({ "group_id": "g1", "name": "Test Group" }));
    });

    let resp = client(&server)
        .groups()
        .create(CreateGroup::new("Test Group"))
        .unwrap();
    m.assert();
    // CreateGroup returns Json (serde_json::Value)
    assert_eq!(resp["group_id"], "g1");
}

#[test]
fn groups_get_fetches_by_id() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(GET).path("/groups/g42");
        then.status(200).json_body(serde_json::json!({
            "group_id": "g42",
            "name": "My Group",
            "member_count": 3
        }));
    });

    let group = client(&server).groups().get("g42").unwrap();
    m.assert();
    assert_eq!(group.group_id.as_deref(), Some("g42"));
    assert_eq!(group.name.as_deref(), Some("My Group"));
}

#[test]
fn groups_members_add_posts_contact_id() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST)
            .path("/groups/g1/members")
            .header("content-type", "application/json")
            .json_body(serde_json::json!({ "contact_id": "c99" }));
        then.status(200).json_body(serde_json::json!({
            "message": "Member added",
            "contact_created": false
        }));
    });

    let resp = client(&server).groups().members("g1").add("c99").unwrap();
    m.assert();
    assert_eq!(resp.message.as_deref(), Some("Member added"));
    assert_eq!(resp.contact_created, Some(false));
}

// ---------------------------------------------------------------------------
// Webhooks
// ---------------------------------------------------------------------------

#[test]
fn webhooks_create_posts_url() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST)
            .path("/webhooks")
            .header("content-type", "application/json")
            .json_body(serde_json::json!({ "webhook_url": "https://example.com/hook" }));
        then.status(201).json_body(serde_json::json!({
            "webhook_id": "wh1",
            "webhook_url": "https://example.com/hook",
            "signing_secret": "secret123"
        }));
    });

    let resp = client(&server)
        .webhooks()
        .create(CreateWebhook::new("https://example.com/hook"))
        .unwrap();
    m.assert();
    assert_eq!(resp.webhook_id.as_deref(), Some("wh1"));
    assert_eq!(
        resp.signing_secret.as_ref().map(|s| s.expose().as_str()),
        Some("secret123")
    );
}

#[test]
fn webhooks_rotate_secret_posts_to_rotate_path() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST).path("/webhooks/wh1/secret/rotate");
        then.status(200).json_body(serde_json::json!({
            "webhook_id": "wh1",
            "signing_secret": "new-secret-xyz",
            "rotated_at": 1700000000_i64,
            "rotation_count": 2
        }));
    });

    let resp = client(&server).webhooks().rotate_secret("wh1").unwrap();
    m.assert();
    assert_eq!(resp.webhook_id.as_deref(), Some("wh1"));
    assert_eq!(
        resp.signing_secret.as_ref().map(|s| s.expose().as_str()),
        Some("new-secret-xyz")
    );
    assert_eq!(resp.rotation_count, Some(2));
}

#[test]
fn webhooks_logs_list_fetches_logs_for_webhook() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(GET).path("/webhooks/wh1/logs");
        then.status(200).json_body(serde_json::json!({
            "logs": [
                { "event_id": "evt1", "response_status": 200 }
            ],
            "pagination": { "total": 1, "limit": 50, "offset": 0, "returned": 1, "has_more": false }
        }));
    });

    let resp = client(&server).webhooks().logs("wh1").list().unwrap();
    m.assert();
    assert_eq!(resp.logs.len(), 1);
    assert_eq!(resp.logs[0].event_id.as_deref(), Some("evt1"));
}

// ---------------------------------------------------------------------------
// Location
// ---------------------------------------------------------------------------

#[test]
fn location_list_fetches_contacts() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(GET).path("/location/contacts");
        then.status(200).json_body(serde_json::json!({
            "friends": [
                { "handle": "+15550001111", "status": "sharing" }
            ]
        }));
    });

    let resp = client(&server).location().list().unwrap();
    m.assert();
    assert_eq!(resp.friends.len(), 1);
    assert_eq!(resp.friends[0].handle.as_deref(), Some("+15550001111"));
}

#[test]
fn location_refresh_posts_to_refresh_path() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST).path("/location/contacts/refresh");
        then.status(200).json_body(serde_json::json!({
            "success": true,
            "friends": []
        }));
    });

    let resp = client(&server).location().refresh().unwrap();
    m.assert();
    assert_eq!(resp.success, Some(true));
}

// ---------------------------------------------------------------------------
// Phone numbers
// ---------------------------------------------------------------------------

#[test]
fn phone_numbers_lookup_uses_query_param() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(GET)
            .path("/phone-numbers/lookup")
            .query_param("number", "+15550001111");
        then.status(200).json_body(serde_json::json!({
            "input": "+15550001111",
            "valid": true,
            "e164": "+15550001111",
            "country": "US"
        }));
    });

    let resp = client(&server)
        .phone_numbers()
        .lookup("+15550001111")
        .unwrap();
    m.assert();
    assert_eq!(resp.input.as_deref(), Some("+15550001111"));
    assert_eq!(resp.valid, Some(true));
    assert_eq!(resp.country.as_deref(), Some("US"));
}

#[test]
fn phone_numbers_batch_posts_numbers_array() {
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(POST)
            .path("/phone-numbers/batch")
            .header("content-type", "application/json")
            .json_body(serde_json::json!({
                "numbers": ["+15550001111", "+15550002222"]
            }));
        then.status(200).json_body(serde_json::json!({
            "results": [
                { "input": "+15550001111", "valid": true, "e164": "+15550001111" },
                { "input": "+15550002222", "valid": true, "e164": "+15550002222" }
            ]
        }));
    });

    let resp = client(&server)
        .phone_numbers()
        .batch(vec!["+15550001111".to_string(), "+15550002222".to_string()])
        .unwrap();
    m.assert();
    assert_eq!(resp.results.len(), 2);
    assert_eq!(resp.results[0].input.as_deref(), Some("+15550001111"));
    assert_eq!(resp.results[1].input.as_deref(), Some("+15550002222"));
}

#[test]
fn custom_user_agent_is_sent() {
    // Verifies ClientConfig::with_user_agent threads through to the executor.
    let server = MockServer::start();
    let m = server.mock(|when, then| {
        when.method(GET)
            .path("/me")
            .header("User-Agent", "my-app/9.9");
        then.status(200)
            .json_body(serde_json::json!({ "valid": true, "user_id": "u1" }));
    });

    let client = BlockingClient::from_config(
        ClientConfig::new("test-key")
            .with_base_url(server.base_url())
            .with_user_agent("my-app/9.9"),
    )
    .unwrap();
    client.account().get().unwrap();
    m.assert();
}