Method decode

packages/core/src/common/stream.ts:339–380

* Decodes a line of text and returns a ServerSentEvent object if a complete event is found. * @param line - The line of text to decode. * @returns A ServerSentEvent object if a complete event is found, otherwise null.

(line: string)

	 * @returns A ServerSentEvent object if a complete event is found, otherwise null.
	 */
	decode(line: string) {
		if (line.endsWith('\r')) {
			line = line.substring(0, line.length - 1);
		}

		if (!line) {
			// empty line and we didn't previously encounter any messages
			if (!this.event && !this.data.length) return null;

			const sse: ServerSentEvent = {
				event: this.event,
				data: this.data.join('\n'),
				raw: this.chunks,
			};

			this.event = null;
			this.data = [];
			this.chunks = [];

			return sse;
		}

		this.chunks.push(line);

		if (line.startsWith(':')) {
			return null;
		}

		let [fieldname, _, value] = partition(line, ':');

		if (value.startsWith(' ')) {
			value = value.substring(1);
		}

		if (fieldname === 'event') {
			this.event = value;
		} else if (fieldname === 'data') {
			this.data.push(value);
		}

		return null;
	}
}

/**