From 74541c7bd7005fb945957bbace348d4a8c59602c Mon Sep 17 00:00:00 2001
From: crupest <crupest@outlook.com>
Date: Fri, 9 Dec 2022 18:22:20 +0800
Subject: Develop secret api. v21

---
 .../CrupestApi.Commons/Crud/DbConnectionFactory.cs | 23 ++++++++++++++++++++++
 1 file changed, 23 insertions(+)

(limited to 'docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs')

diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs
index 80d1b22..2ee01ca 100644
--- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs
+++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs
@@ -1,4 +1,6 @@
 using System.Data;
+using Microsoft.Data.Sqlite;
+using Microsoft.Extensions.Options;
 
 namespace CrupestApi.Commons.Crud;
 
@@ -7,3 +9,24 @@ public interface IDbConnectionFactory
 {
     IDbConnection Get(string? name = null);
 }
+
+public class SqliteConnectionFactory : IDbConnectionFactory
+{
+    private readonly IOptionsMonitor<CrupestApiConfig> _apiConfigMonitor;
+
+    public SqliteConnectionFactory(IOptionsMonitor<CrupestApiConfig> apiConfigMonitor)
+    {
+        _apiConfigMonitor = apiConfigMonitor;
+    }
+
+    public IDbConnection Get(string? name = null)
+    {
+        var connectionString = new SqliteConnectionStringBuilder()
+        {
+            DataSource = Path.Combine(_apiConfigMonitor.CurrentValue.DataDir, $"{name ?? "crupest-api"}.db"),
+            Mode = SqliteOpenMode.ReadWriteCreate
+        }.ToString();
+
+        return new SqliteConnection(connectionString);
+    }
+}
-- 
cgit v1.2.3