CU-868ba84kp Postgres migration work

Author: ucswift

Core/Resgrid.Config/DataConfig.cs

@@ -2,14 +2,43 @@
 {
 	public class DataConfig
 	{
+		/// <summary>
+		/// The underlying database engine
+		/// </summary>
+		public static DatabaseTypes DatabaseType = DatabaseTypes.SqlServer;
+
+		/// <summary>
+		/// The underlying database engine for the document database (does not support SqlServer)
+		/// </summary>
+		public static DatabaseTypes DocDatabaseType = DatabaseTypes.MongoDb;
+
 		public static string ConnectionString = "Server=rgdevserver;Database=Resgrid;User Id=resgrid_app;Password=resgrid123;MultipleActiveResultSets=True;TrustServerCertificate=True;";
 
+		/// <summary>
+		/// Connection string for the core relational Resgrid database
+		/// </summary>
+		public static string CoreConnectionString = "";
+
+		/// <summary>
+		/// Connection string for storing JSON document types (Postgres)
+		/// </summary>
+		public static string DocumentConnectionString = "";
+
+
 		public static string NoSqlConnectionString = "mongodb://resgrid:resgrid123@rgdevserver:27017";
 		public static string NoSqlDatabaseName = "resgrid";
 		public static string NoSqlApplicationName = "Resgrid";
 
 		public static string UsersIdentityRoleId = "38b461d7-e848-46ef-8c06-ece5b618d9d1";
 		public static string AdminsIdentityRoleId = "1f6a03a8-62f4-4179-80fc-2eb96266cf04";
 		public static string AffiliatesIdentityRoleId = "3aba8863-e46d-40cc-ab86-309f9c3e4f97";
+		public static string QueryPrefix = "";
+	}
+
+	public enum DatabaseTypes
+	{
+		SqlServer,
+		Postgres,
+		MongoDb
 	}
 }

Core/Resgrid.Config/OidcConfig.cs

@@ -6,6 +6,11 @@ namespace Resgrid.Config
 {
 	public static class OidcConfig
 	{
+		/// <summary>
+		/// The underlying database engine for the OIDC database (Does not support Mongo)
+		/// </summary>
+		public static DatabaseTypes DatabaseType = DatabaseTypes.SqlServer;
+
 		public static string Key = "";
 
 		public static string ConnectionString = "Server=rgdevserver;Database=ResgridOIDC;User Id=resgrid_odic;Password=resgrid123;MultipleActiveResultSets=True;TrustServerCertificate=True;";

Core/Resgrid.Config/WorkerConfig.cs

@@ -2,6 +2,11 @@
 {
 	public static class WorkerConfig
 	{
+		/// <summary>
+		/// The underlying database engine for the worker database (Does not support Mongo)
+		/// </summary>
+		public static DatabaseTypes DatabaseType = DatabaseTypes.SqlServer;
+
 		public static string WorkerDbConnectionString = "Server=rgdevserver;Database=ResgridWorkers;User Id=resgrid_workers;Password=resgrid123;MultipleActiveResultSets=True;";
 		public static string PayloadKey = "XsBYpdbdHkhuGsU3tvTMawyV6d3M2F8EQ8wQ2jVLBREECQmwngACk2hm4Ykb7eW7Qsm6za8RdJBY5Z3xvN6erYry47nJ5XmL";
 	}

Core/Resgrid.Model/MapLayer.cs

@@ -12,43 +12,67 @@ namespace Resgrid.Model
 	public class MapLayer: NoSqlDocument
 	{
 		[BsonElement("departmentId")]
+		[JsonProperty(PropertyName = "departmentId")]
 		public int DepartmentId { get; set; }
 
 		[Required]
 		[MaxLength(250)]
 		[BsonElement("name")]
+		[JsonProperty(PropertyName = "name")]
 		public string Name { get; set; }
 
 		[BsonElement("type")]
+		[JsonProperty(PropertyName = "type")]
 		public int Type { get; set; }
 
 		[Required]
 		[MaxLength(50)]
 		[BsonElement("color")]
+		[JsonProperty(PropertyName = "color")]
 		public string Color { get; set; }
 
 		[BsonElement("data")]
+		[JsonProperty(PropertyName = "data")]
 		public MapLayerData Data { get; set; }
 
 		[BsonElement("isSearchable")]
+		[JsonProperty(PropertyName = "isSearchable")]
 		public bool IsSearchable { get; set; }
 
 		[BsonElement("isOnByDefault")]
+		[JsonProperty(PropertyName = "isOnByDefault")]
 		public bool IsOnByDefault { get; set; }
 
 		[BsonElement("addedById")]
+		[JsonProperty(PropertyName = "addedById")]
 		public string AddedById { get; set; }
 
 		[BsonElement("addedOn")]
+		[JsonProperty(PropertyName = "addedOn")]
 		public DateTime AddedOn { get; set; }
 
 		[BsonElement("isDeleted")]
+		[JsonProperty(PropertyName = "isDeleted")]
 		public bool IsDeleted { get; set; }
 
 		[BsonElement("updatedById")]
+		[JsonProperty(PropertyName = "updatedById")]
 		public string UpdatedById { get; set; }
 
 		[BsonElement("updatedOn")]
+		[JsonProperty(PropertyName = "updatedOn")]
 		public DateTime UpdatedOn { get; set; }
+
+		[BsonIgnore()]
+		[JsonProperty(PropertyName = "id")]
+		public string PgId { get; set; }
+
+		public string GetId()
+		{
+			if (!String.IsNullOrWhiteSpace(PgId))
+				return PgId;
+
+			return Id.ToString();
+		}
 	}
 }

Core/Resgrid.Model/PersonnelLocation.cs

@@ -39,5 +39,16 @@ public class PersonnelLocation : NoSqlDocument
 
 		[BsonElement("heading")]
 		public decimal? Heading { get; set; }
+
+		[BsonIgnore()]
+		public string PgId { get; set; }
+
+		public string GetId()
+		{
+			if (!String.IsNullOrWhiteSpace(PgId))
+				return PgId;
+
+			return Id.ToString();
+		}
 	}
 }

