Develop secret api. v3

1 files changed, 32 insertions, 4 deletions

diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Secrets/SecretsService.cs b/docker/crupest-api/CrupestApi/CrupestApi.Secrets/SecretsService.cs
index 9281cee..feac08a 100644
--- a/docker/crupest-api/CrupestApi/CrupestApi.Secrets/SecretsService.cs
+++ b/docker/crupest-api/CrupestApi/CrupestApi.Secrets/SecretsService.cs
@@ -108,14 +108,42 @@ INSERT INTO secrets (Key, Secret, Description, ExpireTime, Revoked, CreateTime)
         return new SecretInfo(key, secret, description, expireTime, false, now);
     }
 
-    public Task<List<SecretInfo>> GetSecretListAsync(bool includeExpired = false, bool includeRevoked = false)
+    public async Task<List<SecretInfo>> GetSecretListAsync(bool includeExpired = false, bool includeRevoked = false)
     {
-        throw new NotImplementedException();
+        var dbConnection = await EnsureDatabase();
+
+        var query = await dbConnection.QueryAsync<SecretInfo>(@"
+SELECT Key, Secret, Description, ExpireTime, Revoked, CreateTime FROM secrets
+WHERE @IncludeExpired OR ExpireTime IS NULL OR ExpireTime > @Now AND
+        @IncludeRevoked OR Revoked = 0;
+        ", new
+        {
+            IncludeExpired = includeExpired,
+            IncludeRevoked = includeRevoked,
+            Now = DateTime.Now.ToString("O"),
+        });
+
+        return query.ToList();
     }
 
-    public Task<List<SecretInfo>> GetSecretListByKeyAsync(string key, bool includeExpired = false, bool includeRevoked = false)
+    public async Task<List<SecretInfo>> GetSecretListByKeyAsync(string key, bool includeExpired = false, bool includeRevoked = false)
     {
-        throw new NotImplementedException();
+        var dbConnection = await EnsureDatabase();
+
+        var query = await dbConnection.QueryAsync<SecretInfo>(@"
+SELECT Key, Secret, Description, ExpireTime, Revoked, CreateTime FROM secrets
+WHERE Key = @Key AND
+(@IncludeExpired OR ExpireTime IS NULL OR ExpireTime > @Now) AND
+(@IncludeRevoked OR Revoked = 0);
+        ", new
+        {
+            Key = key,
+            IncludeExpired = includeExpired,
+            IncludeRevoked = includeRevoked,
+            Now = DateTime.Now.ToString("O"),
+        });
+
+        return query.ToList();
     }
 
     public Task<SecretInfo> ModifySecretAsync(string secret, SecretModifyRequest modifyRequest)