use crate::{
    api_traits::{ApiOperation, ContainerRegistry},
    cmds::docker::{DockerListBodyArgs, ImageMetadata, RegistryRepository, RepositoryTag},
    http,
    io::{HttpRunner, Response},
    remote::query,
    Result,
};

use super::Gitlab;

impl<R: HttpRunner<Response = Response>> ContainerRegistry for Gitlab<R> {
    fn list_repositories(&self, args: DockerListBodyArgs) -> Result<Vec<RegistryRepository>> {
        let url = format!(
            "{}/registry/repositories?tags_count=true",
            self.rest_api_basepath()
        );
        query::gitlab_project_registry_repositories(
            &self.runner,
            &url,
            args.body_args,
            self.headers(),
            None,
            ApiOperation::ContainerRegistry,
        )
    }

    fn list_repository_tags(&self, args: DockerListBodyArgs) -> Result<Vec<RepositoryTag>> {
        // if tags is provided, then args.repo_id is Some at this point. This is
        // enforced at the cli clap level.
        let repository_id = args.repo_id.unwrap();
        let url = format!(
            "{}/registry/repositories/{}/tags",
            self.rest_api_basepath(),
            repository_id
        );
        query::gitlab_project_registry_repository_tags(
            &self.runner,
            &url,
            args.body_args,
            self.headers(),
            None,
            ApiOperation::ContainerRegistry,
        )
    }

    fn num_pages_repository_tags(&self, repository_id: i64) -> Result<Option<u32>> {
        let url = self.resource_repository_tags_metadata_url(repository_id);
        query::num_pages(
            &self.runner,
            &url,
            self.headers(),
            ApiOperation::ContainerRegistry,
        )
    }

    fn num_resources_repository_tags(
        &self,
        repository_id: i64,
    ) -> Result<Option<crate::api_traits::NumberDeltaErr>> {
        let url = self.resource_repository_tags_metadata_url(repository_id);
        query::num_resources(
            &self.runner,
            &url,
            self.headers(),
            ApiOperation::ContainerRegistry,
        )
    }

    fn num_pages_repositories(&self) -> Result<Option<u32>> {
        let url = self.resource_repositories_metadata_url();
        query::num_pages(
            &self.runner,
            &url,
            self.headers(),
            ApiOperation::ContainerRegistry,
        )
    }

    fn num_resources_repositories(&self) -> Result<Option<crate::api_traits::NumberDeltaErr>> {
        let url = self.resource_repositories_metadata_url();
        query::num_resources(
            &self.runner,
            &url,
            self.headers(),
            ApiOperation::ContainerRegistry,
        )
    }

    fn get_image_metadata(&self, repository_id: i64, tag: &str) -> Result<ImageMetadata> {
        let url = format!(
            "{}/registry/repositories/{}/tags/{}",
            self.rest_api_basepath(),
            repository_id,
            tag
        );
        query::gitlab_registry_image_tag_metadata::<_, ()>(
            &self.runner,
            &url,
            None,
            self.headers(),
            http::Method::GET,
            ApiOperation::ContainerRegistry,
        )
    }
}

impl<R> Gitlab<R> {
    fn resource_repository_tags_metadata_url(&self, repository_id: i64) -> String {
        let url = format!(
            "{}/registry/repositories/{}/tags?page=1",
            self.rest_api_basepath(),
            repository_id
        );
        url
    }

    fn resource_repositories_metadata_url(&self) -> String {
        let url = format!("{}/registry/repositories?page=1", self.rest_api_basepath());
        url
    }
}

pub struct GitlabRegistryRepositoryFields {
    id: i64,
    location: String,
    tags_count: i64,
    created_at: String,
}

impl From<&serde_json::Value> for GitlabRegistryRepositoryFields {
    fn from(data: &serde_json::Value) -> Self {
        GitlabRegistryRepositoryFields {
            id: data["id"].as_i64().unwrap(),
            location: data["location"].as_str().unwrap().to_string(),
            tags_count: data["tags_count"].as_i64().unwrap(),
            created_at: data["created_at"].as_str().unwrap().to_string(),
        }
    }
}

impl From<GitlabRegistryRepositoryFields> for RegistryRepository {
    fn from(data: GitlabRegistryRepositoryFields) -> Self {
        RegistryRepository::builder()
            .id(data.id)
            .location(data.location)
            .tags_count(data.tags_count)
            .created_at(data.created_at)
            .build()
            .unwrap()
    }
}

pub struct GitlabRepositoryTagFields {
    name: String,
    path: String,
    location: String,
    created_at: String,
}

impl From<&serde_json::Value> for GitlabRepositoryTagFields {
    fn from(data: &serde_json::Value) -> Self {
        GitlabRepositoryTagFields {
            name: data["name"].as_str().unwrap().to_string(),
            path: data["path"].as_str().unwrap().to_string(),
            location: data["location"].as_str().unwrap().to_string(),
            // Repository tags don't have a creation date. It is included when
            // querying a specific tag. Just return default UNIX epoch date.
            created_at: "1970-01-01T00:00:00Z".to_string(),
        }
    }
}

impl From<GitlabRepositoryTagFields> for RepositoryTag {
    fn from(data: GitlabRepositoryTagFields) -> Self {
        RepositoryTag::builder()
            .name(data.name)
            .path(data.path)
            .location(data.location)
            .created_at(data.created_at)
            .build()
            .unwrap()
    }
}

