Skip to content

Commit fedc515

Browse files
authored
Merge pull request #694 from ovh/dev/aamstutz/fix-dbaas-logs-cluster
fix: correctly set cluster_id field in datasource ovh_dbaas_logs_cluster
2 parents b1f4b47 + 5a5f025 commit fedc515

File tree

2 files changed

+49
-11
lines changed

2 files changed

+49
-11
lines changed

ovh/data_dbaas_logs_cluster.go

+4-2
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ func dataSourceDbaasLogsCluster() *schema.Resource {
2323
"cluster_id": {
2424
Type: schema.TypeString,
2525
Optional: true,
26+
Computed: true,
2627
},
2728
// Computed
2829
"urn": {
@@ -137,8 +138,9 @@ func dataSourceDbaasLogsClusterRead(d *schema.ResourceData, meta interface{}) er
137138
var err error
138139
clusterId, err = dbaasGetClusterID(config, serviceName)
139140
if err != nil {
140-
return fmt.Errorf("Error retrieving clusterId for %s:\n\t %q", serviceName, err)
141+
return fmt.Errorf("error retrieving cluster_id for %s:\n\t %q", serviceName, err)
141142
}
143+
d.Set("cluster_id", clusterId)
142144
}
143145

144146
log.Printf("[DEBUG] Will read dbaas logs cluster %s/%s", serviceName, clusterId)
@@ -155,7 +157,7 @@ func dataSourceDbaasLogsClusterRead(d *schema.ResourceData, meta interface{}) er
155157

156158
res := map[string]interface{}{}
157159
if err := config.OVHClient.Get(endpoint, &res); err != nil {
158-
return fmt.Errorf("Error calling GET %s:\n\t %q", endpoint, err)
160+
return fmt.Errorf("error calling GET %s:\n\t %q", endpoint, err)
159161
}
160162

161163
d.Set("archive_allowed_networks", res["archiveAllowedNetworks"])

ovh/data_dbaas_logs_cluster_test.go

+45-9
Original file line numberDiff line numberDiff line change
@@ -8,19 +8,15 @@ import (
88
"github.com/hashicorp/terraform-plugin-testing/helper/resource"
99
)
1010

11-
const testAccDataSourceDbaasLogsCluster = `
12-
data "ovh_dbaas_logs_cluster" "ldp" {
13-
service_name = "%s"
14-
cluster_id = "%s"
15-
}
16-
`
17-
1811
func TestAccDataSourceDbaasLogsCluster(t *testing.T) {
1912
serviceName := os.Getenv("OVH_DBAAS_LOGS_SERVICE_TEST")
2013
clusterId := os.Getenv("OVH_DBAAS_LOGS_CLUSTER_ID")
2114

22-
config := fmt.Sprintf(
23-
testAccDataSourceDbaasLogsCluster,
15+
config := fmt.Sprintf(`
16+
data "ovh_dbaas_logs_cluster" "ldp" {
17+
service_name = "%s"
18+
cluster_id = "%s"
19+
}`,
2420
serviceName,
2521
clusterId,
2622
)
@@ -38,6 +34,46 @@ func TestAccDataSourceDbaasLogsCluster(t *testing.T) {
3834
"service_name",
3935
serviceName,
4036
),
37+
resource.TestCheckResourceAttr(
38+
"data.ovh_dbaas_logs_cluster.ldp",
39+
"cluster_id",
40+
clusterId,
41+
),
42+
),
43+
},
44+
},
45+
})
46+
}
47+
48+
func TestAccDataSourceDbaasLogsClusterDefault(t *testing.T) {
49+
serviceName := os.Getenv("OVH_DBAAS_LOGS_SERVICE_TEST")
50+
clusterId := os.Getenv("OVH_DBAAS_LOGS_CLUSTER_ID")
51+
52+
config := fmt.Sprintf(`
53+
data "ovh_dbaas_logs_cluster" "ldp" {
54+
service_name = "%s"
55+
}`,
56+
serviceName,
57+
)
58+
59+
resource.Test(t, resource.TestCase{
60+
PreCheck: func() { testAccPreCheckDbaasLogsCluster(t) },
61+
62+
Providers: testAccProviders,
63+
Steps: []resource.TestStep{
64+
{
65+
Config: config,
66+
Check: resource.ComposeTestCheckFunc(
67+
resource.TestCheckResourceAttr(
68+
"data.ovh_dbaas_logs_cluster.ldp",
69+
"service_name",
70+
serviceName,
71+
),
72+
resource.TestCheckResourceAttr(
73+
"data.ovh_dbaas_logs_cluster.ldp",
74+
"cluster_id",
75+
clusterId,
76+
),
4177
),
4278
},
4379
},

0 commit comments

Comments
 (0)