2
0

JsonPipeDelimitedArrayConverter.cs 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. using System;
  2. using System.ComponentModel;
  3. using System.Text.Json;
  4. using System.Text.Json.Serialization;
  5. namespace MediaBrowser.Common.Json.Converters
  6. {
  7. /// <summary>
  8. /// Convert Pipe delimited string to array of type.
  9. /// </summary>
  10. /// <typeparam name="T">Type to convert to.</typeparam>
  11. public class JsonPipeDelimitedArrayConverter<T> : JsonConverter<T[]>
  12. {
  13. private readonly TypeConverter _typeConverter;
  14. /// <summary>
  15. /// Initializes a new instance of the <see cref="JsonPipeDelimitedArrayConverter{T}"/> class.
  16. /// </summary>
  17. public JsonPipeDelimitedArrayConverter()
  18. {
  19. _typeConverter = TypeDescriptor.GetConverter(typeof(T));
  20. }
  21. /// <inheritdoc />
  22. public override T[] Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
  23. {
  24. if (reader.TokenType == JsonTokenType.String)
  25. {
  26. var stringEntries = reader.GetString()?.Split('|', StringSplitOptions.RemoveEmptyEntries);
  27. if (stringEntries == null || stringEntries.Length == 0)
  28. {
  29. return Array.Empty<T>();
  30. }
  31. var parsedValues = new object[stringEntries.Length];
  32. var convertedCount = 0;
  33. for (var i = 0; i < stringEntries.Length; i++)
  34. {
  35. try
  36. {
  37. parsedValues[i] = _typeConverter.ConvertFrom(stringEntries[i].Trim());
  38. convertedCount++;
  39. }
  40. catch (FormatException)
  41. {
  42. // TODO log when upgraded to .Net6
  43. // https://github.com/dotnet/runtime/issues/42975
  44. // _logger.LogWarning(e, "Error converting value.");
  45. }
  46. }
  47. var typedValues = new T[convertedCount];
  48. var typedValueIndex = 0;
  49. for (var i = 0; i < stringEntries.Length; i++)
  50. {
  51. if (parsedValues[i] != null)
  52. {
  53. typedValues.SetValue(parsedValues[i], typedValueIndex);
  54. typedValueIndex++;
  55. }
  56. }
  57. return typedValues;
  58. }
  59. return JsonSerializer.Deserialize<T[]>(ref reader, options);
  60. }
  61. /// <inheritdoc />
  62. public override void Write(Utf8JsonWriter writer, T[] value, JsonSerializerOptions options)
  63. {
  64. JsonSerializer.Serialize(writer, value, options);
  65. }
  66. }
  67. }