Fix file processing (#7)

* fix: file processing

* chore: cleanup

* chore: bump version number

* chore: bump version number

Author: Alaaeddine-chakroun

WPAPlugin/Properties/launchSettings.json

@@ -3,12 +3,12 @@
     "Debug": {
       "commandName": "Executable",
       "executablePath": "C:\\Program Files (x86)\\Windows Kits\\10\\Windows Performance Toolkit\\wpa.exe",
-      "commandLineArgs": "-nodefault -addsearchdir \"%USERPROFILE%\\devProjects\\wpa-plugin\\WPAPlugin\\bin\\Debug\\netstandard2.0\""
+      "commandLineArgs": "-nodefault -addsearchdir \"%USERPROFILE%\\devProjects\\windowsperf-wpa-plugin\\WPAPlugin\\bin\\Debug\\netstandard2.0\""
     },
     "Release": {
       "commandName": "Executable",
       "executablePath": "C:\\Program Files (x86)\\Windows Kits\\10\\Windows Performance Toolkit\\wpa.exe",
-      "commandLineArgs": "-nodefault -addsearchdir \"%USERPROFILE%\\devProjects\\wpa-plugin\\WPAPlugin\\bin\\Release\\netstandard2.0\""
+      "commandLineArgs": "-nodefault -addsearchdir \"%USERPROFILE%\\devProjects\\windowsperf-wpa-plugin\\WPAPlugin\\bin\\Release\\netstandard2.0\""
     }
   }
 }

WPAPlugin/WPAPlugin.csproj

@@ -2,9 +2,9 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <AssemblyVersion>1.0.2</AssemblyVersion>
-    <FileVersion>1.0.2</FileVersion>
-    <Version>1.0.2</Version>
+    <AssemblyVersion>1.0.3</AssemblyVersion>
+    <FileVersion>1.0.3</FileVersion>
+    <Version>1.0.3</Version>
   </PropertyGroup>
 
   <ItemGroup>

WPAPlugin/WperfProcessingSourceWithSourceParser.cs

@@ -31,7 +31,6 @@
 
 using System.Collections.Generic;
 using System.IO;
-using System.Linq;
 using Microsoft.Performance.SDK.Processing;
 using NJsonSchema;
 using WPAPlugin.Schemas;
@@ -51,6 +50,9 @@ public class WperfProcessingSourceWithSourceParser : ProcessingSource
     {
         private IApplicationEnvironment applicationEnvironment;
 
+        public WperfProcessingSourceWithSourceParser()
+            : base() { }
+
         /// <summary>
         /// Sets project information
         /// </summary>
@@ -92,13 +94,8 @@ protected override ICustomDataProcessor CreateProcessorCore(
             ProcessorOptions options
         )
         {
-            WperfSourceParser parser = new WperfSourceParser(
-                timelinePathList.ToArray(),
-                countingPathList.ToArray()
-            );
+            WperfSourceParser parser = new WperfSourceParser(timelinePathList, countingPathList);
 
-            timelinePathList.Clear();
-            countingPathList.Clear();
             validationCache.Clear();
             return new WperfCustomDataProcessorWithSourceParser(
                 parser,

WPAPlugin/WperfSourceParser.cs

@@ -47,15 +47,18 @@ namespace WPAPlugin
     /// </summary>
     public class WperfSourceParser : ISourceParser<WperfEvent, WperfSourceParser, string>
     {
-        private readonly string[] timelineFilesPathList;
-        private readonly string[] countFilesPathList;
+        private readonly HashSet<string> timelineFilesPathList;
+        private readonly HashSet<string> countFilesPathList;
 
         /// <summary>
         /// Timeline and count files paths lists need to be passed seperately to the <c>constructor</c>
         /// </summary>
         /// <param name="timelineFilesPathList">List of timeline file paths</param>
         /// <param name="countFilesPathList">List of single count file paths</param>
-        public WperfSourceParser(string[] timelineFilesPathList, string[] countFilesPathList)
+        public WperfSourceParser(
+            HashSet<string> timelineFilesPathList,
+            HashSet<string> countFilesPathList
+        )
         {
             this.timelineFilesPathList = timelineFilesPathList;
             this.countFilesPathList = countFilesPathList;
@@ -96,7 +99,7 @@ private void ProcessTimelineFiles(
             CancellationToken cancellationToken
         )
         {
-            int filesCount = timelineFilesPathList.Length;
+            int filesCount = timelineFilesPathList.Count;
             if (filesCount == 0)
             {
                 return;
@@ -211,7 +214,7 @@ private void ProcessCountFiles(
             CancellationToken cancellationToken
         )
         {
-            int filesCount = countFilesPathList.Length;
+            int filesCount = countFilesPathList.Count;
             if (filesCount == 0)
             {
                 return;
@@ -312,6 +315,8 @@ CancellationToken cancellationToken
         {
             ProcessTimelineFiles(dataProcessor, cancellationToken);
             ProcessCountFiles(dataProcessor, cancellationToken);
+            this.timelineFilesPathList.Clear();
+            this.countFilesPathList.Clear();
         }
     }
 }