/*
 * SPDX-License-Identifier: Apache-2.0
 *
 * The OpenSearch Contributors require contributions made to
 * this file be licensed under the Apache-2.0 license or a
 * compatible open source license.
 */

/*
 * Licensed to Elasticsearch under one or more contributor
 * license agreements. See the NOTICE file distributed with
 * this work for additional information regarding copyright
 * ownership. Elasticsearch licenses this file to you 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
 *
 *     http://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.
 */

/*
 * Modifications Copyright OpenSearch Contributors. See
 * GitHub history for details.
 */

package org.opensearch.cluster.metadata;

import org.opensearch.Version;
import org.opensearch.action.admin.indices.rollover.RolloverInfo;
import org.opensearch.cluster.coordination.CoordinationMetadata;
import org.opensearch.common.Strings;
import org.opensearch.common.compress.CompressedXContent;
import org.opensearch.common.settings.Settings;
import org.opensearch.core.xcontent.ToXContent;
import org.opensearch.core.xcontent.XContentBuilder;
import org.opensearch.common.xcontent.json.JsonXContent;
import org.opensearch.test.OpenSearchTestCase;
import org.opensearch.test.TestCustomMetadata;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;

import static org.opensearch.cluster.DataStreamTestHelper.createFirstBackingIndex;
import static org.opensearch.cluster.DataStreamTestHelper.createTimestampField;
import static org.opensearch.cluster.metadata.AliasMetadata.newAliasMetadataBuilder;
import static org.opensearch.cluster.metadata.IndexMetadata.SETTING_VERSION_CREATED;
import static org.opensearch.cluster.metadata.Metadata.CONTEXT_MODE_API;
import static org.opensearch.cluster.metadata.Metadata.CONTEXT_MODE_GATEWAY;
import static org.hamcrest.Matchers.contains;
import static org.hamcrest.Matchers.equalTo;
import static org.hamcrest.Matchers.is;

public class ToAndFromJsonMetadataTests extends OpenSearchTestCase {

