Skip to content

Commit 64ae1bb

Browse files
autofix-ci[bot]autofix-ci[bot]
authored
ci: apply automated fixes
1 parent 693e472 commit 64ae1bb

5 files changed

Lines changed: 104 additions & 59 deletions

File tree

‎packages/event-bus-client/src/plugin.ts‎

Lines changed: 35 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -19,23 +19,29 @@ declare const __TANSTACK_DEVTOOLS_PROTOCOL__: 'http' | 'https' | undefined
1919

2020
function getDevtoolsPort(): number | undefined {
2121
try {
22-
return typeof __TANSTACK_DEVTOOLS_PORT__ !== 'undefined' ? __TANSTACK_DEVTOOLS_PORT__ : undefined
22+
return typeof __TANSTACK_DEVTOOLS_PORT__ !== 'undefined'
23+
? __TANSTACK_DEVTOOLS_PORT__
24+
: undefined
2325
} catch {
2426
return undefined
2527
}
2628
}
2729

2830
function getDevtoolsHost(): string | undefined {
2931
try {
30-
return typeof __TANSTACK_DEVTOOLS_HOST__ !== 'undefined' ? __TANSTACK_DEVTOOLS_HOST__ : undefined
32+
return typeof __TANSTACK_DEVTOOLS_HOST__ !== 'undefined'
33+
? __TANSTACK_DEVTOOLS_HOST__
34+
: undefined
3135
} catch {
3236
return undefined
3337
}
3438
}
3539

3640
function getDevtoolsProtocol(): 'http' | 'https' | undefined {
3741
try {
38-
return typeof __TANSTACK_DEVTOOLS_PROTOCOL__ !== 'undefined' ? __TANSTACK_DEVTOOLS_PROTOCOL__ : undefined
42+
return typeof __TANSTACK_DEVTOOLS_PROTOCOL__ !== 'undefined'
43+
? __TANSTACK_DEVTOOLS_PROTOCOL__
44+
: undefined
3945
} catch {
4046
return undefined
4147
}
@@ -202,7 +208,10 @@ export class EventClient<TEventMap extends Record<string, any>> {
202208
this.#networkPort = port
203209
this.#networkHost = host
204210
this.#networkProtocol = protocol
205-
this.debugLog('Network transport activated — devtools server detected at port', port)
211+
this.debugLog(
212+
'Network transport activated — devtools server detected at port',
213+
port,
214+
)
206215
}
207216
}
208217

