Misc improvements

.github/workflows/tests.yml

@@ -9,7 +9,7 @@ on:
 
 jobs:
   dotnet-bxes-unit-tests:
-    runs-on: windows-2022
+    runs-on: windows-2025-vs2026
 
     steps:
       - uses: actions/checkout@v4
@@ -25,7 +25,7 @@ jobs:
         run: dotnet test ./bxes/src/csharp/Bxes.Tests
 
   rust-bxes-unit-tests:
-    runs-on: windows-2022
+    runs-on: windows-2025-vs2026
 
     steps:
       - uses: actions/checkout@v4
@@ -37,7 +37,7 @@ jobs:
           RUSTFLAGS: ""
 
   dotnet-procfiler-unit-tests:
-    runs-on: windows-2022
+    runs-on: windows-2025-vs2026
 
     steps:
       - uses: actions/checkout@v4
@@ -86,6 +86,11 @@ jobs:
     steps:
       - uses: actions/checkout@v4
 
+      - name: Install CMake
+        uses: ssrobins/install-cmake@v1
+        with:
+          version: 4.2.0
+
       - name: Setup docker
         uses: docker/setup-qemu-action@v3
 

.run/windows/ProcfilerOnline.cmd

@@ -5,6 +5,7 @@ set OnlineProcfilerSettings__KafkaSettings__TopicName=my-topic
 set OnlineProcfilerSettings__KafkaSettings__BootstrapServers=localhost:9092
 
 dotnet clean %PM_IDE_ROOT%/All.sln
+dotnet build %PM_IDE_ROOT%/ProcfilerBuildTasks/ -c Release
 dotnet build %PM_IDE_ROOT%/All.sln -c Release
 dotnet build %PM_IDE_ROOT%/Procfiler/src/dotnet/ProcfilerLoggerProvider/ -c Release
 dotnet build %PM_IDE_ROOT%/Procfiler/test_data/source/WFWebApp -c Release

All.sln

@@ -125,6 +125,7 @@ EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "scripts", "scripts", "{92C02EAF-93FB-4A2C-A235-8541D893163C}"
 	ProjectSection(SolutionItems) = preProject
 		scripts\macos\generate_grpc_models.sh = scripts\macos\generate_grpc_models.sh
+		scripts\windows\generate_grpc_models.ps1 = scripts\windows\generate_grpc_models.ps1
 	EndProjectSection
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "misc", "misc", "{2918C7E3-3FC8-48A5-ADDF-8358E888B40C}"

Ficus/docker/run/Run.RustFicusBackend.Dockerfile

@@ -1,4 +1,4 @@
-FROM rust:1.92.0 as build
+FROM rust:1.93.0 as build
 
 RUN apt update -y && apt upgrade -y
 RUN apt-get update -y

Ficus/docker/tests/Tests.Rust.Dockerfile

@@ -1,4 +1,4 @@
-FROM rust:1.92.0 as build
+FROM rust:1.93.0 as build
 
 RUN apt update -y && apt upgrade -y
 RUN apt-get update -y

Ficus/src/front/FicusFrontend/FicusDashboard/Components/CaseInfo/CaseInfo.razor

@@ -21,7 +21,7 @@
 @if (myIsLoading)
 {
   <div style="width: 100%; height: 100%; display: flex; align-items: center; justify-content: center;">
-    <Loader />
+    <Loader/>
   </div>
 
   return;
@@ -48,7 +48,7 @@
 </div>
 
 <div class="pipeline-parts-context-values-outer-container">
-  @foreach (var (index, (_, results)) in myPipelinePartsExecutionResults.OrderBy(x => x.Value.Order).Index())
+  @foreach (var (index, results) in myPipelinePartsExecutionResults.OrderBy(x => x.Order).Index())
   {
     <PipelinePartResultsRenderer Results="results"
                                  Lifetime="myCurrentLifetime"
@@ -60,11 +60,11 @@
 @code
 {
   private readonly SequentialLifetimes myLifetimes = new(Lifetime.Eternal);
-  private IReadOnlyDictionary<Guid, PipelinePartExecutionResults> myPipelinePartsExecutionResults = 
-    new Dictionary<Guid, PipelinePartExecutionResults>();
+
+  private IReadOnlyList<PipelinePartExecutionResults> myPipelinePartsExecutionResults = [];
 
   private bool myIsLoading;
-  
+
   private Lifetime myCurrentLifetime;
   private ProcessCaseData? myProcessCaseData;
 

Ficus/src/front/FicusFrontend/FicusDashboard/Services/Cases/ISubscriptionsService.cs

@@ -12,7 +12,7 @@ public interface ISubscriptionsService
   ISignal<Pipeline> AnyPipelineSubEntityUpdated { get; }
 
   void StartUpdatesRequestingRoutine(CancellationToken token);
-  Task<IReadOnlyDictionary<Guid, PipelinePartExecutionResults>> GetCaseExecutionResult(ProcessCaseData data);
+  Task<IReadOnlyList<PipelinePartExecutionResults>> GetCaseExecutionResult(ProcessCaseData data);
 }
 
 public class SubscriptionsService(
@@ -54,7 +54,7 @@ public void StartUpdatesRequestingRoutine(CancellationToken token)
     }, token);
   }
 
