definitions: Auto inject http_client_options for all services (#321)

Signed-off-by: Xuanwo <github@xuanwo.io>

definitions/services/azblob.hcl

@@ -7,7 +7,6 @@ service {
   }
   op "new" {
     required = ["credential", "endpoint"]
-    optional = ["http_client_options"]
   }
 }
 

definitions/services/cos.hcl

@@ -16,7 +16,6 @@ service {
   }
   op "new" {
     required = ["credential"]
-    optional = ["http_client_options"]
   }
 }
 

definitions/services/dropbox.hcl

@@ -7,7 +7,7 @@ storage {
   }
   op "new" {
     required = ["credential"]
-    optional = ["http_client_options", "work_dir"]
+    optional = ["work_dir"]
   }
   op "read" {
     optional = ["size"]

definitions/services/gcs.hcl

@@ -7,7 +7,6 @@ service {
   }
   op "new" {
     required = ["credential", "project"]
-    optional = ["http_client_options"]
   }
 }
 

definitions/services/kodo.hcl

@@ -10,7 +10,6 @@ service {
   }
   op "new" {
     required = ["credential"]
-    optional = ["http_client_options"]
   }
 }
 

definitions/services/oss.hcl

@@ -7,7 +7,6 @@ service {
   }
   op "new" {
     required = ["credential", "endpoint"]
-    optional = ["http_client_options"]
   }
 }
 

definitions/services/qingstor.hcl

@@ -17,7 +17,7 @@ service {
   }
   op "new" {
     required = ["credential"]
-    optional = ["endpoint", "http_client_options"]
+    optional = ["endpoint"]
   }
 }
 

definitions/services/s3.hcl

@@ -16,7 +16,7 @@ service {
   }
   op "new" {
     required = ["credential"]
-    optional = ["endpoint", "http_client_options"]
+    optional = ["endpoint"]
   }
 }
 

definitions/services/uss.hcl

@@ -10,6 +10,6 @@ storage {
   }
   op "new" {
     required = ["credential", "name"]
-    optional = ["http_client_options", "work_dir"]
+    optional = ["work_dir"]
   }
 }

internal/cmd/definitions/parse.go

@@ -93,6 +93,30 @@ func injectContext(ops []*Op) {
 	}
 }
 
+func injectHTTPClientOptions(srv *Service) {
+	// We don't need to inject http client into fs
+	if srv.Name == "fs" {
+		return
+	}
+
+	fn := func(ops []*Op) {
+		for _, op := range ops {
+			if op.Name != "new" {
+				continue
+			}
+			op.Generated = append(op.Generated, "http_client_options")
+			break
+		}
+	}
+
+	// If service exist, inject into service level; Or inject into storage level.
+	if len(srv.Service) > 0 {
+		fn(srv.Service)
+	} else {
+		fn(srv.Storage)
+	}
+}
+
 func parseHCL(src []byte, filename string, in interface{}) (err error) {
 	var diags hcl.Diagnostics
 	defer func() {

internal/cmd/definitions/type.go

@@ -116,6 +116,7 @@ func (srv *Service) Handle() {
 	injectReadCallbackFunc(srv.Storage)
 	injectContext(srv.Service)
 	injectContext(srv.Storage)
+	injectHTTPClientOptions(srv)
 	return
 }