/*
 * This file is part of ETL-Processor
 *
 * Copyright (c) 2023       Comprehensive Cancer Center Mainfranken
 * Copyright (c) 2026  Paul-Christian Volkmer, Datenintegrationszentrum Philipps-Universität Marburg and Contributors
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published
 * by the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */

package dev.dnpm.etl.processor.consent;

import static org.assertj.core.api.Assertions.assertThat;
import static org.springframework.test.web.client.match.MockRestRequestMatchers.requestTo;
import static org.springframework.test.web.client.response.MockRestResponseCreators.withServerError;
import static org.springframework.test.web.client.response.MockRestResponseCreators.withSuccess;

import com.fasterxml.jackson.databind.ObjectMapper;
import dev.dnpm.etl.processor.config.AppConfiguration;
import dev.dnpm.etl.processor.config.AppFhirConfig;
import dev.dnpm.etl.processor.config.GIcsConfigProperties;
import java.net.URI;
import java.nio.charset.StandardCharsets;
import java.util.Objects;
import org.apache.commons.io.IOUtils;
import org.apache.hc.core5.net.URIBuilder;
import org.hl7.fhir.r4.model.OperationOutcome;
import org.hl7.fhir.r4.model.OperationOutcome.IssueSeverity;
import org.hl7.fhir.r4.model.OperationOutcome.IssueType;
import org.hl7.fhir.r4.model.OperationOutcome.OperationOutcomeIssueComponent;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.restclient.test.autoconfigure.RestClientTest;
import org.springframework.http.MediaType;
import org.springframework.retry.support.RetryTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.web.client.MockRestServiceServer;
import org.springframework.web.client.RestTemplate;

@ContextConfiguration(classes = {AppConfiguration.class, ObjectMapper.class})
@TestPropertySource(
    properties = {
      "app.consent.service=gics",
      "app.consent.gics.uri=http://localhost:8090/ttp-fhir/fhir/gics"
    })
@RestClientTest
class GicsGetBroadConsentServiceTest {

  static final String GICS_BASE_URI = "http://localhost:8090/ttp-fhir/fhir/gics";

  MockRestServiceServer mockRestServiceServer;
  AppFhirConfig appFhirConfig;
  GIcsConfigProperties gIcsConfigProperties;

  GicsGetBroadConsentService service;

  static URI expectedGicsConsentedEndpoint() throws Exception {
    return new URIBuilder(URI.create(GICS_BASE_URI))
        .appendPath("/Consent")
        .addParameter("domain:identifier", "MII")
        .addParameter(
            "category", "http://fhir.de/ConsentManagement/CodeSystem/ResultType|consent-status")
        .addParameter(
            "patient.identifier",
            "https://ths-greifswald.de/fhir/gics/identifiers/Patienten-ID|123456")
        .build();
  }

  @BeforeEach
  void setUp(
      @Autowired AppFhirConfig appFhirConfig,
      @Autowired GIcsConfigProperties gIcsConfigProperties) {
    this.appFhirConfig = appFhirConfig;
    this.gIcsConfigProperties = gIcsConfigProperties;

    var restTemplate = new RestTemplate();

    this.mockRestServiceServer = MockRestServiceServer.createServer(restTemplate);
    this.service =
        new GicsGetBroadConsentService(
            this.gIcsConfigProperties,
            RetryTemplate.builder().maxAttempts(1).build(),
            restTemplate,
            this.appFhirConfig);
  }

  @Test
  void shouldReturnTtpBroadConsentStatus() throws Exception {
    var inputStream =
        Objects.requireNonNull(
            this.getClass()
                .getClassLoader()
                .getResourceAsStream("fake_broadConsent_mii_response_permit.json"));

    mockRestServiceServer
        .expect(requestTo(expectedGicsConsentedEndpoint()))
        .andRespond(
            withSuccess(
                IOUtils.toString(inputStream, StandardCharsets.UTF_8), MediaType.APPLICATION_JSON));

    var consentStatus = service.getTtpBroadConsentStatus("123456");
    assertThat(consentStatus).isEqualTo(TtpConsentStatus.BROAD_CONSENT_GIVEN);
  }

  @Test
  void shouldReturnInvalidParameterResponse() throws Exception {
    final OperationOutcome responseWithErrorOutcome =
        new OperationOutcome()
            .addIssue(
                new OperationOutcomeIssueComponent()
                    .setSeverity(IssueSeverity.ERROR)
                    .setCode(IssueType.PROCESSING)
                    .setDiagnostics("Invalid policy parameter..."));

    mockRestServiceServer
        .expect(requestTo(expectedGicsConsentedEndpoint()))
        .andRespond(
            withSuccess(
                appFhirConfig
                    .fhirContext()
                    .newJsonParser()
                    .encodeResourceToString(responseWithErrorOutcome),
                MediaType.APPLICATION_JSON));

    var consentStatus = service.getTtpBroadConsentStatus("123456");
    assertThat(consentStatus).isEqualTo(TtpConsentStatus.FAILED_TO_ASK);
  }

  @Test
  void shouldReturnRequestError() throws Exception {
    mockRestServiceServer
        .expect(requestTo(expectedGicsConsentedEndpoint()))
        .andRespond(withServerError());

    var consentStatus = service.getTtpBroadConsentStatus("123456");
    assertThat(consentStatus).isEqualTo(TtpConsentStatus.FAILED_TO_ASK);
  }
}