🌿 Fern Regeneration -- December 18, 2025 (#143)

Author: fern-api[bot]

.fern/metadata.json

@@ -0,0 +1,10 @@
+{
+  "cliVersion": "0.112.1",
+  "generatorName": "fernapi/fern-go-sdk",
+  "generatorVersion": "1.21.5",
+  "generatorConfig": {
+    "union": "v1",
+    "includeLegacyClientOptions": true
+  },
+  "sdkVersion": "v2.16.1"
+}

.github/workflows/e2e.yml

@@ -18,8 +18,13 @@ jobs:
         go get golang.org/x/tools@v0.9.2-0.20230531220058-a260315e300a
     - name: Build
       run: go build -v ./...
+    - name: Setup wiremock server
+      run: |
+        if [ -f wiremock/docker-compose.test.yml ]; then docker compose -f wiremock/docker-compose.test.yml down && docker compose -f wiremock/docker-compose.test.yml up -d; fi
     - name: Test with the Go CLI
       run: go test -v ./...
       env:
         COHERE_API_KEY: ${{ secrets.COHERE_API_KEY }}
-
+    - name: Teardown wiremock server
+      run: |
+        if [ -f wiremock/docker-compose.test.yml ]; then docker compose -f wiremock/docker-compose.test.yml down; fi

batches/batches_test/batches_test.go

@@ -306,7 +306,8 @@ func (s *SseStreamReader) nextEvent() (*SseEvent, error) {
 }
 
 func (s *SseStreamReader) parseSseLine(_bytes []byte, event *SseEvent) {
-	if bytes.HasPrefix(_bytes, sseDataPrefix) {
+	// Try to parse with space first (standard format), then without space (lenient format)
+	if value, ok := s.tryParseField(_bytes, sseDataPrefix, sseDataPrefixNoSpace); ok {
 		if len(event.data) > 0 {
 			// Join multiple data: lines using the configured delimiter
 			// This allows customization of how multi-line data is concatenated:
@@ -316,16 +317,28 @@ func (s *SseStreamReader) parseSseLine(_bytes []byte, event *SseEvent) {
 			lineDelimiter := s.options.getLineDelimiter()
 			event.data = append(event.data, lineDelimiter...)
 		}
-		event.data = append(event.data, _bytes[len(sseDataPrefix):]...)
-	} else if bytes.HasPrefix(_bytes, sseIdPrefix) {
-		event.id = append(event.id, _bytes[len(sseIdPrefix):]...)
-	} else if bytes.HasPrefix(_bytes, sseEventPrefix) {
-		event.event = append(event.event, _bytes[len(sseEventPrefix):]...)
-	} else if bytes.HasPrefix(_bytes, sseRetryPrefix) {
-		event.retry = append(event.retry, _bytes[len(sseRetryPrefix):]...)
+		event.data = append(event.data, value...)
+	} else if value, ok := s.tryParseField(_bytes, sseIdPrefix, sseIdPrefixNoSpace); ok {
+		event.id = append(event.id, value...)
+	} else if value, ok := s.tryParseField(_bytes, sseEventPrefix, sseEventPrefixNoSpace); ok {
+		event.event = append(event.event, value...)
+	} else if value, ok := s.tryParseField(_bytes, sseRetryPrefix, sseRetryPrefixNoSpace); ok {
+		event.retry = append(event.retry, value...)
 	}
 }
 
+// tryParseField attempts to parse an SSE field by trying multiple prefix patterns in order.
+// This handles APIs that don't strictly follow the SSE specification by omitting the space after the colon.
+// It tries each prefix in the order provided and returns the value after the first matching prefix.
+func (s *SseStreamReader) tryParseField(line []byte, prefixes ...[]byte) ([]byte, bool) {
+	for _, prefix := range prefixes {
+		if bytes.HasPrefix(line, prefix) {
+			return line[len(prefix):], true
+		}
+	}
+	return nil, false
+}
+
 func (event *SseEvent) size() int {
 	return len(event.id) + len(event.data) + len(event.event) + len(event.retry)
 }
@@ -346,4 +359,10 @@ var (
 	sseDataPrefix  = []byte("data: ")
 	sseEventPrefix = []byte("event: ")
 	sseRetryPrefix = []byte("retry: ")
+
+	// Lenient prefixes without space for APIs that don't strictly follow SSE specification
+	sseIdPrefixNoSpace    = []byte("id:")
+	sseDataPrefixNoSpace  = []byte("data:")
+	sseEventPrefixNoSpace = []byte("event:")
+	sseRetryPrefixNoSpace = []byte("retry:")
 )