    public void testSimpleJsonFromAndTo() throws IOException {
        IndexMetadata idx1 = createFirstBackingIndex("data-stream1").build();
        IndexMetadata idx2 = createFirstBackingIndex("data-stream2").build();
        Metadata metadata = Metadata.builder()
            .put(
                IndexTemplateMetadata.builder("foo")
                    .patterns(Collections.singletonList("bar"))
                    .order(1)
                    .settings(Settings.builder().put("setting1", "value1").put("setting2", "value2"))
                    .putAlias(newAliasMetadataBuilder("alias-bar1"))
                    .putAlias(newAliasMetadataBuilder("alias-bar2").filter("{\"term\":{\"user\":\"foobar\"}}"))
                    .putAlias(newAliasMetadataBuilder("alias-bar3").routing("routing-bar"))
            )
            .put(
                "component_template",
                new ComponentTemplate(
                    new Template(
                        Settings.builder().put("setting", "value").build(),
                        new CompressedXContent("{\"baz\":\"eggplant\"}"),
                        Collections.singletonMap("alias", AliasMetadata.builder("alias").build())
                    ),
                    5L,
                    Collections.singletonMap("my_meta", Collections.singletonMap("foo", "bar"))
                )
            )
            .put(
                "index_templatev2",
                new ComposableIndexTemplate(
                    Arrays.asList("foo", "bar*"),
                    new Template(
                        Settings.builder().put("setting", "value").build(),
                        new CompressedXContent("{\"baz\":\"eggplant\"}"),
                        Collections.singletonMap("alias", AliasMetadata.builder("alias").build())
                    ),
                    Collections.singletonList("component_template"),
                    5L,
                    4L,
                    Collections.singletonMap("my_meta", Collections.singletonMap("potato", "chicken")),
                    randomBoolean() ? null : new ComposableIndexTemplate.DataStreamTemplate()
                )
            )
            .put(
                IndexMetadata.builder("test12")
                    .settings(settings(Version.CURRENT).put("setting1", "value1").put("setting2", "value2"))
                    .creationDate(2L)
                    .numberOfShards(1)
                    .numberOfReplicas(2)
                    .putMapping(MAPPING_SOURCE1)
                    .putAlias(newAliasMetadataBuilder("alias1").filter(ALIAS_FILTER1))
                    .putAlias(newAliasMetadataBuilder("alias3").writeIndex(randomBoolean() ? null : randomBoolean()))
                    .putAlias(newAliasMetadataBuilder("alias4").filter(ALIAS_FILTER2))
            )
            .put(
                IndexTemplateMetadata.builder("foo")
                    .patterns(Collections.singletonList("bar"))
                    .order(1)
                    .settings(Settings.builder().put("setting1", "value1").put("setting2", "value2"))
                    .putAlias(newAliasMetadataBuilder("alias-bar1"))
                    .putAlias(newAliasMetadataBuilder("alias-bar2").filter("{\"term\":{\"user\":\"foobar\"}}"))
                    .putAlias(newAliasMetadataBuilder("alias-bar3").routing("routing-bar"))
            )
            .put(idx1, false)
            .put(idx2, false)
            .put(new DataStream("data-stream1", createTimestampField("@timestamp"), List.of(idx1.getIndex())))
            .put(new DataStream("data-stream2", createTimestampField("@timestamp"), List.of(idx2.getIndex())))
            .build();

        XContentBuilder builder = JsonXContent.contentBuilder();
        builder.startObject();
        Metadata.FORMAT.toXContent(builder, metadata);
        builder.endObject();

        Metadata parsedMetadata = Metadata.Builder.fromXContent(createParser(builder));

        // templates
        assertThat(parsedMetadata.templates().get("foo").name(), is("foo"));
        assertThat(parsedMetadata.templates().get("foo").patterns(), is(Collections.singletonList("bar")));
        assertThat(parsedMetadata.templates().get("foo").settings().get("index.setting1"), is("value1"));
        assertThat(parsedMetadata.templates().get("foo").settings().getByPrefix("index.").get("setting2"), is("value2"));
        assertThat(parsedMetadata.templates().get("foo").aliases().size(), equalTo(3));
        assertThat(parsedMetadata.templates().get("foo").aliases().get("alias-bar1").alias(), equalTo("alias-bar1"));
        assertThat(parsedMetadata.templates().get("foo").aliases().get("alias-bar2").alias(), equalTo("alias-bar2"));
        assertThat(
            parsedMetadata.templates().get("foo").aliases().get("alias-bar2").filter().string(),
            equalTo("{\"term\":{\"user\":\"foobar\"}}")
        );
        assertThat(parsedMetadata.templates().get("foo").aliases().get("alias-bar3").alias(), equalTo("alias-bar3"));
        assertThat(parsedMetadata.templates().get("foo").aliases().get("alias-bar3").indexRouting(), equalTo("routing-bar"));
        assertThat(parsedMetadata.templates().get("foo").aliases().get("alias-bar3").searchRouting(), equalTo("routing-bar"));

        // component template
        assertNotNull(parsedMetadata.componentTemplates().get("component_template"));
        assertThat(parsedMetadata.componentTemplates().get("component_template").version(), is(5L));
        assertThat(
            parsedMetadata.componentTemplates().get("component_template").metadata(),
            equalTo(Collections.singletonMap("my_meta", Collections.singletonMap("foo", "bar")))
        );
        assertThat(
            parsedMetadata.componentTemplates().get("component_template").template(),
            equalTo(
                new Template(
                    Settings.builder().put("setting", "value").build(),
                    new CompressedXContent("{\"baz\":\"eggplant\"}"),
                    Collections.singletonMap("alias", AliasMetadata.builder("alias").build())
                )
            )
        );

        // index template v2
        assertNotNull(parsedMetadata.templatesV2().get("index_templatev2"));
        assertThat(parsedMetadata.templatesV2().get("index_templatev2").priority(), is(5L));
        assertThat(parsedMetadata.templatesV2().get("index_templatev2").version(), is(4L));
        assertThat(parsedMetadata.templatesV2().get("index_templatev2").indexPatterns(), is(Arrays.asList("foo", "bar*")));
        assertThat(parsedMetadata.templatesV2().get("index_templatev2").composedOf(), is(Collections.singletonList("component_template")));
        assertThat(
            parsedMetadata.templatesV2().get("index_templatev2").metadata(),
            equalTo(Collections.singletonMap("my_meta", Collections.singletonMap("potato", "chicken")))
        );
        assertThat(
            parsedMetadata.templatesV2().get("index_templatev2").template(),
            equalTo(
                new Template(
                    Settings.builder().put("setting", "value").build(),
                    new CompressedXContent("{\"baz\":\"eggplant\"}"),
                    Collections.singletonMap("alias", AliasMetadata.builder("alias").build())
                )
            )
        );

        // data streams
        assertNotNull(parsedMetadata.dataStreams().get("data-stream1"));
        assertThat(parsedMetadata.dataStreams().get("data-stream1").getName(), is("data-stream1"));
        assertThat(parsedMetadata.dataStreams().get("data-stream1").getTimeStampField().getName(), is("@timestamp"));
        assertThat(parsedMetadata.dataStreams().get("data-stream1").getIndices(), contains(idx1.getIndex()));
        assertNotNull(parsedMetadata.dataStreams().get("data-stream2"));
        assertThat(parsedMetadata.dataStreams().get("data-stream2").getName(), is("data-stream2"));
        assertThat(parsedMetadata.dataStreams().get("data-stream2").getTimeStampField().getName(), is("@timestamp"));
        assertThat(parsedMetadata.dataStreams().get("data-stream2").getIndices(), contains(idx2.getIndex()));
    }

