Refactoring (#94)

* Updated error responses
* Removed wav writer (unused)
* Added OpenAI diarization

Author: djthorpe

README.md

@@ -67,14 +67,17 @@ Available local models can be downloaded from [Hugging Face](https://huggingface
 | GGML Whisper `*.bin` | ✅ | ✅ |  | ✅ |
 | GGML Whisper `ggml-small.en-tdrz.bin`[^1] | ✅ |  | ✅ | ✅ |
 | OpenAI `whisper-1` [^2] | ✅ | ✅ |  | |
-| OpenAI `gpt-4o-*-transcribe` [^4],[^5] | ✅ | |  | ✅ |
+| OpenAI `gpt-4o-*-transcribe` [^4],[^5] | ✅ | |  | ✅ [^6] |
+| OpenAI `gpt-4o-transcribe-diarize` [^7] | ✅ | | ✅ | ✅ |
 | ElevenLabs `scribe_v1`,`scribe_v2` [^3] | ✅ |  |  ✅ | |
 
 [^1]: <https://huggingface.co/akashmjn/tinydiarize-whisper.cpp>
 [^2]: <https://platform.openai.com/docs/models/whisper-1>
 [^3]: <https://elevenlabs.io/docs/models#scribe-v1>
 [^4]: <https://platform.openai.com/docs/models/gpt-4o-transcribe>
 [^5]: <https://platform.openai.com/docs/models/gpt-4o-mini-transcribe>
+[^6]: Realtime streaming with `gpt-4o-*-transcribe` models emits text deltas only (no timestamps)
+[^7]: Realtime streaming with `gpt-4o-transcribe-diarize` emits complete segments with speaker labels and timestamps
 
 ## Docker Deployment
 

cmd/gowhisper/transcribe.go

@@ -66,8 +66,14 @@ func (cmd *TranscribeCommand) Run(ctx *Globals) (err error) {
 		return err
 	}
 
-	// Add real-time segment printing callback
+	// Add real-time segment printing callback with ID tracking
+	var segmentId int32
 	opts = append(opts, httpclient.WithSegmentCallback(func(seg *schema.Segment) error {
+		// Assign incrementing ID if segment has no ID
+		if seg.Id == 0 {
+			seg.Id = segmentId
+		}
+		segmentId++
 		writeSegment(os.Stdout, seg, format)
 		return nil
 	}))

cmd/gowhisper/translate.go

@@ -60,8 +60,14 @@ func (cmd *TranslateCommand) Run(ctx *Globals) (err error) {
 		return err
 	}
 
-	// Add real-time segment printing callback
+	// Add real-time segment printing callback with ID tracking
+	var segmentId int32
 	opts = append(opts, httpclient.WithSegmentCallback(func(seg *schema.Segment) error {
+		// Assign incrementing ID if segment has no ID
+		if seg.Id == 0 {
+			seg.Id = segmentId
+		}
+		segmentId++
 		writeSegment(os.Stdout, seg, format)
 		return nil
 	}))

go.mod

@@ -7,12 +7,10 @@ toolchain go1.24.2
 require (
 	github.com/alecthomas/kong v1.13.0
 	github.com/djthorpe/go-errors v1.0.3
-	github.com/go-audio/audio v1.0.0
 	github.com/go-audio/wav v1.1.0
 	github.com/mutablelogic/go-client v1.3.5
 	github.com/mutablelogic/go-media v1.8.3
 	github.com/mutablelogic/go-server v1.5.18
-	github.com/orcaman/writerseeker v0.0.0-20200621085525-1d3f536ff85e
 	github.com/stretchr/testify v1.11.1
 	go.opentelemetry.io/otel v1.39.0
 	go.opentelemetry.io/otel/trace v1.39.0
@@ -25,6 +23,7 @@ require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/go-asn1-ber/asn1-ber v1.5.8-0.20250403174932-29230038a667 // indirect
+	github.com/go-audio/audio v1.0.0 // indirect
 	github.com/go-audio/riff v1.0.0 // indirect
 	github.com/go-ldap/ldap/v3 v3.4.12 // indirect
 	github.com/go-logr/logr v1.4.3 // indirect

go.sum

@@ -135,8 +135,6 @@ github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8
 github.com/opencontainers/go-digest v1.0.0/go.mod h1:0JzlMkj0TRzQZfJkVvzbP0HBR3IKzErnv2BNG4W4MAM=
 github.com/opencontainers/image-spec v1.1.1 h1:y0fUlFfIZhPF1W537XOLg0/fcx6zcHCJwooC2xJA040=
 github.com/opencontainers/image-spec v1.1.1/go.mod h1:qpqAh3Dmcf36wStyyWU+kCeDgrGnAve2nCC8+7h8Q0M=
-github.com/orcaman/writerseeker v0.0.0-20200621085525-1d3f536ff85e h1:s2RNOM/IGdY0Y6qfTeUKhDawdHDpK9RGBdx80qN4Ttw=
-github.com/orcaman/writerseeker v0.0.0-20200621085525-1d3f536ff85e/go.mod h1:nBdnFKj15wFbf94Rwfq4m30eAcyY9V/IyKAGQFtqkW0=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=

pkg/elevenlabs/transcribe.go

@@ -34,7 +34,7 @@ func (c *Client) Transcribe(ctx context.Context, req TranscribeRequest) (*Transc
 	}
 
 	// Create multipart request, and execute it
-	if payload, err := client.NewMultipartRequest(req, client.ContentTypeAny); err != nil {
+	if payload, err := client.NewStreamingMultipartRequest(req, client.ContentTypeAny); err != nil {
 		return nil, err
 	} else if err := c.DoWithContext(ctx, payload, &response, client.OptPath(TranscribePath)); err != nil {
 		return nil, err

pkg/httpclient/transcribe.go

@@ -56,12 +56,15 @@ func (c *Client) Transcribe(ctx context.Context, model string, r io.Reader, opts
 	if opt.segmentCallback != nil {
 		reqOpts = append(reqOpts, client.OptReqHeader("Accept", "text/event-stream"))
 		reqOpts = append(reqOpts, client.OptTextStreamCallback(func(evt client.TextStreamEvent) error {
-			var segment schema.Segment
-			if evt.Event == schema.TranscribeStreamDeltaType {
+			switch evt.Event {
+			case schema.TranscribeStreamDeltaType:
+				var segment schema.Segment
 				if err := evt.Json(&segment); err != nil {
 					return err
 				}
 				return opt.segmentCallback(&segment)
+			case schema.TranscribeStreamErrorType:
+				return fmt.Errorf("transcribe error: %s", evt.Data)
 			}
 			return nil
 		}))

pkg/httpclient/translate.go

@@ -63,12 +63,15 @@ func (c *Client) Translate(ctx context.Context, model string, r io.Reader, opts
 	if opt.segmentCallback != nil {
 		reqOpts = append(reqOpts, client.OptReqHeader("Accept", "text/event-stream"))
 		reqOpts = append(reqOpts, client.OptTextStreamCallback(func(evt client.TextStreamEvent) error {
-			var segment schema.Segment
-			if evt.Event == schema.TranscribeStreamDeltaType {
+			switch evt.Event {
+			case schema.TranscribeStreamDeltaType:
+				var segment schema.Segment
 				if err := evt.Json(&segment); err != nil {
 					return err
 				}
 				return opt.segmentCallback(&segment)
+			case schema.TranscribeStreamErrorType:
+				return fmt.Errorf("translate error: %s", evt.Data)
 			}
 			return nil
 		}))

pkg/httphandler/httphandler.go

@@ -8,9 +8,6 @@ import (
 	httpresponse "github.com/mutablelogic/go-server/pkg/httpresponse"
 	types "github.com/mutablelogic/go-server/pkg/types"
 	pkg "github.com/mutablelogic/go-whisper/pkg"
-
-	// Namespace imports
-	. "github.com/djthorpe/go-errors"
 )
 
 ///////////////////////////////////////////////////////////////////////////////
@@ -60,13 +57,6 @@ func httperr(err error) error {
 		return err
 	}
 
-	// Map pkg errors to HTTP errors
-	switch {
-	case errors.Is(err, ErrNotFound):
-		return httpresponse.ErrNotFound.With(err.Error())
-	case errors.Is(err, ErrBadParameter):
-		return httpresponse.ErrBadRequest.With(err.Error())
-	default:
-		return httpresponse.ErrInternalError.With(err.Error())
-	}
+	// Map remaining errors to "Internal Error" HTTP errors
+	return httpresponse.ErrInternalError.With(err.Error())
 }

pkg/httphandler/transcribe.go

@@ -43,6 +43,11 @@ func transcribeCreate(w http.ResponseWriter, r *http.Request, manager *pkg.Manag
 		return httpresponse.Error(w, httpresponse.ErrBadRequest.With("missing or invalid audio field"))
 	}
 
+	// Copy filename from multipart audio field if not explicitly set
+	if req.Audio.Path != "" && (req.Filename == nil || *req.Filename == "") {
+		req.Filename = &req.Audio.Path
+	}
+
 	// Create text stream if requested
 	var stream *httpresponse.TextStream
 	var mimetype string