RIC-T39 Backend IC work

Core/Resgrid.Model/CheckInRecord.cs

@@ -27,6 +27,12 @@ public class CheckInRecord : IEntity
 
 		public string Note { get; set; }
 
+		/// <summary>
+		/// Client-supplied idempotency key (the offline outbox event id). When set, a replayed check-in carrying the
+		/// same key returns the original record instead of inserting a duplicate. See offline-first-architecture.md.
+		/// </summary>
+		public string IdempotencyKey { get; set; }
+
 		[NotMapped]
 		public string TableName => "CheckInRecords";
 

Core/Resgrid.Model/IChangeTracked.cs

@@ -0,0 +1,14 @@
+using System;
+
+namespace Resgrid.Model
+{
+	/// <summary>
+	/// Entities that carry a <see cref="ModifiedOn"/> change cursor. It is stamped on every insert and update
+	/// and drives two offline-first concerns: the delta-sync "changed since" query (pull) and last-write-wins
+	/// conflict resolution on reconnect. See <c>docs/architecture/offline-first-architecture.md</c>.
+	/// </summary>
+	public interface IChangeTracked
+	{
+		DateTime? ModifiedOn { get; set; }
+	}
+}

Core/Resgrid.Model/IncidentCommand/CommandStructureNode.cs

@@ -9,7 +9,7 @@ namespace Resgrid.Model
 	/// A live lane / span-of-control node on the command board (Division, Group, Branch, Staging, ...).
 	/// Initially seeded from a <c>CommandDefinitionRole</c> then per-incident editable.
 	/// </summary>
