Skip to content

Commit 65ef437

Browse files
RomanSavhRomanSavh
committedApr 21, 2022
first
·
1.0.41.0.0
0 parents  commit 65ef437

7 files changed

+215
-0
lines changed
 

‎.github/workflows/release.yaml

+25
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
name: Release nuget
2+
3+
on:
4+
release:
5+
types: [ published ]
6+
7+
jobs:
8+
build:
9+
runs-on: ubuntu-latest
10+
steps:
11+
- uses: actions/checkout@v2
12+
- name: Setup .NET Core
13+
uses: actions/setup-dotnet@v1
14+
with:
15+
dotnet-version: 6.0.*
16+
- name: Build
17+
run: dotnet build --configuration Release
18+
- name: Test
19+
run: dotnet test --configuration Release
20+
21+
- name: Create the package - MyJetTools.Sdk.Grpc
22+
run: dotnet pack --configuration Release MyJetTools.Sdk.Grpc/MyJetTools.Sdk.Grpc.csproj /p:Version=${GITHUB_REF#refs/tags/}
23+
24+
- name: Publish the package
25+
run: dotnet nuget push MyJetTools.Sdk.Grpc/bin/Release/*.nupkg -s "https://api.nuget.org/v3/index.json" -k ${{ secrets.NUGET_TOCKEN }}

‎.gitignore

+61
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,61 @@
1+
2+
# Global wildcards
3+
*.aps
4+
*.bak
5+
*.dll
6+
*.log
7+
*.ncb
8+
*.obj
9+
*.old
10+
*.opensdf
11+
*.orig
12+
*.pdb
13+
*.Publish.xml
14+
*.sdf
15+
*.sln.cache
16+
*.suo
17+
*.tmp
18+
*.user
19+
*.lock.json
20+
21+
# Well-known infrastructure folders
22+
/packages/
23+
/target/
24+
**/aspnet_client/
25+
26+
# IDEs
27+
*[Rr]e[Ss]harper*
28+
**/.idea/
29+
**/.metadata/
30+
**/.settings/
31+
/[Tt]est[Rr]esults/
32+
[Bb]in/
33+
[Oo]bj/
34+
[Dd]ebug/
35+
[Rr]elease/
36+
ipch/
37+
**/.vscode/
38+
39+
# Visual Studio project upgrade
40+
[Bb]ackup/
41+
UpgradeLog*
42+
_UpgradeReport_Files/
43+
44+
# Operating Systems generated
45+
.DS_Store
46+
[Dd]esktop.ini
47+
[Tt]humbs.db
48+
49+
#ncrunch
50+
*.*crunch*
51+
_NCrunch_*
52+
53+
#publish profiles
54+
*publish.ps1
55+
*.pubxml
56+
*.psm1
57+
58+
#some test
59+
.vs
60+
node_modules
61+
**/launchSettings.json

‎MyJetTools.Sdk.Grpc.sln

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
2+
Microsoft Visual Studio Solution File, Format Version 12.00
3+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MyJetTools.Sdk.Grpc", "MyJetTools.Sdk.Grpc\MyJetTools.Sdk.Grpc.csproj", "{EFE7DF75-2D8A-4F81-BA8C-3619FDFD375A}"
4+
EndProject
5+
Global
6+
GlobalSection(SolutionConfigurationPlatforms) = preSolution
7+
Debug|Any CPU = Debug|Any CPU
8+
Release|Any CPU = Release|Any CPU
9+
EndGlobalSection
10+
GlobalSection(ProjectConfigurationPlatforms) = postSolution
11+
{EFE7DF75-2D8A-4F81-BA8C-3619FDFD375A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
12+
{EFE7DF75-2D8A-4F81-BA8C-3619FDFD375A}.Debug|Any CPU.Build.0 = Debug|Any CPU
13+
{EFE7DF75-2D8A-4F81-BA8C-3619FDFD375A}.Release|Any CPU.ActiveCfg = Release|Any CPU
14+
{EFE7DF75-2D8A-4F81-BA8C-3619FDFD375A}.Release|Any CPU.Build.0 = Release|Any CPU
15+
EndGlobalSection
16+
EndGlobal

‎MyJetTools.Sdk.Grpc/ExceptionInterceptor.cs

+41
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
using System.Text.Json;
2+
using Grpc.Core;
3+
using Grpc.Core.Interceptors;
4+
using Microsoft.Extensions.Logging;
5+
6+
namespace MyJetTools.Sdk.Grpc;
7+
8+
public class ExceptionInterceptor : Interceptor
9+
{
10+
private readonly ILogger _logger;
11+
12+
public ExceptionInterceptor(ILogger logger)
13+
{
14+
_logger = logger;
15+
}
16+
17+
public override async Task<TResponse> UnaryServerHandler<TRequest, TResponse>(TRequest request, ServerCallContext context,
18+
UnaryServerMethod<TRequest, TResponse> continuation)
19+
{
20+
var sourceAppName = "-none-";
21+
var sourceAppVersion = "-none-";
22+
var sourceAppHost = "-none-";
23+
try
24+
{
25+
sourceAppName = context.RequestHeaders?.Get(SourceInterceptor.GrpcSourceAppHostHeader)?.Value;
26+
sourceAppVersion = context.RequestHeaders?.Get(SourceInterceptor.GrpcSourceAppVersionHeader)?.Value;
27+
sourceAppHost = context.RequestHeaders?.Get(SourceInterceptor.GrpcSourceAppHostHeader)?.Value;
28+
29+
var resp = await base.UnaryServerHandler(request, context, continuation);
30+
31+
return resp;
32+
}
33+
catch (Exception ex)
34+
{
35+
_logger.LogError(ex, "GRPC service exception. Path: {path}; Request: {requestJson}; Source: {sourceAppName}.{sourceAppVersion} [{sourceHost}]",
36+
context.Method, JsonSerializer.Serialize(request), sourceAppName, sourceAppVersion, sourceAppHost);
37+
38+
throw;
39+
}
40+
}
41+
}

‎MyJetTools.Sdk.Grpc/GrpcClientFactory.cs

+24
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
using Grpc.Core;
2+
using Grpc.Core.Interceptors;
3+
using Grpc.Net.Client;
4+
using MyJetTools.Grpc.Sdk.GrpcMetrics;
5+
using ProtoBuf.Grpc.Client;
6+
7+
namespace MyJetTools.Sdk.Grpc;
8+
9+
public class GrpcClientFactory
10+
{
11+
private readonly CallInvoker _channel;
12+
13+
public GrpcClientFactory(string grpcServiceUrl)
14+
{
15+
AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
16+
var channel = GrpcChannel.ForAddress(grpcServiceUrl);
17+
_channel = channel.Intercept(new PrometheusMetricsInterceptor());
18+
}
19+
20+
public TService CreateGrpcService<TService>() where TService : class
21+
{
22+
return _channel.CreateGrpcService<TService>();
23+
}
24+
}

‎MyJetTools.Sdk.Grpc/MyJetTools.Sdk.Grpc.csproj

+13
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
3+
<PropertyGroup>
4+
<TargetFramework>net6.0</TargetFramework>
5+
<ImplicitUsings>enable</ImplicitUsings>
6+
<Nullable>enable</Nullable>
7+
</PropertyGroup>
8+
9+
<ItemGroup>
10+
<PackageReference Include="Grpc.AspNetCore" Version="2.45.0" />
11+
<PackageReference Include="MyJetTools.Grpc.Sdk.GrpcMetrics" Version="1.0.0" />
12+
</ItemGroup>
13+
</Project>

‎MyJetTools.Sdk.Grpc/SourceInterceptor.cs

+35
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
using Grpc.Core;
2+
using Grpc.Core.Interceptors;
3+
4+
namespace MyJetTools.Sdk.Grpc;
5+
6+
public class SourceInterceptor : Interceptor
7+
{
8+
public static string AppName { get; set; }
9+
public static string AppVersion { get; set; }
10+
public static string AppHost { get; set; }
11+
12+
public const string GrpcSourceAppNameHeader = "source-app-name";
13+
public const string GrpcSourceAppVersionHeader = "source-app-name";
14+
public const string GrpcSourceAppHostHeader = "source-app-name";
15+
16+
public override TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> context,
17+
BlockingUnaryCallContinuation<TRequest, TResponse> continuation)
18+
{
19+
context.Options.Headers?.Add(GrpcSourceAppNameHeader, AppName);
20+
context.Options.Headers?.Add(GrpcSourceAppVersionHeader, AppVersion);
21+
context.Options.Headers?.Add(GrpcSourceAppHostHeader, AppHost);
22+
23+
return base.BlockingUnaryCall(request, context, continuation);
24+
}
25+
26+
public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> context,
27+
AsyncUnaryCallContinuation<TRequest, TResponse> continuation)
28+
{
29+
context.Options.Headers?.Add(GrpcSourceAppNameHeader, AppName);
30+
context.Options.Headers?.Add(GrpcSourceAppVersionHeader, AppVersion);
31+
context.Options.Headers?.Add(GrpcSourceAppHostHeader, AppHost);
32+
33+
return base.AsyncUnaryCall(request, context, continuation);
34+
}
35+
}

0 commit comments

Comments
 (0)
Please sign in to comment.