SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Address activity registry review feedback

Browse source
This commit is contained in:
Sipke Schoorstra 2026-05-31 12:35:25 +02:00
parent a98f31141d
commit 6d1b7e3211
No known key found for this signature in database
GPG key ID: 5C10502B28A4268F
1 changed files with 12 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/modules/Elsa.Workflows.Core/Services/ActivityRegistry.cs
View file

@ -324,10 +324,9 @@ public class ActivityRegistry(IActivityDescriber activityDescriber, IEnumerable<
if (_agnosticRegistry.ProvidedActivityDescriptors.ContainsKey(providerType))
yield return _agnosticRegistry;
foreach (var registry in _tenantRegistries.Values)
foreach (var registry in _tenantRegistries.Values.Where(x => x.ProvidedActivityDescriptors.ContainsKey(providerType)))
{
if (registry.ProvidedActivityDescriptors.ContainsKey(providerType))
yield return registry;
yield return registry;
}
}
@ -350,9 +349,15 @@ public class ActivityRegistry(IActivityDescriber activityDescriber, IEnumerable<
private static void RecomputeLatestDescriptor(TenantRegistryData registry, string typeName)
{
var latestDescriptor = registry.ActivityDescriptors.Values
.Where(x => x.TypeName == typeName)
.MaxBy(x => x.Version);
ActivityDescriptor? latestDescriptor = null;
foreach (var descriptor in registry.ActivityDescriptors.Values)
{
if (descriptor.TypeName != typeName)
continue;
if (latestDescriptor == null || descriptor.Version > latestDescriptor.Version)
latestDescriptor = descriptor;
}
if (latestDescriptor == null)
registry.LatestActivityDescriptors.TryRemove(typeName, out _);
@ -370,4 +375,4 @@ public class ActivityRegistry(IActivityDescriber activityDescriber, IEnumerable<
// Normalize null to "*" so both map to the same group
return tenantId ?? Tenant.AgnosticTenantId;
}
}
}