smugmug-cli 0.5.1

use anyhow::{Context, Result};
use serde::{Deserialize, Serialize};

use super::SmugMugClient;

#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct Comment {
    #[serde(rename = "CommentKey", skip_serializing_if = "Option::is_none")]
    pub comment_key: Option<String>,

    #[serde(rename = "Comment")]
    pub text: String,

    #[serde(rename = "Name", skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    #[serde(rename = "Email", skip_serializing_if = "Option::is_none")]
    pub email: Option<String>,

    #[serde(rename = "Rating", skip_serializing_if = "Option::is_none")]
    pub rating: Option<u8>,

    #[serde(rename = "Link", skip_serializing_if = "Option::is_none")]
    pub link: Option<String>,

    #[serde(rename = "SocialID", skip_serializing_if = "Option::is_none")]
    pub social_id: Option<String>,

    #[serde(rename = "ServiceID", skip_serializing_if = "Option::is_none")]
    pub service_id: Option<i32>,

    #[serde(rename = "Date", skip_serializing_if = "Option::is_none")]
    pub date: Option<String>,

    #[serde(rename = "Uri", skip_serializing_if = "Option::is_none")]
    pub uri: Option<String>,
}

#[derive(Debug, Serialize)]
pub struct CreateCommentRequest {
    #[serde(rename = "Comment")]
    pub text: String,

    #[serde(rename = "Name", skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    #[serde(rename = "Email", skip_serializing_if = "Option::is_none")]
    pub email: Option<String>,

    #[serde(rename = "Rating", skip_serializing_if = "Option::is_none")]
    pub rating: Option<u8>,

    #[serde(rename = "Link", skip_serializing_if = "Option::is_none")]
    pub link: Option<String>,
}

// Shape of one page of a comments listing (read through
// `get_all_pages` in the client; kept for the deserialization tests).
#[cfg(test)]
#[derive(Debug, Deserialize)]
struct CommentsResponse {
    #[serde(rename = "Response")]
    response: CommentsResponseData,
}

#[cfg(test)]
#[derive(Debug, Deserialize)]
struct CommentsResponseData {
    #[serde(rename = "Comment")]
    comments: Vec<Comment>,
}

#[derive(Debug, Deserialize)]
struct CommentResponse {
    #[serde(rename = "Response")]
    response: CommentResponseData,
}

#[derive(Debug, Deserialize)]
struct CommentResponseData {
    #[serde(rename = "Comment")]
    comment: Comment,
}

impl SmugMugClient {
    /// List all comments for an image
    pub async fn list_image_comments(&self, image_key: &str) -> Result<Vec<Comment>> {
        let comments_url = format!(
            "https://api.smugmug.com/api/v2/image/{}!comments",
            image_key
        );
        self.get_all_pages(&comments_url, "Comment")
            .await
            .context("Failed to list comments")
    }

