highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-09-17 19:13:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: use utf8 instead of utf-8 for ws messages

Browse Source
This commit is contained in:
Ricardo Arturo Cabral Mejía
2022-11-12 07:11:36 -05:00
parent 4b58bc7861
commit 4dc2405317
5 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
test/integration/features/helpers.ts
View File

@@ -97,7 +97,7 @@ export async function waitForEOSE(ws: WebSocket, subscription: string): Promise<
ws.once('error', onError)
function onMessage(raw: RawData) {
const message = JSON.parse(raw.toString('utf-8'))
const message = JSON.parse(raw.toString('utf8'))
if (message[0] === MessageType.EOSE && message[1] === subscription) {
resolve()
cleanup()
@@ -139,7 +139,7 @@ export async function waitForNextEvent(ws: WebSocket, subscription: string): Pro
}
function onMessage(raw: RawData) {
const message = JSON.parse(raw.toString('utf-8'))
const message = JSON.parse(raw.toString('utf8'))
if (message[0] === MessageType.EVENT && message[1] === subscription) {
resolve(message[2])
cleanup()
@@ -172,7 +172,7 @@ export async function waitForEventCount(
cleanup()
}
function onMessage(raw: RawData) {
const message = JSON.parse(raw.toString('utf-8'))
const message = JSON.parse(raw.toString('utf8'))
if (message[0] === MessageType.EVENT && message[1] === subscription) {
events.push(message[2])
if (!eose && events.length === count) {
@@ -213,7 +213,7 @@ export async function waitForNotice(ws: WebSocket): Promise<void> {
ws.once('error', onError)
function onMessage(raw: RawData) {
const message = JSON.parse(raw.toString('utf-8'))
const message = JSON.parse(raw.toString('utf8'))
if (message[0] === MessageType.NOTICE) {
resolve(message[1])
cleanup()

2
test/unit/factories/websocket-adapter-factory.spec.ts
View File

@@ -28,7 +28,7 @@ describe('webSocketAdapterFactory', () => {
onStub.returns(client)
const request: IncomingMessage = {
headers: {
'sec-websocket-key': Buffer.from('key', 'utf-8').toString('base64'),
'sec-websocket-key': Buffer.from('key', 'utf8').toString('base64'),
},
} as any
const webSocketServerAdapter: IWebSocketServerAdapter = {} as any