aboutsummaryrefslogtreecommitdiff
path: root/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Secrets/SecretService.cs
diff options
context:
space:
mode:
authorcrupest <crupest@outlook.com>2024-11-11 01:12:29 +0800
committerYuqian Yang <crupest@crupest.life>2024-12-19 21:42:01 +0800
commita7fb0508867ee53934be18a6606aa8bc12c2645b (patch)
tree5994f0a62733b13f9f330e3515260ae20dc4a0bd /dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Secrets/SecretService.cs
parent7692763f83ad1be735b0b9e9ab0af8ce666d8de8 (diff)
downloadcrupest-a7fb0508867ee53934be18a6606aa8bc12c2645b.tar.gz
crupest-a7fb0508867ee53934be18a6606aa8bc12c2645b.tar.bz2
crupest-a7fb0508867ee53934be18a6606aa8bc12c2645b.zip
HALF WORK: 2024.12.19
Re-organize file structure.
Diffstat (limited to 'dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Secrets/SecretService.cs')
-rw-r--r--dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Secrets/SecretService.cs48
1 files changed, 48 insertions, 0 deletions
diff --git a/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Secrets/SecretService.cs b/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Secrets/SecretService.cs
new file mode 100644
index 0000000..c693d8d
--- /dev/null
+++ b/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Secrets/SecretService.cs
@@ -0,0 +1,48 @@
+using System.Data;
+using CrupestApi.Commons.Crud;
+using CrupestApi.Commons.Crud.Migrations;
+
+namespace CrupestApi.Commons.Secrets;
+
+public class SecretService : CrudService<SecretInfo>, ISecretService
+{
+ private readonly ILogger<SecretService> _logger;
+
+ public SecretService(ITableInfoFactory tableInfoFactory, IDbConnectionFactory dbConnectionFactory, IDatabaseMigrator migrator, ILoggerFactory loggerFactory)
+ : base(tableInfoFactory, dbConnectionFactory, migrator, loggerFactory)
+ {
+ _logger = loggerFactory.CreateLogger<SecretService>();
+ }
+
+ protected override void AfterMigrate(IDbConnection connection, TableInfo table)
+ {
+ if (table.SelectCount(connection) == 0)
+ {
+ _logger.LogInformation("No secrets found, insert default secrets.");
+ using var transaction = connection.BeginTransaction();
+ var insertClause = InsertClause.Create()
+ .Add(nameof(SecretInfo.Key), SecretsConstants.SecretManagementKey)
+ .Add(nameof(SecretInfo.Secret), "crupest")
+ .Add(nameof(SecretInfo.Description), "This is the init key. Please revoke it immediately after creating a new one.");
+ _table.Insert(connection, insertClause, out var _);
+ transaction.Commit();
+ }
+ }
+
+ public void CreateTestSecret(string key, string secret)
+ {
+ var connection = _dbConnection;
+ var insertClause = InsertClause.Create()
+ .Add(nameof(SecretInfo.Key), key)
+ .Add(nameof(SecretInfo.Secret), secret)
+ .Add(nameof(SecretInfo.Description), "Test secret.");
+ _table.Insert(connection, insertClause, out var _);
+ }
+
+ public List<string> GetPermissions(string secret)
+ {
+ var list = _table.Select<SecretInfo>(_dbConnection,
+ where: WhereClause.Create().Eq(nameof(SecretInfo.Secret), secret));
+ return list.Select(x => x.Key).ToList();
+ }
+}