use event_stream_parser

Author: keisku

Gemfile

@@ -10,6 +10,7 @@ gem "rubocop-minitest", require: false
 gem "rubocop-rake", require: false
 gem "rubocop-shopify", ">= 2.18", require: false if RUBY_VERSION >= "3.1"
 
+gem "event_stream_parser", ">= 1.0"
 gem "puma", ">= 5.0.0"
 gem "rackup", ">= 2.1.0"
 

examples/streamable_http_client.rb

@@ -8,6 +8,7 @@
 require "uri"
 require "json"
 require "logger"
+require "event_stream_parser"
 
 SERVER_URL = "http://localhost:9393"
 
@@ -37,13 +38,13 @@ def connect_sse(session_id, logger)
       if response.code == "200"
         logger.info("SSE stream connected successfully")
 
+        parser = EventStreamParser::Parser.new
         response.read_body do |chunk|
-          chunk.split("\n").each do |line|
-            if line.start_with?("data: ")
-              data = line[6..]
+          parser.feed(chunk) do |type, data, _id|
+            if type.empty?
               logger.info("SSE event: #{data}")
-            elsif line.start_with?(": ")
-              logger.debug("SSE keepalive: #{line}")
+            else
+              logger.info("SSE event (#{type}): #{data}")
             end
           end
         end

lib/mcp/client/http.rb

@@ -145,14 +145,8 @@ def parse_response_body(response, method, params)
 
       def parse_sse_response(body, method, params)
         json_rpc_response = nil
-
-        body.to_s.each_line do |line|
-          line = line.strip
-          next if line.empty?
-          next if line.start_with?(":")
-          next unless line.start_with?("data:")
-
-          data = line.sub(/^data:\s*/, "")
+        parser = EventStreamParser::Parser.new
+        parser.feed(body.to_s) do |_type, data, _id|
           next if data.empty?
 
           begin

test/mcp/client/http_test.rb

@@ -1,6 +1,7 @@
 # frozen_string_literal: true
 
 require "test_helper"
+require "event_stream_parser"
 require "faraday"
 require "webmock/minitest"
 require "mcp/client/http"