support gcs

Author: pasha-codefresh

codefresh/resource_context.go

@@ -9,10 +9,11 @@ import (
 )
 
 const (
-	contextConfig     = "config"
-	contextSecret     = "secret"
-	contextYaml       = "yaml"
-	contextSecretYaml = "secret-yaml"
+	contextConfig        = "config"
+	contextSecret        = "secret"
+	contextYaml          = "yaml"
+	contextSecretYaml    = "secret-yaml"
+	contextGoogleStorage = "storage.gc"
 )
 
 var supportedContextType = []string{
@@ -135,6 +136,43 @@ func resourceContext() *schema.Resource {
 								},
 							},
 						},
+						normalizeFieldName(contextGoogleStorage): {
+							Type:          schema.TypeList,
+							Optional:      true,
+							ForceNew:      true,
+							MaxItems:      1,
+							ConflictsWith: getConflictingContexts(contextGoogleStorage),
+							Elem: &schema.Resource{
+								Schema: map[string]*schema.Schema{
+									"data": {
+										Type:     schema.TypeList,
+										Required: true,
+										MaxItems: 1,
+										Elem: &schema.Resource{
+											Schema: map[string]*schema.Schema{
+												"auth": {
+													Type:     schema.TypeList,
+													Required: true,
+													MaxItems: 1,
+													Elem: &schema.Resource{
+														Schema: map[string]*schema.Schema{
+															"type": {
+																Type:     schema.TypeString,
+																Required: true,
+															},
+															"json_config": {
+																Type:     schema.TypeMap,
+																Required: true,
+															},
+														},
+													},
+												},
+											},
+										},
+									},
+								},
+							},
+						},
 					},
 				},
 			},
@@ -239,6 +277,8 @@ func flattenContextSpec(spec cfClient.ContextSpec) []interface{} {
 		m[normalizeFieldName(currentContextType)] = flattenContextConfig(spec)
 	case contextYaml, contextSecretYaml:
 		m[normalizeFieldName(currentContextType)] = flattenContextYaml(spec)
+	case contextGoogleStorage:
+		m[normalizeFieldName(currentContextType)] = flattenStorageContextConfig(spec)
 	default:
 		log.Printf("[DEBUG] Invalid context type = %v", currentContextType)
 		return nil
@@ -256,6 +296,40 @@ func flattenContextConfig(spec cfClient.ContextSpec) []interface{} {
 	return res
 }
 
+func flattenStorageContextConfig(spec cfClient.ContextSpec) []interface{} {
+	//google.[0].data[0].auth[0].[type, json]
+
+	var res = make([]interface{}, 0)
+	m := make(map[string]interface{})
+
+	dataList := make([]interface{}, 0)
+	data := make(map[string]interface{})
+
+	auth := make(map[string]interface{})
+	auth["json_config"] = spec.Data["auth"].(map[string]interface{})["jsonConfig"]
+	auth["type"] = spec.Data["type"]
+
+	authList := make([]interface{}, 0)
+	authList = append(authList, auth)
+
+	data["auth"] = authList
+
+	dataList = append(dataList, data)
+
+	m["data"] = dataList
+	res = append(res, m)
+	return res
+
+	//contextData := context[0].(map[string]interface{})
+	//contextAuth := contextData["auth"].([]interface{})[0].(map[string]interface{})
+	//data := make(map[string]interface{})
+	//auth := make(map[string]interface{})
+	//auth["type"] = contextAuth["type"]
+	//auth["jsonConfig"] = contextAuth["json_config"]
+	//data["auth"] = auth
+	//return data
+}
+
 func flattenContextYaml(spec cfClient.ContextSpec) []interface{} {
 	var res = make([]interface{}, 0)
 	m := make(map[string]interface{})
@@ -268,11 +342,25 @@ func flattenContextYaml(spec cfClient.ContextSpec) []interface{} {
 	return res
 }
 
+func convertStorageContext(context []interface{}) map[string]interface{} {
+	contextData := context[0].(map[string]interface{})
+	contextAuth := contextData["auth"].([]interface{})[0].(map[string]interface{})
+	data := make(map[string]interface{})
+	auth := make(map[string]interface{})
+	auth["type"] = contextAuth["type"]
+	auth["jsonConfig"] = contextAuth["json_config"]
+	data["auth"] = auth
+	return data
+}
+
 func mapResourceToContext(d *schema.ResourceData) *cfClient.Context {
 
 	var normalizedContextType string
 	var normalizedContextData map[string]interface{}
 
+	spec := d.Get("spec")
+	log.Println(spec)
+
 	if data, ok := d.GetOk("spec.0." + normalizeFieldName(contextConfig) + ".0.data"); ok {
 		normalizedContextType = contextConfig
 		normalizedContextData = data.(map[string]interface{})
@@ -285,6 +373,9 @@ func mapResourceToContext(d *schema.ResourceData) *cfClient.Context {
 	} else if data, ok := d.GetOk("spec.0." + normalizeFieldName(contextSecretYaml) + ".0.data"); ok {
 		normalizedContextType = contextSecretYaml
 		yaml.Unmarshal([]byte(data.(string)), &normalizedContextData)
+	} else if data, ok := d.GetOk("spec.0." + normalizeFieldName(contextGoogleStorage) + ".0.data"); ok {
+		normalizedContextType = contextGoogleStorage
+		normalizedContextData = convertStorageContext(data.([]interface{}))
 	}
 
 	context := &cfClient.Context{

examples/storate_integration/main.tf

@@ -0,0 +1,20 @@
+//data "codefresh_context" "storage_integration" {
+//  name = "pasha-test-t"
+//}
+
+resource "codefresh_context" "storage_integration" {
+  for_each = toset(["create"])
+  name = "pasha-test-t2"
+  spec {
+    storagegc {
+      data {
+        auth {
+          type = "basic"
+          json_config = tomap({
+            "fd": "fd"
+          })
+        }
+      }
+    }
+  }
+}

examples/storate_integration/provider.tf

@@ -0,0 +1,13 @@
+terraform {
+  required_providers {
+    codefresh = {
+      source  = "codefresh.io/app/codefresh"
+      version = "0.1.0"
+    }
+  }
+}
+
+provider "codefresh" {
+  api_url =  var.api_url 
+  token = var.token # If token isn't set the provider expects the $CODEFRESH_API_KEY env variable
+}

examples/storate_integration/vars.tf

@@ -0,0 +1,8 @@
+variable api_url {
+  type = string
+}
+
+variable token {
+  type = string
+  default = ""
+}