fix control service

planetarium · Nov 1, 2023 · 3f27a2f · 3f27a2f
1 parent 5e2647d
commit 3f27a2f
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 4 deletions.
diff --git a/...es.Headless.AccessControlCenter/AccessControlService/MutableSqliteAccessControlService.cs b/...es.Headless.AccessControlCenter/AccessControlService/MutableSqliteAccessControlService.cs
@@ -50,7 +50,7 @@ public void AddTxQuota(Address address, int quota)
             using var command = connection.CreateCommand();
             command.CommandText = AddTxQuotaSql;
             command.Parameters.AddWithValue("@Address", address.ToString());
-            command.Parameters.AddWithValue("@Quota", quota.ToString());
+            command.Parameters.AddWithValue("@Quota", quota);
             command.ExecuteNonQuery();
         }
 

diff --git a/NineChronicles.Headless/Services/RedisAccessControlService.cs b/NineChronicles.Headless/Services/RedisAccessControlService.cs
@@ -34,10 +34,11 @@ public bool IsAccessDenied(Address address)
             if (!result.IsNull)
             {
                 Log.ForContext("Source", nameof(IAccessControlService))
-                    .Debug("\"{Address}\" access level: {level}", address, result);
+                    .Debug("\"{Address}\" Tx Quota: {Quota}", address, result);
+                return Convert.ToInt32(result);
             }
 
-            return Convert.ToInt32(result);
+            return null;
         }
     }
 }
diff --git a/NineChronicles.Headless/Services/SQLiteAccessControlService.cs b/NineChronicles.Headless/Services/SQLiteAccessControlService.cs
@@ -61,7 +61,12 @@ public bool IsAccessDenied(Address address)
 
             var queryResult = command.ExecuteScalar();
 
-            return Convert.ToInt32(queryResult);
+            if (queryResult != null)
+            {
+                return Convert.ToInt32(queryResult);
+            }
+
+            return null;
         }
     }
 }