/* * 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 * * Modifications Copyright OpenSearch Contributors. See * GitHub history for details. */ /* * 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. */ package org.opensearch.hadoop.rest; import org.opensearch.hadoop.util.ByteSequence; import org.opensearch.hadoop.util.StringUtils; public class SimpleRequest implements Request { private final Method method; private final CharSequence uri; private final CharSequence path; private final CharSequence params; private final ByteSequence body; public SimpleRequest(Method method, CharSequence uri, CharSequence path) { this(method, uri, path, null, null); } public SimpleRequest(Method method, CharSequence uri, CharSequence path, CharSequence params) { this(method, uri, path, params, null); } public SimpleRequest(Method method, CharSequence uri, CharSequence path, ByteSequence body) { this(method, uri, path, null, body); } public SimpleRequest(Method method, CharSequence uri, CharSequence path, CharSequence params, ByteSequence body) { this.method = method; this.uri = uri; int queryMark = String.valueOf(path).indexOf('?'); // FOR BWC ISSUES if (StringUtils.hasText(params) && queryMark >= 0) { throw new IllegalArgumentException("Found Request with Query in Path, as well as specified within the params option."); } else if (queryMark >= 0) { this.path = path.subSequence(0, queryMark); this.params = path.subSequence(queryMark + 1, path.length()); } else { this.path = path; this.params = params; } this.body = body; } @Override public Method method() { return method; } @Override public CharSequence uri() { return uri; } @Override public CharSequence path() { return path; } @Override public CharSequence params() { return params; } @Override public ByteSequence body() { return body; } @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; SimpleRequest request = (SimpleRequest) o; if (method != request.method) return false; if (uri != null ? !uri.equals(request.uri) : request.uri != null) return false; if (path != null ? !path.equals(request.path) : request.path != null) return false; if (params != null ? !params.equals(request.params) : request.params != null) return false; return body != null ? body.equals(request.body) : request.body == null; } @Override public int hashCode() { int result = method != null ? method.hashCode() : 0; result = 31 * result + (uri != null ? uri.hashCode() : 0); result = 31 * result + (path != null ? path.hashCode() : 0); result = 31 * result + (params != null ? params.hashCode() : 0); result = 31 * result + (body != null ? body.hashCode() : 0); return result; } @Override public String toString() { StringBuilder sb = new StringBuilder(method.name()); sb.append("@"); sb.append(uri); sb.append("/"); sb.append(path); if (params != null) { sb.append("?"); sb.append(params); } return sb.toString(); } }