add ibm_cd_tekton_pipeline

providers/ibm_cd_tekton_pipeline.go

@@ -0,0 +1,98 @@
+package ibm
+
+import (
+ "context"
+ "fmt"
+ "log"
+ "os"
+
+ "github.com/GoogleCloudPlatform/terraformer/terraformutils"
+ "github.com/IBM/continuous-delivery-go-sdk/cdtoolchainv2"
+ "github.com/IBM/continuous-delivery-go-sdk/cdtektonpipelinev2"
+ "github.com/IBM/go-sdk-core/v5/core"
+)
+
+type CdTektonPipelineGenerator struct {
+ IBMService
+}
+
+func (g *CdTektonPipelineGenerator) createTektonPipelineResource(toolchainToolId, pipelineId, pipelineName string) terraformutils.Resource {
+ // Assuming the ID format "<toolchain_id>/<pipeline_id>" to ensure uniqueness
+ name := fmt.Sprintf("%s/%s", pipelineName, pipelineId)
+ return terraformutils.NewSimpleResource(
+ pipelineId,
+ name,
+ "ibm_cd_tekton_pipeline",
+ "ibm",
+ []string{},
+ )
+}
+
+func (g *CdTektonPipelineGenerator) InitResources() error {
+ ctx := context.Background()
+ apiKey := os.Getenv("IC_API_KEY")
+ if apiKey == "" {
+ log.Fatal("No API key set")
+ }
+ region := g.Args["region"].(string)
+
+ auth := &core.IamAuthenticator{ApiKey: apiKey}
+ service, err := cdtoolchainv2.NewCdToolchainV2(&cdtoolchainv2.CdToolchainV2Options{
+ Authenticator: auth,
+ })
+ tektonService, err := cdtektonpipelinev2.NewCdTektonPipelineV2(&cdtektonpipelinev2.CdTektonPipelineV2Options{
+ Authenticator: auth,
+ })
+ if err != nil {
+ return err
+ }
+
+ // First, list all toolchains
+ listToolchainsOptions := &cdtoolchainv2.ListToolchainsOptions{}
+ if rg := g.Args["resource_group"].(string); rg != "" {
+ rg, err = GetResourceGroupID(apiKey, rg, region)
+ if err != nil {
+ return fmt.Errorf("Error Fetching Resource Group Id %s", err)
+ }
+ listToolchainsOptions.ResourceGroupID = &rg
+ } 
+
+ toolchainCollection, _, err := service.ListToolchainsWithContext(ctx, listToolchainsOptions)
+ if err != nil {
+ return err
+ }
+
+ // Then, for each toolchain, list and process its pipelines
+ for _, toolchain := range toolchainCollection.Toolchains {
+ toolchainId := *toolchain.ID
+ listPipelinesOptions := &cdtoolchainv2.ListToolsOptions{
+ ToolchainID: &toolchainId,
+ }
+ toolchaintoolCollection, _, err := service.ListToolsWithContext(ctx, listPipelinesOptions)
+ if err != nil {
+ log.Printf("Error listing pipelines for toolchain %s: %v", toolchainId, err)
+ continue // Skip to the next toolchain if we can't list pipelines for this one
+ }
+ for _, toolchaintool := range toolchaintoolCollection.Tools {
+ fmt.Printf("Toolchaintool: %s ToolType %s\n", *toolchaintool.ID, *toolchaintool.ToolTypeID)
+ if *toolchaintool.ToolTypeID == "pipeline" {
+
+ pipelineId := *toolchaintool.ID
+ // Get Tekton pipeline details
+ getPipelineOptions := &cdtektonpipelinev2.GetTektonPipelineOptions{
+ ID: &pipelineId,
+ }
+ pipeline, _, err := tektonService.GetTektonPipelineWithContext(ctx, getPipelineOptions)
+ if err != nil {
+ log.Fatalf("Failed to get Tekton pipeline details for pipeline ID %s: %v", pipelineId, err)
+ }
+ if pipeline.ID != nil && pipeline.Name != nil {
+ g.Resources = append(g.Resources, g.createTektonPipelineResource(toolchainId, pipelineId, *pipeline.Name))
+ }
+ }
+ }
+ }
+
+ return nil
+}
+

