atlassian-cli 0.4.3

use atlassian_cli_api::ApiClient;
use wiremock::matchers::{method, path, query_param};
use wiremock::{Mock, MockServer, ResponseTemplate};

// ============================================================================
// Space Operations Tests
// ============================================================================

#[tokio::test]
async fn test_list_spaces() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/spaces"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "id": "123456",
                    "key": "DOCS",
                    "name": "Documentation",
                    "type": "global",
                    "status": "current"
                },
                {
                    "id": "789012",
                    "key": "TEAM",
                    "name": "Team Space",
                    "type": "global",
                    "status": "current"
                }
            ]
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> = client.get("/wiki/api/v2/spaces").await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["results"].as_array().unwrap().len(), 2);
}

#[tokio::test]
async fn test_get_space() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/spaces"))
        .and(query_param("keys", "DOCS"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [{
                "id": "123456",
                "key": "DOCS",
                "name": "Documentation",
                "type": "global",
                "status": "current",
                "description": {
                    "plain": {
                        "value": "Documentation space"
                    }
                }
            }]
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> = client.get("/wiki/api/v2/spaces?keys=DOCS").await;

    assert!(response.is_ok());
}

#[tokio::test]
async fn test_create_space() {
    let mock_server = MockServer::start().await;

    Mock::given(method("POST"))
        .and(path("/wiki/api/v2/spaces"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "999888",
            "key": "NEW",
            "name": "New Space",
            "type": "global",
            "status": "current"
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let payload = serde_json::json!({
        "key": "NEW",
        "name": "New Space",
        "description": {"plain": {"value": "A new space"}}
    });

    let response: Result<serde_json::Value, _> = client.post("/wiki/api/v2/spaces", &payload).await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["key"], "NEW");
}

// ============================================================================
// Page Operations Tests
// ============================================================================

#[tokio::test]
async fn test_list_pages() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages"))
        .and(query_param("space-key", "DOCS"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "id": "100001",
                    "title": "Getting Started",
                    "type": "page",
                    "status": "current"
                },
                {
                    "id": "100002",
                    "title": "API Reference",
                    "type": "page",
                    "status": "current"
                }
            ]
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> =
        client.get("/wiki/api/v2/pages?space-key=DOCS").await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["results"].as_array().unwrap().len(), 2);
}

#[tokio::test]
async fn test_get_page() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100001",
            "title": "Getting Started",
            "type": "page",
            "status": "current",
            "version": {
                "number": 3,
                "message": "Updated content"
            },
            "body": {
                "storage": {
                    "value": "<p>Welcome to the documentation</p>",
                    "representation": "storage"
                }
            }
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> = client.get("/wiki/api/v2/pages/100001").await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["title"], "Getting Started");
    assert_eq!(data["version"]["number"], 3);
}

#[tokio::test]
async fn test_create_page() {
    let mock_server = MockServer::start().await;

    Mock::given(method("POST"))
        .and(path("/wiki/api/v2/pages"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "200001",
            "title": "New Page",
            "type": "page",
            "status": "current"
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let payload = serde_json::json!({
        "spaceId": "123456",
        "title": "New Page",
        "status": "current",
        "body": {
            "representation": "storage",
            "value": "<p>Page content</p>"
        }
    });

    let response: Result<serde_json::Value, _> = client.post("/wiki/api/v2/pages", &payload).await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["id"], "200001");
}

#[tokio::test]
async fn test_update_page() {
    let mock_server = MockServer::start().await;

    // First mock: get current page version
    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100001",
            "title": "Original Title",
            "version": {"number": 2}
        })))
        .mount(&mock_server)
        .await;

    // Second mock: update page
    Mock::given(method("PUT"))
        .and(path("/wiki/api/v2/pages/100001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100001",
            "title": "Updated Title",
            "version": {"number": 3}
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let payload = serde_json::json!({
        "id": "100001",
        "title": "Updated Title",
        "status": "current",
        "version": {"number": 3}
    });

    let response: Result<serde_json::Value, _> =
        client.put("/wiki/api/v2/pages/100001", &payload).await;

    assert!(response.is_ok());
}

// ============================================================================
// Blog Operations Tests
// ============================================================================

#[tokio::test]
async fn test_list_blogposts() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/blogposts"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "id": "300001",
                    "title": "Weekly Update",
                    "status": "current"
                },
                {
                    "id": "300002",
                    "title": "Release Notes",
                    "status": "current"
                }
            ]
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> = client.get("/wiki/api/v2/blogposts").await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["results"].as_array().unwrap().len(), 2);
}