    /// Create a new comment on an image
    pub async fn create_image_comment(
        &self,
        image_key: &str,
        request: CreateCommentRequest,
    ) -> Result<Comment> {
        // Validate inputs
        if request.text.is_empty() {
            anyhow::bail!("Comment text cannot be empty");
        }

        if request.text.len() > 60000 {
            anyhow::bail!("Comment text must be less than 60,000 characters");
        }

        if let Some(ref name) = request.name {
            if name.len() > 50 {
                anyhow::bail!("Name must be less than 50 characters");
            }
        }

        if let Some(ref email) = request.email {
            if email.len() > 50 {
                anyhow::bail!("Email must be less than 50 characters");
            }
        }

        if let Some(rating) = request.rating {
            if rating > 5 {
                anyhow::bail!("Rating must be between 0 and 5");
            }
        }

        let comments_url = format!(
            "https://api.smugmug.com/api/v2/image/{}!comments",
            image_key
        );

        let body = serde_json::to_value(&request)?;
        let response = self.post_with_auth(&comments_url, body).await?;

        let status = response.status();
        let body_text = response.text().await?;

        if !status.is_success() {
            anyhow::bail!("Failed to create comment: {} - {}", status, body_text);
        }

        let comment_response: CommentResponse = serde_json::from_str(&body_text)?;
        Ok(comment_response.response.comment)
    }
}

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

    #[tokio::test]
    async fn test_list_comments_success() {
        let mut server = Server::new_async().await;
        let api_url = server.url();

        let _mock = server
            .mock("GET", "/api/v2/image/IMG123!comments")
            .match_header(
                "authorization",
                mockito::Matcher::Regex("OAuth.*".to_string()),
            )
            .with_status(200)
            .with_body(
                r#"{
                "Response": {
                    "Comment": [
                        {
                            "CommentKey": "CMT123",
                            "Comment": "Great photo!",
                            "Name": "John Doe",
                            "Rating": 5,
                            "Date": "2024-12-15"
                        }
                    ]
                }
            }"#,
            )
            .create_async()
            .await;

        let client = SmugMugClient::new(
            "test_key".to_string(),
            "test_secret".to_string(),
            "test_token".to_string(),
            "test_token_secret".to_string(),
        );

        // Note: This test won't actually call the mock server because the URL is hardcoded
        // in the implementation. We're primarily testing the struct deserialization here.
        let result = serde_json::from_str::<CommentsResponse>(
            r#"{
            "Response": {
                "Comment": [
                    {
                        "CommentKey": "CMT123",
                        "Comment": "Great photo!",
                        "Name": "John Doe",
                        "Rating": 5,
                        "Date": "2024-12-15"
                    }
                ]
            }
        }"#,
        );

        assert!(result.is_ok());
        let response = result.unwrap();
        assert_eq!(response.response.comments.len(), 1);
        assert_eq!(response.response.comments[0].text, "Great photo!");
    }

    #[tokio::test]
    async fn test_create_comment_validation_empty_text() {
        let client = SmugMugClient::new(
            "test_key".to_string(),
            "test_secret".to_string(),
            "test_token".to_string(),
            "test_token_secret".to_string(),
        );

        let request = CreateCommentRequest {
            text: String::new(),
            name: None,
            email: None,
            rating: None,
            link: None,
        };

        let result = client.create_image_comment("IMG123", request).await;
        assert!(result.is_err());
        assert!(result.unwrap_err().to_string().contains("cannot be empty"));
    }

    #[tokio::test]
    async fn test_create_comment_validation_text_too_long() {
        let client = SmugMugClient::new(
            "test_key".to_string(),
            "test_secret".to_string(),
            "test_token".to_string(),
            "test_token_secret".to_string(),
        );

        let request = CreateCommentRequest {
            text: "a".repeat(60001),
            name: None,
            email: None,
            rating: None,
            link: None,
        };

        let result = client.create_image_comment("IMG123", request).await;
        assert!(result.is_err());
        assert!(
            result
                .unwrap_err()
                .to_string()
                .contains("60,000 characters")
        );
    }

    #[tokio::test]
    async fn test_create_comment_validation_name_too_long() {
        let client = SmugMugClient::new(
            "test_key".to_string(),
            "test_secret".to_string(),
            "test_token".to_string(),
            "test_token_secret".to_string(),
        );

        let request = CreateCommentRequest {
            text: "Great photo!".to_string(),
            name: Some("a".repeat(51)),
            email: None,
            rating: None,
            link: None,
        };

        let result = client.create_image_comment("IMG123", request).await;
        assert!(result.is_err());
        assert!(result.unwrap_err().to_string().contains("50 characters"));
    }

    #[tokio::test]
    async fn test_create_comment_validation_rating_invalid() {
        let client = SmugMugClient::new(
            "test_key".to_string(),
            "test_secret".to_string(),
            "test_token".to_string(),
            "test_token_secret".to_string(),
        );

        let request = CreateCommentRequest {
            text: "Great photo!".to_string(),
            name: None,
            email: None,
            rating: Some(6),
            link: None,
        };

        let result = client.create_image_comment("IMG123", request).await;
        assert!(result.is_err());
        assert!(result.unwrap_err().to_string().contains("between 0 and 5"));
    }

    #[test]
    fn test_comment_deserialization() {
        let json = r#"{
            "CommentKey": "CMT123",
            "Comment": "Beautiful sunset!",
            "Name": "Jane Smith",
            "Email": "jane@example.com",
            "Rating": 4,
            "Date": "2024-12-15",
            "Uri": "/api/v2/comment/CMT123"
        }"#;

        let comment: Result<Comment, _> = serde_json::from_str(json);
        assert!(comment.is_ok());

        let comment = comment.unwrap();
        assert_eq!(comment.comment_key, Some("CMT123".to_string()));
        assert_eq!(comment.text, "Beautiful sunset!");
        assert_eq!(comment.name, Some("Jane Smith".to_string()));
        assert_eq!(comment.rating, Some(4));
    }

    #[test]
    fn test_create_comment_request_serialization() {
        let request = CreateCommentRequest {
            text: "Great photo!".to_string(),
            name: Some("John Doe".to_string()),
            email: Some("john@example.com".to_string()),
            rating: Some(5),
            link: None,
        };

        let json = serde_json::to_value(&request).unwrap();
        assert_eq!(json["Comment"], "Great photo!");
        assert_eq!(json["Name"], "John Doe");
        assert_eq!(json["Rating"], 5);
    }
}