pub struct GitlabImageMetadataFields {
    name: String,
    location: String,
    short_sha: String,
    size: i64,
    created_at: String,
}

impl From<&serde_json::Value> for GitlabImageMetadataFields {
    fn from(data: &serde_json::Value) -> Self {
        GitlabImageMetadataFields {
            name: data["name"].as_str().unwrap().to_string(),
            location: data["location"].as_str().unwrap().to_string(),
            short_sha: data["short_revision"].as_str().unwrap().to_string(),
            size: data["total_size"].as_i64().unwrap(),
            created_at: data["created_at"].as_str().unwrap().to_string(),
        }
    }
}

impl From<GitlabImageMetadataFields> for ImageMetadata {
    fn from(data: GitlabImageMetadataFields) -> Self {
        ImageMetadata::builder()
            .name(data.name)
            .location(data.location)
            .short_sha(data.short_sha)
            .size(data.size)
            .created_at(data.created_at)
            .build()
            .unwrap()
    }
}

#[cfg(test)]
mod test {
    use super::*;
    use crate::{
        http::Headers,
        setup_client,
        test::utils::{default_gitlab, ContractType, ResponseContracts},
    };

    #[test]
    fn test_list_repositories_url() {
        let contracts = ResponseContracts::new(ContractType::Gitlab).add_contract(
            200,
            "list_registry_repositories.json",
            None,
        );
        let (client, gitlab) = setup_client!(contracts, default_gitlab(), dyn ContainerRegistry);
        let args = DockerListBodyArgs::builder().repos(true).build().unwrap();
        gitlab.list_repositories(args).unwrap();
        assert_eq!(
            "https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories?tags_count=true",
            client.url().to_string(),
        );
        assert_eq!("1234", client.headers().get("PRIVATE-TOKEN").unwrap());
        assert_eq!(
            Some(ApiOperation::ContainerRegistry),
            *client.api_operation.borrow()
        );
    }

    #[test]
    fn test_list_repository_tags_url() {
        let contracts = ResponseContracts::new(ContractType::Gitlab).add_contract(
            200,
            "list_registry_repository_tags.json",
            None,
        );
        let (client, gitlab) = setup_client!(contracts, default_gitlab(), dyn ContainerRegistry);
        let args = DockerListBodyArgs::builder()
            .repos(false)
            .tags(true)
            .repo_id(Some(1))
            .build()
            .unwrap();
        gitlab.list_repository_tags(args).unwrap();
        assert_eq!(
            client.url().to_string(),
            "https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories/1/tags"
        );
        assert_eq!("1234", client.headers().get("PRIVATE-TOKEN").unwrap());
        assert_eq!(
            Some(ApiOperation::ContainerRegistry),
            *client.api_operation.borrow()
        );
    }

    #[test]
    fn test_query_num_pages_for_tags() {
        let link_headers = r#"<https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories/1/tags?page=1>; rel="next", <https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories/1/tags?page=1>; rel="last""#;
        let mut headers = Headers::new();
        headers.set("link".to_string(), link_headers.to_string());
        let contracts = ResponseContracts::new(ContractType::Gitlab).add_body::<String>(
            200,
            None,
            Some(headers),
        );
        let (client, gitlab) = setup_client!(contracts, default_gitlab(), dyn ContainerRegistry);
        assert_eq!(Some(1), gitlab.num_pages_repository_tags(1).unwrap());
        assert_eq!(
            "https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories/1/tags?page=1",
            client.url().to_string(),
        );
        assert_eq!(
            Some(ApiOperation::ContainerRegistry),
            *client.api_operation.borrow()
        );
    }

    #[test]
    fn test_query_num_pages_for_registry_repositories() {
        let link_headers = r#"<https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories?page=1>; rel="next", <https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories?page=1>; rel="last""#;
        let mut headers = Headers::new();
        headers.set("link".to_string(), link_headers.to_string());
        let contracts = ResponseContracts::new(ContractType::Gitlab).add_body::<String>(
            200,
            None,
            Some(headers),
        );
        let (client, gitlab) = setup_client!(contracts, default_gitlab(), dyn ContainerRegistry);
        assert_eq!(Some(1), gitlab.num_pages_repositories().unwrap());
        assert_eq!(
            "https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories?page=1",
            client.url().to_string(),
        );
        assert_eq!(
            Some(ApiOperation::ContainerRegistry),
            *client.api_operation.borrow()
        );
    }

    #[test]
    fn test_get_gitlab_registry_image_metadata() {
        let contracts = ResponseContracts::new(ContractType::Gitlab).add_contract(
            200,
            "get_registry_repository_tag.json",
            None,
        );
        let (client, gitlab) = setup_client!(contracts, default_gitlab(), dyn ContainerRegistry);
        let _metadata = gitlab.get_image_metadata(1, "v0.0.1").unwrap();
        assert_eq!("https://gitlab.com/api/v4/projects/jordilin%2Fgitlapi/registry/repositories/1/tags/v0.0.1",
            client.url().to_string(),
        );
        assert_eq!(
            Some(ApiOperation::ContainerRegistry),
            *client.api_operation.borrow()
        );
    }
}