Update from https://github.com/CloudImpl-Inc/next-coder/commit/786f8a617a788c3087d6a619ca13da48bf4383d2

Author: CloudimplBot

client/task.go

@@ -69,6 +69,7 @@ func _RunTask(ctx RuntimeContext, runtime RuntimeSupport, event Event) (evt *Tas
 			ctx:           ctx,
 			sessionId:     event.Context.SessionId,
 			serviceClient: getServiceClient(),
+			config:        runtime.GetRuntime().AppConfig(),
 		}
 		ret, err := runtime.InvokeWorkflow(workflowCtx, event.TaskInput)
 		if err != nil {
@@ -106,13 +107,15 @@ func _RunTask(ctx RuntimeContext, runtime RuntimeSupport, event Event) (evt *Tas
 				ctx:           ctx,
 				sessionId:     event.Context.SessionId,
 				serviceClient: getServiceClient(),
+				config:        runtime.GetRuntime().AppConfig(),
 			}
 			ret, err = service.ExecuteWorkflow(workflowCtx, event.Context.EntryPoint, inputObj)
 		} else {
 			srvCtx := ServiceContext{
 				ctx:       ctx,
 				sessionId: event.Context.SessionId,
 				db:        db,
+				config:    runtime.GetRuntime().AppConfig(),
 			}
 			ret, err = service.ExecuteService(srvCtx, event.Context.EntryPoint, inputObj)
 		}

go.mod

@@ -4,6 +4,7 @@ require (
 	github.com/apex/gateway v1.1.2
 	github.com/aws/aws-lambda-go v1.47.0
 	github.com/gin-gonic/gin v1.10.0
+	gopkg.in/yaml.v2 v2.2.2
 )
 
 require (

go.sum

@@ -98,6 +98,7 @@ google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFW
 google.golang.org/protobuf v1.34.1/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v2 v2.2.2 h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.0-20200605160147-a5ece683394c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

polycode/config.go

@@ -10,7 +10,7 @@ type AppConfig map[string]interface{}
 func FromAppConfig(ctx context.Context, configObj any) {
 	srvCtx, ok := ctx.(ServiceContext)
 	if ok {
-		ret := srvCtx.Config()
+		ret := srvCtx.AppConfig()
 		b, err := json.Marshal(configObj)
 		if err != nil {
 			panic(err)
@@ -23,7 +23,7 @@ func FromAppConfig(ctx context.Context, configObj any) {
 	}
 	wkfCtx, ok := ctx.(WorkflowContext)
 	if ok {
-		ret := wkfCtx.Config()
+		ret := wkfCtx.AppConfig()
 		b, err := json.Marshal(configObj)
 		if err != nil {
 			panic(err)

polycode/runtime.go

@@ -17,6 +17,7 @@ var currentRuntime Runtime = nil
 
 type Runtime interface {
 	Name() string
+	AppConfig() AppConfig
 	Start(params []any) error
 }
 

polycode/util.go

@@ -60,3 +60,20 @@ func GetTypeNameWithPkg[T any](value T) (string, string) {
 func IsPointer(data interface{}) bool {
 	return reflect.TypeOf(data).Kind() == reflect.Ptr
 }
+
+// Helper function to convert map[interface{}]interface{} to map[string]interface{}
+func ConvertMap(m interface{}) interface{} {
+	switch x := m.(type) {
+	case map[interface{}]interface{}:
+		converted := make(map[string]interface{})
+		for k, v := range x {
+			converted[k.(string)] = ConvertMap(v) // Recursively convert values
+		}
+		return converted
+	case []interface{}:
+		for i, v := range x {
+			x[i] = ConvertMap(v)
+		}
+	}
+	return m
+}

runtime/aws/runtime.go

@@ -11,7 +11,10 @@ import (
 	"github.com/aws/aws-lambda-go/events"
 	"github.com/aws/aws-lambda-go/lambda"
 	"github.com/gin-gonic/gin"
+	"gopkg.in/yaml.v2"
+	"log"
 	"net/http"
+	"os"
 	"reflect"
 )
 
@@ -20,6 +23,32 @@ type Runtime struct {
 	dbClient *db.Client
 }
 
+func (l *Runtime) AppConfig() polycode.AppConfig {
+	// Load the YAML file
+	yamlFile := "application.yml" // The path to your YAML file
+	var yamlData interface{}
+
+	data, err := os.ReadFile(yamlFile)
+	if os.IsNotExist(err) {
+		log.Println("application.yml not found. Generating empty config...")
+		yamlData = make(map[string]interface{}) // Create an empty config
+	} else if err != nil {
+		fmt.Printf("Error reading YAML file: %v\n", err)
+		os.Exit(1)
+	} else {
+		// Parse the YAML file into a map
+		err = yaml.Unmarshal(data, &yamlData)
+		if err != nil {
+			fmt.Printf("Error unmarshalling YAML: %v\n", err)
+			os.Exit(1)
+		}
+	}
+
+	// Convert map[interface{}]interface{} to map[string]interface{}
+	yamlData = polycode.ConvertMap(yamlData)
+	return yamlData.(map[string]interface{})
+}
+
 func (l *Runtime) GetRuntime() polycode.Runtime {
 	return l
 }

runtime/local/runtime.go

@@ -8,7 +8,10 @@ import (
 	"github.com/CloudImpl-Inc/next-coder-sdk/client/db"
 	"github.com/CloudImpl-Inc/next-coder-sdk/polycode"
 	"github.com/gin-gonic/gin"
+	"gopkg.in/yaml.v2"
 	"io"
+	"log"
+	"os"
 )
 
 //var runtime *Runtime = nil
@@ -17,6 +20,32 @@ type Runtime struct {
 	dbClient *db.Client
 }
 
+func (r *Runtime) AppConfig() polycode.AppConfig {
+	// Load the YAML file
+	yamlFile := "application.yml" // The path to your YAML file
+	var yamlData interface{}
+
+	data, err := os.ReadFile(yamlFile)
+	if os.IsNotExist(err) {
+		log.Println("application.yml not found. Generating empty config...")
+		yamlData = make(map[string]interface{}) // Create an empty config
+	} else if err != nil {
+		fmt.Printf("Error reading YAML file: %v\n", err)
+		os.Exit(1)
+	} else {
+		// Parse the YAML file into a map
+		err = yaml.Unmarshal(data, &yamlData)
+		if err != nil {
+			fmt.Printf("Error unmarshalling YAML: %v\n", err)
+			os.Exit(1)
+		}
+	}
+
+	// Convert map[interface{}]interface{} to map[string]interface{}
+	yamlData = polycode.ConvertMap(yamlData)
+	return yamlData.(map[string]interface{})
+}
+
 func (r *Runtime) GetRuntime() polycode.Runtime {
 	return r
 }