fix: improve error logging and session handling in serverless runtime

internal/core/plugin_manager/serverless_runtime/io.go

@@ -16,18 +16,18 @@ import (
 	"github.com/langgenius/dify-plugin-daemon/pkg/entities/plugin_entities"
 )
 
-func (r *AWSPluginRuntime) Listen(session_id string) *entities.Broadcast[plugin_entities.SessionMessage] {
+func (r *AWSPluginRuntime) Listen(sessionId string) *entities.Broadcast[plugin_entities.SessionMessage] {
 	l := entities.NewBroadcast[plugin_entities.SessionMessage]()
 	// store the listener
-	r.listeners.Store(session_id, l)
+	r.listeners.Store(sessionId, l)
 	return l
 }
 
 // For AWS Lambda, write is equivalent to http request, it's not a normal stream like stdio and tcp
-func (r *AWSPluginRuntime) Write(session_id string, data []byte) {
-	l, ok := r.listeners.Load(session_id)
+func (r *AWSPluginRuntime) Write(sessionId string, data []byte) {
+	l, ok := r.listeners.Load(sessionId)
 	if !ok {
-		log.Error("session %s not found", session_id)
+		log.Error("session %s not found", sessionId)
 		return
 	}
 
@@ -57,16 +57,16 @@ func (r *AWSPluginRuntime) Write(session_id string, data []byte) {
 	}
 	req.Header.Set("Content-Type", "application/json")
 	req.Header.Set("Accept", "text/event-stream")
-	req.Header.Set("Dify-Plugin-Session-ID", session_id)
+	req.Header.Set("Dify-Plugin-Session-ID", sessionId)
 
 	routine.Submit(map[string]string{
 		"module":     "serverless_runtime",
 		"function":   "Write",
-		"session_id": session_id,
+		"session_id": sessionId,
 		"lambda_url": r.LambdaURL,
 	}, func() {
 		// remove the session from listeners
-		defer r.listeners.Delete(session_id)
+		defer r.listeners.Delete(sessionId)
 		defer l.Close()
 		defer l.Send(plugin_entities.SessionMessage{
 			Type: plugin_entities.SESSION_MESSAGE_TYPE_END,

pkg/entities/plugin_entities/event.go

@@ -26,7 +26,11 @@ func ParsePluginUniversalEvent(
 	// handle event
 	event, err := parser.UnmarshalJsonBytes[PluginUniversalEvent](data)
 	if err != nil {
-		error_handler(err.Error())
+		if len(data) > 1024 {
+			error_handler(err.Error() + " original response: " + string(data[:1024]) + "...")
+		} else {
+			error_handler(err.Error() + " original response: " + string(data))
+		}
 		return
 	}