/*
 * 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.autoconfigure.hazelcast;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import java.util.Map;

import com.hazelcast.config.Config;
import com.hazelcast.config.JoinConfig;
import com.hazelcast.config.QueueConfig;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.map.EntryProcessor;
import com.hazelcast.map.IMap;
import com.hazelcast.spring.context.SpringAware;
import com.hazelcast.spring.context.SpringManagedContext;
import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;

import org.springframework.beans.factory.BeanCreationException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.AutoConfigurations;
import org.springframework.boot.test.context.FilteredClassLoader;
import org.springframework.boot.test.context.assertj.AssertableApplicationContext;
import org.springframework.boot.test.context.runner.ApplicationContextRunner;
import org.springframework.boot.test.context.runner.ContextConsumer;
import org.springframework.boot.testsupport.classpath.resources.WithResource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.core.io.ClassPathResource;

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

/**
 * Tests for {@link HazelcastAutoConfiguration} when the client library is not present.
 *
 * @author Stephane Nicoll
 */
class HazelcastAutoConfigurationServerTests {

	private final ApplicationContextRunner contextRunner = new ApplicationContextRunner()
		.withConfiguration(AutoConfigurations.of(HazelcastAutoConfiguration.class));

	@Test
	@WithHazelcastXmlResource
	void defaultConfigFile() {
		// hazelcast.xml present in root classpath
		this.contextRunner.run((context) -> {
			Config config = context.getBean(HazelcastInstance.class).getConfig();
			assertThat(config.getConfigurationUrl()).isEqualTo(new ClassPathResource("hazelcast.xml").getURL());
		});
	}

	@Test
	void systemPropertyWithXml() {
		this.contextRunner
			.withSystemProperties(HazelcastServerConfiguration.CONFIG_SYSTEM_PROPERTY
					+ "=classpath:org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.xml")
			.run((context) -> {
				Config config = context.getBean(HazelcastInstance.class).getConfig();
				assertThat(config.getMapConfigs().keySet()).containsOnly("foobar");
			});
	}

	@Test
	void systemPropertyWithYaml() {
		this.contextRunner
			.withSystemProperties(HazelcastServerConfiguration.CONFIG_SYSTEM_PROPERTY
					+ "=classpath:org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.yaml")
			.run((context) -> {
				Config config = context.getBean(HazelcastInstance.class).getConfig();
				assertThat(config.getMapConfigs().keySet()).containsOnly("foobar");
			});
	}

	@Test
	void systemPropertyWithYml() {
		this.contextRunner
			.withSystemProperties(HazelcastServerConfiguration.CONFIG_SYSTEM_PROPERTY
					+ "=classpath:org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.yml")
			.run((context) -> {
				Config config = context.getBean(HazelcastInstance.class).getConfig();
				assertThat(config.getMapConfigs().keySet()).containsOnly("foobar");
			});
	}

	@Test
	void explicitConfigFileWithXml() {
		this.contextRunner
			.withPropertyValues("spring.hazelcast.config=org/springframework/boot/autoconfigure/hazelcast/"
					+ "hazelcast-specific.xml")
			.run(assertSpecificHazelcastServer(
					"org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.xml"));
	}

	@Test
	void explicitConfigFileWithYaml() {
		this.contextRunner
			.withPropertyValues("spring.hazelcast.config=org/springframework/boot/autoconfigure/hazelcast/"
					+ "hazelcast-specific.yaml")
			.run(assertSpecificHazelcastServer(
					"org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.yaml"));
	}

	@Test
	void explicitConfigFileWithYml() {
		this.contextRunner
			.withPropertyValues("spring.hazelcast.config=org/springframework/boot/autoconfigure/hazelcast/"
					+ "hazelcast-specific.yml")
			.run(assertSpecificHazelcastServer(
					"org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.yml"));
	}

	@Test
	void explicitConfigUrlWithXml() {
		this.contextRunner
			.withPropertyValues("spring.hazelcast.config=classpath:org/springframework/"
					+ "boot/autoconfigure/hazelcast/hazelcast-specific.xml")
			.run(assertSpecificHazelcastServer(
					"org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.xml"));
	}

