using Adaptation.FileHandlers.json.WorkItems; using Adaptation.Shared; using Adaptation.Shared.Duplicator; using Adaptation.Shared.Methods; using log4net; using System; using System.Collections.Generic; using System.Collections.ObjectModel; using System.IO; using System.Linq; using System.Text.Json; using System.Text.Json.Serialization; namespace Adaptation.FileHandlers.ADO; public class ProcessData : IProcessData { private readonly List _Details; List Shared.Properties.IProcessData.Details => _Details; private readonly ILog _Log; public ProcessData(IFileRead fileRead, Logistics logistics, string targetFileLocation, string url, List fileInfoCollection) { if (fileRead.IsEAFHosted) { } if (url is null) throw new ArgumentNullException(nameof(url)); _Details = new List(); _Log = LogManager.GetLogger(typeof(ProcessData)); WriteFiles(fileRead, logistics, targetFileLocation, fileInfoCollection); } string IProcessData.GetCurrentReactor(IFileRead fileRead, Logistics logistics, Dictionary reactors) => throw new Exception(string.Concat("See ", nameof(WriteFiles))); Tuple> IProcessData.GetResults(IFileRead fileRead, Logistics logistics, List fileInfoCollection) => new(logistics.Logistics1[0], Array.Empty(), Array.Empty(), fileInfoCollection); #nullable enable internal static List GetDescriptions(JsonElement[] jsonElements) { List results = new(); Description? description; JsonSerializerOptions jsonSerializerOptions = new() { NumberHandling = JsonNumberHandling.AllowReadingFromString | JsonNumberHandling.WriteAsString }; foreach (JsonElement jsonElement in jsonElements) { if (jsonElement.ValueKind != JsonValueKind.Object) throw new Exception(); description = JsonSerializer.Deserialize(jsonElement.ToString(), jsonSerializerOptions); if (description is null) continue; results.Add(description); } return results; } private void WriteFiles(IFileRead fileRead, Logistics logistics, string destinationDirectory, List fileInfoCollection) { bool keepRelations = true; if (!Directory.Exists(destinationDirectory)) _ = Directory.CreateDirectory(destinationDirectory); string json = File.ReadAllText(logistics.ReportFullPath); WorkItem[]? workItems = JsonSerializer.Deserialize(json); if (workItems is null) throw new Exception(nameof(workItems)); _Details.Add(workItems); ReadOnlyDictionary keyValuePairs = GetWorkItems(workItems, keepRelations); WriteFileStructure(destinationDirectory, keyValuePairs); WriteFiles(fileRead, destinationDirectory, fileInfoCollection, keyValuePairs); } private static ReadOnlyDictionary GetWorkItems(WorkItem[] workItems, bool keepRelations) { ReadOnlyDictionary results; Dictionary keyValuePairs = new(); foreach (WorkItem workItem in workItems) keyValuePairs.Add(workItem.Id, workItem); results = GetKeyValuePairs(new(keyValuePairs), keepRelations); return results; } private static void WriteFileStructure(string destinationDirectory, ReadOnlyDictionary keyValuePairs) { ReadOnlyCollection collection = GetDirectories(destinationDirectory, keyValuePairs); foreach (string directory in collection) { if (directory.Length > 222) continue; if (!Directory.Exists(directory)) _ = Directory.CreateDirectory(directory); } } private static void WriteFiles(IFileRead fileRead, string destinationDirectory, List fileInfoCollection, ReadOnlyDictionary keyValuePairs) { string old; string json; string checkFile; WorkItem workItem; string workItemType; string singletonDirectory; string fileNameWithoutExtension = Path.GetFileNameWithoutExtension(fileRead.ReportFullPath); string rootDirectory = Path.Combine(destinationDirectory, fileNameWithoutExtension); if (string.IsNullOrEmpty(rootDirectory)) throw new NullReferenceException(nameof(rootDirectory)); foreach (KeyValuePair keyValuePair in keyValuePairs) { workItem = keyValuePair.Value.WorkItem; workItemType = workItem.WorkItemType.Replace(" ", "-"); json = JsonSerializer.Serialize(workItem, WorkItemSourceGenerationContext.Default.WorkItem); singletonDirectory = Path.Combine(rootDirectory, workItemType, $"{workItem.Id}-{workItemType}", $"{workItem.Id}"); if (!Directory.Exists(singletonDirectory)) _ = Directory.CreateDirectory(singletonDirectory); checkFile = Path.Combine(singletonDirectory, ".json"); old = File.Exists(checkFile) ? File.ReadAllText(checkFile) : string.Empty; if (old == json) continue; File.WriteAllText(checkFile, json); if (!fileRead.IsEAFHosted) fileInfoCollection.Add(new(checkFile)); } } private static ReadOnlyDictionary GetKeyValuePairs(ReadOnlyDictionary keyValuePairs, bool keepRelations) { Dictionary results = new(); Record record; List nests = new(); WorkItem? parentWorkItem; ReadOnlyCollection childRecords; ReadOnlyCollection relatedRecords; ReadOnlyCollection successorRecords; foreach (KeyValuePair keyValuePair in keyValuePairs) { nests.Clear(); if (keyValuePair.Value.Parent is null) parentWorkItem = null; else _ = keyValuePairs.TryGetValue(keyValuePair.Value.Parent.Value, out parentWorkItem); try { childRecords = Record.GetKeyValuePairs(keyValuePairs, keyValuePair.Value, "Child", nests, keepRelations); // Forward relatedRecords = Record.GetKeyValuePairs(keyValuePairs, keyValuePair.Value, "Related", nests, keepRelations); // Related successorRecords = Record.GetKeyValuePairs(keyValuePairs, keyValuePair.Value, "Successor", nests, keepRelations); // Forward // predecessorRecords = Record.GetKeyValuePairs(keyValuePairs, keyValuePair.Value, "Predecessor", nests, keepRelations); // Reverse record = Record.Get(keyValuePair.Value, parentWorkItem, childRecords, relatedRecords, successorRecords, keepRelations); } catch (Exception) { Dictionary? tag = null; record = new(keyValuePair.Value, parentWorkItem, Array.Empty(), Array.Empty(), Array.Empty(), tag); } results.Add(keyValuePair.Key, record); } return new(results); } private static ReadOnlyCollection GetDirectories(string destinationDirectory, ReadOnlyDictionary keyValuePairs) { List results = new(); Record record; string directory; List nests = new(); ReadOnlyCollection childrenDirectories; string dateDirectory = Path.Combine(destinationDirectory, "_", DateTime.Now.ToString("yyyy-MM-dd")); foreach (KeyValuePair keyValuePair in keyValuePairs) { record = keyValuePair.Value; if (record.Parent is not null && (record.WorkItem.Parent is null || record.Parent.Id != record.WorkItem.Parent.Value)) continue; if (record.Parent is not null) continue; // if (record.WorkItem.Id == 110730) // continue; // if (record.WorkItem.Id == 110732) // continue; nests.Clear(); directory = Path.Combine(dateDirectory, $"{record.WorkItem.WorkItemType.Substring(0, 1)}-{record.WorkItem.Id}-{record.WorkItem.Title.Trim().Substring(0, 1)}"); childrenDirectories = GetChildrenDirectories(keyValuePairs, nests, directory, record); results.AddRange(childrenDirectories); } return new(results.Distinct().ToArray()); } private static string GetIndexLines(ReadOnlyCollection frontMatterLines, Record record) { List results = new(); results.Clear(); results.AddRange(frontMatterLines); results.Add(string.Empty); results.Add($"# {record.WorkItem.Id}"); results.Add(string.Empty); results.Add("## Backlog"); results.Add(string.Empty); results.Add("## Todo"); results.Add(string.Empty); results.Add("## In Progress"); results.Add(string.Empty); results.Add("## Done"); results.Add(string.Empty); return string.Join(Environment.NewLine, results); } private static string GetMarkdownLines(string url, Record record, string jsonDirectory, string iterationPathDirectory) { List results = new(); string link; string target; results.Add($"# {record.WorkItem.Id}"); results.Add(string.Empty); results.Add($"## {record.WorkItem.Title}"); results.Add(string.Empty); if (record.Children is not null) { foreach (Record r in record.Children) results.Add($"- [{r.WorkItem.Id}]({url}{r.WorkItem.Id})"); } results.Add(string.Empty); results.Add("```bash"); if (record.Children is not null) { foreach (Record r in record.Children) { link = Path.Combine(jsonDirectory, $"{r.WorkItem.Id}-{r.WorkItem.WorkItemType}"); target = Path.Combine(iterationPathDirectory, r.WorkItem.WorkItemType, $"{r.WorkItem.Id}-{r.WorkItem.WorkItemType}", r.WorkItem.Id.ToString()); results.Add($"mklink /J \"{link}\" \"{target}\""); } } results.Add("```"); results.Add(string.Empty); return string.Join(Environment.NewLine, results); } private static ReadOnlyCollection GetChildrenDirectories(ReadOnlyDictionary keyValuePairs, List nests, string parentDirectory, Record record) { List results = new(); nests.Add(true); string directory; Record? childRecord; ReadOnlyCollection childrenDirectories; if (record.Children is not null) { foreach (Record r in record.Children) { // if (record.WorkItem.Id == 110730) // continue; // if (record.WorkItem.Id == 110732) // continue; directory = Path.Combine(parentDirectory, $"{r.WorkItem.WorkItemType.Substring(0, 1)}-{r.WorkItem.Id}-{r.WorkItem.Title.Trim().Substring(0, 1)}"); results.Add(directory); if (!keyValuePairs.TryGetValue(r.WorkItem.Id, out childRecord)) continue; if (nests.Count > 99) break; childrenDirectories = GetChildrenDirectories(keyValuePairs, nests, directory, childRecord); results.AddRange(childrenDirectories); } } return new(results); } }