-  public async Task<IReadOnlyDictionary<Guid, PipelinePartExecutionResults>> GetCaseExecutionResult(ProcessCaseData data)
+  public async Task<IReadOnlyList<PipelinePartExecutionResults>> GetCaseExecutionResult(ProcessCaseData data)
   {
     var result = await client.GetPipelineCaseContextValueAsync(new GrpcGetPipelineCaseContextValuesRequest
     {
@@ -68,24 +68,29 @@ public async Task<IReadOnlyDictionary<Guid, PipelinePartExecutionResults>> GetCa
       ProcessName = data.ProcessData.ProcessName
     });
 
-    return result.ContextValues.Select((value, order) =>
-    {
-      var id = value.PipelinePartInfo.Id.ToGuid();
-
-      var results = value.ExecutionResults.Select(r => new PipelinePartExecutionResult
+    return result.ContextValues
+      .Select((x, order) => (Id: x.PipelinePartInfo.Id.ToGuid(), Order: order, Parts: x))
+      .GroupBy(x => x.Id)
+      .Select(group =>
       {
-        ContextValues = r.ContextValues.Select(c => new ContextValueWrapper(c)).ToList()
-      }).ToList();
+        var results = group.SelectMany(x => x.Parts.ExecutionResults).Select(r => new PipelinePartExecutionResult
+        {
+          ContextValues = [.. r.ContextValues.Select(c => new ContextValueWrapper(c))]
+        }).ToList();
 
-      var partResults = new PipelinePartExecutionResults
-      {
-        PipelinePartName = value.PipelinePartInfo.Name,
-        Order = (uint)order,
-        Results = new ViewableList<PipelinePartExecutionResult>(results)
-      };
+        var (_, order, parts) = group.First();
+        var info = parts.PipelinePartInfo;
+
+        var partResults = new PipelinePartExecutionResults
+        {
+          PipelinePartName = info.Name,
+          Order = (uint)order,
+          Results = new ViewableList<PipelinePartExecutionResult>(results)
+        };
 
-      return (id, partResults);
-    }).ToDictionary();
+        return partResults;
+      })
+      .ToList();
   }
 
   private void ProcessState(GrpcSubscriptionAndPipelinesStateResponse reponse)

Ficus/src/python/ficus/grpc_pipelines/constants.py

@@ -152,6 +152,8 @@
 const_discover_ecfg = 'DiscoverECFG'
 const_discover_loops_strict = 'DiscoverLoopsStrict'
 const_discover_traces_timeline_diagram = 'DiscoverTracesTimelineDiagram'
+const_convert_ecfg_to_petri_net = 'ConvertECFGToPetriNet'
+const_serialize_petri_net_bytes = 'SerializePetriNetBytes'
 
 const_prepare_software_log = 'PrepareSoftwareEventLog'
 const_shorten_allocation_type = 'ShortenAllocationType'

Ficus/src/python/ficus/grpc_pipelines/discovery_parts.py

@@ -262,3 +262,29 @@ def to_grpc_part(self) -> GrpcPipelinePartBase:
     append_bool_value(config, const_merge_sequences_of_events, self.merge_sequences_of_events)
 
     return GrpcPipelinePartBase(defaultPart=create_default_pipeline_part(const_discover_ecfg, config))
+
+class ConvertECFGToPetriNet(PipelinePart):
+  def to_grpc_part(self) -> GrpcPipelinePartBase:
+    return GrpcPipelinePartBase(defaultPart=create_default_pipeline_part(const_convert_ecfg_to_petri_net))
+
+class SerializePetriNetPnmlBytes(PipelinePartWithCallback):
+  def __init__(self, save_path: str, use_names_as_ids:bool = False):
+    super().__init__()
+    self.save_path = save_path
+    self.use_names_as_ids = use_names_as_ids
+
+  def to_grpc_part(self) -> GrpcPipelinePartBase:
+    config = GrpcPipelinePartConfiguration()
+    append_bool_value(config, const_pnml_use_names_as_ids, self.use_names_as_ids)
+
+    part = create_complex_get_context_part(self.uuid,
+                                           self.__class__.__name__,
+                                           [const_bytes],
+                                           const_serialize_petri_net_bytes,
+                                           config)
+
+    return GrpcPipelinePartBase(complexContextRequestPart=part)
+
+  def execute_callback(self, values: dict[str, GrpcContextValue]):
+      file_bytes = from_grpc_bytes(values[const_bytes].bytes)
+      write_file_bytes(self.save_path, file_bytes.bytes)

Ficus/src/python/infra/generate_models.py

@@ -15,7 +15,11 @@ def generate_models():
 
     os.mkdir(models_dir)
 
-    python = '/usr/local/bin/python3'
+    if os.name == 'nt':
+        python = 'python'
+    else:
+        python = '/usr/local/bin/python3'
+
     os.popen(f'{python} -m pip install grpcio-tools').read()
     packages = []
 

Ficus/src/rust/ficus/src/event_log/xes/reader/xes_log_trace_reader.rs

