using System.Buffers; using System.Globalization; using System.Text.Json.Schema; namespace System.Text.Json.Serialization.Converters { internal sealed class Int128Converter : JsonPrimitiveConverter<Int128> { public Int128Converter() { base.IsInternalConverterForNumberType = true; } public override Int128 Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options) { if (reader.TokenType != JsonTokenType.Number) ThrowHelper.ThrowInvalidOperationException_ExpectedNumber(reader.TokenType); return ReadCore(ref reader); } public override void Write(Utf8JsonWriter writer, Int128 value, JsonSerializerOptions options) { WriteCore(writer, value); } private unsafe static Int128 ReadCore(ref Utf8JsonReader reader) { int valueLength = reader.ValueLength; byte[] array = null; Span<byte> span = (valueLength > 256) ? ((Span<byte>)(array = ArrayPool<byte>.Shared.Rent(valueLength))) : new Span<byte>(stackalloc byte[256], 256); Span<byte> utf8Destination = span; int length = reader.CopyValue(utf8Destination); if (!TryParse(utf8Destination.Slice(0, length), out Int128 result)) ThrowHelper.ThrowFormatException(NumericType.Int128); if (array != null) ArrayPool<byte>.Shared.Return(array, false); return result; } private unsafe static void WriteCore(Utf8JsonWriter writer, Int128 value) { Span<byte> destination = new Span<byte>(stackalloc byte[40], 40); Format(destination, value, out int written); writer.WriteRawValue(destination.Slice(0, written), false); } internal override Int128 ReadAsPropertyNameCore(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options) { return ReadCore(ref reader); } internal unsafe override void WriteAsPropertyNameCore(Utf8JsonWriter writer, Int128 value, JsonSerializerOptions options, bool isWritingExtensionDataProperty) { Span<byte> span = new Span<byte>(stackalloc byte[40], 40); Format(span, value, out int _); writer.WritePropertyName(span); } internal override Int128 ReadNumberWithCustomHandling(ref Utf8JsonReader reader, JsonNumberHandling handling, JsonSerializerOptions options) { if (reader.TokenType == JsonTokenType.String && (JsonNumberHandling.AllowReadingFromString & handling) != 0) return ReadCore(ref reader); return Read(ref reader, Type, options); } internal unsafe override void WriteNumberWithCustomHandling(Utf8JsonWriter writer, Int128 value, JsonNumberHandling handling) { if ((JsonNumberHandling.WriteAsString & handling) != 0) { Span<byte> span = new Span<byte>(stackalloc byte[42], 42); span[0] = 34; Format(span.Slice(1), value, out int written); int num = written + 2; span[num - 1] = 34; writer.WriteRawValue(span.Slice(0, num), false); } else WriteCore(writer, value); } internal override JsonSchema GetSchema(JsonNumberHandling numberHandling) { return JsonPrimitiveConverter<Int128>.GetSchemaForNumericType(JsonSchemaType.Integer, numberHandling, false); } private static bool TryParse(ReadOnlySpan<byte> buffer, out Int128 result) { return Int128.TryParse(buffer, CultureInfo.InvariantCulture, out result); } private static void Format(Span<byte> destination, Int128 value, out int written) { IFormatProvider invariantCulture = CultureInfo.InvariantCulture; value.TryFormat(destination, out written, default(ReadOnlySpan<char>), invariantCulture); } } }