fix(sse-starlette): handle SSE events with data prefixed with ":ping" and fixed#97

The SSE event parser now correctly handles events where the data is prefixed with ":ping", which was previously ignored. This change ensures that all SSE events are properly processed, addressing an issue where certain events were being discarded.

Author: phodal

src/main/kotlin/cc/unitmesh/devti/llms/azure/ResponseBodyCallback.kt

@@ -46,6 +46,8 @@ class AutoDevHttpException(error: String, private val statusCode: Int) : Runtime
  * SSE.
  */
 class ResponseBodyCallback(private val emitter: FlowableEmitter<SSE>, private val emitDone: Boolean) : Callback {
+    val logger = logger<ResponseBodyCallback>()
+
     override fun onResponse(call: Call, response: Response) {
         var reader: BufferedReader? = null
         try {
@@ -64,16 +66,7 @@ class ResponseBodyCallback(private val emitter: FlowableEmitter<SSE>, private va
                 sse = when {
                     line!!.startsWith("data:") -> {
                         val data = line!!.substring(5).trim { it <= ' ' }
-                        //  https://github.com/sysid/sse-starlette/issues/16
-                        //  ```
-                        //  event: ping
-                        //  data: 2020-12-22 15:33:27.463789
-                        //  ```
-                        if (data.startsWith(":ping") || data.startsWith(": ping")) {
-                            null
-                        } else {
-                            SSE(data)
-                        }
+                        SSE(data)
                     }
 
                     line == "" && sse != null -> {
@@ -99,6 +92,11 @@ class ResponseBodyCallback(private val emitter: FlowableEmitter<SSE>, private va
                         null
                     }
 
+                    // : ping
+                    line!!.startsWith(": ping") -> {
+                        null
+                    }
+
                     else -> {
                         throw SSEFormatException("Invalid sse format! '$line'")
                     }