fix: fix relay openai panic

common/go-channel.go

+package common
+
+func SafeSend(ch chan bool, value bool) (closed bool) {
+	defer func() {
+		// Recover from panic if one occured. A panic would mean the channel was closed.
+		if recover() != nil {
+			closed = true
+		}
+	}()
+
+	// This will panic if the channel is closed.
+	ch <- value
+
+	// If the code reaches here, then the channel was not closed.
+	return false
+}

controller/relay-openai.go

@@ -83,7 +83,7 @@ func openaiStreamHandler(c *gin.Context, resp *http.Response, relayMode int) (*O
 			// wait data out
 			// wait data out
 			time.Sleep(2 * time.Second)
 			time.Sleep(2 * time.Second)
 		}
 		}
-		stopChan <- true
+		common.SafeSend(stopChan, true)
 	}()
 	}()
 	setEventStreamHeaders(c)
 	setEventStreamHeaders(c)
 	c.Stream(func(w io.Writer) bool {
 	c.Stream(func(w io.Writer) bool {