/* * 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.cluster.Diff; import org.opensearch.cluster.DiffableUtils; import org.opensearch.cluster.NamedDiff; import org.opensearch.common.Strings; import org.opensearch.core.common.io.stream.StreamInput; import org.opensearch.core.common.io.stream.StreamOutput; import org.opensearch.common.xcontent.XContentType; import org.opensearch.core.ParseField; import org.opensearch.core.xcontent.ConstructingObjectParser; import org.opensearch.core.xcontent.XContentBuilder; import org.opensearch.core.xcontent.XContentParser; import java.io.IOException; import java.util.EnumSet; import java.util.HashMap; import java.util.Map; import java.util.Objects; import static org.opensearch.cluster.metadata.ComposableIndexTemplateMetadata.MINIMMAL_SUPPORTED_VERSION; /** * {@link ComponentTemplateMetadata} is a custom {@link Metadata} implementation for storing a map * of component templates and their names. * * @opensearch.internal */ public class ComponentTemplateMetadata implements Metadata.Custom { public static final String TYPE = "component_template"; private static final ParseField COMPONENT_TEMPLATE = new ParseField("component_template"); @SuppressWarnings("unchecked") private static final ConstructingObjectParser PARSER = new ConstructingObjectParser<>( TYPE, false, a -> new ComponentTemplateMetadata((Map) a[0]) ); static { PARSER.declareObject(ConstructingObjectParser.constructorArg(), (p, c) -> { Map templates = new HashMap<>(); while (p.nextToken() != XContentParser.Token.END_OBJECT) { String name = p.currentName(); templates.put(name, ComponentTemplate.parse(p)); } return templates; }, COMPONENT_TEMPLATE); } private final Map componentTemplates; public ComponentTemplateMetadata(Map componentTemplates) { this.componentTemplates = componentTemplates; } public ComponentTemplateMetadata(StreamInput in) throws IOException { this.componentTemplates = in.readMap(StreamInput::readString, ComponentTemplate::new); } public Map componentTemplates() { return this.componentTemplates; } @Override public Diff diff(Metadata.Custom before) { return new ComponentTemplateMetadataDiff((ComponentTemplateMetadata) before, this); } public static NamedDiff readDiffFrom(StreamInput in) throws IOException { return new ComponentTemplateMetadataDiff(in); } @Override public EnumSet context() { return Metadata.ALL_CONTEXTS; } @Override public String getWriteableName() { return TYPE; } @Override public Version getMinimalSupportedVersion() { return MINIMMAL_SUPPORTED_VERSION; } @Override public void writeTo(StreamOutput out) throws IOException { out.writeMap(this.componentTemplates, StreamOutput::writeString, (stream, val) -> val.writeTo(stream)); } public static ComponentTemplateMetadata fromXContent(XContentParser parser) throws IOException { return PARSER.parse(parser, null); } @Override public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException { builder.startObject(COMPONENT_TEMPLATE.getPreferredName()); for (Map.Entry template : componentTemplates.entrySet()) { builder.field(template.getKey(), template.getValue()); } builder.endObject(); return builder; } @Override public int hashCode() { return Objects.hash(this.componentTemplates); } @Override public boolean equals(Object obj) { if (obj == null) { return false; } if (obj.getClass() != getClass()) { return false; } ComponentTemplateMetadata other = (ComponentTemplateMetadata) obj; return Objects.equals(this.componentTemplates, other.componentTemplates); } @Override public String toString() { return Strings.toString(XContentType.JSON, this); } /** * A diff between component template metadata. * * @opensearch.internal */ static class ComponentTemplateMetadataDiff implements NamedDiff { final Diff> componentTemplateDiff; ComponentTemplateMetadataDiff(ComponentTemplateMetadata before, ComponentTemplateMetadata after) { this.componentTemplateDiff = DiffableUtils.diff( before.componentTemplates, after.componentTemplates, DiffableUtils.getStringKeySerializer() ); } ComponentTemplateMetadataDiff(StreamInput in) throws IOException { this.componentTemplateDiff = DiffableUtils.readJdkMapDiff( in, DiffableUtils.getStringKeySerializer(), ComponentTemplate::new, ComponentTemplate::readComponentTemplateDiffFrom ); } @Override public Metadata.Custom apply(Metadata.Custom part) { return new ComponentTemplateMetadata(componentTemplateDiff.apply(((ComponentTemplateMetadata) part).componentTemplates)); } @Override public void writeTo(StreamOutput out) throws IOException { componentTemplateDiff.writeTo(out); } @Override public String getWriteableName() { return TYPE; } } }