try to fix ci failures

Signed-off-by: Davanum Srinivas <[email protected]>

Author: dims

node-drainer/main.go

@@ -274,10 +274,18 @@ func handleColdStart(ctx context.Context, components *initializer.Components) er
 
 	slog.Info("Found events to re-process", "count", len(healthEvents))
 
-	// Convert to Event format for compatibility with existing code
+	// Convert HealthEventWithStatus to Event format
+	// Note: RawEvent is only populated during change stream events, not query results
+	// So we reconstruct the Event map from struct fields
 	events := make([]datastore.Event, len(healthEvents))
 	for i, he := range healthEvents {
-		events[i] = he.RawEvent
+		// Reconstruct Event map from struct fields
+		event := datastore.Event{
+			"createdAt":         he.CreatedAt,
+			"healthevent":       he.HealthEvent,
+			"healtheventstatus": he.HealthEventStatus,
+		}
+		events[i] = event
 	}
 
 	// Re-process each event

store-client/pkg/datastore/providers/postgresql/datastore.go

@@ -195,7 +195,8 @@ func (p *PostgreSQLDataStore) NewChangeStreamWatcher(
 	watcher := NewPostgreSQLChangeStreamWatcher(p.db, clientName, tableName)
 	watcher.pipelineFilter = pipelineFilter
 
-	return watcher, nil
+	// Wrap the watcher to provide Unwrap() support for backward compatibility
+	return NewPostgreSQLChangeStreamWatcherWithUnwrap(watcher), nil
 }
 
 // --- Backward Compatibility Methods for MongoDB-style Type Assertions ---