feat: explicit spec environment

README.md

@@ -50,6 +50,9 @@ Try a basic HTTP request handler using [ping.yaml](./examples/ping.yaml):
     out:
       - name: router
         port: in
+  env:
+    PORT:
+      - data: '{{ .PORT }}'
 
 - kind: router
   name: router

README_kr.md

@@ -50,6 +50,9 @@ make build
     out:
       - name: router
         port: in
+  env:
+    PORT:
+      - data: "{{ .PORT }}"
 
 - kind: router
   name: router

examples/helloworld.yaml

@@ -10,6 +10,9 @@
     init:
       - name: hello_world
         port: in
+  env:
+    PORT:
+      - data: '{{ .PORT }}'
 
 - kind: step
   name: good_bye

examples/httpproxy.yaml

@@ -6,6 +6,9 @@
     out:
       - name: proxy
         port: in
+  env:
+    PORT:
+      - data: '{{ .PORT }}'
 
 - kind: http
   name: proxy

examples/loopback.yaml

@@ -6,6 +6,9 @@
     out:
       - name: loopback
         port: in
+  env:
+    PORT:
+      - data: '{{ .PORT }}'
 
 - kind: snippet
   name: loopback

examples/ping.yaml

@@ -6,6 +6,9 @@
     out:
       - name: router
         port: in
+  env:
+    PORT:
+      - data: '{{ .PORT }}'
 
 - kind: router
   name: router

examples/system.yaml

@@ -9,6 +9,9 @@
     error:
       - name: catch
         port: in
+  env:
+    PORT:
+      - data: '{{ .PORT }}'
 
 - kind: router
   name: router

examples/wsproxy.yaml

@@ -15,6 +15,9 @@
     out:
       - name: router
         port: in
+  env:
+    PORT:
+      - data: '{{ .PORT }}'
 
 - kind: router
   name: router

pkg/symbol/loader.go

@@ -3,9 +3,9 @@ package symbol
 import (
 	"context"
 	"errors"
+	"github.com/iancoleman/strcase"
 	"reflect"
 
-	"github.com/iancoleman/strcase"
 	"github.com/siyul-park/uniflow/pkg/resource"
 	"github.com/siyul-park/uniflow/pkg/scheme"
 	"github.com/siyul-park/uniflow/pkg/spec"
@@ -32,8 +32,12 @@ type Loader struct {
 
 // NewLoader creates a new Loader instance with the provided configuration.
 func NewLoader(config LoaderConfig) *Loader {
+	env := map[string]string{}
+	for k, v := range config.Environment {
+		env[strcase.ToScreamingSnake(k)] = v
+	}
 	return &Loader{
-		environment: config.Environment,
+		environment: env,
 		table:       config.Table,
 		scheme:      config.Scheme,
 		specStore:   config.SpecStore,
@@ -50,28 +54,6 @@ func (l *Loader) Load(ctx context.Context, specs ...spec.Spec) error {
 		return err
 	}
 
-	for i, sp := range specs {
-		unstructured := &spec.Unstructured{}
-		if err := spec.As(sp, unstructured); err != nil {
-			return err
-		}
-
-		env := unstructured.GetEnv()
-		if env == nil {
-			env = map[string][]spec.Value{}
-		}
-
-		for k, v := range l.environment {
-			k = strcase.ToScreamingSnake(k)
-			if _, ok := env[k]; !ok {
-				env[k] = append(env[k], spec.Value{Data: v})
-			}
-		}
-
-		unstructured.SetEnv(env)
-		specs[i] = unstructured
-	}
-
 	var values []*value.Value
 	for _, sp := range specs {
 		for _, vals := range sp.GetEnv() {