	@Test
	void explicitConfigUrlWithYaml() {
		this.contextRunner
			.withPropertyValues("spring.hazelcast.config=classpath:org/springframework/"
					+ "boot/autoconfigure/hazelcast/hazelcast-specific.yaml")
			.run(assertSpecificHazelcastServer(
					"org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.yaml"));
	}

	@Test
	void explicitConfigUrlWithYml() {
		this.contextRunner
			.withPropertyValues("spring.hazelcast.config=classpath:org/springframework/"
					+ "boot/autoconfigure/hazelcast/hazelcast-specific.yml")
			.run(assertSpecificHazelcastServer(
					"org/springframework/boot/autoconfigure/hazelcast/hazelcast-specific.yml"));
	}

	private ContextConsumer<AssertableApplicationContext> assertSpecificHazelcastServer(String location) {
		return (context) -> {
			Config config = context.getBean(HazelcastInstance.class).getConfig();
			String configurationLocation = (config.getConfigurationUrl() != null)
					? config.getConfigurationUrl().toString()
					: config.getConfigurationFile().toURI().toURL().toString();
			assertThat(configurationLocation).endsWith(location);
		};
	}

	@Test
	void unknownConfigFile() {
		this.contextRunner.withPropertyValues("spring.hazelcast.config=foo/bar/unknown.xml")
			.run((context) -> assertThat(context).getFailure()
				.isInstanceOf(BeanCreationException.class)
				.hasMessageContaining("foo/bar/unknown.xml"));
	}

	@Test
	void configInstanceWithName() {
		Config config = createTestConfig("my-test-instance");
		HazelcastInstance existing = Hazelcast.newHazelcastInstance(config);
		try {
			this.contextRunner.withUserConfiguration(HazelcastConfigWithName.class)
				.withPropertyValues("spring.hazelcast.config=this-is-ignored.xml")
				.run((context) -> {
					HazelcastInstance hazelcast = context.getBean(HazelcastInstance.class);
					assertThat(hazelcast.getConfig().getInstanceName()).isEqualTo("my-test-instance");
					// Should reuse any existing instance by default.
					assertThat(hazelcast).isEqualTo(existing);
				});
		}
		finally {
			existing.shutdown();
		}
	}

	@Test
	void configInstanceWithoutName() {
		this.contextRunner.withUserConfiguration(HazelcastConfigNoName.class)
			.withPropertyValues("spring.hazelcast.config=this-is-ignored.xml")
			.run((context) -> {
				Config config = context.getBean(HazelcastInstance.class).getConfig();
				Map<String, QueueConfig> queueConfigs = config.getQueueConfigs();
				assertThat(queueConfigs.keySet()).containsOnly("another-queue");
			});
	}

	@Test
	@WithHazelcastXmlResource
	void autoConfiguredConfigUsesApplicationClassLoader() {
		this.contextRunner.run((context) -> {
			Config config = context.getBean(HazelcastInstance.class).getConfig();
			assertThat(config.getClassLoader()).isSameAs(context.getSourceApplicationContext().getClassLoader());
		});
	}

	@Test
	@WithHazelcastXmlResource
	void autoConfiguredConfigUsesSpringManagedContext() {
		this.contextRunner.run((context) -> {
			Config config = context.getBean(HazelcastInstance.class).getConfig();
			assertThat(config.getManagedContext()).isInstanceOf(SpringManagedContext.class);
		});
	}

	@Test
	@WithHazelcastXmlResource
	void autoConfiguredConfigCanUseSpringAwareComponent() {
		this.contextRunner.withPropertyValues("test.hazelcast.key=42").run((context) -> {
			HazelcastInstance hz = context.getBean(HazelcastInstance.class);
			IMap<String, String> map = hz.getMap("test");
			assertThat(map.executeOnKey("test.hazelcast.key", new SpringAwareEntryProcessor<>())).isEqualTo("42");
		});
	}

