mirror of
https://github.com/Xahau/xahau.js.git
synced 2025-12-06 17:27:59 +00:00
fix mock test
This commit is contained in:
@@ -10,7 +10,7 @@ import type {
|
||||
|
||||
import { destroyServer, getFreePort } from './testUtils'
|
||||
|
||||
function createResponse(
|
||||
export function createResponse(
|
||||
request: { id: number | string },
|
||||
response: Record<string, unknown>,
|
||||
): string {
|
||||
@@ -36,24 +36,6 @@ function ping(conn, request): void {
|
||||
}, 1000 * 2)
|
||||
}
|
||||
|
||||
function server_info(conn, request): void {
|
||||
setTimeout(() => {
|
||||
conn.send(
|
||||
createResponse(request, {
|
||||
id: 0,
|
||||
result: {
|
||||
info: {
|
||||
build_version: '1.7.3',
|
||||
network_id: '1.11.0',
|
||||
},
|
||||
},
|
||||
status: 'success',
|
||||
type: 'response',
|
||||
}),
|
||||
)
|
||||
}, 1000 * 2)
|
||||
}
|
||||
|
||||
export interface PortResponse extends BaseResponse {
|
||||
result: {
|
||||
port: number
|
||||
@@ -128,8 +110,6 @@ export default function createMockRippled(port: number): MockedWebSocketServer {
|
||||
mock.testCommand(conn, request)
|
||||
} else if (request.command in mock.responses) {
|
||||
conn.send(createResponse(request, mock.getResponse(request)))
|
||||
} else if (request.command === 'server_info') {
|
||||
server_info(conn, request)
|
||||
} else {
|
||||
throw new XrplError(
|
||||
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions -- We know it's there
|
||||
|
||||
@@ -5,6 +5,7 @@ import BroadcastClient from '../src/client/BroadcastClient'
|
||||
import createMockRippled, {
|
||||
type MockedWebSocketServer,
|
||||
} from './createMockRippled'
|
||||
import rippled from './fixtures/rippled'
|
||||
import { destroyServer, getFreePort } from './testUtils'
|
||||
|
||||
export interface XrplTestContext {
|
||||
@@ -30,6 +31,10 @@ async function setupMockRippledConnection(
|
||||
// We must have an error listener attached for reconnect errors
|
||||
})
|
||||
|
||||
context.client.on('connected', () => {
|
||||
context.mockRippled?.addResponse('server_info', rippled.server_info.normal)
|
||||
})
|
||||
|
||||
return context.client.connect().then(() => context)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user