Pass clickhouse_clickpipe.destination.roles to API call (#319)

Author: eudaimos

examples/clickpipe/kafka_msk_iam_role/main.tf

@@ -61,6 +61,8 @@ resource "clickhouse_clickpipe" "kafka_msk" {
         type = "UInt64"
       }
     ]
+
+    roles = ["custom_role_1", "custom_role_2"]
   }
 
   field_mappings = [

pkg/internal/api/clickpipe_models.go

@@ -115,6 +115,7 @@ type ClickPipeDestination struct {
 	ManagedTable    bool                                 `json:"managedTable"`
 	TableDefinition *ClickPipeDestinationTableDefinition `json:"tableDefinition,omitempty"`
 	Columns         []ClickPipeDestinationColumn         `json:"columns"`
+	Roles           []string                             `json:"roles,omitempty"`
 }
 
 type ClickPipeDestinationUpdate struct {

pkg/resource/clickpipe.go

@@ -675,11 +675,19 @@ func (c *ClickPipeResource) Create(ctx context.Context, request resource.CreateR
 	destinationColumnsModels := make([]models.ClickPipeDestinationColumnModel, len(destinationModel.Columns.Elements()))
 	response.Diagnostics.Append(destinationModel.Columns.ElementsAs(ctx, &destinationColumnsModels, false)...)
 
+	// Extract roles from the destination model
+	var rolesSlice []string
+	if !destinationModel.Roles.IsNull() && len(destinationModel.Roles.Elements()) > 0 {
+		rolesSlice = make([]string, len(destinationModel.Roles.Elements()))
+		response.Diagnostics.Append(destinationModel.Roles.ElementsAs(ctx, &rolesSlice, false)...)
+	}
+
 	clickPipe.Destination = api.ClickPipeDestination{
 		Database:     destinationModel.Database.ValueString(),
 		Table:        destinationModel.Table.ValueString(),
 		ManagedTable: destinationModel.ManagedTable.ValueBool(),
 		Columns:      make([]api.ClickPipeDestinationColumn, len(destinationColumnsModels)),
+		Roles:        rolesSlice,
 	}
 
 	if destinationModel.ManagedTable.ValueBool() {