providers/ibm_provider.go

@@ -0,0 +1,192 @@
+// Copyright 2019 The Terraformer Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package ibm
+
+import (
+ "errors"
+ "os"
+
+ "github.com/GoogleCloudPlatform/terraformer/terraformutils"
+)
+
+const DefaultRegion = "us-south"
+const NoRegion = ""
+
+type IBMProvider struct { //nolint
+ terraformutils.Provider
+ ResourceGroup string
+ Region string
+ VPC string
+}
+
+func (p *IBMProvider) Init(args []string) error {
+ p.ResourceGroup = args[0]
+ p.Region = args[1]
+ p.VPC = args[2]
+
+ var err error
+ if p.Region != NoRegion {
+ err = os.Setenv("IC_REGION", p.Region)
+ } else {
+ p.Region = DefaultRegion
+ err = os.Setenv("IC_REGION", DefaultRegion)
+ }
+ if err != nil {
+ return err
+ }
+ return nil
+}
+
+func (p *IBMProvider) GetName() string {
+ return "ibm"
+}
+
+func (p *IBMProvider) GetProviderData(arg ...string) map[string]interface{} {
+ return map[string]interface{}{
+ "provider": map[string]interface{}{
+ "ibm": map[string]interface{}{
+ "region": p.Region,
+ },
+ },
+ }
+}
+
+func (IBMProvider) GetResourceConnections() map[string]map[string][]string {
+ return map[string]map[string][]string{
+ "ibm_is_vpc_route": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ },
+ "ibm_is_vpc_routing_table": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ },
+ "ibm_is_subnet": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ "ibm_is_public_gateway": []string{"public_gateway", "id"},
+ },
+ "ibm_is_vpc_address_prefix": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ },
+ "ibm_is_lb": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ "ibm_is_subnet": []string{"subnets", "id"},
+ "ibm_is_security_group": []string{"security_groups", "id"},
+ },
+ "ibm_is_instance": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ "ibm_is_image": []string{"image", "id"},
+ "ibm_is_subnet": []string{"primary_network_interface.subnet", "id"},
+ "ibm_is_security_group": []string{"primary_network_interface.security_groups", "id"},
+ "ibm_is_volume": []string{"volumes", "id"},
+ },
+ "ibm_is_security_group": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ },
+ "ibm_is_network_acl": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ "ibm_is_subnet": []string{"subnets", "id"},
+ },
+ "ibm_is_public_gateway": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ "ibm_is_floating_ip": []string{"floating_ip.id", "id"},
+ },
+ "ibm_container_vpc_cluster": {
+ "ibm_is_vpc": []string{"vpc_id", "id"},
+ "ibm_is_subnet": []string{"zones.subnet_id", "id"},
+ },
+ "ibm_vpe_gateway": {
+ "ibm_is_vpc": []string{"vpc", "id"},
+ "ibm_is_security_group": []string{"security_groups", "id"},
+ "ibm_is_subnet": []string{"ips.subnet", "id"},
+ },
+ "ibm_is_vpn_gateway": {
+ "ibm_is_subnet": []string{"subnet", "id"},
+ },
+ }
+}
+
+func (p *IBMProvider) GetSupportedService() map[string]terraformutils.ServiceGenerator {
+ return map[string]terraformutils.ServiceGenerator{
+ "ibm_kp": &KPGenerator{},
+ "ibm_container_vpc_cluster": &VPCClusterGenerator{},
+ "ibm_container_cluster": &ContainerClusterGenerator{},
+ "ibm_cos": &COSGenerator{},
+ "ibm_database_elasticsearch": &DatabaseElasticSearchGenerator{},
+ "ibm_database_etcd": &DatabaseETCDGenerator{},
+ "ibm_database_mongo": &DatabaseMongoGenerator{},
+ "ibm_database_postgresql": &DatabasePostgresqlGenerator{},
+ "ibm_database_rabbitmq": &DatabaseRabbitMQGenerator{},
+ "ibm_database_redis": &DatabaseRedisGenerator{},
+ "ibm_iam": &IAMGenerator{},
+ "ibm_is_instance_group": &InstanceGroupGenerator{},
+ "ibm_is_vpc": &VPCGenerator{},
+ "ibm_is_vpc_address_prefix": &VPCAddressPrefixGenerator{},
+ "ibm_is_vpc_route": &VPCRouteGenerator{},
+ "ibm_is_vpc_routing_table": &VPCRoutingTableGenerator{},
+ "ibm_is_subnet": &SubnetGenerator{},
+ "ibm_is_instance": &InstanceGenerator{},
+ "ibm_is_security_group": &SecurityGroupGenerator{},
+ "ibm_cis": &CISGenerator{},
+ "ibm_is_network_acl": &NetworkACLGenerator{},
+ "ibm_is_public_gateway": &PublicGatewayGenerator{},
+ "ibm_is_volume": &VolumeGenerator{},
+ "ibm_is_vpn_gateway": &VPNGatewayGenerator{},
+ "ibm_is_lb": &LBGenerator{},
+ "ibm_is_ssh_key": &SSHKeyGenerator{},
+ "ibm_is_floating_ip": &FloatingIPGenerator{},
+ "ibm_is_image": &ImageGenerator{},
+ "ibm_is_ipsec_policy": &IpsecGenerator{},
+ "ibm_is_ike_policy": &IkeGenerator{},
+ "ibm_is_flow_log": &FlowLogGenerator{},
+ "ibm_is_instance_template": &InstanceTemplateGenerator{},
+ "ibm_function": &CloudFunctionGenerator{},
+ "ibm_cd_toolchain": &CdToolchainGenerator{},
+ "ibm_cd_toolchain_tool_pipeline": &CdToolchainToolPipelineGenerator{},
+ "ibm_cd_tekton_pipeline": &CdTektonPipelineGenerator{},
+ "ibm_private_dns": &privateDNSTemplateGenerator{},
+ "ibm_certificate_manager": &CMGenerator{},
+ "ibm_direct_link": &DLGenerator{},
+ "ibm_transit_gateway": &TGGenerator{},
+ "ibm_vpe_gateway": &VPEGenerator{},
+ "ibm_satellite_control_plane": &SatelliteControlPlaneGenerator{},
+ "ibm_satellite_data_plane": &SatelliteDataPlaneGenerator{},
+ "ibm_secrets_manager": &SecretsManagerGenerator{},
+ "ibm_continuous_delivery": &ContinuousDeliveryGenerator{},
+ "ibm_cloud_sysdig_monitor": &MonitoringGenerator{},
+ "ibm_cloud_logdna": &LogAnalysisGenerator{},
+ "ibm_cloud_atracker": &ActivityTrackerGenerator{},
+ "ibm_cloud_watson_studio": &WatsonStudioGenerator{},
+ "ibm_cloud_watson_machine_learning": &WatsonMachineLearningGenerator{},
+ "ibm_cloudant": &CloudantGenerator{},
+ "ibm_code_engine": &CodeEngineGenerator{},
+ }
+}
+
+func (p *IBMProvider) InitService(serviceName string, verbose bool) error {
+ var isSupported bool
+ if _, isSupported = p.GetSupportedService()[serviceName]; !isSupported {
+ return errors.New("IBM: " + serviceName + " not supported service")
+ }
+ p.Service = p.GetSupportedService()[serviceName]
+ p.Service.SetName(serviceName)
+ p.Service.SetVerbose(verbose)
+ p.Service.SetProviderName(p.GetName())
+
+ p.Service.SetArgs(map[string]interface{}{
+ "resource_group": p.ResourceGroup,
+ "region": p.Region,
+ "vpc": p.VPC,
+ })
+ return nil
+}