/* 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. */ #region Utf8Json License https://github.com/neuecc/Utf8Json/blob/master/LICENSE // MIT License // // Copyright (c) 2017 Yoshifumi Kawai // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in all // copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE // SOFTWARE. #endregion using System; using System.Collections; using System.Collections.Generic; using OpenSearch.Net.Extensions; using OpenSearch.Net.Utf8Json.Internal; namespace OpenSearch.Net.Utf8Json.Formatters { internal sealed class PrimitiveObjectFormatter : IJsonFormatter { public static readonly IJsonFormatter Default = new PrimitiveObjectFormatter(); private static readonly Dictionary TypeToJumpCode = new Dictionary() { { typeof(bool), 0 }, { typeof(char), 1 }, { typeof(sbyte), 2 }, { typeof(byte), 3 }, { typeof(short), 4 }, { typeof(ushort), 5 }, { typeof(int), 6 }, { typeof(uint), 7 }, { typeof(long), 8 }, { typeof(ulong),9 }, { typeof(float), 10 }, { typeof(double), 11 }, { typeof(DateTime), 12 }, { typeof(string), 13 }, { typeof(byte[]), 14 } }; public void Serialize(ref JsonWriter writer, object value, IJsonFormatterResolver formatterResolver) { if (value == null) { writer.WriteNull(); return; } var t = value.GetType(); if (TypeToJumpCode.TryGetValue(t, out var key)) { switch (key) { case 0: writer.WriteBoolean((bool)value); return; case 1: CharFormatter.Default.Serialize(ref writer, (char)value, formatterResolver); return; case 2: writer.WriteSByte((sbyte)value); return; case 3: writer.WriteByte((byte)value); return; case 4: writer.WriteInt16((short)value); return; case 5: writer.WriteUInt16((ushort)value); return; case 6: writer.WriteInt32((int)value); return; case 7: writer.WriteUInt32((uint)value); return; case 8: writer.WriteInt64((long)value); return; case 9: writer.WriteUInt64((ulong)value); return; case 10: writer.WriteSingle((float)value); return; case 11: writer.WriteDouble((double)value); return; case 12: ISO8601DateTimeFormatter.Default.Serialize(ref writer, (DateTime)value, formatterResolver); return; case 13: writer.WriteString((string)value); return; case 14: ByteArrayFormatter.Default.Serialize(ref writer, (byte[])value, formatterResolver); return; default: break; } } if (t.IsEnum) { writer.WriteString(t.ToString()); // enum as string return; } if (value is IDictionary dict) { var count = 0; writer.WriteBeginObject(); foreach (DictionaryEntry item in dict) { if (count++ != 0) writer.WriteValueSeparator(); writer.WritePropertyName((string)item.Key); Serialize(ref writer, item.Value, formatterResolver); } writer.WriteEndObject(); return; } if (value is ICollection collection) { var count = 0; writer.WriteBeginArray(); foreach (var item in collection) { if (count++ != 0) writer.WriteValueSeparator(); Serialize(ref writer, item, formatterResolver); } writer.WriteEndArray(); return; } throw new InvalidOperationException("Not supported primitive object resolver. type:" + t.Name); } public object Deserialize(ref JsonReader reader, IJsonFormatterResolver formatterResolver) { var token = reader.GetCurrentJsonToken(); switch (token) { case JsonToken.BeginObject: { var dict = new Dictionary(); reader.ReadIsBeginObjectWithVerify(); var count = 0; while (!reader.ReadIsEndObjectWithSkipValueSeparator(ref count)) { var key = reader.ReadPropertyName(); var value = Deserialize(ref reader, formatterResolver); dict.Add(key, value); } return dict; } case JsonToken.BeginArray: { var list = new List(4); reader.ReadIsBeginArrayWithVerify(); var count = 0; while (!reader.ReadIsEndArrayWithSkipValueSeparator(ref count)) { list.Add(Deserialize(ref reader, formatterResolver)); } return list; } case JsonToken.Number: var numberSegment = reader.ReadNumberSegment(); // conditional operator here would cast both to double, so don't use. // Check for IsLong first, avoid floating point rounding if (numberSegment.IsLong()) return NumberConverter.ReadInt64(numberSegment.Array, numberSegment.Offset, out _); return NumberConverter.ReadDouble(numberSegment.Array, numberSegment.Offset, out _); case JsonToken.String: return reader.ReadString(); case JsonToken.True: return reader.ReadBoolean(); // require advance case JsonToken.False: return reader.ReadBoolean(); // require advance case JsonToken.ValueSeparator: case JsonToken.NameSeparator: case JsonToken.EndArray: case JsonToken.EndObject: throw new InvalidOperationException("Invalid Json Token:" + token); case JsonToken.Null: reader.ReadIsNull(); return null; case JsonToken.None: default: return null; } } } }