Fixed known_endpoints insertions

johnsimons · johnsimons · commit 315cf2a0b12f · 2025-09-01T16:46:29.000+10:00
diff --git a/src/ServiceControl.Audit.Persistence.PostgreSQL/UnitOfWork/PostgreSQLAuditIngestionUnitOfWork.cs b/src/ServiceControl.Audit.Persistence.PostgreSQL/UnitOfWork/PostgreSQLAuditIngestionUnitOfWork.cs
@@ -116,7 +116,8 @@ INSERT INTO known_endpoints (
                 ) VALUES (
                     @id, @name, @host_id, @host, @last_seen
                 )
-                ON CONFLICT (id) DO NOTHING;";
+                ON CONFLICT (id) DO UPDATE SET
+                    last_seen = GREATEST(known_endpoints.last_seen, EXCLUDED.last_seen);";
 
         cmd.Parameters.AddWithValue("id", knownEndpoint.Id);
         cmd.Parameters.AddWithValue("name", knownEndpoint.Name);

Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,8 @@ INSERT INTO known_endpoints (`
`116`	`116`	`) VALUES (`
`117`	`117`	`@id, @name, @host_id, @host, @last_seen`
`118`	`118`	`)`
`119`		`- ON CONFLICT (id) DO NOTHING;";`
	`119`	`+ ON CONFLICT (id) DO UPDATE SET`
	`120`	`+ last_seen = GREATEST(known_endpoints.last_seen, EXCLUDED.last_seen);";`
`120`	`121`
`121`	`122`	`cmd.Parameters.AddWithValue("id", knownEndpoint.Id);`
`122`	`123`	`cmd.Parameters.AddWithValue("name", knownEndpoint.Name);`