feat(devops): process interface struct

Author: liujian-bytedance

devops/internal/model/container.go

@@ -594,14 +594,14 @@ func ConvertCodeToValue(code string, schema *devmodel.JsonSchema, inputType refl
 				if !ok {
 					continue
 				}
-				result = parseCompositeLit(cl, schema)
+				result = parseCompositeLit(cl, schema, "")
 			case *ast.CompositeLit:
 				if schema.Type == devmodel.JsonTypeOfArray {
 					result = parseArrayLit(v, schema)
 				} else if schema.Type == devmodel.JsonTypeOfObject && schema.AdditionalProperties != nil {
 					result = parseMapLit(v, schema)
 				} else {
-					result = parseCompositeLit(v, schema)
+					result = parseCompositeLit(v, schema, "schema.Message")
 				}
 			case *ast.BasicLit:
 				result = parseBasicLit(v)
@@ -626,6 +626,12 @@ func ConvertCodeToValue(code string, schema *devmodel.JsonSchema, inputType refl
 	})
 
 	val := reflect.New(inputType)
+	if schema.Type == "interface" {
+		implType, ok := GetRegisteredType("schema.Message")
+		if ok {
+			val = reflect.New(implType.Type)
+		}
+	}
 
 	if err := convertToValue(result, val.Elem()); err != nil {
 		return reflect.Value{}, err
@@ -646,9 +652,9 @@ func parseCallExpr(call *ast.CallExpr) interface{} {
 	return nil
 }
 
-func parseCompositeLit(cl *ast.CompositeLit, schema *devmodel.JsonSchema) map[string]interface{} {
+func parseCompositeLit(cl *ast.CompositeLit, schema *devmodel.JsonSchema, identifier string) map[string]interface{} {
 	data := make(map[string]interface{})
-	fieldTagMap := buildFieldTagMap(schema)
+	fieldTagMap := buildFieldTagMap(schema, identifier)
 
 	for _, elt := range cl.Elts {
 		kv, ok := elt.(*ast.KeyValueExpr)
@@ -698,7 +704,7 @@ func parseExpr(expr ast.Expr, schema *devmodel.JsonSchema) interface{} {
 			if schema.AdditionalProperties != nil {
 				return parseMapLit(v, schema)
 			}
-			return parseCompositeLit(v, schema)
+			return parseCompositeLit(v, schema, "")
 		case devmodel.JsonTypeOfArray:
 			return parseArrayLit(v, schema)
 		default:
@@ -751,7 +757,7 @@ func parseMapLit(cl *ast.CompositeLit, schema *devmodel.JsonSchema) map[string]i
 			} else if valueSchema.Type == devmodel.JsonTypeOfArray {
 				value = parseArrayLit(v, valueSchema)
 			} else {
-				value = parseCompositeLit(v, valueSchema)
+				value = parseCompositeLit(v, valueSchema, "")
 			}
 		default:
 			value = parseExpr(kv.Value, valueSchema)
@@ -761,7 +767,15 @@ func parseMapLit(cl *ast.CompositeLit, schema *devmodel.JsonSchema) map[string]i
 	return m
 }
 
-func buildFieldTagMap(schema *devmodel.JsonSchema) map[string]*FieldInfo {
+func buildFieldTagMap(schema *devmodel.JsonSchema, identifier string) map[string]*FieldInfo {
+	if schema.Type == "interface" {
+		implType, ok := GetRegisteredType(identifier)
+		if !ok {
+			return nil
+		}
+		return buildFieldTagMap(implType.Schema, identifier)
+	}
+
 	fieldTagMap := make(map[string]*FieldInfo)
 	for jsonKey, propSchema := range schema.Properties {
 		if propSchema.Description == "" {

devops/internal/model/types.go

@@ -89,6 +89,15 @@ var registeredTypes = []RegisteredType{
 	//{Identifier: "*bool", Type: generic.TypeOf[*bool]()},
 }
 
+func GetRegisteredType(identifier string) (*RegisteredType, bool) {
+	for _, rt := range registeredTypes {
+		if rt.Identifier == identifier {
+			return &rt, true
+		}
+	}
+	return nil, false
+}
+
 func RegisterType(rt reflect.Type) {
 	if _, ok := registeredTypeMap[rt.String()]; ok {
 		return