/*
* Copyright (c) 2021 PANTHEON.tech, s.r.o. and others. All rights reserved.
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
package org.opendaylight.restconf.api;
import static com.google.common.base.Verify.verifyNotNull;
import static java.util.Objects.requireNonNull;
import com.google.common.base.MoreObjects;
import com.google.common.base.MoreObjects.ToStringHelper;
import com.google.common.collect.ImmutableList;
import com.google.common.escape.Escaper;
import com.google.common.escape.Escapers;
import java.io.IOException;
import java.io.NotSerializableException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.ObjectStreamException;
import java.text.ParseException;
import java.util.HexFormat;
import java.util.Objects;
import org.eclipse.jdt.annotation.NonNullByDefault;
import org.eclipse.jdt.annotation.Nullable;
import org.opendaylight.yangtools.concepts.HierarchicalIdentifier;
import org.opendaylight.yangtools.concepts.Immutable;
import org.opendaylight.yangtools.yang.common.UnresolvedQName;
import org.opendaylight.yangtools.yang.common.UnresolvedQName.Unqualified;
/**
* Intermediate representation of a parsed {@code api-path} string as defined in
* RFC section 3.5.3.1. It models the path
* as a series of {@link Step}s.
*/
@NonNullByDefault
public final class ApiPath implements HierarchicalIdentifier {
@java.io.Serial
private static final long serialVersionUID = 1L;
/**
* A single step in an {@link ApiPath}.
*/
public abstract static sealed class Step implements Immutable {
private final @Nullable String module;
private final Unqualified identifier;
Step(final @Nullable String module, final String identifier) {
this.identifier = verifyNotNull(UnresolvedQName.tryLocalName(identifier),
"Unexpected invalid identifier %s", identifier);
this.module = module;
}
public Unqualified identifier() {
return identifier;
}
public @Nullable String module() {
return module;
}
@Override
public abstract int hashCode();
@Override
public abstract boolean equals(@Nullable Object obj);
final boolean equals(final Step other) {
return Objects.equals(module, other.module) && identifier.equals(other.identifier);
}
@Override
public final String toString() {
return addToStringAttributes(MoreObjects.toStringHelper(this).omitNullValues()).toString();
}
ToStringHelper addToStringAttributes(final ToStringHelper helper) {
return helper.add("module", module).add("identifier", identifier);
}
void appendTo(final StringBuilder sb) {
if (module != null) {
sb.append(module).append(':');
}
sb.append(identifier.getLocalName());
}
}
/**
* An {@code api-identifier} step in a {@link ApiPath}.
*/
public static final class ApiIdentifier extends Step {
public ApiIdentifier(final @Nullable String module, final String identifier) {
super(module, identifier);
}
@Override
public int hashCode() {
return Objects.hash(module(), identifier());
}
@Override
public boolean equals(final @Nullable Object obj) {
return this == obj || obj instanceof ApiIdentifier other && equals(other);
}
}
/**
* A {@code list-instance} step in a {@link ApiPath}.
*/
public static final class ListInstance extends Step {
private final ImmutableList keyValues;
ListInstance(final @Nullable String module, final String identifier, final ImmutableList keyValues) {
super(module, identifier);
this.keyValues = requireNonNull(keyValues);
}
public ImmutableList keyValues() {
return keyValues;
}
@Override
public int hashCode() {
return Objects.hash(module(), identifier(), keyValues);
}
@Override
public boolean equals(final @Nullable Object obj) {
return this == obj || obj instanceof ListInstance other && equals(other)
&& keyValues.equals(other.keyValues);
}
@Override
ToStringHelper addToStringAttributes(final ToStringHelper helper) {
return super.addToStringAttributes(helper).add("keyValues", keyValues);
}
@Override
void appendTo(final StringBuilder sb) {
super.appendTo(sb);
sb.append('=');
final var it = keyValues.iterator();
while (true) {
sb.append(PERCENT_ESCAPER.escape(it.next()));
if (it.hasNext()) {
sb.append(',');
} else {
break;
}
}
}
}
// Escaper based on RFC8040-requirement to percent-encode reserved characters, as defined in
// https://tools.ietf.org/html/rfc3986#section-2.2
public static final Escaper PERCENT_ESCAPER;
static {
final var hexFormat = HexFormat.of().withUpperCase();
final var builder = Escapers.builder();
for (char ch : new char[] {
// Reserved characters as per https://tools.ietf.org/html/rfc3986#section-2.2
':', '/', '?', '#', '[', ']', '@',
'!', '$', '&', '\'', '(', ')', '*', '+', ',', ';', '=',
}) {
builder.addEscape(ch, "%" + hexFormat.toHighHexDigit(ch) + hexFormat.toLowHexDigit(ch));
}
PERCENT_ESCAPER = builder.build();
}
private static final ApiPath EMPTY = new ApiPath(ImmutableList.of());
private final ImmutableList steps;
private ApiPath(final ImmutableList steps) {
this.steps = requireNonNull(steps);
}
/**
* Return an empty ApiPath.
*
* @return An empty ApiPath.
*/
public static ApiPath empty() {
return EMPTY;
}
/**
* Parse an {@link ApiPath} from a raw Request URI fragment or another source. The string is expected to contain
* percent-encoded bytes. Any sequence of such bytes is interpreted as a {@code UTF-8}-encoded string. Invalid
* sequences are rejected.
*
* @param str Request URI part
* @return An {@link ApiPath}
* @throws NullPointerException if {@code str} is {@code null}
* @throws ParseException if the string cannot be parsed
*/
public static ApiPath parse(final String str) throws ParseException {
return str.isEmpty() ? EMPTY : parseString(ApiPathParser.newStrict(), str);
}
/**
* Parse an {@link ApiPath} from a raw Request URI fragment. The string is expected to contain percent-encoded
* bytes. Any sequence of such bytes is interpreted as a {@code UTF-8}-encoded string. Invalid sequences are
* rejected, but consecutive slashes may be tolerated, depending on runtime configuration.
*
* @param str Request URI part
* @return An {@link ApiPath}
* @throws NullPointerException if {@code str} is {@code null}
* @throws ParseException if the string cannot be parsed
*/
public static ApiPath parseUrl(final String str) throws ParseException {
return str.isEmpty() ? EMPTY : parseString(ApiPathParser.newUrl(), str);
}
/**
* Return the {@link Step}s of this path.
*
* @return Path steps
*/
public ImmutableList steps() {
return steps;
}
@Override
public boolean contains(final ApiPath other) {
if (this == other) {
return true;
}
final var oit = other.steps.iterator();
for (var step : steps) {
if (!oit.hasNext() || !step.equals(oit.next())) {
return false;
}
}
return true;
}
/**
* Returns the index of a Step in this path matching specified module and identifier. This method is equivalent to
* {@code indexOf(module, identifier, 0)}.
*
* @param module Requested {@link Step#module()}
* @param identifier Requested {@link Step#identifier()}
* @return Index of the step in {@link #steps}, or {@code -1} if a matching step is not found
* @throws NullPointerException if {@code identifier} is {@code null}
*/
public int indexOf(final String module, final String identifier) {
return indexOf(module, identifier, 0);
}
/**
* Returns the index of a Step in this path matching specified module and identifier, starting search at specified
* index.
*
* @param module Requested {@link Step#module()}
* @param identifier Requested {@link Step#identifier()}
* @param fromIndex index from which to search
* @return Index of the step in {@link #steps}, or {@code -1} if a matching step is not found
* @throws NullPointerException if {@code identifier} is {@code null}
*/
public int indexOf(final String module, final String identifier, final int fromIndex) {
final var id = requireNonNull(identifier);
for (int i = fromIndex, size = steps.size(); i < size; ++i) {
final var step = steps.get(i);
if (id.equals(step.identifier.getLocalName()) && Objects.equals(module, step.module)) {
return i;
}
}
return -1;
}
public ApiPath subPath(final int fromIndex) {
return subPath(fromIndex, steps.size());
}
public ApiPath subPath(final int fromIndex, final int toIndex) {
final var subList = steps.subList(fromIndex, toIndex);
if (subList == steps) {
return this;
} else if (subList.isEmpty()) {
return EMPTY;
} else {
return new ApiPath(subList);
}
}
@Override
public int hashCode() {
return steps.hashCode();
}
@Override
public boolean equals(final @Nullable Object obj) {
return obj == this || obj instanceof ApiPath other && steps.equals(other.steps());
}
@Override
public String toString() {
if (steps.isEmpty()) {
return "";
}
final var sb = new StringBuilder();
final var it = steps.iterator();
while (true) {
it.next().appendTo(sb);
if (it.hasNext()) {
sb.append('/');
} else {
break;
}
}
return sb.toString();
}
@java.io.Serial
Object writeReplace() throws ObjectStreamException {
return new APv1(toString());
}
@java.io.Serial
private void writeObject(final ObjectOutputStream stream) throws IOException {
throw nse();
}
@java.io.Serial
private void readObject(final ObjectInputStream stream) throws IOException, ClassNotFoundException {
throw nse();
}
@java.io.Serial
private void readObjectNoData() throws ObjectStreamException {
throw nse();
}
private NotSerializableException nse() {
return new NotSerializableException(getClass().getName());
}
private static ApiPath parseString(final ApiPathParser parser, final String str) throws ParseException {
final var steps = parser.parseSteps(str);
return steps.isEmpty() ? EMPTY : new ApiPath(steps);
}
}