Skip to content

Commit 49e4307

Browse files
committed
RHINENG-25740: mark deleted systems only as culled
and let delete_system() running from the job deal with stale/unstale trigger
1 parent 83aef14 commit 49e4307

3 files changed

Lines changed: 4 additions & 6 deletions

File tree

listener/common_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,11 +72,11 @@ func assertSystemNotInDB(t *testing.T) {
7272
assert.Equal(t, 0, int(systemCount))
7373
}
7474

75-
func assertSystemStaleAndCulled(t *testing.T) {
75+
func assertSystemCulled(t *testing.T) {
7676
var systemCount int64
7777
now := time.Now()
7878
assert.Nil(t, database.DB.Model(models.SystemPlatform{}).
79-
Where("stale = true AND stale_timestamp < ? AND culled_timestamp < ?", now, now).
79+
Where("culled_timestamp < ?", now).
8080
Where("inventory_id = ?::uuid", id).Count(&systemCount).Error)
8181

8282
assert.Equal(t, 1, int(systemCount))

listener/events.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,8 +81,6 @@ func HandleDelete(event mqueue.PlatformEvent) error {
8181
// mark system as stale and let system_culling job remove it later
8282
query := database.DB.Model(&models.SystemInventory{}).Where("inventory_id = ?::uuid", event.ID).
8383
Updates(map[string]interface{}{
84-
"stale": true,
85-
"stale_timestamp": gorm.Expr("NOW()"),
8684
"culled_timestamp": gorm.Expr("NOW()"),
8785
})
8886
err = query.Error

listener/events_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ func TestDeleteSystem(t *testing.T) {
5050
deleteEvent := createTestDeleteEvent(id)
5151
err := HandleDelete(deleteEvent)
5252
assert.NoError(t, err)
53-
assertSystemStaleAndCulled(t)
53+
assertSystemCulled(t)
5454
deleteData(t)
5555
}
5656

@@ -136,7 +136,7 @@ func TestCreateDeleteUpload(t *testing.T) {
136136
deleteEvent := createTestDeleteEvent(id)
137137
err = HandleDelete(deleteEvent)
138138
assert.NoError(t, err)
139-
assertSystemStaleAndCulled(t)
139+
assertSystemCulled(t)
140140

141141
// second upload of now deleted system should not change anything
142142
changedName := "UPDATED"

0 commit comments

Comments
 (0)