/* 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.
*/
/*
* Modifications Copyright OpenSearch Contributors. See
* GitHub history for details.
*
* Licensed to Elasticsearch B.V. under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch B.V. 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.
*/
using System;
using System.IO;
using System.IO.Compression;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace OpenSearch.Net
{
public class InMemoryConnection : IConnection
{
internal static readonly byte[] EmptyBody = Encoding.UTF8.GetBytes("");
private readonly string _contentType;
private readonly Exception _exception;
private readonly byte[] _responseBody;
private readonly int _statusCode;
///
/// Every request will succeed with this overload, note that it won't actually return mocked responses
/// so using this overload might fail if you are using it to test high level bits that need to deserialize the response.
///
public InMemoryConnection() => _statusCode = 200;
public InMemoryConnection(byte[] responseBody, int statusCode = 200, Exception exception = null, string contentType = RequestData.MimeType)
{
_responseBody = responseBody;
_statusCode = statusCode;
_exception = exception;
_contentType = contentType;
}
public virtual TResponse Request(RequestData requestData)
where TResponse : class, IOpenSearchResponse, new() =>
ReturnConnectionStatus(requestData);
public virtual Task RequestAsync(RequestData requestData, CancellationToken cancellationToken)
where TResponse : class, IOpenSearchResponse, new() =>
ReturnConnectionStatusAsync(requestData, cancellationToken);
void IDisposable.Dispose() => DisposeManagedResources();
protected TResponse ReturnConnectionStatus(RequestData requestData, byte[] responseBody = null, int? statusCode = null,
string contentType = null
)
where TResponse : class, IOpenSearchResponse, new()
{
var body = responseBody ?? _responseBody;
var data = requestData.PostData;
if (data != null)
{
using (var stream = requestData.MemoryStreamFactory.Create())
{
if (requestData.HttpCompression)
using (var zipStream = new GZipStream(stream, CompressionMode.Compress))
data.Write(zipStream, requestData.ConnectionSettings);
else
data.Write(stream, requestData.ConnectionSettings);
}
}
requestData.MadeItToResponse = true;
var sc = statusCode ?? _statusCode;
Stream s = body != null ? requestData.MemoryStreamFactory.Create(body) : requestData.MemoryStreamFactory.Create(EmptyBody);
return ResponseBuilder.ToResponse(requestData, _exception, sc, null, s, contentType ?? _contentType ?? RequestData.MimeType);
}
protected async Task ReturnConnectionStatusAsync(RequestData requestData, CancellationToken cancellationToken,
byte[] responseBody = null, int? statusCode = null, string contentType = null
)
where TResponse : class, IOpenSearchResponse, new()
{
var body = responseBody ?? _responseBody;
var data = requestData.PostData;
if (data != null)
{
using (var stream = requestData.MemoryStreamFactory.Create())
{
if (requestData.HttpCompression)
using (var zipStream = new GZipStream(stream, CompressionMode.Compress))
await data.WriteAsync(zipStream, requestData.ConnectionSettings, cancellationToken).ConfigureAwait(false);
else
await data.WriteAsync(stream, requestData.ConnectionSettings, cancellationToken).ConfigureAwait(false);
}
}
requestData.MadeItToResponse = true;
var sc = statusCode ?? _statusCode;
Stream s = body != null ? requestData.MemoryStreamFactory.Create(body) : requestData.MemoryStreamFactory.Create(EmptyBody);
return await ResponseBuilder
.ToResponseAsync(requestData, _exception, sc, null, s, contentType ?? _contentType, cancellationToken)
.ConfigureAwait(false);
}
protected virtual void DisposeManagedResources() { }
}
}