#[tokio::test]
async fn test_create_blogpost() {
    let mock_server = MockServer::start().await;

    Mock::given(method("POST"))
        .and(path("/wiki/api/v2/blogposts"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "300003",
            "title": "New Blog Post",
            "status": "current"
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let payload = serde_json::json!({
        "spaceId": "123456",
        "title": "New Blog Post",
        "status": "current",
        "type": "blogpost",
        "body": {
            "representation": "storage",
            "value": "<p>Blog content</p>"
        }
    });

    let response: Result<serde_json::Value, _> =
        client.post("/wiki/api/v2/blogposts", &payload).await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["id"], "300003");
}

// ============================================================================
// Attachment Operations Tests
// ============================================================================

#[tokio::test]
async fn test_list_attachments() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100001/attachments"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "id": "att-001",
                    "title": "diagram.png",
                    "fileSize": 102400,
                    "mediaType": "image/png"
                },
                {
                    "id": "att-002",
                    "title": "report.pdf",
                    "fileSize": 524288,
                    "mediaType": "application/pdf"
                }
            ]
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> =
        client.get("/wiki/api/v2/pages/100001/attachments").await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["results"].as_array().unwrap().len(), 2);
}

#[tokio::test]
async fn test_get_attachment() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/attachments/att-001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "att-001",
            "title": "diagram.png",
            "fileSize": 102400,
            "mediaType": "image/png",
            // The real v2 API returns downloadLink relative to the /wiki context,
            // i.e. WITHOUT a /wiki prefix. The old fixture invented one, which is
            // why no test caught the dropped-/wiki download bug.
            "downloadLink": "/download/attachments/100001/diagram.png?version=1&api=v2"
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> =
        client.get("/wiki/api/v2/attachments/att-001").await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["id"], "att-001");
    assert_eq!(data["fileSize"], 102400);
}

// ============================================================================
// Search Operations Tests
// ============================================================================

#[tokio::test]
async fn test_search_cql() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/rest/api/content/search"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "content": {
                        "id": "100001",
                        "type": "page",
                        "title": "Search Result 1"
                    }
                },
                {
                    "content": {
                        "id": "100002",
                        "type": "page",
                        "title": "Search Result 2"
                    }
                }
            ],
            "size": 2
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> = client
        .get("/wiki/rest/api/content/search?cql=type%3Dpage")
        .await;

    assert!(response.is_ok());
    let data = response.unwrap();
    assert_eq!(data["size"], 2);
}

#[tokio::test]
async fn test_search_text() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/rest/api/search"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "content": {
                        "id": "100003",
                        "title": "Documentation Page"
                    }
                }
            ],
            "size": 1
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> = client
        .get("/wiki/rest/api/search?cql=text~%22documentation%22")
        .await;

    assert!(response.is_ok());
}

// ============================================================================
// Bulk Operations Tests
// ============================================================================

#[tokio::test]
async fn test_bulk_export_json() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/rest/api/content/search"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "content": {
                        "id": "100001"
                    }
                },
                {
                    "content": {
                        "id": "100002"
                    }
                }
            ]
        })))
        .mount(&mock_server)
        .await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100001",
            "title": "Page 1",
            "body": {"storage": {"value": "<p>Content 1</p>"}}
        })))
        .mount(&mock_server)
        .await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100002"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100002",
            "title": "Page 2",
            "body": {"storage": {"value": "<p>Content 2</p>"}}
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    // Test search to get page IDs
    let response: Result<serde_json::Value, _> = client
        .get("/wiki/rest/api/content/search?cql=type%3Dpage")
        .await;

    assert!(response.is_ok());
}

