🐛 fix(image.go): change action from "image" to "generate"

✨ feat(http): add goroutines to handle requests asynchronously in commands.go

🎨 refactor(image): rename action from "image" to "generate" in Slack and Telegram interfaces

interfaces/discord/image.go

@@ -9,7 +9,7 @@ import (
 
 func generate(ctx context.Context, msg *memory.Message) error {
 	req := structs.NewActionRequest()
-	req.Action = "image"
+	req.Action = "generate"
 	req.Params = promptFromMessage(msg)
 	req.Message = msg
 	req.Context = ctx

interfaces/http/commands.go

@@ -77,10 +77,12 @@ func complete(w http.ResponseWriter, r *http.Request) {
 
 	request.Writer = utils.NewHTTPResponseWriteCloser(w)
 
-	if err := channels.RunCompletion(request); err != nil {
-		_ = render.Render(w, r, ErrInvalidRequest(err))
-		return
-	}
+	go func() {
+		if err := channels.RunCompletion(request); err != nil {
+			_ = render.Render(w, r, ErrInvalidRequest(err))
+			return
+		}
+	}()
 
 	for {
 		select {
@@ -118,15 +120,17 @@ func generate(w http.ResponseWriter, r *http.Request) {
 	req := structs.NewActionRequest()
 	req.ID = msg.ExternalID
 	req.Context = ctx
-	req.Action = "image"
+	req.Action = "generate"
 	req.Params = params.Prompt
 	req.Message = msg
 	req.Writers = []io.WriteCloser{utils.NewHTTPResponseWriteCloser(w)}
 
-	if err := channels.RunAction(req); err != nil {
-		_ = render.Render(w, r, ErrInvalidRequest(err))
-		return
-	}
+	go func() {
+		if err := channels.RunAction(req); err != nil {
+			_ = render.Render(w, r, ErrInvalidRequest(err))
+			return
+		}
+	}()
 
 	for {
 		select {
@@ -169,10 +173,12 @@ func tts(w http.ResponseWriter, r *http.Request) {
 	req.Message = msg
 	req.Writers = []io.WriteCloser{utils.NewHTTPResponseWriteCloser(w)}
 
-	if err := channels.RunAction(req); err != nil {
-		_ = render.Render(w, r, ErrInvalidRequest(err))
-		return
-	}
+	go func() {
+		if err := channels.RunAction(req); err != nil {
+			_ = render.Render(w, r, ErrInvalidRequest(err))
+			return
+		}
+	}()
 
 	for {
 		select {
@@ -234,8 +240,19 @@ func action(w http.ResponseWriter, r *http.Request) {
 	req.Thought = fmt.Sprintf("User wants to run action %s", params.Action)
 	req.Writers = []io.WriteCloser{&utils.HTTPResponseWriteCloser{Writer: w}}
 
-	if err := channels.RunAction(req); err != nil {
-		_ = render.Render(w, r, ErrInvalidRequest(err))
-		return
+	go func() {
+		if err := channels.RunAction(req); err != nil {
+			_ = render.Render(w, r, ErrInvalidRequest(err))
+			return
+		}
+	}()
+
+	for {
+		select {
+		case <-ctx.Done():
+			return
+		case <-req.Writers[0].(*utils.HTTPResponseWriteCloser).CloseCh:
+			return
+		}
 	}
 }

interfaces/slack/image.go

@@ -9,7 +9,7 @@ import (
 
 func generate(ctx context.Context, msg *memory.Message) error {
 	req := structs.NewActionRequest()
-	req.Action = "image"
+	req.Action = "generate"
 	req.Params = promptFromMessage(msg)
 	req.Message = msg
 	req.Context = ctx

interfaces/telegram/image.go

@@ -45,7 +45,7 @@ func aiAction(ctx context.Context, msg *memory.Message) error {
 func aiGenerate(ctx context.Context, msg *memory.Message) error {
 	req := structs.NewActionRequest()
 	req.Context = ctx
-	req.Action = "image"
+	req.Action = "generate"
 	req.Params = promptFromMessage(msg)
 	req.Writers = append(req.Writers, NewImageWriter(ctx, req, false))