@@ -309,7 +318,9 @@ export class EventClient<TEventMap extends Record<string, any>> {
309318
const target = this.#eventTarget()
310319
try {
311320
target.dispatchEvent(new CustomEvent(event.type, { detail: event }))
312-
target.dispatchEvent(new CustomEvent('tanstack-devtools-global', { detail: event }))
321+
target.dispatchEvent(
322+
new CustomEvent('tanstack-devtools-global', { detail: event }),
323+
)
313324
} catch {
314325
// EventTarget may not support CustomEvent in all environments
315326
}
@@ -349,18 +360,26 @@ export class EventClient<TEventMap extends Record<string, any>> {
349360

350361
this.#wsReconnectAttempts++
351362
if (this.#wsReconnectAttempts >= this.#wsMaxReconnectAttempts) {
352-
this.debugLog('WebSocket permanently unavailable, falling back to HTTP-only')
363+
this.debugLog(
364+
'WebSocket permanently unavailable, falling back to HTTP-only',
365+
)
353366
this.#wsGaveUp = true
354367
// Flush any queued events via HTTP POST
355368
const queued = [...this.#queuedEvents]
356369
this.#queuedEvents = []
357370
for (const event of queued) {
358-
this.sendViaHttp({ ...event, eventId: generateEventId(), source: 'server-bridge' })
371+
this.sendViaHttp({
372+
...event,
373+
eventId: generateEventId(),
374+
source: 'server-bridge',
375+
})
359376
}
360377
return
361378
}
362379

363-
this.debugLog(`Scheduling reconnect in ${this.#wsReconnectDelay}ms (attempt ${this.#wsReconnectAttempts}/${this.#wsMaxReconnectAttempts})`)
380+
this.debugLog(
381+
`Scheduling reconnect in ${this.#wsReconnectDelay}ms (attempt ${this.#wsReconnectAttempts}/${this.#wsMaxReconnectAttempts})`,
382+
)
364383
this.#wsReconnectTimer = setTimeout(() => {
365384
this.#wsReconnectTimer = null
366385
this.connectWebSocket()
@@ -560,7 +579,11 @@ export class EventClient<TEventMap extends Record<string, any>> {
560579
}
561580

562581
/** @internal — only for testing and createNetworkTransportClient */
563-
___enableNetworkTransport(port: number, host: string, protocol: 'http' | 'https') {
582+
___enableNetworkTransport(
583+
port: number,
584+
host: string,
585+
protocol: 'http' | 'https',
586+
) {
564587
this.#useNetworkTransport = true
565588
this.#networkTransportDetected = true
566589
this.#networkPort = port
@@ -591,7 +614,9 @@ export class EventClient<TEventMap extends Record<string, any>> {
591614
* Used for testing and for environments where compile-time placeholder
592615
* replacement is not available.
593616
*/
594-
export function createNetworkTransportClient<TEventMap extends Record<string, any>>({
617+
export function createNetworkTransportClient<
618+
TEventMap extends Record<string, any>,
619+
>({
595620
pluginId,
596621
port,
597622
host = 'localhost',

‎packages/event-bus-client/tests/integration.test.ts‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,9 @@ describe('End-to-end: ServerEventBus + EventClient network transport', () => {
5555
// Wait for connection + delivery
5656
const fromClient = await Promise.race([
5757
serverReceived,
58-
new Promise((_, reject) => setTimeout(() => reject(new Error('timeout: client→server')), 3000)),
58+
new Promise((_, reject) =>
59+
setTimeout(() => reject(new Error('timeout: client→server')), 3000),
60+
),
5961
])
6062

6163
expect(fromClient.payload).toEqual({ direction: 'client-to-server' })
@@ -75,7 +77,9 @@ describe('End-to-end: ServerEventBus + EventClient network transport', () => {
7577

7678
const fromServer = await Promise.race([
7779
clientReceived,
78-
new Promise((_, reject) => setTimeout(() => reject(new Error('timeout: server→client')), 3000)),
80+
new Promise((_, reject) =>
81+
setTimeout(() => reject(new Error('timeout: server→client')), 3000),
82+
),
7983
])
8084

8185
expect(fromServer.payload).toEqual({ direction: 'server-to-client' })

‎packages/event-bus-client/tests/network-transport.test.ts‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,9 @@ describe('EventClient network transport emit', () => {
4646

4747
const event = await Promise.race([
4848
received,
49-
new Promise((_, reject) => setTimeout(() => reject(new Error('timeout')), 3000)),
49+
new Promise((_, reject) =>
50+
setTimeout(() => reject(new Error('timeout')), 3000),
51+
),
5052
])
5153

5254
expect(event.type).toBe('test-network:event')
@@ -90,7 +92,9 @@ describe('EventClient network transport emit', () => {
9092

9193
const event = await Promise.race([
9294
received,
93-
new Promise((_, reject) => setTimeout(() => reject(new Error('timeout')), 3000)),
95+
new Promise((_, reject) =>
96+
setTimeout(() => reject(new Error('timeout')), 3000),
97+
),
9498
])
9599

96100
expect(event.type).toBe('test-receive:incoming')

‎packages/event-bus/src/server/server.ts‎

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -299,7 +299,10 @@ export class ServerEventBus {
299299
socket: Duplex,
300300
head: Buffer,
301301
) => {
302-
if (req.url === '/__devtools/ws' || req.url?.startsWith('/__devtools/ws?')) {
302+
if (
303+
req.url === '/__devtools/ws' ||
304+
req.url?.startsWith('/__devtools/ws?')
305+
) {
303306
wss.handleUpgrade(req, socket, head, (ws) => {
304307
this.debugLog(
305308
'WebSocket connection established (external server)',
@@ -331,7 +334,10 @@ export class ServerEventBus {
331334

332335
// Handle connection upgrade for WebSocket
333336
server.on('upgrade', (req, socket, head) => {
334-
if (req.url === '/__devtools/ws' || req.url?.startsWith('/__devtools/ws?')) {
337+
if (
338+
req.url === '/__devtools/ws' ||
339+
req.url?.startsWith('/__devtools/ws?')
340+
) {
335341
wss.handleUpgrade(req, socket, head, (ws) => {
336342
this.debugLog('WebSocket connection established')
337343
wss.emit('connection', ws, req)

‎packages/event-bus/tests/server.test.ts‎

Lines changed: 49 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -272,9 +272,7 @@ describe('ServerEventBus', () => {
272272
const port = await bus.start()
273273

274274
// Connect a "browser" client (no ?bridge=server)
275-
const browserWs = new WebSocket(
276-
`ws://localhost:${port}/__devtools/ws`,
277-
)
275+
const browserWs = new WebSocket(`ws://localhost:${port}/__devtools/ws`)
278276
await new Promise<void>((resolve) => browserWs.on('open', resolve))
279277

280278
// Connect a "server bridge" client
@@ -285,9 +283,7 @@ describe('ServerEventBus', () => {
285283

286284
// Listen for messages on the browser client
287285
const received = new Promise<any>((resolve) => {
288-
browserWs.on('message', (data) =>
289-
resolve(JSON.parse(data.toString())),
290-
)
286+
browserWs.on('message', (data) => resolve(JSON.parse(data.toString())))
291287
})
292288

293289
// Send event from bridge
@@ -344,14 +340,10 @@ describe('ServerEventBus', () => {
344340
bus = new ServerEventBus({ port: 0 })
345341
const port = await bus.start()
346342

347-
const browserWs1 = new WebSocket(
348-
`ws://localhost:${port}/__devtools/ws`,
349-
)
343+
const browserWs1 = new WebSocket(`ws://localhost:${port}/__devtools/ws`)
350344
await new Promise<void>((resolve) => browserWs1.on('open', resolve))
351345

352-
const browserWs2 = new WebSocket(
353-
`ws://localhost:${port}/__devtools/ws`,
354-
)
346+
const browserWs2 = new WebSocket(`ws://localhost:${port}/__devtools/ws`)
355347
await new Promise<void>((resolve) => browserWs2.on('open', resolve))
356348

357349
let received = false
@@ -396,19 +388,23 @@ describe('ServerEventBus', () => {
396388
const browserWs = new WebSocket(`ws://localhost:${port}/__devtools/ws`)
397389
await new Promise<void>((resolve) => browserWs.on('open', resolve))
398390

399-
const bridgeWs = new WebSocket(`ws://localhost:${port}/__devtools/ws?bridge=server`)
391+
const bridgeWs = new WebSocket(
392+
`ws://localhost:${port}/__devtools/ws?bridge=server`,
393+
)
400394
await new Promise<void>((resolve) => bridgeWs.on('open', resolve))
401395

402396
const received = new Promise<any>((resolve) => {
403397
browserWs.on('message', (data) => resolve(JSON.parse(data.toString())))
404398
})
405399

406-
bridgeWs.send(JSON.stringify({
407-
type: 'test:event',
408-
payload: { from: 'external-bridge' },
409-
pluginId: 'test',
410-
source: 'server-bridge',
411-
}))
400+
bridgeWs.send(
401+
JSON.stringify({
402+
type: 'test:event',
403+
payload: { from: 'external-bridge' },
404+
pluginId: 'test',
405+
source: 'server-bridge',
406+
}),
407+
)
412408

413409
const event = await received
414410
expect(event.type).toBe('test:event')
@@ -434,18 +430,23 @@ describe('ServerEventBus', () => {
434430

435431
// POST with source: 'server-bridge'
436432
await new Promise<void>((resolve) => {
437-
const req = http.request({
438-
hostname: 'localhost',
439-
port,
440-
path: '/__devtools/send',
441-
method: 'POST',
442-
headers: { 'Content-Type': 'application/json' },
443-
}, () => resolve())
444-
req.write(JSON.stringify({
445-
type: 'test:event',
446-
payload: { from: 'bridge' },
447-
source: 'server-bridge',
448-
}))
433+
const req = http.request(
434+
{
435+
hostname: 'localhost',
436+
port,
437+
path: '/__devtools/send',
438+
method: 'POST',
439+
headers: { 'Content-Type': 'application/json' },
440+
},
441+
() => resolve(),
442+
)
443+
req.write(
444+
JSON.stringify({
445+
type: 'test:event',
446+
payload: { from: 'bridge' },
447+
source: 'server-bridge',
448+
}),
449+
)
449450
req.end()
450451
})
451452

@@ -483,18 +484,23 @@ describe('ServerEventBus', () => {
483484
})
484485

485486
await new Promise<void>((resolve) => {
486-
const req = http.request({
487-
hostname: 'localhost',
488-
port,
489-
path: '/__devtools/send',
490-
method: 'POST',
491-
headers: { 'Content-Type': 'application/json' },
492-
}, () => resolve())
493-
req.write(JSON.stringify({
494-
type: 'test:event',
495-
payload: { from: 'bridge' },
496-
source: 'server-bridge',
497-
}))
487+
const req = http.request(
488+
{
489+
hostname: 'localhost',
490+
port,
491+
path: '/__devtools/send',
492+
method: 'POST',
493+
headers: { 'Content-Type': 'application/json' },
494+
},
495+
() => resolve(),
496+
)
497+
req.write(
498+
JSON.stringify({
499+
type: 'test:event',
500+
payload: { from: 'bridge' },
501+
source: 'server-bridge',
502+
}),
503+
)
498504
req.end()
499505
})
500506

0 commit comments

Comments
 (0)