Changed sender parameter to channel.

Requests/CreatePolicy.cs

@@ -1,5 +1,4 @@
 using HermesSocketServer.Models;
-using HermesSocketServer.Services;
 using ILogger = Serilog.ILogger;
 
 namespace HermesSocketServer.Requests
@@ -8,16 +7,14 @@ namespace HermesSocketServer.Requests
     {
         public string Name => "create_policy";
         public string[] RequiredKeys => ["groupId", "path",  "count", "span"];
-        private ChannelManager _channels;
         private ILogger _logger;
 
-        public CreatePolicy(ChannelManager channels, ILogger logger)
+        public CreatePolicy(ILogger logger)
         {
-            _channels = channels;
             _logger = logger;
         }
 
-        public async Task<RequestResult> Grant(string sender, IDictionary<string, object>? data)
+        public async Task<RequestResult> Grant(Channel channel, IDictionary<string, object> data)
         {
             var id = Guid.NewGuid();
             string groupId = data["groupId"].ToString()!;
@@ -28,19 +25,17 @@ namespace HermesSocketServer.Requests
             var policy = new PolicyMessage()
             {
                 Id = id,
-                UserId = sender,
+                UserId = channel.Id,
                 GroupId = Guid.Parse(groupId),
                 Path = path,
                 Usage = count,
                 Span = span,
             };
 
-            var channel = _channels.Get(sender);
             bool result = channel.Policies.Set(id.ToString(), policy);
-
             if (result)
             {
-                _logger.Information($"Added policy to channel [policy id: {id}][group id: {groupId}][path: {path}][count: {count}][span: {span}][channel: {sender}]");
+                _logger.Information($"Added policy to channel [policy id: {id}][group id: {groupId}][path: {path}][count: {count}][span: {span}][channel: {channel.Id}]");
                 return RequestResult.Successful(policy);
             }
             return RequestResult.Failed("Something went wrong when updating the cache.");