Commit 9367c0f9: removed unused projects

removed unused projects

9367c0f9

Labyrinth Apps

committed May 22, 2022

master

succeeded

Files

Details



	LabApps.Actors.Client.gRPC
	actors.proto
	GrpcClient.cs
	LabApps.Actors.Client.gRPC.csproj
	LabApps.Actors.Common.AzFn
	Constants.cs
	LabApps.Actors.Common.AzFn.csproj
	LabApps.Actors.Runtime.AzureFn
	DomainEntityBase.cs
	EntityActorRef.cs
	EntityRuntime.cs
	IEntityActor.cs
	LabApps.Actors.Runtime.AzureFn.csproj
	TypedEntityActorRef.cs
	LabApps.Actors.Server.gRPC
	actors.proto
	ActorService.cs
	LabApps.Actors.Server.gRPC.csproj
	LabApps.Actors.Testing2.gRPCCli
	AzFnClient.cs
	LabApps.Actors.Testing2.gRPCCli.csproj
	Program.cs
	LabApps.Actors.Testing2.gRPCServer
	appsettings.Development.json
	appsettings.json
	LabApps.Actors.Testing2.gRPCServer.csproj
	Program.cs
	Startup.cs
	Actors.sln

actors.proto

-26

/LabApps.Actors.Client.gRPC/actors.proto

View

syntax = "proto3";

option csharp_namespace = "LabApps.Actors.Client.gRPC";

package actors_grpc;

service ActorIO {

rpc UnaryPump(PumpRequest) returns (PumpResponse);

}

message FaultDetail {

string FaultText = 1;

string FaultType = 2;

}

message PumpRequest {

string SessionId = 1;

bytes Buffer = 2;

}

message PumpResponse {

string SessionId = 1;

bytes Buffer = 2;

FaultDetail Fault = 3;

}

GrpcClient.cs

-66

/LabApps.Actors.Client.gRPC/GrpcClient.cs

View

using Datafac;

using Google.Protobuf;

using Grpc.Net.Client;

using LabApps.Actors.Events.MsgPack;

using LabApps.Types.Memory;

using System;

using System.Text;

using System.Threading.Tasks;

namespace LabApps.Actors.Client.gRPC

