Merge remote-tracking branch 'origin/master' into jason_dev

Author: jason

src/Infrastructure/BotSharp.Abstraction/Infrastructures/Events/IEventPublisher.cs

@@ -10,7 +10,7 @@ public interface IEventPublisher
     /// <returns></returns>
     Task BroadcastAsync(string channel, string message);
 
-    Task PublishAsync(string channel, string message, EventPriority? priority = null);
+    Task<string?> PublishAsync(string channel, string message, EventPriority? priority = null);
 
     Task ReDispatchAsync(string channel, int count = 10, string order = "asc");
 

src/Infrastructure/BotSharp.Abstraction/Repositories/IBotSharpRepository.cs

@@ -5,6 +5,7 @@
 using BotSharp.Abstraction.Shared;
 using BotSharp.Abstraction.Tasks.Models;
 using BotSharp.Abstraction.Translation.Models;
+using BotSharp.Abstraction.Users.Enums;
 using BotSharp.Abstraction.Users.Models;
 using BotSharp.Abstraction.VectorStorage.Models;
 
@@ -26,7 +27,7 @@ public interface IBotSharpRepository : IHaveServiceProvider
 
     #region User
     User? GetUserByEmail(string email) => throw new NotImplementedException();
-    User? GetUserByPhone(string phone, string type = "client", string regionCode = "CN") => throw new NotImplementedException();
+    User? GetUserByPhone(string phone, string type = UserType.Client, string regionCode = "CN") => throw new NotImplementedException();
     User? GetAffiliateUserByPhone(string phone) => throw new NotImplementedException();
     User? GetUserById(string id) => throw new NotImplementedException();
     List<User> GetUserByIds(List<string> ids) => throw new NotImplementedException();

src/Infrastructure/BotSharp.Abstraction/Users/Models/User.cs

@@ -23,6 +23,7 @@ public class User
     public bool Verified { get; set; }
     public string RegionCode { get; set; } = "CN";
     public string? AffiliateId { get; set; }
+    public string? AffiliateCode { get; set; }
     public string? EmployeeId { get; set; }
     public bool IsDisabled { get; set; }
     public IEnumerable<string> Permissions { get; set; } = [];

src/Infrastructure/BotSharp.Abstraction/Utilities/Pagination.cs

@@ -1,7 +1,9 @@
 using BotSharp.Abstraction.Infrastructures;
+using System.Diagnostics;
 
 namespace BotSharp.Abstraction.Utilities;
 
+[DebuggerStepThrough]
 public class Pagination : ICacheKey
 {
     private int _page;

src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisPublisher.cs

@@ -21,7 +21,7 @@ public async Task BroadcastAsync(string channel, string message)
         await _subscriber.PublishAsync(channel, message);
     }
 