@@ -63,10 +63,10 @@ impl<'a> TraceXesEventLogIterator<'a> {
       match self.reader.borrow_mut().read_event_into(&mut self.buffer) {
         Ok(quick_xml::events::Event::End(end)) => match end.name().0 {
           EVENT_TAG_NAME => {
-            name.as_ref()?;
-            date?;
+            let name = name?;
+            let date = date.unwrap_or(DateTime::<Utc>::MIN_UTC);
 
-            let event = XesEventImpl::new_all_fields(name.unwrap(), date.unwrap(), Some(payload));
+            let event = XesEventImpl::new_all_fields(name, date, Some(payload));
             return Some(event);
           }
           _ => continue,

Ficus/src/rust/ficus/src/event_log/xes/xes_event.rs

@@ -9,23 +9,14 @@ use crate::{
   },
 };
 use chrono::{DateTime, Utc};
-use std::{
-  collections::HashMap,
-  fmt::{Debug, Formatter},
-  sync::Arc,
-};
+use std::{collections::HashMap, fmt::Debug, sync::Arc};
 
+#[derive(Debug)]
 pub struct XesEventImpl {
   event_base: EventBase,
   payload: Option<HashMap<Arc<str>, EventPayloadValue>>,
 }
 
-impl Debug for XesEventImpl {
-  fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
-    f.write_str(self.name_pointer())
-  }
-}
-
 impl XesEventImpl {
   pub fn new_all_fields(name: Arc<str>, timestamp: DateTime<Utc>, payload: Option<HashMap<Arc<str>, EventPayloadValue>>) -> Self {
     Self {

Ficus/src/rust/ficus/src/features/clustering/error.rs

@@ -2,10 +2,10 @@ use crate::{
   pipelines::errors::pipeline_errors::{PipelinePartExecutionError, RawPartExecutionError},
   utils::dataset::dataset::LabeledDataset,
 };
-use std::fmt::Display;
 
 pub type ClusteringResult = Result<LabeledDataset, ClusteringError>;
 
+#[derive(Debug)]
 pub enum ClusteringError {
   NoRepeatSet,
   FailedToCreateNdArray,
@@ -14,21 +14,7 @@ pub enum ClusteringError {
 }
 
 impl From<ClusteringError> for PipelinePartExecutionError {
-  fn from(val: ClusteringError) -> Self {
-    PipelinePartExecutionError::Raw(RawPartExecutionError::new(val.to_string()))
-  }
-}
-
-impl Display for ClusteringError {
-  fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-    f.write_str(
-      match self {
-        Self::NoRepeatSet => "NoRepeatSet".to_owned(),
-        Self::FailedToCreateNdArray => "FailedToCreateNdArray".to_owned(),
-        Self::FailedToCalculateSilhouetteScore => "FailedToCalculateSilhouetteScore".to_owned(),
-        Self::RawError(message) => message.clone(),
-      }
-      .as_str(),
-    )
+  fn from(err: ClusteringError) -> Self {
+    PipelinePartExecutionError::Raw(RawPartExecutionError::new(format!("{err:?}")))
   }
 }

Ficus/src/rust/ficus/src/features/discovery/alpha/alpha.rs

@@ -68,11 +68,7 @@ fn add_one_length_loops(provider: &impl AlphaPlusRelationsProvider, original_log
       }
     }
 
-    let id = petri_net.add_transition(Transition::empty(
-      transition_name.to_owned(),
-      false,
-      Some(transition_name.to_owned()),
-    ));
+    let id = petri_net.add_transition(Transition::empty(transition_name.to_owned(), Some(transition_name.to_owned())));
 
     let place_id = match petri_net.find_place_id_by_name(alpha_set.to_string().as_str()) {
       Some(found_place_id) => found_place_id,
@@ -196,7 +192,7 @@ fn create_petri_net(info: &dyn EventLogInfo, alpha_sets: Vec<&AlphaSet>) -> Defa
   let mut petri_net = PetriNet::default();
   let mut event_classes_to_transition_ids = HashMap::new();
   for class in info.all_event_classes() {
-    let id = petri_net.add_transition(Transition::empty(class.to_owned(), false, Some(class.to_owned())));
+    let id = petri_net.add_transition(Transition::empty(class.to_owned(), Some(class.to_owned())));
     event_classes_to_transition_ids.insert(class.as_ref(), id);
   }
 

Ficus/src/rust/ficus/src/features/discovery/alpha/alpha_plus_plus_nfc/alpha_plus_plus_nfc.rs

@@ -195,7 +195,7 @@ pub fn discover_petri_net_alpha_plus_plus_nfc<TLog: EventLog>(log: &TLog) -> Def
   let mut resulting_net = DefaultPetriNet::default();
   let mut transitions_to_ids = HashMap::new();
   for transition in info.all_event_classes().iter().copied().chain(one_length_loop_transitions.iter()) {
-    let id = resulting_net.add_transition(Transition::empty((*transition).to_owned(), false, Some((*transition).to_owned())));
+    let id = resulting_net.add_transition(Transition::empty((*transition).to_owned(), Some((*transition).to_owned())));
     transitions_to_ids.insert(transition, id);
   }