9933110232

Committed 15 Jul 2024 03:07AM UTC coverage: 84.08% (+6.6%) from 77.441%

Build # 9933110232

Build Type

push

github

Committed by

JaCraig

Commit Message

fix: Adding tests and a couple fixes

Run Details

1150 of 1440 branches covered (79.86%)

Branch coverage included in aggregate %.

5 of 5 new or added lines in 3 files covered. (100.0%)

3 existing lines in 2 files now uncovered.

1459 of 1663 relevant lines covered (87.73%)

5905.53 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

82.86

/Archivist/Formats/JSON/JsonReader.cs

﻿using Archivist.BaseClasses;
using Archivist.DataTypes;
using Archivist.ExtensionMethods;
using Archivist.Interfaces;
using System;
using System.Dynamic;
using System.IO;
using System.Text.Json;
using System.Threading.Tasks;

namespace Archivist.Formats.JSON
{
    /// <summary>
    /// Represents a reader for JSON files.
    /// </summary>
    public class JsonReader : ReaderBaseClass
    {
        /// <summary>
        /// Initializes a new instance of the <see cref="JsonReader"/> class.
        /// </summary>
        /// <param name="options">The options to use when deserializing JSON.</param>
        public JsonReader(JsonSerializerOptions? options)
        {
            Options = options ?? new JsonSerializerOptions(JsonSerializerDefaults.Web);
        }

        /// <summary>
        /// Gets the header information for the JSON format.
        /// </summary>
        public override byte[] HeaderInfo => Array.Empty<byte>();

        /// <summary>
        /// The options to use when deserializing JSON.
        /// </summary>
        private JsonSerializerOptions Options { get; }

        /// <summary>
        /// Determines if the reader can read the specified stream.
        /// </summary>
        /// <param name="stream">The stream to read.</param>
        /// <returns><c>true</c> if the reader can read the stream; otherwise, <c>false</c>.</returns>
        public override bool InternalCanRead(Stream? stream)
        {
            if (stream is null)
                return false;
            try
            {
                ExpandoObject? TestObject = JsonSerializer.Deserialize<ExpandoObject>(stream!, Options);
                _ = stream.Seek(0, SeekOrigin.Begin);
                return true;
            }
            catch
            {
                return false;
            }
        }

        /// <summary>
        /// Reads a JSON file asynchronously from the specified stream.
        /// </summary>
        /// <param name="stream">The stream to read the JSON file from.</param>
        /// <returns>The parsed JSON file.</returns>
        public override async Task<IGenericFile?> ReadAsync(Stream? stream)
        {
            if (stream?.CanRead != true)
                return new StructuredObject();
            var StreamData = await stream.ReadAllAsync().ConfigureAwait(false);
            if (string.IsNullOrEmpty(StreamData))
                return new StructuredObject();
            ExpandoObject? Data = JsonSerializer.Deserialize<ExpandoObject>(StreamData, Options);
            if (Data is null)
                return new StructuredObject();

            return new StructuredObject(Data);
        }
    }
}

1	using Archivist.BaseClasses;
2	using Archivist.DataTypes;
3	using Archivist.ExtensionMethods;
4	using Archivist.Interfaces;
5	using System;
6	using System.Dynamic;
7	using System.IO;
8	using System.Text.Json;
9	using System.Threading.Tasks;
10
11	namespace Archivist.Formats.JSON
12	{
13	/// <summary>
14	/// Represents a reader for JSON files.
15	/// </summary>
16	public class JsonReader : ReaderBaseClass
17	{
18	/// <summary>
19	/// Initializes a new instance of the <see cref="JsonReader"/> class.
20	/// </summary>
21	/// <param name="options">The options to use when deserializing JSON.</param>
22	public JsonReader(JsonSerializerOptions? options)	29✔
23	{
24	Options = options ?? new JsonSerializerOptions(JsonSerializerDefaults.Web);	29✔
25	}	29✔
26
27	/// <summary>
28	/// Gets the header information for the JSON format.
29	/// </summary>
30	public override byte[] HeaderInfo => Array.Empty<byte>();	3✔
31
32	/// <summary>
33	/// The options to use when deserializing JSON.
34	/// </summary>
35	private JsonSerializerOptions Options { get; }	3✔
36
37	/// <summary>
38	/// Determines if the reader can read the specified stream.
39	/// </summary>
40	/// <param name="stream">The stream to read.</param>
41	/// <returns><c>true</c> if the reader can read the stream; otherwise, <c>false</c>.</returns>
42	public override bool InternalCanRead(Stream? stream)
43	{
44	if (stream is null)	2✔
45	return false;	1✔
46	try
47	{
48	ExpandoObject? TestObject = JsonSerializer.Deserialize<ExpandoObject>(stream!, Options);	1✔
49	_ = stream.Seek(0, SeekOrigin.Begin);	×
50	return true;	×
51	}
52	catch	1✔
53	{
54	return false;	1✔
55	}
56	}	1✔
57
58	/// <summary>
59	/// Reads a JSON file asynchronously from the specified stream.
60	/// </summary>
61	/// <param name="stream">The stream to read the JSON file from.</param>
62	/// <returns>The parsed JSON file.</returns>
63	public override async Task<IGenericFile?> ReadAsync(Stream? stream)
64	{
65	if (stream?.CanRead != true)	4✔
66	return new StructuredObject();	2✔
67	var StreamData = await stream.ReadAllAsync().ConfigureAwait(false);	2✔
68	if (string.IsNullOrEmpty(StreamData))	2!
UNCOV 69	return new StructuredObject();	×
70	ExpandoObject? Data = JsonSerializer.Deserialize<ExpandoObject>(StreamData, Options);	2✔
71	if (Data is null)	2!
72	return new StructuredObject();	×
73
74	return new StructuredObject(Data);	2✔
75	}	4✔
76	}
77	}

JaCraig / Archivist / 9933110232

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous