fixed user access issue.

External/Implementations/Postgres/TokenRecordDataAccess.cs

@@ -1,7 +1,6 @@
 using CarCareTracker.External.Interfaces;
 using CarCareTracker.Models;
 using Npgsql;
-using System.Net.Mail;
 
 namespace CarCareTracker.External.Implementations
 {

External/Implementations/Postgres/UserAccessDataAcces.cs

@@ -0,0 +1,212 @@
+using CarCareTracker.External.Interfaces;
+using CarCareTracker.Models;
+using Npgsql;
+using System.Net.Mail;
+
+namespace CarCareTracker.External.Implementations
+{
+    public class PGUserAccessDataAccess : IUserAccessDataAccess
+    {
+        private NpgsqlConnection pgDataSource;
+        private readonly ILogger<PGUserAccessDataAccess> _logger;
+        private static string tableName = "useraccessrecords";
+        public PGUserAccessDataAccess(IConfiguration config, ILogger<PGUserAccessDataAccess> 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} (userId INT, vehicleId INT, PRIMARY KEY(userId, vehicleId))";
+                using (var ctext = new NpgsqlCommand(initCMD, pgDataSource))
+                {
+                    ctext.ExecuteNonQuery();
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+            }
+        }
+        /// <summary>
+        /// Gets a list of vehicles user have access to.
+        /// </summary>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public List<UserAccess> GetUserAccessByUserId(int userId)
+        {
+            try
+            {
+                string cmd = $"SELECT userId, vehicleId FROM app.{tableName} WHERE userId = @userId";
+                var results = new List<UserAccess>();
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("userId", userId);
+                    using (NpgsqlDataReader reader = ctext.ExecuteReader())
+                        while (reader.Read())
+                        {
+                            UserAccess result = new UserAccess()
+                            {
+                                Id = new UserVehicle
+                                {
+                                    UserId = int.Parse(reader["userId"].ToString()),
+                                    VehicleId = int.Parse(reader["vehicleId"].ToString())
+                                }
+                            };
+                            results.Add(result);
+                        }
+                }
+                return results;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return new List<UserAccess>();
+            }
+        }
+        public UserAccess GetUserAccessByVehicleAndUserId(int userId, int vehicleId)
+        {
+            try
+            {
+                string cmd = $"SELECT userId, vehicleId FROM app.{tableName} WHERE userId = @userId AND vehicleId = @vehicleId";
+                UserAccess result = null;
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("userId", userId);
+                    ctext.Parameters.AddWithValue("vehicleId", vehicleId);
+                    using (NpgsqlDataReader reader = ctext.ExecuteReader())
+                        while (reader.Read())
+                        {
+                            result = new UserAccess()
+                            {
+                                Id = new UserVehicle
+                                {
+                                    UserId = int.Parse(reader["userId"].ToString()),
+                                    VehicleId = int.Parse(reader["vehicleId"].ToString())
+                                }
+                            };
+                            return result;
+                        }
+                }
+                return result;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return new UserAccess();
+            }
+        }
+        public List<UserAccess> GetUserAccessByVehicleId(int vehicleId)
+        {
+            try
+            {
+                string cmd = $"SELECT userId, vehicleId FROM app.{tableName} WHERE vehicleId = @vehicleId";
+                var results = new List<UserAccess>();
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("vehicleId", vehicleId);
+                    using (NpgsqlDataReader reader = ctext.ExecuteReader())
+                        while (reader.Read())
+                        {
+                            UserAccess result = new UserAccess()
+                            {
+                                Id = new UserVehicle
+                                {
+                                    UserId = int.Parse(reader["userId"].ToString()),
+                                    VehicleId = int.Parse(reader["vehicleId"].ToString())
+                                }
+                            };
+                            results.Add(result);
+                        }
+                }
+                return results;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return new List<UserAccess>();
+            }
+        }
+        public bool SaveUserAccess(UserAccess userAccess)
+        {
+            try
+            {
+                string cmd = $"INSERT INTO app.{tableName} (userId, vehicleId) VALUES(@userId, @vehicleId)";
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("userId", userAccess.Id.UserId);
+                    ctext.Parameters.AddWithValue("vehicleId", userAccess.Id.VehicleId);
+                    return ctext.ExecuteNonQuery() > 0;
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return false;
+            }
+        }
+        public bool DeleteUserAccess(int userId, int vehicleId)
+        {
+            try
+            {
+                string cmd = $"DELETE FROM app.{tableName} WHERE userId = @userId AND vehicleId = @vehicleId";
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("userId", userId);
+                    ctext.Parameters.AddWithValue("vehicleId", vehicleId);
+                    return ctext.ExecuteNonQuery() > 0;
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return false;
+            }
+        }
+        /// <summary>
+        /// Delete all access records when a vehicle is deleted.
+        /// </summary>
+        /// <param name="vehicleId"></param>
+        /// <returns></returns>
+        public bool DeleteAllAccessRecordsByVehicleId(int vehicleId)
+        {
+            try
+            {
+                string cmd = $"DELETE FROM app.{tableName} WHERE vehicleId = @vehicleId";
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("vehicleId", vehicleId);
+                    return ctext.ExecuteNonQuery() > 0;
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return false;
+            }
+        }
+        /// <summary>
+        /// Delee all access records when a user is deleted.
+        /// </summary>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public bool DeleteAllAccessRecordsByUserId(int userId)
+        {
+            try
+            {
+                string cmd = $"DELETE FROM app.{tableName} WHERE userId = @userId";
+                using (var ctext = new NpgsqlCommand(cmd, pgDataSource))
+                {
+                    ctext.Parameters.AddWithValue("userId", userId);
+                    return ctext.ExecuteNonQuery() > 0;
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex.Message);
+                return false;
+            }
+        }
+    }
+}

Logic/UserLogic.cs

@@ -48,6 +48,12 @@ namespace CarCareTracker.Logic
             if (existingUser.Id != default)
             {
                 //user exists.
+                //check if user is already a collaborator
+                var userAccess = _userAccess.GetUserAccessByVehicleAndUserId(existingUser.Id, vehicleId);
+                if (userAccess != null)
+                {
+                    return new OperationResponse { Success = false, Message = "User is already a collaborator" };
+                }
                 var result = AddUserAccessToVehicle(existingUser.Id, vehicleId);
                 if (result)
                 {

Program.cs

@@ -30,6 +30,7 @@ if (!string.IsNullOrWhiteSpace(builder.Configuration["POSTGRES_CONNECTION"])){
     builder.Services.AddSingleton<IUserConfigDataAccess, PGUserConfigDataAccess>();
     builder.Services.AddSingleton<IUserRecordDataAccess, PGUserRecordDataAccess>();
     builder.Services.AddSingleton<ITokenRecordDataAccess, PGTokenRecordDataAccess>();
+    builder.Services.AddSingleton<IUserAccessDataAccess, PGUserAccessDataAccess>();
 }
 else
 {
@@ -48,12 +49,9 @@ else
     builder.Services.AddSingleton<IUserConfigDataAccess, UserConfigDataAccess>();
     builder.Services.AddSingleton<IUserRecordDataAccess, UserRecordDataAccess>();
     builder.Services.AddSingleton<ITokenRecordDataAccess, TokenRecordDataAccess>();
+    builder.Services.AddSingleton<IUserAccessDataAccess, UserAccessDataAccess>();
 }
 
-
-
-builder.Services.AddSingleton<IUserAccessDataAccess, UserAccessDataAccess>();
-
 //configure helpers
 builder.Services.AddSingleton<IFileHelper, FileHelper>();
 builder.Services.AddSingleton<IGasHelper, GasHelper>();

config/userConfig.json

@@ -1 +1 @@
-{"UseDarkMode":true,"EnableCsvImports":false,"UseMPG":true,"UseDescending":false,"EnableAuth":false,"UserNameHash":"","UserPasswordHash":""}
+{"UseDarkMode":true,"EnableCsvImports":true,"UseMPG":false,"UseDescending":true,"EnableAuth":true,"HideZero":false,"UseUKMPG":false,"UseThreeDecimalGasCost":true,"UseMarkDownOnSavedNotes":false,"EnableAutoReminderRefresh":false,"EnableAutoOdometerInsert":false,"EnableShopSupplies":false,"PreferredGasUnit":"l","PreferredGasMileageUnit":"l/100km","UserNameHash":"8c6976e5b5410415bde908bd4dee15dfb167a9c873fc4bb8a81f6f2ab448a918","UserPasswordHash":"8b3b357e205f36f3c3858994f0d15ce9451284e0e42493a817fc0d66a02bc3a2","UserLanguage":"en_US","VisibleTabs":[0,8,1,4,2,3,6,7],"DefaultTab":8}