Skip to content

Commit f14d243

Browse files
mrlubosmrlubos
authored
Merge pull request #3055 from nachogarcia/main
fix: handle CLRF and CR line endings in SSE parser
2 parents 271a0a2 + d663232 commit f14d243

File tree

243 files changed

+547
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

243 files changed

+547
-0
lines changed

‎.changeset/smooth-oranges-love.md‎

Lines changed: 5 additions & 0 deletions

‎examples/openapi-ts-angular-common/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-angular/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-axios/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-fastify/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-fetch/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-ky/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-next/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-ofetch/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

‎examples/openapi-ts-openai/src/client/core/serverSentEvents.gen.ts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,8 @@ export const createSseClient = <TData = unknown>({
169169
const { done, value } = await reader.read();
170170
if (done) break;
171171
buffer += value;
172+
// Normalize line endings: CRLF -> LF, then CR -> LF
173+
buffer = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');
172174

173175
const chunks = buffer.split('\n\n');
174176
buffer = chunks.pop() ?? '';

0 commit comments

Comments
 (0)