Feature/04 grpc (#14)

* Initial implementation ok for GRPC * Added GRPC.

Author: foyzulkarim

.gitignore

@@ -112,3 +112,6 @@ dist
 /server/WebApplication2/.vs/WebApplication2/v16
 /server/WebApplication2/WebApplication2/.config
 server/Server/.vs/Server/DesignTimeBuild/.dtbcache.v2
+
+bin/
+obj/

client/src/components/Posts.js

@@ -356,9 +356,13 @@ export const Posts = () => {
  let dispatch = useDispatch();
 
  const posts = useSelector(state => {
- return state.posts.postList;
+ return state.postContext.postList;
  });
 
+ const postContext = useSelector(state => {
+ return state.postContext;
+ })
+
  let fetchData = () => {
  dispatch({ type: "FETCH_POSTS" });
  dispatch({ type: "CLEAR_SELECTION" });
@@ -368,6 +372,12 @@ export const Posts = () => {
  fetchData();
  }, []);
 
+ // useEffect(() => {
+ // if (postContext.shouldReload || posts.length === 0) {
+ // fetchData();
+ // }
+ // }, [postContext.shouldReload]);
+
  return (
  <div className="container">
  <div id="blog" className="row">

client/src/reducers/index.js

@@ -7,7 +7,7 @@ import PermissionReducer from "./permissionReducer";
 import UsersReducer from "./usersReducer";
 
 const rootReducer = combineReducers({
- posts: PostsReducer,
+ postContext: PostsReducer,
  userContext: UserReducer,
  usersContext: UsersReducer,
  resourceContext: ResourceReducer,

client/src/reducers/postsReducer.js

@@ -2,7 +2,8 @@ const initialState = {
  postList: [],
  selectedPost: {},
  selectedComments: [],
- notificationText: ''
+ notificationText: '',
+ shouldReload: false
 };
 
 export default (state = initialState, action) => {

server/AuthGrpcService/AuthGrpcService.csproj

@@ -0,0 +1,23 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+ <PropertyGroup>
+ <TargetFramework>net5.0</TargetFramework>
+ <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+ <DockerfileContext>..\Server</DockerfileContext>
+ </PropertyGroup>
+
+ <ItemGroup>
+ <Protobuf Include="Protos\greet.proto" GrpcServices="Server" />
+ </ItemGroup>
+
+ <ItemGroup>
+ <PackageReference Include="Grpc.AspNetCore" Version="2.33.1" />
+ <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="5.0.0" />
+ <PackageReference Include="StackExchange.Redis" Version="2.2.3" />
+ </ItemGroup>
+
+ <ItemGroup>
+ <ProjectReference Include="..\RedisLibrary\AuthLibrary.csproj" />
+ </ItemGroup>
+
+</Project>

server/AuthGrpcService/Program.cs

@@ -0,0 +1,27 @@
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Hosting;
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace AuthGrpcService
+{
+ public class Program
+ {
+ public static void Main(string[] args)
+ {
+ CreateHostBuilder(args).Build().Run();
+ }
+
+ // Additional configuration is required to successfully run gRPC on macOS.
+ // For instructions on how to configure Kestrel and gRPC clients on macOS, visit https://go.microsoft.com/fwlink/?linkid=2099682
+ public static IHostBuilder CreateHostBuilder(string[] args) =>
+ Host.CreateDefaultBuilder(args)
+ .ConfigureWebHostDefaults(webBuilder =>
+ {
+ webBuilder.UseStartup<Startup>();
+ });
+ }
+}

server/AuthGrpcService/Properties/launchSettings.json

@@ -0,0 +1,12 @@
+{
+ "profiles": {
+ "AuthGrpcService": {
+ "commandName": "Project",
+ "environmentVariables": {
+ "ASPNETCORE_ENVIRONMENT": "Development"
+ },
+ "dotnetRunMessages": "true",
+ "applicationUrl": "http://localhost:5004;https://localhost:5005"
+ }
+ }
+}

server/AuthGrpcService/Protos/greet.proto

@@ -0,0 +1,21 @@
+syntax = "proto3";
+
+option csharp_namespace = "AuthGrpcService";
+
+package greet;
+
+// The greeting service definition.
+service Greeter {
+ // Sends a greeting
+ rpc SayHello (HelloRequest) returns (HelloReply);
+}
+
+// The request message containing the user's name.
+message HelloRequest {
+ string name = 1;
+}
+
+// The response message containing the greetings.
+message HelloReply {
+ string message = 1;
+}

server/AuthGrpcService/Services/GreeterService.cs

@@ -0,0 +1,84 @@
+using Grpc.Core;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Security.Claims;
+using System.Threading.Tasks;
+using AuthLibrary.Services;
+using Microsoft.AspNetCore.Authorization;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+
+namespace AuthGrpcService
+{
+ [Authorize]
+ public class GreeterService : Greeter.GreeterBase
+ {
+ private readonly ILogger<GreeterService> _logger;
+ private readonly RedisService redisService;
+
+ public GreeterService(ILogger<GreeterService> logger, RedisService redisService)
+ {
+ this.redisService = redisService;
+ _logger = logger;
+ }
+
+ public override async Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
+ {
+ var user = context.GetHttpContext().User;
+ var userName = user.Identity.Name;
+ var claimsIdentity = user.Identities.First() as ClaimsIdentity;
+ var claim = claimsIdentity.Claims.First(x => x.Type == "jti");
+ var jti = claim.Value;
+ string msg = "";
+ var inValid = string.IsNullOrWhiteSpace(userName) || string.IsNullOrWhiteSpace(jti) || string.IsNullOrWhiteSpace(request.Name);
+ if (inValid)
+ {
+ return new HelloReply
+ {
+ Message = "Unauthorized"
+ };
+ }
+
+ var redisValue = await redisService.Get(userName);
+ if (string.IsNullOrWhiteSpace(redisValue))
+ {
+ return new HelloReply
+ {
+ Message = "Unauthorized"
+ };
+ }
+
+ var dbValue = (dynamic)JsonConvert.DeserializeObject(redisValue);
+ var jtiArray = ((dbValue as dynamic).jtis as dynamic) as JArray;
+ var list = jtiArray.ToObject<List<string>>();
+ var validJti = list.Exists(x => x == jti);
+
+ if (!validJti)
+ {
+ return new HelloReply
+ {
+ Message = "Unauthorized"
+ };
+ }
+
+ var permissionViewModels = JsonConvert.DeserializeObject<List<dynamic>>(
+ ((dbValue as dynamic).resources as JValue).ToString());
+ var permitted = permissionViewModels.Exists(x => x.Name == request.Name && Convert.ToBoolean(x.IsAllowed));
+
+ if (!permitted)
+ {
+ return new HelloReply
+ {
+ Message = "Forbid"
+ };
+ }
+
+ return new HelloReply
+ {
+ Message = string.Empty
+ };
+ }
+ }
+}

server/AuthGrpcService/Startup.cs

@@ -0,0 +1,58 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using AuthLibrary.Services;
+using Microsoft.IdentityModel.Tokens;
+
+namespace AuthGrpcService
+{
+ public class Startup
+ {
+ const string BizBook365Com = "bizbook365.com";
+ private const string SecretKey = "a55ae165-912d-4052-b61e-aeeb6d6d2c07";
+ private readonly SymmetricSecurityKey SigningKey = new SymmetricSecurityKey(Encoding.ASCII.GetBytes(SecretKey));
+
+ // This method gets called by the runtime. Use this method to add services to the container.
+ // For more information on how to configure your application, visit https://go.microsoft.com/fwlink/?LinkID=398940
+ public void ConfigureServices(IServiceCollection services)
+ {
+ services.AddSingleton<RedisService>();
+ services.AddGrpc();
+ services.AddAuthorization();
+ services.AddTokenValidation(BizBook365Com, BizBook365Com, SigningKey);
+ }
+
+ // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
+ public void Configure(IApplicationBuilder app, IWebHostEnvironment env, RedisService redisService)
+ {
+ if (env.IsDevelopment())
+ {
+ app.UseDeveloperExceptionPage();
+ }
+
+ app.UseRouting();
+
+ app.UseAuthentication();
+ app.UseAuthorization();
+
+ redisService.Connect();
+
+ app.UseEndpoints(endpoints =>
+ {
+ endpoints.MapGrpcService<GreeterService>();
+
+ endpoints.MapGet("/", async context =>
+ {
+ await context.Response.WriteAsync("Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909");
+ });
+ });
+ }
+ }
+}