Core/Resgrid.Model/Repositories/IMapLayersRepository.cs

@@ -0,0 +1,14 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Resgrid.Model.Repositories
+{
+	public interface IMapLayersDocRepository
+	{
+		Task<List<MapLayer>> GetAllMapLayersByDepartmentIdAsync(int departmentId, MapLayerTypes type);
+		Task<MapLayer> GetByIdAsync(string id);
+		Task<MapLayer> GetByOldIdAsync(string id);
+		Task<MapLayer> InsertAsync(MapLayer mapLayer);
+		Task<MapLayer> UpdateAsync(MapLayer mapLayer);
+	}
+}

Core/Resgrid.Model/Repositories/IOidcRepository.cs

@@ -1,4 +1,6 @@
-namespace Resgrid.Model.Repositories
+using System.Threading.Tasks;
+
+namespace Resgrid.Model.Repositories
 {
 	/// <summary>
 	/// Interface IOidcRepository
@@ -9,6 +11,6 @@ public interface IOidcRepository
 		/// Updates the Oidc Database
 		/// </summary>
 		/// <returns>If the operation was successful</returns>
-		bool UpdateOidcDatabase();
+		Task<bool> UpdateOidcDatabaseAsync();
 	}
 }

Core/Resgrid.Model/Repositories/IPersonnelLocationsDocRepository.cs

@@ -0,0 +1,15 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Resgrid.Model.Repositories
+{
+	public interface IPersonnelLocationsDocRepository
+	{
+		Task<List<PersonnelLocation>> GetAllLocationsByUnitIdAsync(string userId);
+		Task<PersonnelLocation> GetLatestLocationsByUnitIdAsync(string userId);
+		Task<List<PersonnelLocation>> GetLatestLocationsByDepartmentIdAsync(int departmentId);
+		Task<PersonnelLocation> GetByIdAsync(string id);
+		Task<PersonnelLocation> GetByOldIdAsync(string id);
+		Task<PersonnelLocation> InsertAsync(PersonnelLocation location);
+	}
+}

Core/Resgrid.Model/Repositories/IUnitLocationsDocRepository.cs

@@ -0,0 +1,15 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace Resgrid.Model.Repositories
+{
+	public interface IUnitLocationsDocRepository
+	{
+		Task<List<UnitsLocation>> GetAllLocationsByUnitIdAsync(int unitId);
+		Task<UnitsLocation> GetLatestLocationsByUnitIdAsync(int unitId);
+		Task<List<UnitsLocation>> GetLatestLocationsByDepartmentIdAsync(int departmentId);
+		Task<UnitsLocation> GetByIdAsync(string id);
+		Task<UnitsLocation> GetByOldIdAsync(string id);
+		Task<UnitsLocation> InsertAsync(UnitsLocation location);
+	}
+}

Core/Resgrid.Model/UnitsLocation.cs

@@ -39,5 +39,16 @@ public class UnitsLocation : NoSqlDocument
 
 		[BsonElement("heading")]
 		public decimal? Heading { get; set; }
+
+		[BsonIgnore()]
+		public string PgId { get; set; }
+
+		public string GetId()
+		{
+			if (!String.IsNullOrWhiteSpace(PgId))
+				return PgId;
+
+			return Id.ToString();
+		}
 	}
 }