(msg: d.DevServerMessage)
| 95 | }; |
| 96 | |
| 97 | const receiveMessageFromMain = (msg: d.DevServerMessage) => { |
| 98 | // the server process received a message from main thread |
| 99 | try { |
| 100 | if (msg) { |
| 101 | if (msg.startServer) { |
| 102 | startServer(msg); |
| 103 | } else if (msg.closeServer) { |
| 104 | closeServer(); |
| 105 | } else if (msg.compilerRequestResults) { |
| 106 | for (let i = compilerRequestResolves.length - 1; i >= 0; i--) { |
| 107 | const r = compilerRequestResolves[i]; |
| 108 | if (r.path === msg.compilerRequestResults.path) { |
| 109 | r.resolve(msg.compilerRequestResults); |
| 110 | compilerRequestResolves.splice(i, 1); |
| 111 | } |
| 112 | } |
| 113 | } else if (serverCtx) { |
| 114 | if (msg.buildResults && !msg.isActivelyBuilding) { |
| 115 | buildResultsResolves.forEach((r) => r.resolve(msg.buildResults)); |
| 116 | buildResultsResolves.length = 0; |
| 117 | } |
| 118 | if (webSocket) { |
| 119 | webSocket.sendToBrowser(msg); |
| 120 | } |
| 121 | } |
| 122 | } |
| 123 | } catch (e) { |
| 124 | let stack: string | null = null; |
| 125 | if (e instanceof Error) { |
| 126 | stack = e.stack; |
| 127 | } |
| 128 | sendMsg({ |
| 129 | error: { message: e + '', stack }, |
| 130 | }); |
| 131 | } |
| 132 | }; |
| 133 | |
| 134 | return receiveMessageFromMain; |
| 135 | } |
no test coverage detected