{

public interface IActorClient : IDisposable

{

ValueTask<SerializedEvent?> Pump(Guid sessionId, SerializedEvent? outgoing);

}

public sealed class GrpcClient : IActorClient

{

private readonly GrpcChannel _channel;

private readonly ActorIO.ActorIOClient _client;

private readonly IDataFactories _factories;

public GrpcClient(string address, IDataFactories factories)

{

_channel = GrpcChannel.ForAddress(address);

_client = new ActorIO.ActorIOClient(_channel);

_factories = factories;

}

private volatile bool _disposed = false;

public void Dispose()

{

if (_disposed) return;

_disposed = true;

_channel.Dispose();

}

private static void ThrowIfFaulted(FaultDetail fault)

{

if (!(fault is null))

{

var message = new StringBuilder();

message.AppendLine("An unhandled exception occurred on the server:");

message.AppendLine(" Exception type: "); message.AppendLine(fault.FaultType);

message.AppendLine(" Exception text: "); message.AppendLine(fault.FaultText);

throw new Exception(message.ToString());

}

public async ValueTask<SerializedEvent?> Pump(Guid sessionId, SerializedEvent? outgoing)

{

var pumpRequest = new PumpRequest()

{

SessionId = sessionId.ToString("N"),

Buffer = outgoing is null ? null : ByteString.CopyFrom(MsgPackHelper<SerializedEvent>.Serialize(outgoing)),

};

var pumpResponse = await _client.UnaryPumpAsync(pumpRequest);

ThrowIfFaulted(pumpResponse.Fault);

var buffer = pumpResponse.Buffer;

return buffer is null

? null

: buffer.IsEmpty

? null

: MsgPackHelper<SerializedEvent>.Deserialize(Block.Wrap(buffer.Memory));

}

LabApps.Actors.Client.gRPC.csproj

-58

/LabApps.Actors.Client.gRPC/LabApps.Actors.Client.gRPC.csproj

View

<Description>gRPC client for actors.</Description>

<TargetFrameworks>netstandard2.0;net6.0</TargetFrameworks>

<Nullable>enable</Nullable>

<WarningsAsErrors>nullable</WarningsAsErrors>

<LangVersion>latest</LangVersion>

<Company>MetaFac</Company>

<Product>Actors</Product>

<Authors>MetaFac Contributors</Authors>

<PackageProjectUrl>https://dev.azure.com/labapps21/LAP</PackageProjectUrl>

<RepositoryUrl>https://dev.azure.com/labapps21/LAP/_git/Actors</RepositoryUrl>

<PackageLicenseExpression>Apache-2.0</PackageLicenseExpression>

<PackageRequireLicenseAcceptance>False</PackageRequireLicenseAcceptance>

<AssemblyOriginatorKeyFile>..\SigningKey.snk</AssemblyOriginatorKeyFile>

<PackageTags>actors thread concurrency labapps</PackageTags>

<PackageReadmeFile>README.md</PackageReadmeFile>

<SymbolPackageFormat>snupkg</SymbolPackageFormat>

</PropertyGroup>

</None>

</ItemGroup>

<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

</PackageReference>

<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

</PackageReference>

</ItemGroup>

</ItemGroup>

</ItemGroup>

</Project>

Constants.cs

-10

/LabApps.Actors.Common.AzFn/Constants.cs

View

namespace LabApps.Actors.Common.AzFn

{

public static class Constants

{

public static class Functions

{

public const string UnaryPump = nameof(UnaryPump);

}

LabApps.Actors.Common.AzFn.csproj

-43

/LabApps.Actors.Common.AzFn/LabApps.Actors.Common.AzFn.csproj

View

<Description>Common types for Azure Functions actors</Description>

<TargetFrameworks>netstandard2.0;net6.0</TargetFrameworks>

<Nullable>enable</Nullable>

<WarningsAsErrors>nullable</WarningsAsErrors>

<LangVersion>latest</LangVersion>

<Company>MetaFac</Company>

<Product>Actors</Product>

<Authors>MetaFac Contributors</Authors>

<PackageProjectUrl>https://dev.azure.com/labapps21/LAP</PackageProjectUrl>

<RepositoryUrl>https://dev.azure.com/labapps21/LAP/_git/Actors</RepositoryUrl>

<PackageLicenseExpression>Apache-2.0</PackageLicenseExpression>

<PackageRequireLicenseAcceptance>False</PackageRequireLicenseAcceptance>

<AssemblyOriginatorKeyFile>..\SigningKey.snk</AssemblyOriginatorKeyFile>

<PackageTags>actors thread concurrency labapps</PackageTags>

<PackageReadmeFile>README.md</PackageReadmeFile>

<SymbolPackageFormat>snupkg</SymbolPackageFormat>

</PropertyGroup>

</None>

</ItemGroup>

<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

</PackageReference>

</ItemGroup>

</Project>

DomainEntityBase.cs

-68

/LabApps.Actors.Runtime.AzureFn/DomainEntityBase.cs

View

using Datafac;

using LabApps.Actors.Core;

using LabApps.Platform.Abstractions;

using LabApps.Types.Memory;

using Microsoft.Extensions.Logging;

using Newtonsoft.Json;

using System;

namespace LabApps.Actors.Runtime.AzureFn

{

[JsonObject(MemberSerialization.OptIn)]

public abstract class DomainEntityBase : IEntityActor

{

protected static IActorFactories? _actorFactories;

protected static IDataFactories? _dataFactories;

protected static ITimeOfDayClock? _timeOfDayClock;

[JsonIgnore]

private readonly ILogger _logger;

[JsonProperty("stateType")]

public string? StateTypeName { get; set; } = null;

[JsonProperty("state")]

public byte[]? StateBytes { get; set; } = null;

[JsonIgnore]

private IActor? _actor = null;

protected DomainEntityBase(ILogger logger)

{

_logger = logger;

}

public void Submit(ActorAddress address, object message, IActorRef sender)

{

try

{

if (_actorFactories is null)

throw new ArgumentNullException(nameof(_actorFactories), "Is your static constructor correct?");

if (_dataFactories is null)

throw new ArgumentNullException(nameof(_dataFactories), "Is your static constructor correct?");

if (_timeOfDayClock is null)

throw new ArgumentNullException(nameof(_timeOfDayClock), "Is your static constructor correct?");

if (_actor is null)

{

var runtime = new EntityRuntime(_logger, _actorFactories, _dataFactories, _timeOfDayClock);

_actor = runtime.GetOrAdd(address);

if (_actor.HasState)

{

_actor.LoadState(StateTypeName, new Block(StateBytes));

}

_actor.ReceiveAsync(message, sender, false, 0).ConfigureAwait(false).GetAwaiter().GetResult();

if (_actor.HasState)

{

StateBytes = _actor.SaveState().Memory.ToArray();

}

catch (Exception e)

{

_logger.LogError(e, $"Actor ({address}) failed to process event ({message.GetType().FullName}) from ({sender.Address})");

}

EntityActorRef.cs

/LabApps.Actors.Runtime.AzureFn/EntityActorRef.cs

View

EntityRuntime.cs

/LabApps.Actors.Runtime.AzureFn/EntityRuntime.cs

View

IEntityActor.cs

/LabApps.Actors.Runtime.AzureFn/IEntityActor.cs

View

LabApps.Actors.Runtime.AzureFn.csproj

/LabApps.Actors.Runtime.AzureFn/LabApps.Actors.Runtime.AzureFn.csproj

View

TypedEntityActorRef.cs

/LabApps.Actors.Runtime.AzureFn/TypedEntityActorRef.cs

View

actors.proto

/LabApps.Actors.Server.gRPC/actors.proto

View

ActorService.cs

/LabApps.Actors.Server.gRPC/ActorService.cs

View

LabApps.Actors.Server.gRPC.csproj

/LabApps.Actors.Server.gRPC/LabApps.Actors.Server.gRPC.csproj

View

AzFnClient.cs

/LabApps.Actors.Testing2.gRPCCli/AzFnClient.cs

View

LabApps.Actors.Testing2.gRPCCli.csproj

/LabApps.Actors.Testing2.gRPCCli/LabApps.Actors.Testing2.gRPCCli.csproj

View

Program.cs

/LabApps.Actors.Testing2.gRPCCli/Program.cs

View

appsettings.Development.json

/LabApps.Actors.Testing2.gRPCServer/appsettings.Development.json

View

appsettings.json

/LabApps.Actors.Testing2.gRPCServer/appsettings.json

View

LabApps.Actors.Testing2.gRPCServer.csproj

/LabApps.Actors.Testing2.gRPCServer/LabApps.Actors.Testing2.gRPCServer.csproj

View

Program.cs

/LabApps.Actors.Testing2.gRPCServer/Program.cs

View

Startup.cs

/LabApps.Actors.Testing2.gRPCServer/Startup.cs

View

Actors.sln

/Actors.sln

View