/*
 * Copyright 2012-present the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.springframework.boot.webflux.autoconfigure;

import java.nio.charset.StandardCharsets;

import org.junit.jupiter.api.Test;

import org.springframework.boot.autoconfigure.AutoConfigurations;
import org.springframework.boot.http.codec.CodecCustomizer;
import org.springframework.boot.test.context.FilteredClassLoader;
import org.springframework.boot.test.context.runner.ReactiveWebApplicationContextRunner;
import org.springframework.boot.test.context.runner.WebApplicationContextRunner;
import org.springframework.http.codec.multipart.DefaultPartHttpMessageReader;
import org.springframework.http.codec.multipart.PartEventHttpMessageReader;
import org.springframework.http.codec.support.DefaultServerCodecConfigurer;
import org.springframework.util.unit.DataSize;
import org.springframework.web.reactive.config.WebFluxConfigurer;

import static org.assertj.core.api.Assertions.assertThat;

/**
 * Tests for {@link ReactiveMultipartAutoConfiguration}.
 *
 * @author Chris Bono
 * @author Brian Clozel
 */
class ReactiveMultipartAutoConfigurationTests {

	private final ReactiveWebApplicationContextRunner contextRunner = new ReactiveWebApplicationContextRunner()
		.withConfiguration(AutoConfigurations.of(ReactiveMultipartAutoConfiguration.class));

	@Test
	void shouldNotProvideCustomizerForNonReactiveApp() {
		new WebApplicationContextRunner()
			.withConfiguration(AutoConfigurations.of(ReactiveMultipartAutoConfiguration.class))
			.run((context) -> assertThat(context).doesNotHaveBean(CodecCustomizer.class));
	}

	@Test
	void shouldNotProvideCustomizerWhenWebFluxNotAvailable() {
		this.contextRunner.withClassLoader(new FilteredClassLoader(WebFluxConfigurer.class))
			.run((context) -> assertThat(context).doesNotHaveBean(CodecCustomizer.class));
	}

	@Test
	void shouldConfigureMultipartPropertiesForDefaultReader() {
		this.contextRunner
			.withPropertyValues("spring.webflux.multipart.max-in-memory-size=1GB",
					"spring.webflux.multipart.max-headers-size=16KB",
					"spring.webflux.multipart.max-disk-usage-per-part=3GB", "spring.webflux.multipart.max-parts=7",
					"spring.webflux.multipart.headers-charset:UTF_16")
			.run((context) -> {
				CodecCustomizer customizer = context.getBean(CodecCustomizer.class);
				DefaultServerCodecConfigurer configurer = new DefaultServerCodecConfigurer();
				customizer.customize(configurer);
				DefaultPartHttpMessageReader partReader = getDefaultPartReader(configurer);
				assertThat(partReader).hasFieldOrPropertyWithValue("maxParts", 7);
				assertThat(partReader).hasFieldOrPropertyWithValue("maxHeadersSize",
						Math.toIntExact(DataSize.ofKilobytes(16).toBytes()));
				assertThat(partReader).hasFieldOrPropertyWithValue("headersCharset", StandardCharsets.UTF_16);
				assertThat(partReader).hasFieldOrPropertyWithValue("maxInMemorySize",
						Math.toIntExact(DataSize.ofGigabytes(1).toBytes()));
				assertThat(partReader).hasFieldOrPropertyWithValue("maxDiskUsagePerPart",
						DataSize.ofGigabytes(3).toBytes());
			});
	}

	@Test
	void shouldConfigureMultipartPropertiesForPartEventReader() {
		this.contextRunner
			.withPropertyValues("spring.webflux.multipart.max-in-memory-size=1GB",
					"spring.webflux.multipart.max-headers-size=16KB",
					"spring.webflux.multipart.max-disk-usage-per-part=3GB", "spring.webflux.multipart.max-parts=7",
					"spring.webflux.multipart.headers-charset:UTF_16")
			.run((context) -> {
				CodecCustomizer customizer = context.getBean(CodecCustomizer.class);
				DefaultServerCodecConfigurer configurer = new DefaultServerCodecConfigurer();
				customizer.customize(configurer);
				PartEventHttpMessageReader partReader = getPartEventReader(configurer);
				assertThat(partReader).hasFieldOrPropertyWithValue("maxParts", 7);
				assertThat(partReader).hasFieldOrPropertyWithValue("maxHeadersSize",
						Math.toIntExact(DataSize.ofKilobytes(16).toBytes()));
				assertThat(partReader).hasFieldOrPropertyWithValue("headersCharset", StandardCharsets.UTF_16);
				assertThat(partReader).hasFieldOrPropertyWithValue("maxInMemorySize",
						Math.toIntExact(DataSize.ofGigabytes(1).toBytes()));
				assertThat(partReader).hasFieldOrPropertyWithValue("maxPartSize", DataSize.ofGigabytes(3).toBytes());
			});
	}

	private DefaultPartHttpMessageReader getDefaultPartReader(DefaultServerCodecConfigurer codecConfigurer) {
		return codecConfigurer.getReaders()
			.stream()
			.filter(DefaultPartHttpMessageReader.class::isInstance)
			.map(DefaultPartHttpMessageReader.class::cast)
			.findFirst()
			.orElseThrow(() -> new IllegalStateException("Could not find DefaultPartHttpMessageReader"));
	}

	private PartEventHttpMessageReader getPartEventReader(DefaultServerCodecConfigurer codecConfigurer) {
		return codecConfigurer.getReaders()
			.stream()
			.filter(PartEventHttpMessageReader.class::isInstance)
			.map(PartEventHttpMessageReader.class::cast)
			.findFirst()
			.orElseThrow(() -> new IllegalStateException("Could not find PartEventHttpMessageReader"));
	}

}
