starred/aryx
1
0
Fork 0
mirror of https://github.com/davidkaya/aryx.git synced 2026-08-08 12:48:48 +02:00
Code Issues 3 Packages Projects Releases 10 Wiki Activity

refactor: simplify handoff payload parsing

Browse Source 
Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
This commit is contained in:
David Kaya
2026-03-24 21:37:36 +01:00
co-authored by Copilot
parent 8b2e7cd2c0
commit cf6a25a9da
1 changed files with 29 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sidecar/src/Eryx.AgentHost/Services/WorkflowRequestInfoInterpreter.cs
+29 -29
View File
@@ -1,4 +1,5 @@
using System.Collections.Concurrent;
using System.Text.Json;
using Eryx.AgentHost.Contracts;
using Microsoft.Agents.AI.Workflows;
using Microsoft.Extensions.AI;
@@ -7,9 +8,6 @@ namespace Eryx.AgentHost.Services;
internal static class WorkflowRequestInfoInterpreter
{
private static readonly Type? HandoffTargetType = LoadType(
"Microsoft.Agents.AI.Workflows.Specialized.HandoffTarget, Microsoft.Agents.AI.Workflows");
public static AgentActivityEventDto? TryCreateActivityFromRequest(
RunTurnCommandDto command,
RequestInfoEvent requestInfo,
@@ -60,16 +58,22 @@ internal static class WorkflowRequestInfoInterpreter
out AgentIdentity agent)
{
agent = default;
if (!TryReadPortableValue(requestInfo.Request.Data, HandoffTargetType, out object? handoffTarget))
object? handoffValue = requestInfo.Request.Data.As<object>();
if (handoffValue is null)
{
return false;
}
WorkflowRequestHandoffPayload? handoffTarget = DeserializeHandoffPayload(handoffValue);
if (handoffTarget?.Target is not WorkflowRequestHandoffAgentPayload target)
{
return false;
}
object? target = handoffTarget?.GetType().GetProperty("Target")?.GetValue(handoffTarget);
agent = AgentIdentityResolver.ResolveAgentIdentity(
pattern,
GetStringProperty(target, "Id"),
GetStringProperty(target, "Name"));
target.Id,
target.Name);
return !string.IsNullOrWhiteSpace(agent.AgentName);
}
@@ -136,30 +140,26 @@ internal static class WorkflowRequestInfoInterpreter
return false;
}
private static Type? LoadType(string assemblyQualifiedName)
{
return Type.GetType(assemblyQualifiedName, throwOnError: false);
}
private static bool TryReadPortableValue(PortableValue portableValue, Type? targetType, out object? value)
{
value = null;
if (targetType is null || !portableValue.IsType(targetType))
{
return false;
}
value = portableValue.AsType(targetType);
return value is not null;
}
private static string? GetStringProperty(object? instance, string propertyName)
{
return instance?.GetType().GetProperty(propertyName)?.GetValue(instance) as string;
}
private static string? NormalizeOptionalString(string? value)
{
return string.IsNullOrWhiteSpace(value) ? null : value.Trim();
}
private static WorkflowRequestHandoffPayload? DeserializeHandoffPayload(object handoffValue)
{
string json = JsonSerializer.Serialize(handoffValue, handoffValue.GetType());
return JsonSerializer.Deserialize<WorkflowRequestHandoffPayload>(json);
}
}
internal sealed class WorkflowRequestHandoffPayload
{
public WorkflowRequestHandoffAgentPayload? Target { get; init; }
}
internal sealed class WorkflowRequestHandoffAgentPayload
{
public string? Id { get; init; }
public string? Name { get; init; }
}