added pg data access for user config record.

External/Implementations/Postgres/UserConfigDataAccess.cs

@@ -0,0 +1,108 @@
+using CarCareTracker.External.Interfaces;
+using CarCareTracker.Models;
+using Npgsql;
+using System.Text.Json;
+
+namespace CarCareTracker.External.Implementations
+{
+    public class PGUserConfigDataAccess: IUserConfigDataAccess
+    {
+        private NpgsqlConnection pgDataSource;
+        private readonly ILogger<PGUserConfigDataAccess> _logger;
+        private static string tableName = "userconfigrecords";
+        public PGUserConfigDataAccess(IConfiguration config, ILogger<PGUserConfigDataAccess> logger)
+        {
+            pgDataSource = new NpgsqlConnection(config["POSTGRES_CONNECTION"]);
+            _logger = logger;
+            try
+            {
+                pgDataSource.Open();
+                //create table if not exist.
+                string initCMD = $"CREATE TABLE IF NOT EXISTS app.{tableName} (id INT primary key, data jsonb not null)";
+                using (var ctext = new NpgsqlCommand(initCMD, pgDataSource))
+                {
+                    ctext.ExecuteNonQuery();
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+            }
+        }
+        public UserConfigData GetUserConfig(int userId)
+        {
+            try
+            {
+                string cmd = $"SELECT data FROM app.{tableName} WHERE id = @id";
+                var result = new UserConfigData();
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("id", userId);
+                    using (NpgsqlDataReader reader = ctext.ExecuteReader())
+                        while (reader.Read())
+                        {
+                            UserConfigData userConfig = JsonSerializer.Deserialize<UserConfigData>(reader["data"] as string);
+                            result = userConfig;
+                        }
+                }
+                return result;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return new UserConfigData();
+            }
+        }
+        public bool SaveUserConfig(UserConfigData userConfigData)
+        {
+            var existingRecord = GetUserConfig(userConfigData.Id);
+            try
+            {
+                if (existingRecord.Id == default)
+                {
+                    string cmd = $"INSERT INTO app.{tableName} (id, data) VALUES(@id, CAST(@data AS jsonb))";
+                    using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                    {
+                        var serializedData = JsonSerializer.Serialize(userConfigData);
+                        ctext.Parameters.AddWithValue("id", userConfigData.Id);
+                        ctext.Parameters.AddWithValue("data", serializedData);
+                        return ctext.ExecuteNonQuery() > 0;
+                    }
+                }
+                else
+                {
+                    string cmd = $"UPDATE app.{tableName} SET data = CAST(@data AS jsonb) WHERE id = @id";
+                    using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                    {
+                        var serializedData = JsonSerializer.Serialize(userConfigData);
+                        ctext.Parameters.AddWithValue("id", userConfigData.Id);
+                        ctext.Parameters.AddWithValue("data", serializedData);
+                        return ctext.ExecuteNonQuery() > 0;
+                    }
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return false;
+            }
+        }
+        public bool DeleteUserConfig(int userId)
+        {
+            try
+            {
+                string cmd = $"DELETE FROM app.{tableName} WHERE id = @id";
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("id", userId);
+                    return ctext.ExecuteNonQuery() > 0;
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return false;
+            }
+        }
+    }
+}

Program.cs

@@ -27,6 +27,7 @@ if (!string.IsNullOrWhiteSpace(builder.Configuration["POSTGRES_CONNECTION"])){
     builder.Services.AddSingleton<ISupplyRecordDataAccess, PGSupplyRecordDataAccess>();
     builder.Services.AddSingleton<IPlanRecordDataAccess, PGPlanRecordDataAccess>();
     builder.Services.AddSingleton<IPlanRecordTemplateDataAccess, PGPlanRecordTemplateDataAccess>();
+    builder.Services.AddSingleton<IUserConfigDataAccess, PGUserConfigDataAccess>();
 }
 else
 {
@@ -42,12 +43,12 @@ else
     builder.Services.AddSingleton<ISupplyRecordDataAccess, SupplyRecordDataAccess>();
     builder.Services.AddSingleton<IPlanRecordDataAccess, PlanRecordDataAccess>();
     builder.Services.AddSingleton<IPlanRecordTemplateDataAccess, PlanRecordTemplateDataAccess>();
+    builder.Services.AddSingleton<IUserConfigDataAccess, UserConfigDataAccess>();
 }
 
 builder.Services.AddSingleton<IUserRecordDataAccess, UserRecordDataAccess>();
 builder.Services.AddSingleton<ITokenRecordDataAccess, TokenRecordDataAccess>();
 builder.Services.AddSingleton<IUserAccessDataAccess, UserAccessDataAccess>();
-builder.Services.AddSingleton<IUserConfigDataAccess, UserConfigDataAccess>();
 
 //configure helpers
 builder.Services.AddSingleton<IFileHelper, FileHelper>();