Fix indentation and formatting issues in multiple files.

api/chat_main_handler.go

@@ -546,31 +546,33 @@ func (h *ChatHandler) chatStream(w http.ResponseWriter, chatSession sqlc_queries
 	if regenerate {
 		answer_id = chatUuid
 	}
-	
+
 	for {
 		response, err := stream.Recv()
-		if errors.Is(err, io.EOF) {
-			// send the last message
-			if len(answer) > 0 {
-				final_resp := constructChatCompletionStreamReponse(answer_id, answer)
-				data, _ := json.Marshal(final_resp)
-				fmt.Fprintf(w, "data: %v\n\n", string(data))
-				flusher.Flush()
-			}
-			if chatSession.Debug {
-				req_j, _ := json.Marshal(openai_req)
-				log.Println(string(req_j))
-				answer = answer + "\n" + string(req_j)
-				req_as_resp := constructChatCompletionStreamReponse(answer_id, answer)
-				data, _ := json.Marshal(req_as_resp)
-				fmt.Fprintf(w, "data: %v\n\n", string(data))
-				flusher.Flush()
-			}
-			break
-		}
 		if err != nil {
-			RespondWithError(w, http.StatusInternalServerError, fmt.Sprintf("Stream error: %v", err), nil)
-			return "", "", true
+			if errors.Is(err, io.EOF) {
+				// send the last message
+				if len(answer) > 0 {
+					final_resp := constructChatCompletionStreamReponse(answer_id, answer)
+					data, _ := json.Marshal(final_resp)
+					fmt.Fprintf(w, "data: %v\n\n", string(data))
+					flusher.Flush()
+				}
+				if chatSession.Debug {
+					req_j, _ := json.Marshal(openai_req)
+					log.Println(string(req_j))
+					answer = answer + "\n" + string(req_j)
+					req_as_resp := constructChatCompletionStreamReponse(answer_id, answer)
+					data, _ := json.Marshal(req_as_resp)
+					fmt.Fprintf(w, "data: %v\n\n", string(data))
+					flusher.Flush()
+				}
+				return answer, answer_id, false
+			} else {
+				log.Printf("%v", err)
+				RespondWithError(w, http.StatusInternalServerError, fmt.Sprintf("Stream error: %v", err), nil)
+				return "", "", true
+			}
 		}
 		textIdx := response.Choices[0].Index
 		delta := response.Choices[0].Delta.Content
@@ -592,7 +594,6 @@ func (h *ChatHandler) chatStream(w http.ResponseWriter, chatSession sqlc_queries
 			flusher.Flush()
 		}
 	}
-	return answer, answer_id, false
 }
 
 func (h *ChatHandler) CompletionStream(w http.ResponseWriter, chatSession sqlc_queries.ChatSession, chat_compeletion_messages []models.Message, chatUuid string, regenerate bool, streamOutput bool) (string, string, bool) {
@@ -617,7 +618,6 @@ func (h *ChatHandler) CompletionStream(w http.ResponseWriter, chatSession sqlc_q
 		return "", "", true
 	}
 
-
 	client := openai.NewClientWithConfig(config)
 	// latest message contents
 	prompt := chat_compeletion_messages[len(chat_compeletion_messages)-1].Content
@@ -1466,7 +1466,7 @@ func (h *ChatHandler) chatStreamGemini(w http.ResponseWriter, chatSession sqlc_q
 		if err != nil {
 			if errors.Is(err, io.EOF) {
 				fmt.Println("End of stream reached")
-				break
+				return answer, answer_id, false
 			} else {
 				fmt.Printf("Error while reading response: %+v", err)
 				return "", "", true

api/chat_snapshot_handler.go

@@ -36,7 +36,7 @@ func (h *ChatSnapshotHandler) CreateChatSnapshot(w http.ResponseWriter, r *http.
 		RespondWithError(w, http.StatusInternalServerError, err.Error(), err)
 		return
 	}
-uuid, err := h.service.CreateChatSnapshot(r.Context(), chatSessionUuid, user_id)
+	uuid, err := h.service.CreateChatSnapshot(r.Context(), chatSessionUuid, user_id)
 	if err != nil {
 		RespondWithError(w, http.StatusInternalServerError, err.Error(), err)
 	}

api/chat_snapshot_service.go

@@ -62,7 +62,6 @@ func (s *ChatSnapshotService) CreateChatSnapshot(ctx context.Context, chatSessio
 
 }
 
-
 func (s *ChatSnapshotService) CreateChatBot(ctx context.Context, chatSessionUuid string, userId int32) (string, error) {
 	chatSession, err := s.q.GetChatSessionByUUID(ctx, chatSessionUuid)
 	if err != nil {

api/llm/gemini/gemini.go

@@ -39,7 +39,6 @@ func (p PartBlob) toPart() string {
 	return fmt.Sprintf("data:%s;base64,%s", b.MIMEType, b.Data)
 }
 
-
 // from https://github.com/google/generative-ai-go/blob/main/genai/generativelanguagepb_veneer.gen.go#L56
 // Blob contains raw media bytes.
 //
@@ -65,8 +64,6 @@ func ImageData(mimeType string, data []byte) Blob {
 	}
 }
 
-
-
 type GeminiMessage struct {
 	Role  string `json:"role"`
 	Parts []Part `json:"parts"`
@@ -169,7 +166,7 @@ func GenGemminPayload(chat_compeletion_messages []models.Message, chatFiles []sq
 			if imageExt.Contains(chatFile.MimeType) {
 				return &PartBlob{Blob: ImageData(chatFile.MimeType, chatFile.Data)}
 			} else {
-				return &PartString{Text: "file: " + chatFile.Name + "\n<<<"+ string(chatFile.Data) + ">>>\n"}
+				return &PartString{Text: "file: " + chatFile.Name + "\n<<<" + string(chatFile.Data) + ">>>\n"}
 			}
 		})
 		fmt.Printf("partsFromFiles: %+v\n", partsFromFiles)

api/middleware_authenticate.go

@@ -94,11 +94,11 @@ func AdminOnlyHandlerFunc(handlerFunc http.HandlerFunc) http.HandlerFunc {
 
 func IsAuthorizedMiddleware(handler http.Handler) http.Handler {
 	noAuthPaths := map[string]bool{
-		"/": true,
+		"/":            true,
 		"/favicon.ico": true,
-		"/api/login":  true,
-		"/api/signup": true,
-		"/api/tts":    true,
+		"/api/login":   true,
+		"/api/signup":  true,
+		"/api/tts":     true,
 	}
 	jwtSigningKey := []byte(jwtSecretAndAud.Secret)
 	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {

api/models/models.go

@@ -39,4 +39,3 @@ func (m *Message) SetTokenCount(tokenCount int32) *Message {
 	m.tokenCount = tokenCount
 	return m
 }
-