-    public async Task PublishAsync(string channel, string message, EventPriority? priority = null)
+    public async Task<string?> PublishAsync(string channel, string message, EventPriority? priority = null)
     {
         var db = _redis.GetDatabase();
 
@@ -34,7 +34,7 @@ public async Task PublishAsync(string channel, string message, EventPriority? pr
         if (CheckMessageExists(db, channel, "message", message))
         {
             _logger.LogError($"The message already exists {channel} {message}");
-            return;
+            return null;
         }
 
         // Add a message to the stream, keeping only the latest 1 million messages
@@ -46,6 +46,8 @@ public async Task PublishAsync(string channel, string message, EventPriority? pr
             maxLength: 1000 * 10000);
 
         _logger.LogInformation($"Published message {channel} {message} ({messageId})");
+
+        return messageId;
     }
 
     private bool CheckMessageExists(IDatabase db, string channel, string fieldName, string desiredValue)
@@ -91,7 +93,10 @@ public async Task ReDispatchAsync(string channel, int count = 10, string order =
 
             try
             {
-                var messageId = await db.StreamAddAsync(channel, "message", entry.Values[0].Value);
+                var messageId = await db.StreamAddAsync(channel, [
+                    new NameValueEntry("message", entry.Values[0].Value),
+                    new NameValueEntry("timestamp", DateTime.UtcNow.ToString("o"))
+                ]);
 
                 _logger.LogWarning($"ReDispatched message: {channel} {entry.Values[0].Value} ({messageId})");
 

src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs

@@ -42,6 +42,8 @@ public async Task SubscribeAsync(string channel, string group, bool priorityEnab
 
         while (true)
         {
+            await Task.Delay(100);
+
             if (priorityEnabled)
             {
                 if (await HandleGroupMessage(db, $"{channel}-{EventPriority.High}", group, received) > 0)

src/Infrastructure/BotSharp.Core/Infrastructures/Utilities.cs

@@ -23,7 +23,7 @@ public static string HashTextSha256(string text)
 
         var data = sha256.ComputeHash(Encoding.UTF8.GetBytes(text));
         var sb = new StringBuilder();
-        foreach(var c in data)
+        foreach (var c in data)
         {
             sb.Append(c.ToString("x2"));
         }
@@ -47,4 +47,36 @@ public static void ClearCache()
             memcache.Compact(100);
         }
     }
+
+    public static string HideMiddleDigits(string input, bool isEmail = false)
+    {
+        if (string.IsNullOrWhiteSpace(input))
+        {
+            return input;
+        }
+
+        if (isEmail)
+        {
+            int atIndex = input.IndexOf('@');
+            if (atIndex > 1)
+            {
+                string localPart = input.Substring(0, atIndex);
+                if (localPart.Length > 2)
+                {
+                    string maskedLocalPart = $"{localPart[0]}{new string('*', localPart.Length - 2)}{localPart[^1]}";
+                    return $"{maskedLocalPart}@{input.Substring(atIndex + 1)}";
+                }
+            }
+        }
+        else
+        {
+            if (input.Length > 6)
+            {
+                return $"{input.Substring(0, 3)}{new string('*', input.Length - 6)}{input.Substring(input.Length - 3)}";
+            }
+        }
+
+        return input;
+    }
+
 }

src/Infrastructure/BotSharp.Core/Repository/FileRepository/FileRepository.User.cs

@@ -11,7 +11,7 @@ public partial class FileRepository
         return Users.FirstOrDefault(x => x.Email == email.ToLower());
     }
 
-    public User? GetUserByPhone(string phone, string? type = "client", string regionCode = "CN")
+    public User? GetUserByPhone(string phone, string? type = UserType.Client, string regionCode = "CN")
     {
         var query = Users.Where(x => x.Phone == phone);
 

src/Infrastructure/BotSharp.Core/Users/Services/UserService.cs

@@ -172,7 +172,7 @@ public async Task<bool> UpdatePassword(string password, string verificationCode)
         var base64 = Encoding.UTF8.GetString(Convert.FromBase64String(authorization));
         var (id, password) = base64.SplitAsTuple(":");
         var db = _services.GetRequiredService<IBotSharpRepository>();
-        var record = db.GetUserByPhone(id, type: "internal");
+        var record = db.GetUserByPhone(id, type: UserType.Internal);
         var isCanLogin = record != null && !record.IsDisabled
             && record.Type == UserType.Internal && new List<string>
             {
@@ -548,7 +548,7 @@ public async Task<bool> VerifyPhoneExisting(string phone, string regionCode)
         }
 
         var db = _services.GetRequiredService<IBotSharpRepository>();
-        var UserByphone = db.GetUserByPhone(phone, regionCode);
+        var UserByphone = db.GetUserByPhone(phone, regionCode: regionCode);
         if (UserByphone != null && UserByphone.Verified)
         {
             return true;

src/Infrastructure/BotSharp.OpenAPI/ViewModels/Users/UserCreationModel.cs

@@ -13,6 +13,7 @@ public class UserCreationModel
     public string Type { get; set; } = UserType.Client;
     public string Role { get; set; } = UserRole.User;
     public string RegionCode { get; set; } = "CN";
+    public string? AffiliateCode { get; set; } 
     public User ToUser()
     {
         return new User
@@ -25,7 +26,8 @@ public User ToUser()
             Password = Password,
             Role = Role,
             Type = Type,
-            RegionCode = RegionCode
+            RegionCode = RegionCode,
+            AffiliateCode = AffiliateCode
         };
     }
 }