using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Text; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using Newtonsoft.Json.Serialization; using SabreTools.Core; using SabreTools.Core.Tools; using SabreTools.DatItems; using SabreTools.DatItems.Formats; namespace SabreTools.DatFiles.Formats { /// /// Represents parsing and writing of a reference SabreDAT JSON /// internal class SabreJSON : DatFile { /// /// Constructor designed for casting a base DatFile /// /// Parent DatFile to copy from public SabreJSON(DatFile? datFile) : base(datFile) { } /// public override void ParseFile(string filename, int indexId, bool keep, bool statsOnly = false, bool throwOnError = false) { // Prepare all internal variables StreamReader sr = new(System.IO.File.OpenRead(filename), new UTF8Encoding(false)); JsonTextReader jtr = new(sr); // If we got a null reader, just return if (jtr == null) return; // Otherwise, read the file to the end try { jtr.Read(); while (!sr.EndOfStream) { // Skip everything not a property name if (jtr.TokenType != JsonToken.PropertyName) { jtr.Read(); continue; } switch (jtr.Value) { // Header value case "header": ReadHeader(jtr); jtr.Read(); break; // Machine array case "machines": ReadMachines(jtr, statsOnly, filename, indexId); jtr.Read(); break; default: jtr.Read(); break; } } } catch (Exception ex) when (!throwOnError) { logger.Warning($"Exception found while parsing '{filename}': {ex}"); } jtr.Close(); } /// /// Read header information /// /// JsonTextReader to use to parse the header private void ReadHeader(JsonTextReader jtr) { // If the reader is invalid, skip if (jtr == null) return; // Read in the header and apply any new fields jtr.Read(); JsonSerializer js = new(); DatHeader? header = js.Deserialize(jtr); Header.ConditionalCopy(header); } /// /// Read machine array information /// /// JsonTextReader to use to parse the machine /// True to only add item statistics while parsing, false otherwise /// Name of the file to be parsed /// Index ID for the DAT private void ReadMachines(JsonTextReader jtr, bool statsOnly, string filename, int indexId) { // If the reader is invalid, skip if (jtr == null) return; // Read in the machine array jtr.Read(); JsonSerializer js = new(); JArray? machineArray = js.Deserialize(jtr); // Loop through each machine object and process foreach (JObject machineObj in (machineArray ?? []).Cast()) { ReadMachine(machineObj, statsOnly, filename, indexId); } } /// /// Read machine object information /// /// JObject representing a single machine /// True to only add item statistics while parsing, false otherwise /// Name of the file to be parsed /// Index ID for the DAT private void ReadMachine(JObject machineObj, bool statsOnly, string filename, int indexId) { // If object is invalid, skip it if (machineObj == null) return; // Prepare internal variables Machine? machine = null; // Read the machine info, if possible if (machineObj.ContainsKey("machine")) machine = machineObj["machine"]?.ToObject(); // Read items, if possible if (machineObj.ContainsKey("items")) ReadItems(machineObj["items"] as JArray, statsOnly, filename, indexId, machine); } /// /// Read item array information /// /// JArray representing the items list /// True to only add item statistics while parsing, false otherwise /// Name of the file to be parsed /// Index ID for the DAT /// Machine information to add to the parsed items private void ReadItems( JArray? itemsArr, bool statsOnly, // Standard Dat parsing string filename, int indexId, // Miscellaneous Machine? machine) { // If the array is invalid, skip if (itemsArr == null) return; // Loop through each datitem object and process foreach (JObject itemObj in itemsArr.Cast()) { ReadItem(itemObj, statsOnly, filename, indexId, machine); } } /// /// Read item information /// /// JObject representing a single datitem /// True to only add item statistics while parsing, false otherwise /// Name of the file to be parsed /// Index ID for the DAT /// Machine information to add to the parsed items private void ReadItem( JObject itemObj, bool statsOnly, // Standard Dat parsing string filename, int indexId, // Miscellaneous Machine? machine) { // If we have an empty item, skip it if (itemObj == null) return; // Prepare internal variables DatItem? datItem = null; // Read the datitem info, if possible if (itemObj.ContainsKey("datitem")) { JToken? datItemObj = itemObj["datitem"]; if (datItemObj == null) return; switch (datItemObj.Value("type").AsEnumValue()) { case ItemType.Adjuster: datItem = datItemObj.ToObject(); break; case ItemType.Analog: datItem = datItemObj.ToObject(); break; case ItemType.Archive: datItem = datItemObj.ToObject(); break; case ItemType.BiosSet: datItem = datItemObj.ToObject(); break; case ItemType.Blank: datItem = datItemObj.ToObject(); break; case ItemType.Chip: datItem = datItemObj.ToObject(); break; case ItemType.Condition: datItem = datItemObj.ToObject(); break; case ItemType.Configuration: datItem = datItemObj.ToObject(); break; case ItemType.ConfLocation: datItem = datItemObj.ToObject(); break; case ItemType.ConfSetting: datItem = datItemObj.ToObject(); break; case ItemType.Control: datItem = datItemObj.ToObject(); break; case ItemType.DataArea: datItem = datItemObj.ToObject(); break; case ItemType.Device: datItem = datItemObj.ToObject(); break; case ItemType.DeviceReference: datItem = datItemObj.ToObject(); break; case ItemType.DipLocation: datItem = datItemObj.ToObject(); break; case ItemType.DipValue: datItem = datItemObj.ToObject(); break; case ItemType.DipSwitch: datItem = datItemObj.ToObject(); break; case ItemType.Disk: datItem = datItemObj.ToObject(); break; case ItemType.DiskArea: datItem = datItemObj.ToObject(); break; case ItemType.Display: datItem = datItemObj.ToObject(); break; case ItemType.Driver: datItem = datItemObj.ToObject(); break; case ItemType.Extension: datItem = datItemObj.ToObject(); break; case ItemType.Feature: datItem = datItemObj.ToObject(); break; case ItemType.Info: datItem = datItemObj.ToObject(); break; case ItemType.Input: datItem = datItemObj.ToObject(); break; case ItemType.Instance: datItem = datItemObj.ToObject(); break; case ItemType.Media: datItem = datItemObj.ToObject(); break; case ItemType.Part: datItem = datItemObj.ToObject(); break; case ItemType.PartFeature: datItem = datItemObj.ToObject(); break; case ItemType.Port: datItem = datItemObj.ToObject(); break; case ItemType.RamOption: datItem = datItemObj.ToObject(); break; case ItemType.Release: datItem = datItemObj.ToObject(); break; case ItemType.ReleaseDetails: datItem = datItemObj.ToObject(); break; case ItemType.Rom: datItem = datItemObj.ToObject(); break; case ItemType.Sample: datItem = datItemObj.ToObject(); break; case ItemType.Serials: datItem = datItemObj.ToObject(); break; case ItemType.SharedFeature: datItem = datItemObj.ToObject(); break; case ItemType.Slot: datItem = datItemObj.ToObject(); break; case ItemType.SlotOption: datItem = datItemObj.ToObject(); break; case ItemType.SoftwareList: datItem = datItemObj.ToObject(); break; case ItemType.Sound: datItem = datItemObj.ToObject(); break; case ItemType.SourceDetails: datItem = datItemObj.ToObject(); break; } } // If we got a valid datitem, copy machine info and add if (datItem != null) { datItem.CopyMachineInformation(machine); datItem.SetFieldValue(DatItem.SourceKey, new Source { Index = indexId, Name = filename }); ParseAddHelper(datItem, statsOnly); } } /// public override bool WriteToFile(string outfile, bool ignoreblanks = false, bool throwOnError = false) { try { logger.User($"Writing to '{outfile}'..."); FileStream fs = System.IO.File.Create(outfile); // If we get back null for some reason, just log and return if (fs == null) { logger.Warning($"File '{outfile}' could not be created for writing! Please check to see if the file is writable"); return false; } StreamWriter sw = new(fs, new UTF8Encoding(false)); JsonTextWriter jtw = new(sw) { Formatting = Formatting.Indented, IndentChar = '\t', Indentation = 1 }; // Write out the header WriteHeader(jtw); // Write out each of the machines and roms string? lastgame = null; // Use a sorted list of games to output foreach (string key in Items.SortedKeys) { ConcurrentList datItems = Items.FilteredItems(key); // If this machine doesn't contain any writable items, skip if (!ContainsWritable(datItems)) continue; // Resolve the names in the block datItems = DatItem.ResolveNames(datItems); for (int index = 0; index < datItems.Count; index++) { DatItem datItem = datItems[index]; // If we have a different game and we're not at the start of the list, output the end of last item if (lastgame != null && lastgame.ToLowerInvariant() != datItem.GetFieldValue(DatItem.MachineKey)!.GetFieldValue(Models.Metadata.Machine.NameKey)?.ToLowerInvariant()) SabreJSON.WriteEndGame(jtw); // If we have a new game, output the beginning of the new item if (lastgame == null || lastgame.ToLowerInvariant() != datItem.GetFieldValue(DatItem.MachineKey)!.GetFieldValue(Models.Metadata.Machine.NameKey)?.ToLowerInvariant()) SabreJSON.WriteStartGame(jtw, datItem); // Check for a "null" item datItem = ProcessNullifiedItem(datItem); // Write out the item if we're not ignoring if (!ShouldIgnore(datItem, ignoreblanks)) WriteDatItem(jtw, datItem); // Set the new data to compare against lastgame = datItem.GetFieldValue(DatItem.MachineKey)!.GetFieldValue(Models.Metadata.Machine.NameKey); } } // Write the file footer out SabreJSON.WriteFooter(jtw); logger.User($"'{outfile}' written!{Environment.NewLine}"); jtw.Close(); fs.Dispose(); } catch (Exception ex) when (!throwOnError) { logger.Error(ex); return false; } return true; } /// /// Write out DAT header using the supplied JsonTextWriter /// /// JsonTextWriter to output to private void WriteHeader(JsonTextWriter jtw) { jtw.WriteStartObject(); // Write the DatHeader jtw.WritePropertyName("header"); JsonSerializer js = new() { Formatting = Formatting.Indented }; js.Serialize(jtw, Header); jtw.WritePropertyName("machines"); jtw.WriteStartArray(); jtw.Flush(); } /// /// Write out Game start using the supplied JsonTextWriter /// /// JsonTextWriter to output to /// DatItem object to be output private static void WriteStartGame(JsonTextWriter jtw, DatItem datItem) { // No game should start with a path separator if (!string.IsNullOrEmpty(datItem.GetFieldValue(DatItem.MachineKey)!.GetFieldValue(Models.Metadata.Machine.NameKey))) datItem.GetFieldValue(DatItem.MachineKey)!.SetFieldValue(Models.Metadata.Machine.NameKey, datItem.GetFieldValue(DatItem.MachineKey)!.GetFieldValue(Models.Metadata.Machine.NameKey)!.TrimStart(Path.DirectorySeparatorChar)); // Build the state jtw.WriteStartObject(); // Write the Machine jtw.WritePropertyName("machine"); JsonSerializer js = new() { Formatting = Formatting.Indented }; js.Serialize(jtw, datItem.GetFieldValue(DatItem.MachineKey)!); jtw.WritePropertyName("items"); jtw.WriteStartArray(); jtw.Flush(); } /// /// Write out Game end using the supplied JsonTextWriter /// /// JsonTextWriter to output to private static void WriteEndGame(JsonTextWriter jtw) { // End items jtw.WriteEndArray(); // End machine jtw.WriteEndObject(); jtw.Flush(); } /// /// Write out DatItem using the supplied JsonTextWriter /// /// JsonTextWriter to output to /// DatItem object to be output private void WriteDatItem(JsonTextWriter jtw, DatItem datItem) { // Pre-process the item name ProcessItemName(datItem, true); // Build the state jtw.WriteStartObject(); // Write the DatItem jtw.WritePropertyName("datitem"); JsonSerializer js = new() { ContractResolver = new BaseFirstContractResolver(), Formatting = Formatting.Indented }; js.Serialize(jtw, datItem); // End item jtw.WriteEndObject(); jtw.Flush(); } /// /// Write out DAT footer using the supplied JsonTextWriter /// /// JsonTextWriter to output to private static void WriteFooter(JsonTextWriter jtw) { // End items jtw.WriteEndArray(); // End machine jtw.WriteEndObject(); // End machines jtw.WriteEndArray(); // End file jtw.WriteEndObject(); jtw.Flush(); } // https://github.com/dotnet/runtime/issues/728 private class BaseFirstContractResolver : DefaultContractResolver { public BaseFirstContractResolver() { NamingStrategy = new CamelCaseNamingStrategy(); } protected override IList CreateProperties(Type type, MemberSerialization memberSerialization) { return base.CreateProperties(type, memberSerialization) .Where(p => p != null) .OrderBy(p => BaseTypesAndSelf(p.DeclaringType).Count()) .ToList(); static IEnumerable BaseTypesAndSelf(Type? t) { while (t != null) { yield return t; t = t.BaseType; } } } } } }