Net Core API Project With EF6 code first, Responsitory Design Partern - P5 - Sử dụng JWT để thực hiện Authorization Part 2.
Bài đăng này đã không được cập nhật trong 5 năm
Hi All
ở 4 phần trước mình đã hướng dẫn các bạn
- Tạo projecy .Net core.
- Tạo Repository
- Tạo Configuration from database
và hôm nay mình sẽ tiếp tục bài viết để hướng dẫn các bạn sử dụng JWT để thực hiện Authorization.
Phần 1: .Net Core API Project With EF6 code first, Responsitory Design Partern
Phần 2: .Net Core API Project With EF6 code first, Responsitory Design Partern - P2 - Create Repository
Ok trong phần trước chúng ta đã config để sử dụng JWT để check xem User có quyền truy cập lên controller hay ko và sẽ trả về lỗi 401 khi bị AccessToke bị phát hiện ko đúng là do server render. Tiếp tục hôm nay chúng ta sẽ kiểm tra người dùng thêm 1 bước nữa. Đó là check xem người dùng có quyền truy cập vào controller hay ko.
Create Database
Việc đầu tiên của phân quyền là chúng ta cần có một database được thiết kế để lưu trữ thông tin về role của user. Ở đây mình sẽ dựng các table sau:
- User => chứa thông tin người dùng
- UserType => chứa các role mà hệ thống sẽ sử dụng
- UserTypeUser = > Mapping giữa User và UserType để biết 1 user có bao nhiêu role.
Create migration
Chúng ta sẽ tạo thêm 3 model ở Folder "NetCoreAPISample\DataAccess\Model" như sau
User Model
public class User : BaseEntity
{
public User()
{
UserTypeUser = new HashSet<UserTypeUser>();
}
public string Email { get; set; }
public string FullName { get; set; }
public string Password { get; set; }
public virtual ICollection<UserTypeUser> UserTypeUser { get; set; }
}
UserType Model
public class UserType : BaseEntity
{
public UserType()
{
UserTypeUser = new HashSet<UserTypeUser>();
}
public string UserTypeName { get; set; }
public string Description { get; set; }
public virtual ICollection<UserTypeUser> UserTypeUser { get; set; }
}
UserTypeUser Model
public class UserTypeUser : BaseEntity
{
public int UserId { get; set; }
public int UserTypeId { get; set; }
public virtual User User { get; set; }
public virtual UserType UserType { get; set; }
}
Update DBContext
using DataAccess.Model;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Text;
namespace DataAccess.DBContext
{
public class SampleNetCoreAPIContext : DbContext
{
public SampleNetCoreAPIContext(DbContextOptions<SampleNetCoreAPIContext> options)
: base(options)
{ }
public virtual DbSet<Blog> Blogs { get; set; }
public virtual DbSet<Post> Posts { get; set; }
public virtual DbSet<SampleNetCoreConfig> SampleNetCoreConfig { get; set; }
public virtual DbSet<User> User { get; set; }
public virtual DbSet<UserTypeUser> UserTypeUser { get; set; }
public virtual DbSet<UserType> UserType { get; set; }
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity<User>(entity =>
{
entity.ToTable("users");
});
modelBuilder.Entity<UserTypeUser>(entity =>
{
entity.ToTable("user_type_users");
});
modelBuilder.Entity<UserType>(entity =>
{
entity.ToTable("user_types");
});
modelBuilder.Entity<Blog>(entity =>
{
entity.ToTable("blogs");
entity.Property(e => e.Id).HasColumnType("int(11)");
});
modelBuilder.Entity<Post>(entity =>
{
entity.ToTable("posts");
entity.HasIndex(e => e.BlogId)
.HasName("FK_Post_Blog_BlogId_idx");
entity.HasOne(d => d.Blog)
.WithMany(p => p.Posts)
.HasForeignKey(d => d.BlogId)
.HasConstraintName("FK_Post_Blog_BlogId");
});
}
}
}
Open "Package Manager Console" và input
add-migration add_authorization_table
EntityFrameWork sẽ render migration như sau:
using Microsoft.EntityFrameworkCore.Migrations;
using System;
using System.Collections.Generic;
namespace DataAccess.Migrations
{
public partial class add_authorization_table : Migration
{
protected override void Up(MigrationBuilder migrationBuilder)
{
migrationBuilder.CreateTable(
name: "user_types",
columns: table => new
{
Id = table.Column<int>(nullable: false)
.Annotation("MySQL:AutoIncrement", true),
Active = table.Column<bool>(nullable: false),
CreatedTime = table.Column<DateTime>(nullable: true),
Description = table.Column<string>(nullable: true),
UpdatedTime = table.Column<DateTime>(nullable: true),
UserTypeName = table.Column<string>(nullable: true)
},
constraints: table =>
{
table.PrimaryKey("PK_user_types", x => x.Id);
});
migrationBuilder.CreateTable(
name: "users",
columns: table => new
{
Id = table.Column<int>(nullable: false)
.Annotation("MySQL:AutoIncrement", true),
Active = table.Column<bool>(nullable: false),
CreatedTime = table.Column<DateTime>(nullable: true),
Email = table.Column<string>(nullable: true),
FullName = table.Column<string>(nullable: true),
Password = table.Column<string>(nullable: true),
UpdatedTime = table.Column<DateTime>(nullable: true)
},
constraints: table =>
{
table.PrimaryKey("PK_users", x => x.Id);
});
migrationBuilder.CreateTable(
name: "user_type_users",
columns: table => new
{
Id = table.Column<int>(nullable: false)
.Annotation("MySQL:AutoIncrement", true),
Active = table.Column<bool>(nullable: false),
CreatedTime = table.Column<DateTime>(nullable: true),
UpdatedTime = table.Column<DateTime>(nullable: true),
UserId = table.Column<int>(nullable: false),
UserTypeId = table.Column<int>(nullable: false)
},
constraints: table =>
{
table.PrimaryKey("PK_user_type_users", x => x.Id);
table.ForeignKey(
name: "FK_user_type_users_users_UserId",
column: x => x.UserId,
principalTable: "users",
principalColumn: "Id",
onDelete: ReferentialAction.Cascade);
table.ForeignKey(
name: "FK_user_type_users_user_types_UserTypeId",
column: x => x.UserTypeId,
principalTable: "user_types",
principalColumn: "Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateIndex(
name: "IX_user_type_users_UserId",
table: "user_type_users",
column: "UserId");
migrationBuilder.CreateIndex(
name: "IX_user_type_users_UserTypeId",
table: "user_type_users",
column: "UserTypeId");
}
protected override void Down(MigrationBuilder migrationBuilder)
{
migrationBuilder.DropTable(
name: "user_type_users");
migrationBuilder.DropTable(
name: "users");
migrationBuilder.DropTable(
name: "user_types");
}
}
}
Open "Package Manager Console" và input
update-database
kết quả như sau:
PM> update-database
Applying migration '20180919090857_add_authorization_table'.
Done.
PM>
Add Enum
trong 3 table mà chúng ta vừa add sẽ có table UserType là master data nên chúng ta sẽ Enum hóa table này bằng cách tạo ra các enum tương ứng với các record trong table UserType
Trong Project "NetCoreAPISample\Common" add file "Enum.cs"
public enum UserTypeEnum
{
Administrator = 1,
Staff = 2,
Manager = 3
}
Config Policy
Các bạn vui lòng vào link sau: Microsof Document để tìm hiểu cái chúng ta chuẩn bị làm nhé. Hiện nay thì .Net core có 2 cách để chúng ta thực hiện Authorization:
- Role
- Policy
Role thì nó đang base theo Asp.Net MVC thuần và khá hạn chế trong việc check các thông tin đi kèm.
Policy là một cách mới mà Microsoft đưa ra ở bản .Net core 2.0 cho phép người dùng có thể thực hiện check nhiều cái hơn, nói một cách khác chúng ta có thể custom đc cái chúng ta sẽ check một cách dễ dàng.
In ASP.NET Core authorization comes in two flavors. One is traditional role-based authorization, which works the same way it does in classic ASP.NET MVC, and still has the structural limitation of being rather flat and not ideal for expressing sophisticated authorization logic. Policy-based authentication is a new approach that provides a richer and more expressive model. This is because a policy is a collection of requirements based on claims and custom logic based on any other information that can be injected from the HTTP context or external sources. These requirements are each associated with one or more handlers, which are responsible for the actual evaluation of the requirement.
Do vậy trong bài này mình đang sử dụng Policy để triển khai check Authorization.
Có một vấn đề khi sử dụng Policy để thực hiện authorization là các bạn phải chuẩn bị sẵn các kịch bản cho Policy.
Ví dụ như có UserType = "administration" thì sẽ phải có 1 policy là "administration", như vậy nếu một controller muốn có nhiều Policy thì sẽ phải triển khai như nào?
Và Mục tiêu của config lần này là:
- 1 controller có thể được access với nhiều Policy và một cách dynamic
- Với mỗi UserType chúng ta có thể custom được chúng ta cần check cái gì
- Thoải mái thêm UserType và mỗi lần thêm chúng ta ko cần care việc tạo policy cho UserType đó
Tạo policy động
Bài toán mình đặt ra ở trên là để sử dụng Policy thì chúng ta cần phải tạo trước các Policy. Vậy chả nhẽ chúng ta tạo bằng tay và lưu ở 1 folder nào đó ? Và mình đã nãy ra ý nghĩ là vì sao chúng ta ko tạo ra 1 đoạn code để tổ hợp tất cả các trường hợp có thể ghép lại với nhau của 1 list UserType và từ đó tạo 1 template và apply cho toàn bô.
Ví dụ:
Administrator
Staff
Manager
Với 3 loại UserType này chúng ta cần phải có các Policy sau
Administrator
Staff
Manager
Administrator,Staff
Administrator,Manager
.
.
.
Administrator,Staff,Manager
Và nếu thêm mới các UserType thì sẽ ko ảnh hưởng và code lại. May mắn là mình có lượm nhặt được 1 số đoạn code tổ hợp khá là hay và mình chia sẻ với các bạn:
Các bạn vào folder "\NetCoreAPISample\Security\Extension" và view file "PolicyExtension"
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace Security.Extension
{
public static class PolicyExtension
{
public static IEnumerable<TSource> Prepend<TSource>(this IEnumerable<TSource> source, TSource item)
{
if (source == null)
throw new ArgumentNullException("source");
yield return item;
foreach (var element in source)
yield return element;
}
public static IEnumerable<IEnumerable<TSource>> Permutate<TSource>(this IEnumerable<TSource> source)
{
if (source == null)
throw new ArgumentNullException("source");
var list = source.ToList();
if (list.Count > 1)
return from s in list
from p in Permutate(list.Take(list.IndexOf(s)).Concat(list.Skip(list.IndexOf(s) + 1)))
select p.Prepend(s);
return new[] { list };
}
public static IEnumerable<IEnumerable<TSource>> Combinate<TSource>(this IEnumerable<TSource> source, int k)
{
if (source == null)
throw new ArgumentNullException("source");
var list = source.ToList();
if (k > list.Count)
throw new ArgumentOutOfRangeException("k");
if (k == 0)
yield return Enumerable.Empty<TSource>();
foreach (var l in list)
foreach (var c in Combinate(list.Skip(list.Count - k - 2), k - 1))
yield return c.Prepend(l);
}
}
}
Nhìn vào khá là khó hiểu nhưng nôm na là đoạn code trên sẽ giúp chúng ta tổ hợp tất cả các trường hợp thành các chuỗi string Đoạn mình ko giải thích nhé hihi.
Config Statup
Sau khi chúng ta có tổ hợp thì chúng ta sẽ thực hiện add Policy ở Startup.
var userRoleTypes = Enum.GetValues(typeof(UserTypeEnum)).Cast<UserTypeEnum>().ToList();
for (int i = 1; i <= userRoleTypes.Count(); i++)
{
foreach (var policyNames in userRoleTypes.Combinate(i))
{
///Administrator,Customer
var policyConcat = string.Join(",", policyNames);
var result = policyNames.GroupBy(c => c).Where(c => c.Count() > 1).Select(c => new { charName = c.Key, charCount = c.Count() });
if (result.Count() <= 0)
{
services.AddAuthorization(options =>
{
options.AddPolicy(policyConcat, policy => policy.Requirements.Add(new CustomAuthoRequire(policyConcat)));
});
}
}
}
ahihi chúng ta vừa tạo ra các Policy add vào hệ thống rồi đấy các bạn
Buổi sau mình sẽ hướng dẫn các bạn handle ở tầng midware nhé 
All rights reserved