    private static final String MAPPING_SOURCE1 = "{\"mapping1\":{\"text1\":{\"type\":\"string\"}}}";
    private static final String MAPPING_SOURCE2 = "{\"mapping2\":{\"text2\":{\"type\":\"string\"}}}";
    private static final String ALIAS_FILTER1 = "{\"field1\":\"value1\"}";
    private static final String ALIAS_FILTER2 = "{\"field2\":\"value2\"}";

    public void testToXContentGateway_FlatSettingTrue_ReduceMappingFalse() throws IOException {
        Map<String, String> mapParams = new HashMap<String, String>() {
            {
                put(Metadata.CONTEXT_MODE_PARAM, CONTEXT_MODE_GATEWAY);
                put("flat_settings", "true");
                put("reduce_mappings", "false");
            }
        };

        Metadata metadata = buildMetadata();
        XContentBuilder builder = JsonXContent.contentBuilder().prettyPrint();
        builder.startObject();
        metadata.toXContent(builder, new ToXContent.MapParams(mapParams));
        builder.endObject();

        assertEquals(
            "{\n"
                + "  \"meta-data\" : {\n"
                + "    \"version\" : 0,\n"
                + "    \"cluster_uuid\" : \"clusterUUID\",\n"
                + "    \"cluster_uuid_committed\" : false,\n"
                + "    \"cluster_coordination\" : {\n"
                + "      \"term\" : 1,\n"
                + "      \"last_committed_config\" : [\n"
                + "        \"commitedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"last_accepted_config\" : [\n"
                + "        \"acceptedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"voting_config_exclusions\" : [\n"
                + "        {\n"
                + "          \"node_id\" : \"exlucdedNodeId\",\n"
                + "          \"node_name\" : \"excludedNodeName\"\n"
                + "        }\n"
                + "      ]\n"
                + "    },\n"
                + "    \"settings\" : {\n"
                + "      \"index.version.created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "    },\n"
                + "    \"templates\" : {\n"
                + "      \"template\" : {\n"
                + "        \"order\" : 0,\n"
                + "        \"index_patterns\" : [\n"
                + "          \"pattern1\",\n"
                + "          \"pattern2\"\n"
                + "        ],\n"
                + "        \"settings\" : {\n"
                + "          \"index.version.created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "        },\n"
                + "        \"mappings\" : {\n"
                + "          \"key1\" : { }\n"
                + "        },\n"
                + "        \"aliases\" : { }\n"
                + "      }\n"
                + "    },\n"
                + "    \"index-graveyard\" : {\n"
                + "      \"tombstones\" : [ ]\n"
                + "    }\n"
                + "  }\n"
                + "}",
            Strings.toString(builder)
        );
    }

    public void testToXContentAPI_SameTypeName() throws IOException {
        Map<String, String> mapParams = new HashMap<String, String>() {
            {
                put(Metadata.CONTEXT_MODE_PARAM, CONTEXT_MODE_API);
            }
        };

        Metadata metadata = Metadata.builder()
            .clusterUUID("clusterUUID")
            .coordinationMetadata(CoordinationMetadata.builder().build())
            .put(
                IndexMetadata.builder("index")
                    .state(IndexMetadata.State.OPEN)
                    .settings(Settings.builder().put(SETTING_VERSION_CREATED, Version.CURRENT.id))
                    .putMapping(
                        new MappingMetadata(
                            "type",
                            // the type name is the root value,
                            // the original logic in ClusterState.toXContent will reduce
                            new HashMap<String, Object>() {
                                {
                                    put("type", new HashMap<String, Object>() {
                                        {
                                            put("key", "value");
                                        }
                                    });
                                }
                            }
                        )
                    )
                    .numberOfShards(1)
                    .primaryTerm(0, 1L)
                    .numberOfReplicas(2)
            )
            .build();
        XContentBuilder builder = JsonXContent.contentBuilder().prettyPrint();
        builder.startObject();
        metadata.toXContent(builder, new ToXContent.MapParams(mapParams));
        builder.endObject();

        assertEquals(
            "{\n"
                + "  \"metadata\" : {\n"
                + "    \"cluster_uuid\" : \"clusterUUID\",\n"
                + "    \"cluster_uuid_committed\" : false,\n"
                + "    \"cluster_coordination\" : {\n"
                + "      \"term\" : 0,\n"
                + "      \"last_committed_config\" : [ ],\n"
                + "      \"last_accepted_config\" : [ ],\n"
                + "      \"voting_config_exclusions\" : [ ]\n"
                + "    },\n"
                + "    \"templates\" : { },\n"
                + "    \"indices\" : {\n"
                + "      \"index\" : {\n"
                + "        \"version\" : 2,\n"
                + "        \"mapping_version\" : 1,\n"
                + "        \"settings_version\" : 1,\n"
                + "        \"aliases_version\" : 1,\n"
                + "        \"routing_num_shards\" : 1,\n"
                + "        \"state\" : \"open\",\n"
                + "        \"settings\" : {\n"
                + "          \"index\" : {\n"
                + "            \"number_of_shards\" : \"1\",\n"
                + "            \"number_of_replicas\" : \"2\",\n"
                + "            \"version\" : {\n"
                + "              \"created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "            }\n"
                + "          }\n"
                + "        },\n"
                + "        \"mappings\" : {\n"
                + "          \"type\" : {\n"
                + "            \"key\" : \"value\"\n"
                + "          }\n"
                + "        },\n"
                + "        \"aliases\" : [ ],\n"
                + "        \"primary_terms\" : {\n"
                + "          \"0\" : 1\n"
                + "        },\n"
                + "        \"in_sync_allocations\" : {\n"
                + "          \"0\" : [ ]\n"
                + "        },\n"
                + "        \"rollover_info\" : { },\n"
                + "        \"system\" : false\n"
                + "      }\n"
                + "    },\n"
                + "    \"index-graveyard\" : {\n"
                + "      \"tombstones\" : [ ]\n"
                + "    }\n"
                + "  }\n"
                + "}",
            Strings.toString(builder)
        );
    }

    public void testToXContentGateway_FlatSettingFalse_ReduceMappingTrue() throws IOException {
        Map<String, String> mapParams = new HashMap<String, String>() {
            {
                put(Metadata.CONTEXT_MODE_PARAM, CONTEXT_MODE_GATEWAY);
                put("flat_settings", "false");
                put("reduce_mappings", "true");
            }
        };

        Metadata metadata = buildMetadata();
        XContentBuilder builder = JsonXContent.contentBuilder().prettyPrint();
        builder.startObject();
        metadata.toXContent(builder, new ToXContent.MapParams(mapParams));
        builder.endObject();

        assertEquals(
            "{\n"
                + "  \"meta-data\" : {\n"
                + "    \"version\" : 0,\n"
                + "    \"cluster_uuid\" : \"clusterUUID\",\n"
                + "    \"cluster_uuid_committed\" : false,\n"
                + "    \"cluster_coordination\" : {\n"
                + "      \"term\" : 1,\n"
                + "      \"last_committed_config\" : [\n"
                + "        \"commitedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"last_accepted_config\" : [\n"
                + "        \"acceptedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"voting_config_exclusions\" : [\n"
                + "        {\n"
                + "          \"node_id\" : \"exlucdedNodeId\",\n"
                + "          \"node_name\" : \"excludedNodeName\"\n"
                + "        }\n"
                + "      ]\n"
                + "    },\n"
                + "    \"settings\" : {\n"
                + "      \"index.version.created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "    },\n"
                + "    \"templates\" : {\n"
                + "      \"template\" : {\n"
                + "        \"order\" : 0,\n"
                + "        \"index_patterns\" : [\n"
                + "          \"pattern1\",\n"
                + "          \"pattern2\"\n"
                + "        ],\n"
                + "        \"settings\" : {\n"
                + "          \"index\" : {\n"
                + "            \"version\" : {\n"
                + "              \"created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "            }\n"
                + "          }\n"
                + "        },\n"
                + "        \"mappings\" : { },\n"
                + "        \"aliases\" : { }\n"
                + "      }\n"
                + "    },\n"
                + "    \"index-graveyard\" : {\n"
                + "      \"tombstones\" : [ ]\n"
                + "    }\n"
                + "  }\n"
                + "}",
            Strings.toString(builder)
        );
    }

    public void testToXContentAPI_FlatSettingTrue_ReduceMappingFalse() throws IOException {
        Map<String, String> mapParams = new HashMap<String, String>() {
            {
                put(Metadata.CONTEXT_MODE_PARAM, CONTEXT_MODE_API);
                put("flat_settings", "true");
                put("reduce_mappings", "false");
            }
        };

        final Metadata metadata = buildMetadata();

        XContentBuilder builder = JsonXContent.contentBuilder().prettyPrint();
        builder.startObject();
        metadata.toXContent(builder, new ToXContent.MapParams(mapParams));
        builder.endObject();

        assertEquals(
            "{\n"
                + "  \"metadata\" : {\n"
                + "    \"cluster_uuid\" : \"clusterUUID\",\n"
                + "    \"cluster_uuid_committed\" : false,\n"
                + "    \"cluster_coordination\" : {\n"
                + "      \"term\" : 1,\n"
                + "      \"last_committed_config\" : [\n"
                + "        \"commitedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"last_accepted_config\" : [\n"
                + "        \"acceptedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"voting_config_exclusions\" : [\n"
                + "        {\n"
                + "          \"node_id\" : \"exlucdedNodeId\",\n"
                + "          \"node_name\" : \"excludedNodeName\"\n"
                + "        }\n"
                + "      ]\n"
                + "    },\n"
                + "    \"templates\" : {\n"
                + "      \"template\" : {\n"
                + "        \"order\" : 0,\n"
                + "        \"index_patterns\" : [\n"
                + "          \"pattern1\",\n"
                + "          \"pattern2\"\n"
                + "        ],\n"
                + "        \"settings\" : {\n"
                + "          \"index.version.created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "        },\n"
                + "        \"mappings\" : {\n"
                + "          \"key1\" : { }\n"
                + "        },\n"
                + "        \"aliases\" : { }\n"
                + "      }\n"
                + "    },\n"
                + "    \"indices\" : {\n"
                + "      \"index\" : {\n"
                + "        \"version\" : 2,\n"
                + "        \"mapping_version\" : 1,\n"
                + "        \"settings_version\" : 1,\n"
                + "        \"aliases_version\" : 1,\n"
                + "        \"routing_num_shards\" : 1,\n"
                + "        \"state\" : \"open\",\n"
                + "        \"settings\" : {\n"
                + "          \"index.number_of_replicas\" : \"2\",\n"
                + "          \"index.number_of_shards\" : \"1\",\n"
                + "          \"index.version.created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "        },\n"
                + "        \"mappings\" : {\n"
                + "          \"type\" : {\n"
                + "            \"type1\" : {\n"
                + "              \"key\" : \"value\"\n"
                + "            }\n"
                + "          }\n"
                + "        },\n"
                + "        \"aliases\" : [\n"
                + "          \"alias\"\n"
                + "        ],\n"
                + "        \"primary_terms\" : {\n"
                + "          \"0\" : 1\n"
                + "        },\n"
                + "        \"in_sync_allocations\" : {\n"
                + "          \"0\" : [\n"
                + "            \"allocationId\"\n"
                + "          ]\n"
                + "        },\n"
                + "        \"rollover_info\" : {\n"
                + "          \"rolloveAlias\" : {\n"
                + "            \"met_conditions\" : { },\n"
                + "            \"time\" : 1\n"
                + "          }\n"
                + "        },\n"
                + "        \"system\" : false\n"
                + "      }\n"
                + "    },\n"
                + "    \"index-graveyard\" : {\n"
                + "      \"tombstones\" : [ ]\n"
                + "    }\n"
                + "  }\n"
                + "}",
            Strings.toString(builder)
        );
    }

    public void testToXContentAPI_FlatSettingFalse_ReduceMappingTrue() throws IOException {
        Map<String, String> mapParams = new HashMap<String, String>() {
            {
                put(Metadata.CONTEXT_MODE_PARAM, CONTEXT_MODE_API);
                put("flat_settings", "false");
                put("reduce_mappings", "true");
            }
        };

        final Metadata metadata = buildMetadata();

        XContentBuilder builder = JsonXContent.contentBuilder().prettyPrint();
        builder.startObject();
        metadata.toXContent(builder, new ToXContent.MapParams(mapParams));
        builder.endObject();

        assertEquals(
            "{\n"
                + "  \"metadata\" : {\n"
                + "    \"cluster_uuid\" : \"clusterUUID\",\n"
                + "    \"cluster_uuid_committed\" : false,\n"
                + "    \"cluster_coordination\" : {\n"
                + "      \"term\" : 1,\n"
                + "      \"last_committed_config\" : [\n"
                + "        \"commitedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"last_accepted_config\" : [\n"
                + "        \"acceptedConfigurationNodeId\"\n"
                + "      ],\n"
                + "      \"voting_config_exclusions\" : [\n"
                + "        {\n"
                + "          \"node_id\" : \"exlucdedNodeId\",\n"
                + "          \"node_name\" : \"excludedNodeName\"\n"
                + "        }\n"
                + "      ]\n"
                + "    },\n"
                + "    \"templates\" : {\n"
                + "      \"template\" : {\n"
                + "        \"order\" : 0,\n"
                + "        \"index_patterns\" : [\n"
                + "          \"pattern1\",\n"
                + "          \"pattern2\"\n"
                + "        ],\n"
                + "        \"settings\" : {\n"
                + "          \"index\" : {\n"
                + "            \"version\" : {\n"
                + "              \"created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "            }\n"
                + "          }\n"
                + "        },\n"
                + "        \"mappings\" : { },\n"
                + "        \"aliases\" : { }\n"
                + "      }\n"
                + "    },\n"
                + "    \"indices\" : {\n"
                + "      \"index\" : {\n"
                + "        \"version\" : 2,\n"
                + "        \"mapping_version\" : 1,\n"
                + "        \"settings_version\" : 1,\n"
                + "        \"aliases_version\" : 1,\n"
                + "        \"routing_num_shards\" : 1,\n"
                + "        \"state\" : \"open\",\n"
                + "        \"settings\" : {\n"
                + "          \"index\" : {\n"
                + "            \"number_of_shards\" : \"1\",\n"
                + "            \"number_of_replicas\" : \"2\",\n"
                + "            \"version\" : {\n"
                + "              \"created\" : \""
                + Version.CURRENT.id
                + "\"\n"
                + "            }\n"
                + "          }\n"
                + "        },\n"
                + "        \"mappings\" : {\n"
                + "          \"type\" : {\n"
                + "            \"type1\" : {\n"
                + "              \"key\" : \"value\"\n"
                + "            }\n"
                + "          }\n"
                + "        },\n"
                + "        \"aliases\" : [\n"
                + "          \"alias\"\n"
                + "        ],\n"
                + "        \"primary_terms\" : {\n"
                + "          \"0\" : 1\n"
                + "        },\n"
                + "        \"in_sync_allocations\" : {\n"
                + "          \"0\" : [\n"
                + "            \"allocationId\"\n"
                + "          ]\n"
                + "        },\n"
                + "        \"rollover_info\" : {\n"
                + "          \"rolloveAlias\" : {\n"
                + "            \"met_conditions\" : { },\n"
                + "            \"time\" : 1\n"
                + "          }\n"
                + "        },\n"
                + "        \"system\" : false\n"
                + "      }\n"
                + "    },\n"
                + "    \"index-graveyard\" : {\n"
                + "      \"tombstones\" : [ ]\n"
                + "    }\n"
                + "  }\n"
                + "}",
            Strings.toString(builder)
        );
    }

    private Metadata buildMetadata() throws IOException {
        return Metadata.builder()
            .clusterUUID("clusterUUID")
            .coordinationMetadata(
                CoordinationMetadata.builder()
                    .term(1)
                    .lastCommittedConfiguration(new CoordinationMetadata.VotingConfiguration(new HashSet<String>() {
                        {
                            add("commitedConfigurationNodeId");
                        }
                    }))
                    .lastAcceptedConfiguration(new CoordinationMetadata.VotingConfiguration(new HashSet<String>() {
                        {
                            add("acceptedConfigurationNodeId");
                        }
                    }))
                    .addVotingConfigExclusion(new CoordinationMetadata.VotingConfigExclusion("exlucdedNodeId", "excludedNodeName"))
                    .build()
            )
            .persistentSettings(Settings.builder().put(SETTING_VERSION_CREATED, Version.CURRENT.id).build())
            .transientSettings(Settings.builder().put(SETTING_VERSION_CREATED, Version.CURRENT.id).build())
            .put(
                IndexMetadata.builder("index")
                    .state(IndexMetadata.State.OPEN)
                    .settings(Settings.builder().put(SETTING_VERSION_CREATED, Version.CURRENT.id))
                    .putMapping(new MappingMetadata("type", new HashMap<String, Object>() {
                        {
                            put("type1", new HashMap<String, Object>() {
                                {
                                    put("key", "value");
                                }
                            });
                        }
                    }))
                    .putAlias(AliasMetadata.builder("alias").indexRouting("indexRouting").build())
                    .numberOfShards(1)
                    .primaryTerm(0, 1L)
                    .putInSyncAllocationIds(0, new HashSet<String>() {
                        {
                            add("allocationId");
                        }
                    })
                    .numberOfReplicas(2)
                    .putRolloverInfo(new RolloverInfo("rolloveAlias", new ArrayList<>(), 1L))
            )
            .put(
                IndexTemplateMetadata.builder("template")
                    .patterns(Arrays.asList("pattern1", "pattern2"))
                    .order(0)
                    .settings(Settings.builder().put(SETTING_VERSION_CREATED, Version.CURRENT.id))
                    .putMapping("type", "{ \"key1\": {} }")
                    .build()
            )
            .build();
    }

    public static class CustomMetadata extends TestCustomMetadata {
        public static final String TYPE = "custom_md";

        CustomMetadata(String data) {
            super(data);
        }

        @Override
        public String getWriteableName() {
            return TYPE;
        }

        @Override
        public Version getMinimalSupportedVersion() {
            return Version.CURRENT;
        }

        @Override
        public EnumSet<Metadata.XContentContext> context() {
            return EnumSet.of(Metadata.XContentContext.GATEWAY, Metadata.XContentContext.SNAPSHOT);
        }
    }
}