using System;

using ChoETL;

using System.Linq;

​

public class Program

{

    public static void Main()

    {

        PrintLibVersion();

        //For each Steps_0.json files, split the instrumentData and write them to separate files

        dynamic keys = null;

        dynamic props = null;

        dynamic steps_keys = null;

        //Capture Keys

        using (var r = ChoJSONReader.LoadText(json).WithJSONPath("$..Job.Keys"))

        {

            keys = r.FirstOrDefault();

        }

        //Capture props

        using (var r = ChoJSONReader.LoadText(json).WithJSONPath("$..Job.Props"))

        {

            props = r.FirstOrDefault();

        }

        //Capture Steps.Keys

        using (var r = ChoJSONReader.LoadText(json).WithJSONPath("$..Job.Steps.Keys"))

        {

            steps_keys = r.FirstOrDefault();

        }

        int fileCount = 0;

        //Loop thro Steps, write to individual files

        using (var r = ChoJSONReader.LoadText(json).WithJSONPath("$..Job.Steps.InstrumentData")

               .NotifyAfter(1)

               .Setup(s => s.RowsLoaded += (o, e) => $"Rows loaded: {e.RowsLoaded} <- {DateTime.Now}".Print())

​

               //Callback used to hook up to loader, stream the nodes to file (this avoids loading to memory)

               .Configure(c => c.CustomJObjectLoader = (sr, s) =>

                          {

                              string outFilePath = $"C:\\Projects\\GitHub\\ChoETL\\data\\InstrumentData_{fileCount++}.json";

                              $"Writing to `{outFilePath}` file...".Print();

​

                              using (var topJo = new ChoJObjectWriter(Console.Out))

                              {

                                  topJo.Formatting = Newtonsoft.Json.Formatting.Indented;

                                  using (var job_jo = new ChoJObjectWriter("Job", topJo))

                                  {

                                      job_jo.WriteProperty("Keys", keys);

                                      job_jo.WriteProperty("Props", props);

                                      using (var steps_jo = new ChoJObjectWriter("Steps", job_jo))

                                      {

                                            steps_jo.WriteProperty("Keys", steps_keys);

                                            steps_jo.WriteProperty("InstrumentData", sr);

                                      }

                                  }

                              }

​

                              "".Print();

​

                              return ChoJSONObjects.EmptyJObject;

                          })

              )

        {

            r.Loop();

        }

    }

    static void PrintLibVersion()

    {

        $"{typeof(ChoJSONReader).Assembly.GetName().Name} v{typeof(ChoJSONReader).Assembly.GetName().Version.ToString()}".Print();

        "".Print();

    }

    static string json = @"{

  ""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

            }

          ]

        }

      ]

    }

  }

}";

}