using System;

using System.Text;

using System.IO;

using System.Collections.Generic;

using Newtonsoft.Json;

​

public class DataSplitter

{

    public enum State { Root, Steps, StepObj, Data, DataObj };

​

    private readonly List<string> templateParts;

​

    public static DataSplitter Create(TextReader source)

    {

        var splitter = new DataSplitter();

        var buffer = new StringBuilder();

        var bufferWriter = new StringWriter(buffer);

        var state = State.Root;

        var stepIndex = -1;

​

        using (var reader = new JsonTextReader(source))

        using (var writer = new JsonTextWriter(bufferWriter))

        {

            while (reader.Read())

            {

                switch (state)

                {

                    case State.Root:

​

                        writer.WriteToken(reader.TokenType, reader.Value);

​

                        if (reader.TokenType == JsonToken.StartArray && reader.Path == "Job.Steps")

                        {

                            CompletePart();

                            state = State.Steps;

                        }

​

                        break;

​

                    case State.Steps:

​

                        if (reader.TokenType == JsonToken.StartObject)

                        {

                            stepIndex++;

                            state = State.StepObj;

                        }

                        else if (reader.TokenType == JsonToken.EndArray)

                        {

                            state = State.Root;

                        }

​

                        writer.WriteToken(reader.TokenType, reader.Value);

                        break;

​

                    case State.StepObj:

​

                        writer.WriteToken(reader.TokenType, reader.Value);

​

                        if (reader.TokenType == JsonToken.StartArray && reader.Path == $"Job.Steps[{stepIndex}].InstrumentData")

                        {

                            CompletePart();

                            state = State.Data;

                        }

                        else if (reader.TokenType == JsonToken.EndObject && reader.Path == $"Job.Steps[{stepIndex}]")

                        {

                            CompletePart();

                            state = State.Steps;

                        }

​

                        break;

​

                    case State.Data:

​

                        if (reader.TokenType == JsonToken.EndArray && reader.Path == $"Job.Steps[{stepIndex}].InstrumentData")

                        {

                            writer.WriteToken(reader.TokenType, reader.Value);

                            state = State.StepObj;

                        }

​

                        break;

                }

            }

​

            CompletePart();

​

            void CompletePart()

            {

                writer.Flush();

                splitter.templateParts.Add(buffer.ToString());

                buffer.Length = 0;

            }

        }

​

        return splitter;

    }

​

    private DataSplitter()

    {

        this.templateParts = new List<string>();

    }

​

    public void Split(TextReader source, Action<int, int, string> handler)

    {

        var buffer = new StringBuilder(GetStart());

        var bufferWriter = new StringWriter(buffer);

        var state = State.Root;

        var stepIndex = -1;

        var dataIndex = -1;

        var bufferStepsStart = buffer.Length;

        var bufferDataStart = -1;

​

        using (var reader = new JsonTextReader(source))

        using (var writer = new JsonTextWriter(bufferWriter))

        {           

            while (reader.Read())

            {

                switch (state)

                {

                    case State.Root:

​

                        if (reader.TokenType == JsonToken.StartArray && reader.Path == "Job.Steps")

                        {

                            state = State.Steps;

                        }

​

                        break;

​

                    case State.Steps:

​

                        if (reader.TokenType == JsonToken.StartObject)

                        {

                            buffer.Append(GetStepStart(++stepIndex));

                            bufferDataStart = buffer.Length;

                            state = State.StepObj;

                        }

                        else if (reader.TokenType == JsonToken.EndArray)

                        {

                            state = State.Root;

                        }

​

                        break;

​

                    case State.StepObj:

​

                        if (reader.TokenType == JsonToken.StartArray && reader.Path == $"Job.Steps[{stepIndex}].InstrumentData")

                        {                       

                            dataIndex = -1;

                            state = State.Data;

                        }

                        else if (reader.TokenType == JsonToken.EndObject && reader.Path == $"Job.Steps[{stepIndex}]")

                        {

                            buffer.Length = bufferStepsStart;

                            state = State.Steps;

                        }

​

                        break;

​

                    case State.Data:

​

                        if (reader.TokenType == JsonToken.StartObject)

                        {

                            dataIndex++;

                            writer.WriteToken(reader.TokenType, reader.Value);

                            state = State.DataObj;

                        }

                        else if (reader.TokenType == JsonToken.EndArray)

                        {

                            state = State.StepObj;

                        }

​

                        break;

​

                    case State.DataObj:

​

                        writer.WriteToken(reader.TokenType, reader.Value);

​

                        if (reader.TokenType == JsonToken.EndObject && reader.Path == $"Job.Steps[{stepIndex}].InstrumentData[{dataIndex}]")

                        {

                            writer.Flush();

                            buffer.Append(GetStepEnd(stepIndex));

                            buffer.Append(GetEnd());

​

                            handler(stepIndex, dataIndex, buffer.ToString());

​

                            buffer.Length = bufferDataStart;

                            state = State.Data;

                        }

​

                        break;

                }

            }

        }

    }

​

    private string GetStart() => templateParts[0];

​

    private string GetEnd() => templateParts[templateParts.Count - 1];

​

    private string GetStepStart(int index) => templateParts[index * 2 + 1];

​

    private string GetStepEnd(int index) => templateParts[index * 2 + 2];

}

​

public class Program

{

    public static void Main()

    {

        var reader = new StringReader(JsonText);

        var splitter = DataSplitter.Create(reader);

​

        reader = new StringReader(JsonText);

        splitter.Split(reader, (step, index, content) => {

            Console.WriteLine("=== step: {0}, index: {1} ===", step, index);

            Console.WriteLine(content);

         });

    }

    private const string JsonText = @"{

  ""Job"": {

    ""Keys"": {

      ""JobID"": ""test123"",

      ""DeviceID"": ""TEST01""

    },

    ""Props"": {

      ""FileType"": ""Measurements"",

      ""InstrumentDescriptions"": [

        {

          ""InstrumentID"": ""1723007"",

          ""InstrumentType"": ""Actual1"",

          ""Name"": ""U"",

          ""DataType"": ""Double"",

          ""Units"": ""degC""

        },

        {

          ""InstrumentID"": ""2424009"",

          ""InstrumentType"": ""Actual2"",

          ""Name"": ""VG03"",

          ""DataType"": ""Double"",

          ""Units"": ""Pa""

        }

      ]

    },

    ""Steps"": [

      {

        ""Keys"": {

          ""StepID"": ""START"",

          ""StepResult"": ""NormalEnd""

        },

        ""InstrumentData"": [

          {

            ""Keys"": {

              ""InstrumentID"": ""1723007""

            },

            ""Measurements"": [

              {

                ""DateTime"": ""2021-11-16 21:18:37.000"",

                ""Value"": 540

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.100"",

                ""Value"": 539

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.200"",

                ""Value"": 540

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.300"",

                ""Value"": 540

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.400"",

                ""Value"": 540

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.500"",

                ""Value"": 540

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.600"",

                ""Value"": 540

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.700"",

                ""Value"": 538

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.800"",

                ""Value"": 540

              }

            ]

          },

          {

            ""Keys"": {

              ""InstrumentID"": ""2424009""

            },

            ""Measurements"": [

              {

                ""DateTime"": ""2021-11-16 21:18:37.000"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.100"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.200"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.300"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.400"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.500"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.600"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.700"",

                ""Value"": 1333.22

              },

              {

                ""DateTime"": ""2021-11-16 21:18:37.800"",

                ""Value"": 1333.22

              }

            ]

          }

        ]

      }

    ]

  }

}";

}