feat(crdr): enable disaster recovery integration

This reverts commit fa2ce0d.

CHANGELOG.md

@@ -9,6 +9,9 @@ nav_order: 1
 <!-- Always keep the following header in place: -->
 <!--## [MAJOR.MINOR.PATCH] - YYYY-MM-DD -->
 
+## [MAJOR.MINOR.PATCH] - YYYY-MM-DD
+
+- Add `disaster_recovery` service integration type support
 
 ## [4.33.0] - 2025-01-16
 

docs/resources/pg.md

@@ -356,7 +356,7 @@ Optional:
 
 Required:
 
-- `integration_type` (String) Type of the service integration. The possible value is `read_replica`.
+- `integration_type` (String) Type of the service integration. The possible values are `read_replica` and `disaster_recovery`.
 - `source_service_name` (String) Name of the source service
 
 

internal/schemautil/service.go

@@ -100,6 +100,10 @@ func getBootstrapIntegrationTypes(kind string) []service.IntegrationType {
 		list = append(list, service.IntegrationTypeReadReplica)
 	}
 
+	if kind == ServiceTypePG {
+		list = append(list, service.IntegrationTypeDisasterRecovery)
+	}
+
 	return list
 }
 

internal/schemautil/wait.go

@@ -260,7 +260,9 @@ func backupsReady(s *service.ServiceGetOut) bool {
 	// See https://github.com/aiven/terraform-provider-aiven/pull/172
 	for _, i := range s.ServiceIntegrations {
 		switch i.IntegrationType {
-		case service.IntegrationTypeReadReplica:
+		case service.IntegrationTypeReadReplica, service.IntegrationTypeDisasterRecovery:
+			// fixme: disaster recovery will have a backup eventually,
+			//  remove this when BE is ready
 			if lo.FromPtr(i.DestService) == s.ServiceName {
 				return true
 			}

internal/sdkprovider/service/pg/pg_test.go

@@ -1090,7 +1090,6 @@ func testAccCheckAivenServicePGAttributes(n string) resource.TestCheckFunc {
 }
 
 func TestAccAivenServicePG_disaster_recovery(t *testing.T) {
-	t.Skip("the feature is disabled")
 	primaryName := "aiven_pg.primary"
 	secondaryName := "aiven_pg.secondary"
 	projectName := os.Getenv("AIVEN_PROJECT_NAME")