|
| 1 | +let connected = false; |
| 2 | +let socket: WebSocket; |
| 3 | +let initialised = false; |
| 4 | + |
| 5 | +const defaultLog = console.log; |
| 6 | +const defaultWarn = console.warn; |
| 7 | +const defaultError = console.error; |
| 8 | + |
| 9 | +/** |
| 10 | + * Overrides console.log, warn & error to also send to logging server. |
| 11 | + * Allows retrieving logs when running Cypress tests. |
| 12 | + * Logging server must be running for this to work. See https://www.npmjs.com/package/browser-logging-server. |
| 13 | + */ |
| 14 | +export const initialise = (host: string = "localhost", port: number = 8888) => { |
| 15 | + if (initialised) return; |
| 16 | + initialised = true; |
| 17 | + |
| 18 | + socket = new WebSocket(`ws://${host}:${port}`); |
| 19 | + socket.onopen = () => (connected = true); |
| 20 | + |
| 21 | + console.log(`Piping browser logs to logging server at ws://${host}:${port}`); |
| 22 | + |
| 23 | + console.log = pipeToLoggingServer(defaultLog, "INFO"); |
| 24 | + console.warn = pipeToLoggingServer(defaultWarn, "WARN"); |
| 25 | + console.error = pipeToLoggingServer(defaultError, "ERROR"); |
| 26 | +}; |
| 27 | + |
| 28 | +const pipeToLoggingServer = (logger: (...args: any[]) => void, logLevel: string) => (...args: any[]) => { |
| 29 | + logger(...args); |
| 30 | + |
| 31 | + sendToLoggingServer(Date.now(), logLevel, args, 0); |
| 32 | +}; |
| 33 | + |
| 34 | +const sendToLoggingServer = (timestamp: number, logLevel: string, message: any[], retryCount: number) => { |
| 35 | + if (!connected && retryCount < 10) { |
| 36 | + // websocket not connected - retry a bit later |
| 37 | + setTimeout(() => sendToLoggingServer(timestamp, logLevel, message, retryCount++), 200); |
| 38 | + return; |
| 39 | + } |
| 40 | + try { |
| 41 | + socket.send(JSON.stringify({ timestamp, logLevel, message }, replaceErrors)); |
| 42 | + } catch (e) { |
| 43 | + defaultError("Error sending to logging server:", e); |
| 44 | + } |
| 45 | +}; |
| 46 | + |
| 47 | +// override error stringification (otherwise they display as "{}") |
| 48 | +const replaceErrors = (key: string, value: any) => { |
| 49 | + if (value instanceof Error) { |
| 50 | + const error: { [key: string]: any } = {}; |
| 51 | + |
| 52 | + Object.getOwnPropertyNames(value).forEach(key => { |
| 53 | + // @ts-ignore |
| 54 | + error[key] = value[key]; |
| 55 | + }); |
| 56 | + |
| 57 | + return error; |
| 58 | + } |
| 59 | + |
| 60 | + return value; |
| 61 | +}; |
0 commit comments