Chore: linter

.golangci.yml

@@ -1,32 +1,44 @@
+version: "2"
 run:
-  timeout: 1m
   concurrency: 2
   tests: false
-
 linters:
-  enable-all: false
+  default: none
-  disable-all: true
   enable:
+    - bodyclose
     - errcheck
-    - gosimple
+    - fatcontext
     - govet
     - ineffassign
-    - staticcheck
+    - noctx
-    - typecheck
+    - perfsprint
-    - unused
     - prealloc
-  presets:
+    - staticcheck
-    - performance
+    - unused
-
+  settings:
-linters-settings:
+    funlen:
-  funlen:
+      lines: 80
-    lines: 80
+      statements: 50
-    statements: 50
+    lll:
-  lll:
+      line-length: 80
-    line-length: 80
+  exclusions:
-
+    generated: lax
+    presets:
+      - comments
+      - common-false-positives
+      - legacy
+      - std-error-handling
+    paths:
+      - third_party$
+      - builtin$
+      - examples$
 issues:
-  exclude:
-  # Display all issues
   max-issues-per-linter: 0
   max-same-issues: 0
+formatters:
+  exclusions:
+    generated: lax
+    paths:
+      - third_party$
+      - builtin$
+      - examples$

bot.go

@@ -43,9 +43,10 @@ var (
 	interruptResp       = false
 	ragger              *rag.RAG
 	chunkParser         ChunkParser
-	orator              extra.Orator
+	//nolint:unused // TTS_ENABLED conditionally uses this
-	asr                 extra.STT
+	orator          extra.Orator
-	defaultLCPProps     = map[string]float32{
+	asr             extra.STT
+	defaultLCPProps = map[string]float32{
 		"temperature":    0.8,
 		"dry_multiplier": 0.0,
 		"min_p":          0.05,
@@ -272,6 +273,7 @@ func roleToIcon(role string) string {
 	return "<" + role + ">: "
 }
 
+// FIXME: it should not be here; move to extra
 func checkGame(role string, tv *tview.TextView) {
 	// Handle Cluedo game flow
 	// should go before form msg, since formmsg takes chatBody and makes ioreader out of it
@@ -283,8 +285,7 @@ func checkGame(role string, tv *tview.TextView) {
 			playerOrder = []string{cfg.UserRole, cfg.AssistantRole, cfg.CluedoRole2}
 			cluedoState = extra.CluedoPrepCards(playerOrder)
 		}
-
+		// notifyUser("got in cluedo", "yay")
-		notifyUser("got in cluedo", "yay")
 		currentPlayer := playerOrder[0]
 		playerOrder = append(playerOrder[1:], currentPlayer) // Rotate turns
 		if role == cfg.UserRole {
@@ -296,7 +297,6 @@ func checkGame(role string, tv *tview.TextView) {
 			})
 		}
 	}
-	return
 }
 
 func chatRound(userMsg, role string, tv *tview.TextView, regen, resume bool) {

extra/audio.go

@@ -46,17 +46,12 @@ type KokoroOrator struct {
 }
 
 func stoproutine(orator Orator) {
-	select {
+	<-TTSDoneChan
-	case <-TTSDoneChan:
+	orator.GetLogger().Info("orator got done signal")
-		orator.GetLogger().Info("orator got done signal")
+	orator.Stop()
-		orator.Stop()
+	// drain the channel
-		// close(TTSTextChan)
+	for len(TTSTextChan) > 0 {
-		// TTSTextChan = make(chan string, 10000)
+		<-TTSTextChan
-		// drain the channel
-		for len(TTSTextChan) > 0 {
-			<-TTSTextChan
-		}
-		return
 	}
 }
 

extra/stt.go

@@ -32,7 +32,6 @@ type WhisperSTT struct {
 	ServerURL   string
 	SampleRate  int
 	AudioBuffer *bytes.Buffer
-	streamer    StreamCloser
 	recording   bool
 }
 
@@ -90,7 +89,7 @@ func (stt *WhisperSTT) StopRecording() (string, error) {
 		return "", err
 	}
 	// Send request
-	resp, err := http.Post("http://localhost:8081/inference", writer.FormDataContentType(), body)
+	resp, err := http.Post(stt.ServerURL, writer.FormDataContentType(), body)
 	if err != nil {
 		stt.logger.Error("fn: StopRecording", "error", err)
 		return "", err
@@ -122,7 +121,9 @@ func (stt *WhisperSTT) writeWavHeader(w io.Writer, dataSize int) {
 	binary.LittleEndian.PutUint16(header[34:36], 16)
 	copy(header[36:40], "data")
 	binary.LittleEndian.PutUint32(header[40:44], uint32(dataSize))
-	w.Write(header)
+	if _, err := w.Write(header); err != nil {
+		stt.logger.Error("writeWavHeader", "error", err)
+	}
 }
 
 func (stt *WhisperSTT) IsRecording() bool {
@@ -136,7 +137,9 @@ func (stt *WhisperSTT) microphoneStream(sampleRate int) error {
 	in := make([]int16, 64)
 	stream, err := portaudio.OpenDefaultStream(1, 0, float64(sampleRate), len(in), in)
 	if err != nil {
-		portaudio.Terminate()
+		if paErr := portaudio.Terminate(); paErr != nil {
+			return fmt.Errorf("failed to open microphone: %w; terminate error: %w", err, paErr)
+		}
 		return fmt.Errorf("failed to open microphone: %w", err)
 	}
 	go func(stream *portaudio.Stream) {

pngmeta/metareader.go

@@ -22,7 +22,6 @@ const (
 	writeHeader = "\x89\x50\x4E\x47\x0D\x0A\x1A\x0A"
 )
 
-
 type PngEmbed struct {
 	Key   string
 	Value string
@@ -96,7 +95,7 @@ func ReadCard(fname, uname string) (*models.CharCard, error) {
 		return nil, err
 	}
 	if charSpec.Name == "" {
-		return nil, fmt.Errorf("failed to find role; fname %s\n", fname)
+		return nil, fmt.Errorf("failed to find role; fname %s", fname)
 	}
 	return charSpec.Simplify(uname, fname), nil
 }

rag/main.go

@@ -235,7 +235,7 @@ func (r *RAG) LineToVector(line string) ([]float32, error) {
 	}
 	defer resp.Body.Close()
 	if resp.StatusCode != 200 {
-		err = fmt.Errorf("non 200 resp; code: %v\n", resp.StatusCode)
+		err = fmt.Errorf("non 200 resp; code: %v", resp.StatusCode)
 		r.logger.Error(err.Error())
 		return nil, err
 	}