-	public class CommandStructureNode : IEntity
+	public class CommandStructureNode : IEntity, IChangeTracked
 	{
 		public string CommandStructureNodeId { get; set; }
 
@@ -36,6 +36,12 @@ public class CommandStructureNode : IEntity
 		/// <summary>The CommandDefinitionRole this node was seeded from, if any.</summary>
 		public int? SourceRoleId { get; set; }
 
+		/// <summary>Soft-delete tombstone so a lane removed offline propagates on delta sync (null = live).</summary>
+		public DateTime? DeletedOn { get; set; }
+
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "CommandStructureNodes";
 
@@ -61,7 +67,7 @@ public object IdValue
 	/// Assigns a resource to a command structure node. Polymorphic: the resource may be an own-department
 	/// unit/person, a linked (mutual-aid) department unit/person, or an incident ad-hoc unit/person.
 	/// </summary>
-	public class ResourceAssignment : IEntity
+	public class ResourceAssignment : IEntity, IChangeTracked
 	{
 		public string ResourceAssignmentId { get; set; }
 
@@ -85,6 +91,9 @@ public class ResourceAssignment : IEntity
 
 		public DateTime? ReleasedOn { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "ResourceAssignments";
 

Core/Resgrid.Model/IncidentCommand/IncidentAdHocResources.cs

@@ -9,7 +9,7 @@ namespace Resgrid.Model
 	/// An incident-scoped, ad-hoc unit created on the fly for resources not in Resgrid (e.g. a mutual-aid
 	/// crew from a non-Resgrid agency, or a unit formed from on-scene personnel). Not a real department Unit.
 	/// </summary>
-	public class IncidentAdHocUnit : IEntity
+	public class IncidentAdHocUnit : IEntity, IChangeTracked
 	{
 		public string IncidentAdHocUnitId { get; set; }
 
@@ -34,6 +34,9 @@ public class IncidentAdHocUnit : IEntity
 
 		public DateTime? ReleasedOn { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "IncidentAdHocUnits";
 
@@ -59,7 +62,7 @@ public object IdValue
 	/// An incident-scoped, ad-hoc person created on the fly for resources not in Resgrid. May ride an ad-hoc
 	/// (or real) unit for accountability via <see cref="RidingResourceKind"/> + <see cref="RidingResourceId"/>.
 	/// </summary>
-	public class IncidentAdHocPersonnel : IEntity
+	public class IncidentAdHocPersonnel : IEntity, IChangeTracked
 	{
 		public string IncidentAdHocPersonnelId { get; set; }
 
@@ -88,6 +91,9 @@ public class IncidentAdHocPersonnel : IEntity
 
 		public DateTime? ReleasedOn { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "IncidentAdHocPersonnel";
 

Core/Resgrid.Model/IncidentCommand/IncidentCommand.cs

@@ -9,7 +9,7 @@ namespace Resgrid.Model
 	/// A live incident-command instance established on a specific <c>Call</c>. Seeded (optionally) from a
 	/// <c>CommandDefinition</c> template and then freely editable by the Commander for the life of the incident.
 	/// </summary>
-	public class IncidentCommand : IEntity
+	public class IncidentCommand : IEntity, IChangeTracked
 	{
 		public string IncidentCommandId { get; set; }
 
@@ -40,6 +40,9 @@ public class IncidentCommand : IEntity
 
 		public DateTime? ClosedOn { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "IncidentCommands";
 

Core/Resgrid.Model/IncidentCommand/IncidentCommandChanges.cs

@@ -0,0 +1,38 @@
+using System.Collections.Generic;
+
+namespace Resgrid.Model
+{
+	/// <summary>
+	/// Delta payload for offline sync: every change-tracked incident-command row whose <see cref="IChangeTracked.ModifiedOn"/>
+	/// (or, for the append-only timeline, OccurredOn) is newer than the client's last sync cursor, scoped to a department.
+	/// Soft-deleted / closed / released rows ARE included (with their state columns set) so the client can remove or
+	/// update them locally. The client stores <see cref="ServerTimestampMs"/> and passes it back as the next `since`.
+	/// Ad-hoc resources are not change-tracked and are pulled separately (full refetch). See
+	/// docs/architecture/offline-first-architecture.md.
+	/// </summary>
+	public class IncidentCommandChanges
+	{
+		/// <summary>Server clock (Unix epoch ms) captured at the start of the read; the client's next-sync cursor.</summary>
+		public long ServerTimestampMs { get; set; }
+
+		public List<IncidentCommand> Commands { get; set; } = new List<IncidentCommand>();
+
+		public List<CommandStructureNode> Nodes { get; set; } = new List<CommandStructureNode>();
+
+		public List<ResourceAssignment> Assignments { get; set; } = new List<ResourceAssignment>();
+
+		public List<TacticalObjective> Objectives { get; set; } = new List<TacticalObjective>();
+
+		public List<IncidentTimer> Timers { get; set; } = new List<IncidentTimer>();
+
+		public List<IncidentMapAnnotation> Annotations { get; set; } = new List<IncidentMapAnnotation>();
+
+		public List<IncidentRoleAssignment> Roles { get; set; } = new List<IncidentRoleAssignment>();
+
+		public List<IncidentAdHocUnit> AdHocUnits { get; set; } = new List<IncidentAdHocUnit>();
+
+		public List<IncidentAdHocPersonnel> AdHocPersonnel { get; set; } = new List<IncidentAdHocPersonnel>();
+
+		public List<CommandLogEntry> TimelineEntries { get; set; } = new List<CommandLogEntry>();
+	}
+}

Core/Resgrid.Model/IncidentCommand/IncidentRole.cs

@@ -149,7 +149,7 @@ public static IncidentCapabilities GetCapabilities(IncidentRoleType role)
 	/// Assigns a Resgrid user to a functional incident-command role for a specific incident (Call). Incident-scoped,
 	/// not a department-wide claim. Optionally scoped to a structure node for supervisors.
 	/// </summary>
-	public class IncidentRoleAssignment : IEntity
+	public class IncidentRoleAssignment : IEntity, IChangeTracked
 	{
 		public string IncidentRoleAssignmentId { get; set; }
 
@@ -174,6 +174,9 @@ public class IncidentRoleAssignment : IEntity
 
 		public DateTime? RemovedOn { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "IncidentRoleAssignments";
 

Core/Resgrid.Model/IncidentCommand/IncidentTacticals.cs

@@ -6,7 +6,7 @@
 namespace Resgrid.Model
 {
 	/// <summary>A tactical objective / benchmark for an incident (e.g. "Primary search complete").</summary>
-	public class TacticalObjective : IEntity
+	public class TacticalObjective : IEntity, IChangeTracked
 	{
 		public string TacticalObjectiveId { get; set; }
 
@@ -32,6 +32,9 @@ public class TacticalObjective : IEntity
 
 		public int SortOrder { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "TacticalObjectives";
 
@@ -57,7 +60,7 @@ public object IdValue
 	/// A scene / benchmark / role timer for an incident. Personnel accountability (PAR) is handled by the
 	/// Checkin feature, not by these timers.
 	/// </summary>
-	public class IncidentTimer : IEntity
+	public class IncidentTimer : IEntity, IChangeTracked
 	{
 		public string IncidentTimerId { get; set; }
 
@@ -89,6 +92,9 @@ public class IncidentTimer : IEntity
 
 		public DateTime? AcknowledgedOn { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "IncidentTimers";
 
@@ -111,7 +117,7 @@ public object IdValue
 	}
 
 	/// <summary>A real-time map annotation (markup) on the tactical map, synced across devices.</summary>
-	public class IncidentMapAnnotation : IEntity
+	public class IncidentMapAnnotation : IEntity, IChangeTracked
 	{
 		public string IncidentMapAnnotationId { get; set; }
 
@@ -138,6 +144,9 @@ public class IncidentMapAnnotation : IEntity
 
 		public DateTime? DeletedOn { get; set; }
 
+		/// <summary>Change cursor for offline delta sync + last-write-wins; stamped on every write.</summary>
+		public DateTime? ModifiedOn { get; set; }
+
 		[NotMapped]
 		public string TableName => "IncidentMapAnnotations";
 

Core/Resgrid.Model/Services/IIncidentCommandService.cs

@@ -19,6 +19,13 @@ public interface IIncidentCommandService
 		Task<IncidentCommandBoard> GetCommandBoardAsync(int departmentId, int callId);
 		Task<List<PersonnelCallCheckInStatus>> GetAccountabilityForCallAsync(int departmentId, int callId);
 
+		/// <summary>
+		/// Offline-first delta pull: returns every change-tracked incident-command row (and append-only timeline entry)
+		/// for the department whose ModifiedOn/OccurredOn is newer than <paramref name="sinceUtc"/>. Includes
+		/// soft-deleted/closed/released rows so a reconnecting client can reconcile removals. See the offline-first doc.
+		/// </summary>
+		Task<IncidentCommandChanges> GetChangesSinceAsync(int departmentId, System.DateTime sinceUtc);
+
 		/// <summary>
 		/// Sweeps personnel accountability (PAR) for the call and raises <c>CriticalParDetectedEvent</c> once per
 		/// member each time they transition into the Critical (overdue) state. Idempotent via a timeline marker —

Core/Resgrid.Model/Services/IIncidentResourcesService.cs

@@ -26,5 +26,12 @@ public interface IIncidentResourcesService
 
 		/// <summary>Forms a new ad-hoc unit and attaches the given ad-hoc personnel to it as its roster.</summary>
 		Task<IncidentAdHocUnit> FormUnitFromPersonnelAsync(IncidentAdHocUnit unit, List<string> adHocPersonnelIds, string userId, CancellationToken cancellationToken = default(CancellationToken));
+
+		/// <summary>
+		/// Offline-first delta pull for ad-hoc resources: returns the department's ad-hoc units and personnel whose
+		/// ModifiedOn is newer than <paramref name="sinceUtc"/> (released rows included so the client reconciles them).
+		/// Aggregated into the unified /Sync/Changes payload by SyncController. See offline-first-architecture.md.
+		/// </summary>
+		Task<(List<IncidentAdHocUnit> Units, List<IncidentAdHocPersonnel> Personnel)> GetAdHocChangesSinceAsync(int departmentId, System.DateTime sinceUtc);
 	}
 }

Core/Resgrid.Services/CheckInTimerService.cs

@@ -320,8 +320,36 @@ public async Task<List<ResolvedCheckInTimer>> ResolveAllTimersForCallAsync(Call
 
 		public async Task<CheckInRecord> PerformCheckInAsync(CheckInRecord record, CancellationToken cancellationToken = default)
 		{
+			// Offline idempotency: when the client supplies its outbox event id, a replayed check-in returns the
+			// original record instead of inserting a duplicate. Dedup is in-memory over the call's (small) check-in
+			// set, so only replayed events — which carry a key — pay the extra read; live UI check-ins skip it.
+			if (!string.IsNullOrWhiteSpace(record.IdempotencyKey))
+			{
+				var existing = await _recordRepository.GetByCallIdAsync(record.CallId);
+				var duplicate = existing?.FirstOrDefault(r => r.IdempotencyKey == record.IdempotencyKey);
+				if (duplicate != null)
+					return duplicate;
+			}
+
 			record.Timestamp = DateTime.UtcNow;
-			var saved = await _recordRepository.SaveOrUpdateAsync(record, cancellationToken);
+
+			CheckInRecord saved;
+			try
+			{
+				saved = await _recordRepository.SaveOrUpdateAsync(record, cancellationToken);
+			}
+			catch (Exception) when (!string.IsNullOrWhiteSpace(record.IdempotencyKey))
+			{
+				// The in-memory pre-check above is check-then-insert and races under concurrent replays; the filtered
+				// unique index UX_CheckInRecords_Department_IdempotencyKey is the real guard. If we lost the race,
+				// adopt the winner — same idempotent result as the pre-check — rather than surfacing a 500 (which would
+				// just trigger another retry).
+				var existing = await _recordRepository.GetByCallIdAsync(record.CallId);
+				var winner = existing?.FirstOrDefault(r => r.IdempotencyKey == record.IdempotencyKey);
+				if (winner != null)
+					return winner;
+				throw;
+			}
 
 			// Real-time board refresh is best-effort: the check-in is already persisted, so a CQRS/Redis
 			// publish failure must not fail the check-in — that would 500 the caller and a retry would