	@Test
	@WithHazelcastXmlResource
	void autoConfiguredConfigWithoutHazelcastSpringDoesNotUseSpringManagedContext() {
		this.contextRunner
			.withClassLoader(
					new FilteredClassLoader(Thread.currentThread().getContextClassLoader(), SpringManagedContext.class))
			.run((context) -> {
				Config config = context.getBean(HazelcastInstance.class).getConfig();
				assertThat(config.getManagedContext()).isNull();
			});
	}

	@Test
	@WithHazelcastXmlResource
	void autoConfiguredContextCanOverrideManagementContextUsingCustomizer() {
		this.contextRunner.withBean(TestHazelcastConfigCustomizer.class).run((context) -> {
			Config config = context.getBean(HazelcastInstance.class).getConfig();
			assertThat(config.getManagedContext()).isNull();
		});
	}

	@Test
	@WithHazelcastXmlResource
	void autoConfiguredConfigSetsHazelcastLoggingToSlf4j() {
		this.contextRunner.run((context) -> {
			Config config = context.getBean(HazelcastInstance.class).getConfig();
			assertThat(config.getProperty(HazelcastServerConfiguration.HAZELCAST_LOGGING_TYPE)).isEqualTo("slf4j");
		});
	}

	@Test
	void autoConfiguredConfigCanOverrideHazelcastLogging() {
		this.contextRunner.withUserConfiguration(HazelcastConfigWithJDKLogging.class).run((context) -> {
			Config config = context.getBean(HazelcastInstance.class).getConfig();
			assertThat(config.getProperty(HazelcastServerConfiguration.HAZELCAST_LOGGING_TYPE)).isEqualTo("jdk");
		});
	}

	private static Config createTestConfig(String instanceName) {
		Config config = new Config(instanceName);
		JoinConfig join = config.getNetworkConfig().getJoin();
		join.getAutoDetectionConfig().setEnabled(false);
		join.getMulticastConfig().setEnabled(false);
		return config;
	}

	@Configuration(proxyBeanMethods = false)
	static class HazelcastConfigWithName {

		@Bean
		Config myHazelcastConfig() {
			return new Config("my-test-instance");
		}

	}

	@Configuration(proxyBeanMethods = false)
	static class HazelcastConfigNoName {

		@Bean
		Config anotherHazelcastConfig() {
			Config config = createTestConfig("another-test-instance");
			config.addQueueConfig(new QueueConfig("another-queue"));
			return config;
		}

	}

	@Configuration(proxyBeanMethods = false)
	static class HazelcastConfigWithJDKLogging {

		@Bean
		Config anotherHazelcastConfig() {
			Config config = new Config();
			config.setProperty(HazelcastServerConfiguration.HAZELCAST_LOGGING_TYPE, "jdk");
			return config;
		}

	}

	@SpringAware
	static class SpringAwareEntryProcessor<V> implements EntryProcessor<String, V, String> {

		@Autowired
		private Environment environment;

		@Override
		public String process(Map.Entry<String, V> entry) {
			return this.environment.getProperty(entry.getKey());
		}

	}

	@Order(1)
	static class TestHazelcastConfigCustomizer implements HazelcastConfigCustomizer {

		@Override
		public void customize(Config config) {
			config.setManagedContext(null);
		}

	}

	@Target(ElementType.METHOD)
	@Retention(RetentionPolicy.RUNTIME)
	@WithResource(name = "hazelcast.xml", content = """
			<hazelcast
				xsi:schemaLocation="http://www.hazelcast.com/schema/config hazelcast-config-5.0.xsd"
				xmlns="http://www.hazelcast.com/schema/config" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
				<instance-name>default-instance</instance-name>
				<map name="defaultCache" />
				<network>
					<join>
						<auto-detection enabled="false" />
						<multicast enabled="false" />
					</join>
				</network>
			</hazelcast>
			""")
	@interface WithHazelcastXmlResource {

	}

}
