Update main.go

main.go

@@ -4,13 +4,11 @@ import (
 	"bufio"
 	"bytes"
 	"encoding/json"
-	"fmt"
 	"io"
 	"log"
 	"net/http"
 	"os"
 	"strings"
-	"time"
 
 	"github.com/google/uuid"
 )
@@ -62,7 +60,6 @@ type TextConfig struct {
 }
 
 func main() {
-	// Hugging Face 必须监听 7860
 	port := os.Getenv("PORT")
 	if port == "" {
 		port = "7860"
@@ -81,7 +78,6 @@ func main() {
 }
 
 func handleResponses(w http.ResponseWriter, r *http.Request) {
-	reqID := uuid.New().String()[:8]
 	if r.Method != http.MethodPost {
 		http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
 		return
@@ -98,9 +94,9 @@ func handleResponses(w http.ResponseWriter, r *http.Request) {
 	}
 
 	if stream {
-		handleStreamingResponse(w, waveReq, reqID)
+		handleStreamingResponse(w, waveReq)
 	} else {
-		handleNonStreamingResponse(w, waveReq, reqID)
+		handleNonStreamingResponse(w, waveReq)
 	}
 }
 
@@ -131,11 +127,11 @@ func makeWaveRequest(waveReq *WaveRequest) (*http.Response, error) {
 	httpReq.Header.Set("X-Wave-Apitype", "openai-responses")
 	httpReq.Header.Set("X-Wave-Clientid", uuid.New().String())
 
-	client := &http.Client{Timeout: 5 * time.Minute}
+	client := &http.Client{}
 	return client.Do(httpReq)
 }
 
-func handleStreamingResponse(w http.ResponseWriter, waveReq *WaveRequest, reqID string) {
+func handleStreamingResponse(w http.ResponseWriter, waveReq *WaveRequest) {
 	resp, err := makeWaveRequest(waveReq)
 	if err != nil {
 		http.Error(w, err.Error(), http.StatusBadGateway)
@@ -152,7 +148,7 @@ func handleStreamingResponse(w http.ResponseWriter, waveReq *WaveRequest, reqID
 	}
 }
 
-func handleNonStreamingResponse(w http.ResponseWriter, waveReq *WaveRequest, reqID string) {
+func handleNonStreamingResponse(w http.ResponseWriter, waveReq *WaveRequest) {
 	resp, _ := makeWaveRequest(waveReq)
 	defer resp.Body.Close()