#[tokio::test]
async fn test_bulk_add_labels() {
    let mock_server = MockServer::start().await;

    Mock::given(method("POST"))
        .and(path("/wiki/rest/api/content/100001/label"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {"prefix": "global", "name": "archived"}
            ]
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let payload = serde_json::json!([{
        "prefix": "global",
        "name": "archived"
    }]);

    let response: Result<serde_json::Value, _> = client
        .post("/wiki/rest/api/content/100001/label", &payload)
        .await;

    assert!(response.is_ok());
}

// ============================================================================
// Draft Publishing Tests
// ============================================================================

#[tokio::test]
async fn test_publish_draft_page() {
    let mock_server = MockServer::start().await;

    // Mock: get current page (draft status)
    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100001",
            "title": "Draft Page",
            "status": "draft",
            "version": {"number": 1}
        })))
        .mount(&mock_server)
        .await;

    // Mock: publish page (PUT with version 1)
    Mock::given(method("PUT"))
        .and(path("/wiki/api/v2/pages/100001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100001",
            "title": "Draft Page",
            "status": "current",
            "version": {"number": 1, "message": "Published via CLI"}
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    // Verify we can get the draft page
    let get_response: Result<serde_json::Value, _> = client.get("/wiki/api/v2/pages/100001").await;
    assert!(get_response.is_ok());
    let data = get_response.unwrap();
    assert_eq!(data["status"], "draft");

    // Publish the page with version 1 (not incremented)
    let publish_payload = serde_json::json!({
        "id": "100001",
        "status": "current",
        "title": "Draft Page",
        "version": {"number": 1, "message": "Published via CLI"},
        "body": {
            "representation": "storage",
            "value": "<p>Published content</p>"
        }
    });

    let put_response: Result<serde_json::Value, _> = client
        .put("/wiki/api/v2/pages/100001", &publish_payload)
        .await;

    assert!(put_response.is_ok());
    let result = put_response.unwrap();
    assert_eq!(result["status"], "current");
    assert_eq!(result["version"]["number"], 1);
}

#[tokio::test]
async fn test_update_published_page_increments_version() {
    let mock_server = MockServer::start().await;

    // Mock: get current page (published, version 3)
    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100002"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100002",
            "title": "Published Page",
            "status": "current",
            "version": {"number": 3}
        })))
        .mount(&mock_server)
        .await;

    // Mock: update page (version should be 4)
    Mock::given(method("PUT"))
        .and(path("/wiki/api/v2/pages/100002"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "100002",
            "title": "Published Page Updated",
            "status": "current",
            "version": {"number": 4}
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    // Verify current version
    let get_response: Result<serde_json::Value, _> = client.get("/wiki/api/v2/pages/100002").await;
    assert!(get_response.is_ok());
    let data = get_response.unwrap();
    assert_eq!(data["version"]["number"], 3);

    // Update the page (version should increment to 4)
    let update_payload = serde_json::json!({
        "id": "100002",
        "status": "current",
        "title": "Published Page Updated",
        "version": {"number": 4}
    });

    let put_response: Result<serde_json::Value, _> = client
        .put("/wiki/api/v2/pages/100002", &update_payload)
        .await;

    assert!(put_response.is_ok());
    let result = put_response.unwrap();
    assert_eq!(result["version"]["number"], 4);
}

#[tokio::test]
async fn test_publish_draft_blogpost() {
    let mock_server = MockServer::start().await;

    // Mock: get current blog post (draft status)
    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/blogposts/300001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "300001",
            "title": "Draft Blog Post",
            "status": "draft",
            "version": {"number": 1}
        })))
        .mount(&mock_server)
        .await;

    // Mock: publish blog post (PUT with version 1)
    Mock::given(method("PUT"))
        .and(path("/wiki/api/v2/blogposts/300001"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "id": "300001",
            "title": "Draft Blog Post",
            "status": "current",
            "version": {"number": 1, "message": "Published via CLI"}
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    // Verify we can get the draft blog post
    let get_response: Result<serde_json::Value, _> =
        client.get("/wiki/api/v2/blogposts/300001").await;
    assert!(get_response.is_ok());
    let data = get_response.unwrap();
    assert_eq!(data["status"], "draft");

    // Publish the blog post with version 1
    let publish_payload = serde_json::json!({
        "id": "300001",
        "status": "current",
        "title": "Draft Blog Post",
        "version": {"number": 1, "message": "Published via CLI"},
        "body": {
            "representation": "storage",
            "value": "<p>Published blog content</p>"
        }
    });

    let put_response: Result<serde_json::Value, _> = client
        .put("/wiki/api/v2/blogposts/300001", &publish_payload)
        .await;

    assert!(put_response.is_ok());
    let result = put_response.unwrap();
    assert_eq!(result["status"], "current");
    assert_eq!(result["version"]["number"], 1);
}

// ============================================================================
// Comments
// ============================================================================

// Regression: the v2 footer-comment object has no top-level `createdAt` (it lives
// at `version.createdAt`) and only returns `body` when body-format is requested.
// The old model required a top-level `createdAt: String`, so this payload aborted
// the whole `page comments` command with "missing field `createdAt`".
#[tokio::test]
async fn test_list_page_comments_real_shape() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/api/v2/pages/100001/footer-comments"))
        .and(query_param("body-format", "storage"))
        .respond_with(ResponseTemplate::new(200).set_body_json(serde_json::json!({
            "results": [
                {
                    "id": "c-1",
                    "title": "Re: Design",
                    "version": { "number": 1, "createdAt": "2026-01-02T03:04:05Z" },
                    "body": { "storage": { "value": "<p>Looks good</p>", "representation": "storage" } }
                },
                { "id": "c-2" }
            ]
        })))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    let response: Result<serde_json::Value, _> = client
        .get("/wiki/api/v2/pages/100001/footer-comments?body-format=storage")
        .await;

    assert!(response.is_ok(), "comments request failed: {response:?}");
    let data = response.unwrap();
    let results = data["results"].as_array().unwrap();
    assert_eq!(results.len(), 2);
    assert_eq!(results[0]["version"]["createdAt"], "2026-01-02T03:04:05Z");
    assert!(results[0].get("createdAt").is_none());
}

// Regression: downloadLink is relative to the /wiki context, so the bytes must be
// fetched from /wiki + downloadLink. Fetching base_url + downloadLink dropped the
// /wiki segment and every download 404'd. Query string must survive too.
#[tokio::test]
async fn test_download_attachment_bytes_uses_wiki_prefix() {
    let mock_server = MockServer::start().await;

    Mock::given(method("GET"))
        .and(path("/wiki/download/attachments/100001/diagram.png"))
        .and(query_param("version", "1"))
        .respond_with(ResponseTemplate::new(200).set_body_bytes(b"PNGDATA".to_vec()))
        .mount(&mock_server)
        .await;

    let client = ApiClient::new(mock_server.uri())
        .unwrap()
        .with_basic_auth("test@example.com", "fake-token");

    // This is exactly the path download_attachment builds from the v2 downloadLink
    // "/download/attachments/100001/diagram.png?version=1&api=v2".
    let bytes = client
        .get_bytes("/wiki/download/attachments/100001/diagram.png?version=1&api=v2")
        .await;

    assert!(bytes.is_ok(), "download failed: {bytes:?}");
    assert_eq!(bytes.unwrap(), b"PNGDATA".to_vec());
}