using Elsa.Expressions.Helpers;
using Elsa.Expressions.Services;
using Elsa.Extensions;
using Elsa.Workflows.Core.Models;
using Elsa.Workflows.Core.Services;
using Elsa.Workflows.Management.Models;
namespace Elsa.Workflows.Management.Mappers;
///
/// Maps s to s and vice versa.
///
public class VariableDefinitionMapper
{
private readonly IWellKnownTypeRegistry _wellKnownTypeRegistry;
///
/// Constructor.
///
public VariableDefinitionMapper(IWellKnownTypeRegistry wellKnownTypeRegistry)
{
_wellKnownTypeRegistry = wellKnownTypeRegistry;
}
///
/// Maps a to a .
///
public Variable? Map(VariableDefinition source)
{
if (!_wellKnownTypeRegistry.TryGetTypeOrDefault(source.TypeName, out var type))
return null;
var variableGenericType = typeof(Variable<>).MakeGenericType(type);
var variable = (Variable)Activator.CreateInstance(variableGenericType)!;
variable.Name = source.Name;
variable.Value = source.Value.ConvertTo(type);
variable.StorageDriverType = !string.IsNullOrEmpty(source.StorageDriverTypeName) ? Type.GetType(source.StorageDriverTypeName) : default;
return variable;
}
///
/// Maps a list of s to a list of .
///
public IEnumerable Map(IEnumerable? source) =>
source?
.Select(Map)
.Where(x => x != null)
.Select(x => x!)
?? Enumerable.Empty();
///
/// Maps a to a .
///
public VariableDefinition Map(Variable source)
{
var variableType = source.GetType();
var value = source.Value;
var valueType = variableType.IsConstructedGenericType ? variableType.GetGenericArguments().FirstOrDefault() ?? typeof(object) : typeof(object);
var valueTypeAlias = _wellKnownTypeRegistry.GetAliasOrDefault(valueType);
var storageDriverTypeName = source.StorageDriverType?.GetSimpleAssemblyQualifiedName();
var serializedValue = value.Format();
return new VariableDefinition(source.Name, valueTypeAlias, serializedValue, storageDriverTypeName);
}
///
/// Maps a list of s to a list of s.
///
public IEnumerable Map(IEnumerable? source) => source?.Select(Map) ?? Enumerable.Empty();
}