Update from https://github.com/cloudimpl/next-coder/commit/8e052fe04386ee516fda85d6c932d82fb357c4d6

Author: CloudimplBot

polycode/cli.go

@@ -20,29 +20,9 @@ func runCliCommand(args []string) error {
 }
 
 func getAppInfo(filePath string) error {
-	var services []ServiceDescription
-	for srvName, srv := range serviceMap {
-		serviceData := ServiceDescription{
-			Name:  srvName,
-			Tasks: make([]MethodDescription, 0),
-		}
-
-		res, err := srv.ExecuteService(nil, "@definition", nil)
-		if err != nil {
-			return err
-		}
-
-		taskList := res.([]string)
-		for _, taskName := range taskList {
-			description, err := GetMethodDescription(srv, taskName)
-			if err != nil {
-				return err
-			}
-
-			serviceData.Tasks = append(serviceData.Tasks, description)
-		}
-
-		services = append(services, serviceData)
+	services, err := ExtractServiceDescription()
+	if err != nil {
+		return err
 	}
 
 	req := StartAppRequest{

polycode/model.go

@@ -4,10 +4,6 @@ import (
 	"time"
 )
 
-type DescribeMethodRequest struct {
-	Name string `json:"name"`
-}
-
 type BackoffStrategy struct {
 	InitialInterval time.Duration `json:"initialInterval"`
 	MaxInterval     time.Duration `json:"maxInterval"`

polycode/runtime.go

@@ -22,9 +22,9 @@ type Service interface {
 	GetDescription(method string) (string, error)
 	GetInputType(method string) (any, error)
 	GetOutputType(method string) (any, error)
+	IsWorkflow(method string) bool
 	ExecuteService(ctx ServiceContext, method string, input any) (any, error)
 	ExecuteWorkflow(ctx WorkflowContext, method string, input any) (any, error)
-	IsWorkflow(method string) bool
 }
 
 func RegisterService(service Service) {
@@ -103,12 +103,9 @@ func loadAppConfig() AppConfig {
 }
 
 func sendStartApp() {
-	var services []ServiceDescription
-	for name := range serviceMap {
-		services = append(services, ServiceDescription{
-			Name: name,
-			// ToDo: Add task info
-		})
+	services, err := ExtractServiceDescription()
+	if err != nil {
+		log.Fatalf("client: %s\n", err.Error())
 	}
 
 	req := StartAppRequest{
@@ -118,7 +115,6 @@ func sendStartApp() {
 		Routes:   loadRoutes(),
 	}
 
-	var err error
 	for {
 		err = serviceClient.StartApp(req)
 		if err == nil {
@@ -171,27 +167,6 @@ func runService(ctx context.Context, taskLogger Logger, event ServiceStartEvent)
 		return ErrorToServiceComplete(err2)
 	}
 
-	if event.Method == "@DescribeMethod" {
-		inputObj := DescribeMethodRequest{}
-		err = ConvertType(event.Input, &inputObj)
-		if err != nil {
-			err2 := ErrServiceExecError.Wrap(err)
-			taskLogger.Error().Msg(err2.Error())
-			return ErrorToServiceComplete(err2)
-		}
-
-		fmt.Printf("service %s describing method %s", event.Service, inputObj.Name)
-		description, err := GetMethodDescription(service, inputObj.Name)
-		if err != nil {
-			err2 := ErrServiceExecError.Wrap(err)
-			taskLogger.Error().Msg(err2.Error())
-			return ErrorToServiceComplete(err2)
-		}
-
-		evt = ValueToServiceComplete(description)
-		return
-	}
-
 	meta := ServiceMeta{
 		IsWorkflow: service.IsWorkflow(event.Method),
 	}

polycode/util.go

@@ -142,3 +142,32 @@ func GetMethodDescription(service Service, method string) (MethodDescription, er
 		Input:       inputSchema,
 	}, nil
 }
+
+func ExtractServiceDescription() ([]ServiceDescription, error) {
+	var services []ServiceDescription
+	for srvName, srv := range serviceMap {
+		serviceData := ServiceDescription{
+			Name:  srvName,
+			Tasks: make([]MethodDescription, 0),
+		}
+
+		res, err := srv.ExecuteService(nil, "@definition", nil)
+		if err != nil {
+			return nil, err
+		}
+
+		taskList := res.([]string)
+		for _, taskName := range taskList {
+			description, err := GetMethodDescription(srv, taskName)
+			if err != nil {
+				return nil, err
+			}
+
+			serviceData.Tasks = append(serviceData.Tasks, description)
+		}
+
+		services = append(services, serviceData)
+	}
+
+	return services, nil
+}