Skip to content

Commit 7c158a6

Browse files
cdavernascdavernas
authored
Merge pull request #475 from serverlessworkflow/feat-asyncapi-v3
Implement the `AsyncAPI` function call
2 parents e680ab7 + 076ce93 commit 7c158a6

File tree

19 files changed

+267
-30
lines changed

19 files changed

+267
-30
lines changed

‎src/api/Synapse.Api.Client.Http/Synapse.Api.Client.Http.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@
4343

4444
<ItemGroup>
4545
<PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="9.0.0" />
46-
<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha5.2" />
46+
<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha6.2" />
4747
<PackageReference Include="System.Reactive" Version="6.0.1" />
4848
</ItemGroup>
4949

‎src/api/Synapse.Api.Http/Synapse.Api.Http.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@
4545
<ItemGroup>
4646
<PackageReference Include="Neuroglia.Mediation.AspNetCore" Version="4.18.1" />
4747
<PackageReference Include="Neuroglia.Security.AspNetCore" Version="4.18.1" />
48-
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.1.0" />
48+
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.2.0" />
4949
</ItemGroup>
5050

5151
<ItemGroup>

‎src/api/Synapse.Api.Server/Synapse.Api.Server.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
<PackageReference Include="Microsoft.AspNetCore.Authentication.OpenIdConnect" Version="9.0.0" />
3636
<PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.Server" Version="9.0.0" />
3737
<PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
38-
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.1.0" />
38+
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.2.0" />
3939
</ItemGroup>
4040

4141
<ItemGroup>

‎src/cli/Synapse.Cli/Synapse.Cli.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
<PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.0" />
3434
<PackageReference Include="moment.net" Version="1.3.4" />
3535
<PackageReference Include="NetEscapades.Configuration.Yaml" Version="3.1.0" />
36-
<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha5.2" />
36+
<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha6.2" />
3737
<PackageReference Include="Spectre.Console" Version="0.49.1" />
3838
<PackageReference Include="System.CommandLine.NamingConventionBinder" Version="2.0.0-beta4.22272.1" />
3939
</ItemGroup>

‎src/core/Synapse.Core.Infrastructure/Services/XmlSchemaHandler.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,8 @@
1515
using Neuroglia.Serialization;
1616
using ServerlessWorkflow.Sdk;
1717
using System.Net;
18-
using System.Xml.Schema;
1918
using System.Xml;
20-
using Avro.Generic;
19+
using System.Xml.Schema;
2120

2221
namespace Synapse.Core.Infrastructure.Services;
2322

‎src/core/Synapse.Core.Infrastructure/Synapse.Core.Infrastructure.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@
5151
<PackageReference Include="Neuroglia.Mediation" Version="4.18.1" />
5252
<PackageReference Include="Neuroglia.Plugins" Version="4.18.1" />
5353
<PackageReference Include="Neuroglia.Serialization.Xml" Version="4.18.1" />
54-
<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha5.2" />
54+
<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha6.2" />
5555
</ItemGroup>
5656

5757
<ItemGroup>

‎src/core/Synapse.Core/Synapse.Core.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@
7070
<PackageReference Include="Neuroglia.Data.Infrastructure.ResourceOriented" Version="4.18.1" />
7171
<PackageReference Include="Neuroglia.Eventing.CloudEvents" Version="4.18.1" />
7272
<PackageReference Include="Semver" Version="3.0.0" />
73-
<PackageReference Include="ServerlessWorkflow.Sdk" Version="1.0.0-alpha5.2" />
73+
<PackageReference Include="ServerlessWorkflow.Sdk" Version="1.0.0-alpha6.2" />
7474
</ItemGroup>
7575

7676
</Project>

‎src/correlator/Synapse.Correlator/Synapse.Correlator.csproj

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,8 @@
4242
<PackageReference Include="Neuroglia.Mediation.AspNetCore" Version="4.18.1" />
4343
<PackageReference Include="Neuroglia.Eventing.CloudEvents.Infrastructure" Version="4.18.1" />
4444
<PackageReference Include="Neuroglia.Security.AspNetCore" Version="4.18.1" />
45-
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.1.0" />
46-
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.0.0" />
45+
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.2.0" />
46+
<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.2.0" />
4747
</ItemGroup>
4848

4949
<ItemGroup>

‎src/dashboard/Synapse.Dashboard/Services/WorkflowGraphBuilder.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,15 +226,15 @@ protected INodeViewModel BuildTaskNode(TaskNodeRenderingContext context)
226226
protected virtual NodeViewModel BuildCallTaskNode(TaskNodeRenderingContext<CallTaskDefinition> context)
227227
{
228228
ArgumentNullException.ThrowIfNull(context);
229-
var content = string.Empty;
229+
string content; ;
230230
string callType;
231231
switch (context.TaskDefinition.Call.ToLower())
232232
{
233233
case "asyncapi":
234234
{
235235
var definition = (AsyncApiCallDefinition)this.JsonSerializer.Convert(context.TaskDefinition.With, typeof(AsyncApiCallDefinition))!;
236236
callType = context.TaskDefinition.Call.ToLower();
237-
content = definition.OperationRef;
237+
content = definition.Operation!;
238238
break;
239239
}
240240
case "grpc":

‎src/dashboard/Synapse.Dashboard/Synapse.Dashboard.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111

1212
<ItemGroup>
1313
<PackageReference Include="Blazor.Bootstrap" Version="3.2.0" />
14-
<PackageReference Include="BlazorMonaco" Version="3.2.0" />
14+
<PackageReference Include="BlazorMonaco" Version="3.3.0" />
1515
<PackageReference Include="IdentityModel" Version="7.0.0" />
1616
<PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly" Version="9.0.0" />
1717
<PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.Authentication" Version="9.0.0" />

‎src/runner/Synapse.Runner/Program.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,9 @@
1212
// limitations under the License.
1313

1414
using Moq;
15+
using Neuroglia.AsyncApi;
16+
using Neuroglia.AsyncApi.Client;
17+
using Neuroglia.AsyncApi.Client.Bindings;
1518
using Neuroglia.Serialization.Xml;
1619
using NReco.Logging.File;
1720
using ServerlessWorkflow.Sdk.IO;
@@ -97,6 +100,8 @@
97100
services.AddServerlessWorkflowIO();
98101
services.AddNodeJSScriptExecutor();
99102
services.AddPythonScriptExecutor();
103+
services.AddAsyncApi();
104+
services.AddAsyncApiClient(options => options.AddAllBindingHandlers());
100105
services.AddSingleton<SecretsManager>();
101106
services.AddSingleton<ISecretsManager>(provider => provider.GetRequiredService<SecretsManager>());
102107
services.AddSingleton<IHostedService>(provider => provider.GetRequiredService<SecretsManager>());

0 commit comments

Comments
 (0)