diff options
author | Kristóf Marussy <kristof@marussy.com> | 2022-11-10 14:35:24 +0100 |
---|---|---|
committer | Kristóf Marussy <kristof@marussy.com> | 2022-11-10 14:35:24 +0100 |
commit | 4971c864a603e0c01f7ad84a23697905d096283b (patch) | |
tree | fc2ed2ced39aa50aa98602ad4bd2a9d877577dcd /subprojects | |
parent | refactor: rename CallKind to Polarity (diff) | |
download | refinery-4971c864a603e0c01f7ad84a23697905d096283b.tar.gz refinery-4971c864a603e0c01f7ad84a23697905d096283b.tar.zst refinery-4971c864a603e0c01f7ad84a23697905d096283b.zip |
feat(web): backend URL configuration
To point the frontend to a backend server, update the config.json
file in the website root.
The config.json is generated automatically in debug mode and when
running from a standalone jar.
Diffstat (limited to 'subprojects')
15 files changed, 213 insertions, 131 deletions
diff --git a/subprojects/frontend/package.json b/subprojects/frontend/package.json index 10de68ee..ed4b101b 100644 --- a/subprojects/frontend/package.json +++ b/subprojects/frontend/package.json | |||
@@ -29,21 +29,21 @@ | |||
29 | "@codemirror/lint": "^6.0.0", | 29 | "@codemirror/lint": "^6.0.0", |
30 | "@codemirror/search": "^6.2.2", | 30 | "@codemirror/search": "^6.2.2", |
31 | "@codemirror/state": "^6.1.2", | 31 | "@codemirror/state": "^6.1.2", |
32 | "@codemirror/view": "^6.4.0", | 32 | "@codemirror/view": "^6.4.1", |
33 | "@emotion/react": "^11.10.5", | 33 | "@emotion/react": "^11.10.5", |
34 | "@emotion/styled": "^11.10.5", | 34 | "@emotion/styled": "^11.10.5", |
35 | "@fontsource/inter": "^4.5.14", | 35 | "@fontsource/inter": "^4.5.14", |
36 | "@fontsource/jetbrains-mono": "^4.5.11", | 36 | "@fontsource/jetbrains-mono": "^4.5.11", |
37 | "@lezer/common": "^1.0.1", | 37 | "@lezer/common": "^1.0.1", |
38 | "@lezer/highlight": "^1.1.2", | 38 | "@lezer/highlight": "^1.1.2", |
39 | "@lezer/lr": "^1.2.3", | 39 | "@lezer/lr": "^1.2.4", |
40 | "@material-icons/svg": "^1.0.33", | 40 | "@material-icons/svg": "^1.0.33", |
41 | "@mui/icons-material": "5.10.9", | 41 | "@mui/icons-material": "5.10.9", |
42 | "@mui/material": "5.10.12", | 42 | "@mui/material": "5.10.13", |
43 | "ansi-styles": "^6.2.1", | 43 | "ansi-styles": "^6.2.1", |
44 | "escape-string-regexp": "^5.0.0", | 44 | "escape-string-regexp": "^5.0.0", |
45 | "lodash-es": "^4.17.21", | 45 | "lodash-es": "^4.17.21", |
46 | "loglevel": "^1.8.0", | 46 | "loglevel": "^1.8.1", |
47 | "loglevel-plugin-prefix": "^0.8.4", | 47 | "loglevel-plugin-prefix": "^0.8.4", |
48 | "mobx": "^6.6.2", | 48 | "mobx": "^6.6.2", |
49 | "mobx-react-lite": "^3.4.0", | 49 | "mobx-react-lite": "^3.4.0", |
@@ -56,7 +56,7 @@ | |||
56 | "zod": "^3.19.1" | 56 | "zod": "^3.19.1" |
57 | }, | 57 | }, |
58 | "devDependencies": { | 58 | "devDependencies": { |
59 | "@lezer/generator": "^1.1.1", | 59 | "@lezer/generator": "^1.1.3", |
60 | "@types/eslint": "^8.4.10", | 60 | "@types/eslint": "^8.4.10", |
61 | "@types/html-minifier-terser": "^7.0.0", | 61 | "@types/html-minifier-terser": "^7.0.0", |
62 | "@types/lodash-es": "^4.17.6", | 62 | "@types/lodash-es": "^4.17.6", |
@@ -65,12 +65,12 @@ | |||
65 | "@types/prettier": "^2.7.1", | 65 | "@types/prettier": "^2.7.1", |
66 | "@types/react": "^18.0.25", | 66 | "@types/react": "^18.0.25", |
67 | "@types/react-dom": "^18.0.8", | 67 | "@types/react-dom": "^18.0.8", |
68 | "@typescript-eslint/eslint-plugin": "^5.42.0", | 68 | "@typescript-eslint/eslint-plugin": "^5.42.1", |
69 | "@typescript-eslint/parser": "^5.42.0", | 69 | "@typescript-eslint/parser": "^5.42.1", |
70 | "@vitejs/plugin-react": "^2.2.0", | 70 | "@vitejs/plugin-react": "^2.2.0", |
71 | "@xstate/cli": "^0.3.3", | 71 | "@xstate/cli": "^0.3.3", |
72 | "cross-env": "^7.0.3", | 72 | "cross-env": "^7.0.3", |
73 | "eslint": "^8.26.0", | 73 | "eslint": "^8.27.0", |
74 | "eslint-config-airbnb": "^19.0.4", | 74 | "eslint-config-airbnb": "^19.0.4", |
75 | "eslint-config-airbnb-typescript": "^17.0.0", | 75 | "eslint-config-airbnb-typescript": "^17.0.0", |
76 | "eslint-config-prettier": "^8.5.0", | 76 | "eslint-config-prettier": "^8.5.0", |
@@ -84,9 +84,9 @@ | |||
84 | "html-minifier-terser": "^7.0.0", | 84 | "html-minifier-terser": "^7.0.0", |
85 | "prettier": "^2.7.1", | 85 | "prettier": "^2.7.1", |
86 | "typescript": "4.8.4", | 86 | "typescript": "4.8.4", |
87 | "vite": "^3.2.2", | 87 | "vite": "^3.2.3", |
88 | "vite-plugin-inject-preload": "^1.1.0", | 88 | "vite-plugin-inject-preload": "^1.1.0", |
89 | "vite-plugin-pwa": "^0.13.2", | 89 | "vite-plugin-pwa": "^0.13.3", |
90 | "workbox-window": "^6.5.4" | 90 | "workbox-window": "^6.5.4" |
91 | } | 91 | } |
92 | } | 92 | } |
diff --git a/subprojects/frontend/src/RootStore.ts b/subprojects/frontend/src/RootStore.ts index 54a80501..2e76d66d 100644 --- a/subprojects/frontend/src/RootStore.ts +++ b/subprojects/frontend/src/RootStore.ts | |||
@@ -23,18 +23,17 @@ export default class RootStore { | |||
23 | pwaStore: false, | 23 | pwaStore: false, |
24 | themeStore: false, | 24 | themeStore: false, |
25 | }); | 25 | }); |
26 | import('./editor/EditorStore') | 26 | (async () => { |
27 | .then(({ default: EditorStore }) => { | 27 | const { default: EditorStore } = await import('./editor/EditorStore'); |
28 | runInAction(() => { | 28 | runInAction(() => { |
29 | if (this.disposed) { | 29 | if (this.disposed) { |
30 | return; | 30 | return; |
31 | } | 31 | } |
32 | this.editorStore = new EditorStore(initialValue, this.pwaStore); | 32 | this.editorStore = new EditorStore(initialValue, this.pwaStore); |
33 | }); | ||
34 | }) | ||
35 | .catch((error) => { | ||
36 | log.error('Failed to load EditorStore', error); | ||
37 | }); | 33 | }); |
34 | })().catch((error) => { | ||
35 | log.error('Failed to load EditorStore', error); | ||
36 | }); | ||
38 | } | 37 | } |
39 | 38 | ||
40 | dispose(): void { | 39 | dispose(): void { |
diff --git a/subprojects/frontend/src/xtext/XtextClient.ts b/subprojects/frontend/src/xtext/XtextClient.ts index e7d26ae6..14fb2430 100644 --- a/subprojects/frontend/src/xtext/XtextClient.ts +++ b/subprojects/frontend/src/xtext/XtextClient.ts | |||
@@ -35,8 +35,7 @@ export default class XtextClient { | |||
35 | this.webSocketClient = new XtextWebSocketClient( | 35 | this.webSocketClient = new XtextWebSocketClient( |
36 | () => this.onReconnect(), | 36 | () => this.onReconnect(), |
37 | () => this.onDisconnect(), | 37 | () => this.onDisconnect(), |
38 | (resource, stateId, service, push) => | 38 | this.onPush.bind(this), |
39 | this.onPush(resource, stateId, service, push), | ||
40 | ); | 39 | ); |
41 | this.updateService = new UpdateService(store, this.webSocketClient); | 40 | this.updateService = new UpdateService(store, this.webSocketClient); |
42 | this.contentAssistService = new ContentAssistService(this.updateService); | 41 | this.contentAssistService = new ContentAssistService(this.updateService); |
diff --git a/subprojects/frontend/src/xtext/XtextWebSocketClient.ts b/subprojects/frontend/src/xtext/XtextWebSocketClient.ts index a39620cb..6b734546 100644 --- a/subprojects/frontend/src/xtext/XtextWebSocketClient.ts +++ b/subprojects/frontend/src/xtext/XtextWebSocketClient.ts | |||
@@ -7,7 +7,8 @@ import CancelledError from '../utils/CancelledError'; | |||
7 | import PendingTask from '../utils/PendingTask'; | 7 | import PendingTask from '../utils/PendingTask'; |
8 | import getLogger from '../utils/getLogger'; | 8 | import getLogger from '../utils/getLogger'; |
9 | 9 | ||
10 | import webSocketMachine, { isWebSocketURLLocal } from './webSocketMachine'; | 10 | import fetchBackendConfig from './fetchBackendConfig'; |
11 | import webSocketMachine from './webSocketMachine'; | ||
11 | import { | 12 | import { |
12 | type XtextWebPushService, | 13 | type XtextWebPushService, |
13 | XtextResponse, | 14 | XtextResponse, |
@@ -42,26 +43,18 @@ export default class XtextWebSocketClient { | |||
42 | private readonly pendingRequests = new Map<string, PendingTask<unknown>>(); | 43 | private readonly pendingRequests = new Map<string, PendingTask<unknown>>(); |
43 | 44 | ||
44 | private readonly interpreter = interpret( | 45 | private readonly interpreter = interpret( |
45 | webSocketMachine | 46 | webSocketMachine.withConfig({ |
46 | .withContext({ | 47 | actions: { |
47 | ...webSocketMachine.context, | 48 | openWebSocket: () => this.openWebSocket(), |
48 | webSocketURL: `${window.location.origin.replace( | 49 | closeWebSocket: () => this.closeWebSocket(), |
49 | /^http/, | 50 | notifyReconnect: () => this.onReconnect(), |
50 | 'ws', | 51 | notifyDisconnect: () => this.onDisconnect(), |
51 | )}/xtext-service`, | 52 | cancelPendingRequests: () => this.cancelPendingRequests(), |
52 | }) | 53 | }, |
53 | .withConfig({ | 54 | services: { |
54 | actions: { | 55 | pingService: () => this.sendPing(), |
55 | openWebSocket: ({ webSocketURL }) => this.openWebSocket(webSocketURL), | 56 | }, |
56 | closeWebSocket: () => this.closeWebSocket(), | 57 | }), |
57 | notifyReconnect: () => this.onReconnect(), | ||
58 | notifyDisconnect: () => this.onDisconnect(), | ||
59 | cancelPendingRequests: () => this.cancelPendingRequests(), | ||
60 | }, | ||
61 | services: { | ||
62 | pingService: () => this.sendPing(), | ||
63 | }, | ||
64 | }), | ||
65 | { | 58 | { |
66 | logger: log.log.bind(log), | 59 | logger: log.log.bind(log), |
67 | }, | 60 | }, |
@@ -151,6 +144,7 @@ export default class XtextWebSocketClient { | |||
151 | | 'webSocket' | 144 | | 'webSocket' |
152 | | 'interpreter' | 145 | | 'interpreter' |
153 | | 'openListener' | 146 | | 'openListener' |
147 | | 'openWebSocket' | ||
154 | | 'errorListener' | 148 | | 'errorListener' |
155 | | 'closeListener' | 149 | | 'closeListener' |
156 | | 'messageListener' | 150 | | 'messageListener' |
@@ -160,6 +154,7 @@ export default class XtextWebSocketClient { | |||
160 | webSocket: observable.ref, | 154 | webSocket: observable.ref, |
161 | interpreter: false, | 155 | interpreter: false, |
162 | openListener: false, | 156 | openListener: false, |
157 | openWebSocket: false, | ||
163 | errorListener: false, | 158 | errorListener: false, |
164 | closeListener: false, | 159 | closeListener: false, |
165 | messageListener: false, | 160 | messageListener: false, |
@@ -221,9 +216,7 @@ export default class XtextWebSocketClient { | |||
221 | get networkMissing(): boolean { | 216 | get networkMissing(): boolean { |
222 | return ( | 217 | return ( |
223 | this.state.matches('connection.temporarilyOffline') || | 218 | this.state.matches('connection.temporarilyOffline') || |
224 | (this.disconnectedByUser && | 219 | (this.disconnectedByUser && this.state.matches('network.offline')) |
225 | this.state.matches('network.offline') && | ||
226 | !isWebSocketURLLocal(this.state.context.webSocketURL)) | ||
227 | ); | 220 | ); |
228 | } | 221 | } |
229 | 222 | ||
@@ -275,17 +268,27 @@ export default class XtextWebSocketClient { | |||
275 | this.interpreter.send(document.hidden ? 'TAB_HIDDEN' : 'TAB_VISIBLE'); | 268 | this.interpreter.send(document.hidden ? 'TAB_HIDDEN' : 'TAB_VISIBLE'); |
276 | } | 269 | } |
277 | 270 | ||
278 | private openWebSocket(webSocketURL: string | undefined): void { | 271 | private openWebSocket(): void { |
279 | if (this.webSocket !== undefined) { | 272 | if (this.webSocket !== undefined) { |
280 | throw new Error('WebSocket already open'); | 273 | throw new Error('WebSocket already open'); |
281 | } | 274 | } |
282 | 275 | ||
283 | if (webSocketURL === undefined) { | ||
284 | throw new Error('URL not configured'); | ||
285 | } | ||
286 | |||
287 | log.debug('Creating WebSocket'); | 276 | log.debug('Creating WebSocket'); |
288 | 277 | ||
278 | (async () => { | ||
279 | const { webSocketURL } = await fetchBackendConfig(); | ||
280 | this.openWebSocketWithURL(webSocketURL); | ||
281 | })().catch((error) => { | ||
282 | log.error('Error while initializing connection', error); | ||
283 | const message = error instanceof Error ? error.message : String(error); | ||
284 | this.interpreter.send({ | ||
285 | type: 'ERROR', | ||
286 | message, | ||
287 | }); | ||
288 | }); | ||
289 | } | ||
290 | |||
291 | private openWebSocketWithURL(webSocketURL: string): void { | ||
289 | this.webSocket = new WebSocket(webSocketURL, XTEXT_SUBPROTOCOL_V1); | 292 | this.webSocket = new WebSocket(webSocketURL, XTEXT_SUBPROTOCOL_V1); |
290 | this.webSocket.addEventListener('open', this.openListener); | 293 | this.webSocket.addEventListener('open', this.openListener); |
291 | this.webSocket.addEventListener('close', this.closeListener); | 294 | this.webSocket.addEventListener('close', this.closeListener); |
@@ -295,7 +298,9 @@ export default class XtextWebSocketClient { | |||
295 | 298 | ||
296 | private closeWebSocket() { | 299 | private closeWebSocket() { |
297 | if (this.webSocket === undefined) { | 300 | if (this.webSocket === undefined) { |
298 | throw new Error('WebSocket already closed'); | 301 | // We might get here when there is a network error before the socket is initialized |
302 | // and we don't have to do anything to close it. | ||
303 | return; | ||
299 | } | 304 | } |
300 | 305 | ||
301 | log.debug('Closing WebSocket'); | 306 | log.debug('Closing WebSocket'); |
diff --git a/subprojects/frontend/src/xtext/fetchBackendConfig.ts b/subprojects/frontend/src/xtext/fetchBackendConfig.ts new file mode 100644 index 00000000..f8087a70 --- /dev/null +++ b/subprojects/frontend/src/xtext/fetchBackendConfig.ts | |||
@@ -0,0 +1,16 @@ | |||
1 | /* eslint-disable @typescript-eslint/no-redeclare -- Declare types with their companion objects */ | ||
2 | |||
3 | import { z } from 'zod'; | ||
4 | |||
5 | export const BackendConfig = z.object({ | ||
6 | webSocketURL: z.string().url(), | ||
7 | }); | ||
8 | |||
9 | export type BackendConfig = z.infer<typeof BackendConfig>; | ||
10 | |||
11 | export default async function fetchBackendConfig(): Promise<BackendConfig> { | ||
12 | const configURL = `${import.meta.env.BASE_URL}config.json`; | ||
13 | const response = await fetch(configURL); | ||
14 | const rawConfig = (await response.json()) as unknown; | ||
15 | return BackendConfig.parse(rawConfig); | ||
16 | } | ||
diff --git a/subprojects/frontend/src/xtext/webSocketMachine.ts b/subprojects/frontend/src/xtext/webSocketMachine.ts index b5b40d11..5f6bc604 100644 --- a/subprojects/frontend/src/xtext/webSocketMachine.ts +++ b/subprojects/frontend/src/xtext/webSocketMachine.ts | |||
@@ -6,12 +6,10 @@ const { raise } = actions; | |||
6 | const ERROR_WAIT_TIMES = ['200', '1s', '5s', '30s'].map(ms); | 6 | const ERROR_WAIT_TIMES = ['200', '1s', '5s', '30s'].map(ms); |
7 | 7 | ||
8 | export interface WebSocketContext { | 8 | export interface WebSocketContext { |
9 | webSocketURL: string | undefined; | ||
10 | errors: string[]; | 9 | errors: string[]; |
11 | } | 10 | } |
12 | 11 | ||
13 | export type WebSocketEvent = | 12 | export type WebSocketEvent = |
14 | | { type: 'CONFIGURE'; webSocketURL: string } | ||
15 | | { type: 'CONNECT' } | 13 | | { type: 'CONNECT' } |
16 | | { type: 'DISCONNECT' } | 14 | | { type: 'DISCONNECT' } |
17 | | { type: 'OPENED' } | 15 | | { type: 'OPENED' } |
@@ -25,24 +23,6 @@ export type WebSocketEvent = | |||
25 | | { type: 'OFFLINE' } | 23 | | { type: 'OFFLINE' } |
26 | | { type: 'ERROR'; message: string }; | 24 | | { type: 'ERROR'; message: string }; |
27 | 25 | ||
28 | export function isWebSocketURLLocal(webSocketURL: string | undefined): boolean { | ||
29 | if (webSocketURL === undefined) { | ||
30 | return false; | ||
31 | } | ||
32 | let hostname: string; | ||
33 | try { | ||
34 | ({ hostname } = new URL(webSocketURL)); | ||
35 | } catch { | ||
36 | return false; | ||
37 | } | ||
38 | // https://stackoverflow.com/a/57949518 | ||
39 | return ( | ||
40 | hostname === 'localhost' || | ||
41 | hostname === '[::1]' || | ||
42 | hostname.match(/^127(?:\.(?:25[0-5]|2[0-4]\d|[01]?\d\d?)){3}$/) !== null | ||
43 | ); | ||
44 | } | ||
45 | |||
46 | export default createMachine( | 26 | export default createMachine( |
47 | { | 27 | { |
48 | id: 'webSocket', | 28 | id: 'webSocket', |
@@ -53,7 +33,6 @@ export default createMachine( | |||
53 | }, | 33 | }, |
54 | tsTypes: {} as import('./webSocketMachine.typegen').Typegen0, | 34 | tsTypes: {} as import('./webSocketMachine.typegen').Typegen0, |
55 | context: { | 35 | context: { |
56 | webSocketURL: undefined, | ||
57 | errors: [], | 36 | errors: [], |
58 | }, | 37 | }, |
59 | type: 'parallel', | 38 | type: 'parallel', |
@@ -65,16 +44,12 @@ export default createMachine( | |||
65 | disconnected: { | 44 | disconnected: { |
66 | id: 'disconnected', | 45 | id: 'disconnected', |
67 | entry: ['clearErrors', 'notifyDisconnect'], | 46 | entry: ['clearErrors', 'notifyDisconnect'], |
68 | on: { | ||
69 | CONFIGURE: { actions: 'configure' }, | ||
70 | }, | ||
71 | }, | 47 | }, |
72 | timedOut: { | 48 | timedOut: { |
73 | id: 'timedOut', | 49 | id: 'timedOut', |
74 | always: [ | 50 | always: [ |
75 | { | 51 | { |
76 | target: 'temporarilyOffline', | 52 | target: 'temporarilyOffline', |
77 | cond: 'needsNetwork', | ||
78 | in: '#offline', | 53 | in: '#offline', |
79 | }, | 54 | }, |
80 | { target: 'socketCreated', in: '#tabVisible' }, | 55 | { target: 'socketCreated', in: '#tabVisible' }, |
@@ -89,7 +64,6 @@ export default createMachine( | |||
89 | always: [ | 64 | always: [ |
90 | { | 65 | { |
91 | target: 'temporarilyOffline', | 66 | target: 'temporarilyOffline', |
92 | cond: 'needsNetwork', | ||
93 | in: '#offline', | 67 | in: '#offline', |
94 | }, | 68 | }, |
95 | ], | 69 | ], |
@@ -183,7 +157,7 @@ export default createMachine( | |||
183 | }, | 157 | }, |
184 | }, | 158 | }, |
185 | on: { | 159 | on: { |
186 | CONNECT: { target: '.timedOut', cond: 'hasWebSocketURL' }, | 160 | CONNECT: '.timedOut', |
187 | DISCONNECT: '.disconnected', | 161 | DISCONNECT: '.disconnected', |
188 | }, | 162 | }, |
189 | }, | 163 | }, |
@@ -224,10 +198,6 @@ export default createMachine( | |||
224 | }, | 198 | }, |
225 | }, | 199 | }, |
226 | { | 200 | { |
227 | guards: { | ||
228 | hasWebSocketURL: ({ webSocketURL }) => webSocketURL !== undefined, | ||
229 | needsNetwork: ({ webSocketURL }) => !isWebSocketURLLocal(webSocketURL), | ||
230 | }, | ||
231 | delays: { | 201 | delays: { |
232 | IDLE_TIMEOUT: ms('5m'), | 202 | IDLE_TIMEOUT: ms('5m'), |
233 | OPEN_TIMEOUT: ms('10s'), | 203 | OPEN_TIMEOUT: ms('10s'), |
@@ -239,10 +209,6 @@ export default createMachine( | |||
239 | }, | 209 | }, |
240 | }, | 210 | }, |
241 | actions: { | 211 | actions: { |
242 | configure: assign((context, { webSocketURL }) => ({ | ||
243 | ...context, | ||
244 | webSocketURL, | ||
245 | })), | ||
246 | pushError: assign((context, { message }) => ({ | 212 | pushError: assign((context, { message }) => ({ |
247 | ...context, | 213 | ...context, |
248 | errors: [...context.errors, message], | 214 | errors: [...context.errors, message], |
diff --git a/subprojects/frontend/types/ImportMeta.d.ts b/subprojects/frontend/types/ImportMeta.d.ts index 2008e268..c32b48f5 100644 --- a/subprojects/frontend/types/ImportMeta.d.ts +++ b/subprojects/frontend/types/ImportMeta.d.ts | |||
@@ -1,5 +1,6 @@ | |||
1 | interface ImportMeta { | 1 | interface ImportMeta { |
2 | env: { | 2 | env: { |
3 | BASE_URL: string; | ||
3 | DEV: boolean; | 4 | DEV: boolean; |
4 | MODE: string; | 5 | MODE: string; |
5 | PROD: boolean; | 6 | PROD: boolean; |
diff --git a/subprojects/frontend/vite.config.ts b/subprojects/frontend/vite.config.ts index e690d005..526ea541 100644 --- a/subprojects/frontend/vite.config.ts +++ b/subprojects/frontend/vite.config.ts | |||
@@ -30,6 +30,7 @@ const apiPort = portNumberOrElse('API_PORT', 1312); | |||
30 | const apiSecure = apiPort === 443; | 30 | const apiSecure = apiPort === 443; |
31 | const publicHost = process.env.PUBLIC_HOST || listenHost; | 31 | const publicHost = process.env.PUBLIC_HOST || listenHost; |
32 | const publicPort = portNumberOrElse('PUBLIC_PORT', listenPort); | 32 | const publicPort = portNumberOrElse('PUBLIC_PORT', listenPort); |
33 | const publicSecure = publicPort === 443; | ||
33 | 34 | ||
34 | const { name: packageName, version: packageVersion } = JSON.parse( | 35 | const { name: packageName, version: packageVersion } = JSON.parse( |
35 | readFileSync(path.join(thisDir, 'package.json'), 'utf8'), | 36 | readFileSync(path.join(thisDir, 'package.json'), 'utf8'), |
@@ -56,6 +57,23 @@ const minifyPlugin: PluginOption = { | |||
56 | }, | 57 | }, |
57 | }; | 58 | }; |
58 | 59 | ||
60 | const backendConfigPlugin: PluginOption = { | ||
61 | name: 'backend-config', | ||
62 | configureServer(server) { | ||
63 | const protocol = publicSecure ? 'wss' : 'ws'; | ||
64 | const webSocketURL = `${protocol}://${publicHost}:${publicPort}/xtext-service`; | ||
65 | const config = JSON.stringify({ webSocketURL }); | ||
66 | server.middlewares.use((req, res, next) => { | ||
67 | if (req.url === '/config.json') { | ||
68 | res.setHeader('Content-Type', 'application/json'); | ||
69 | res.end(config); | ||
70 | } else { | ||
71 | next(); | ||
72 | } | ||
73 | }); | ||
74 | }, | ||
75 | }; | ||
76 | |||
59 | export default defineConfig({ | 77 | export default defineConfig({ |
60 | logLevel: 'info', | 78 | logLevel: 'info', |
61 | mode, | 79 | mode, |
@@ -63,6 +81,7 @@ export default defineConfig({ | |||
63 | cacheDir: path.join(thisDir, 'build/vite/cache'), | 81 | cacheDir: path.join(thisDir, 'build/vite/cache'), |
64 | plugins: [ | 82 | plugins: [ |
65 | minifyPlugin, | 83 | minifyPlugin, |
84 | backendConfigPlugin, | ||
66 | react(), | 85 | react(), |
67 | injectPreload({ | 86 | injectPreload({ |
68 | files: [ | 87 | files: [ |
@@ -90,6 +109,12 @@ export default defineConfig({ | |||
90 | ], | 109 | ], |
91 | dontCacheBustURLsMatching: /\.(?:css|js|woff2?)$/, | 110 | dontCacheBustURLsMatching: /\.(?:css|js|woff2?)$/, |
92 | navigateFallbackDenylist: [/^\/xtext-service/], | 111 | navigateFallbackDenylist: [/^\/xtext-service/], |
112 | runtimeCaching: [ | ||
113 | { | ||
114 | urlPattern: 'config.json', | ||
115 | handler: 'StaleWhileRevalidate', | ||
116 | }, | ||
117 | ], | ||
93 | }, | 118 | }, |
94 | includeAssets: ['apple-touch-icon.png', 'favicon.svg', 'mask-icon.svg'], | 119 | includeAssets: ['apple-touch-icon.png', 'favicon.svg', 'mask-icon.svg'], |
95 | manifest: { | 120 | manifest: { |
diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/CacheControlFilter.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/CacheControlFilter.java index fbce62c1..fd2af1b2 100644 --- a/subprojects/language-web/src/main/java/tools/refinery/language/web/CacheControlFilter.java +++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/CacheControlFilter.java | |||
@@ -13,8 +13,9 @@ import java.util.regex.Pattern; | |||
13 | public class CacheControlFilter implements Filter { | 13 | public class CacheControlFilter implements Filter { |
14 | private static final Pattern CACHE_URI_PATTERN = Pattern.compile(".*\\.(css|gif|js|map|png|svg|woff2?)"); | 14 | private static final Pattern CACHE_URI_PATTERN = Pattern.compile(".*\\.(css|gif|js|map|png|svg|woff2?)"); |
15 | 15 | ||
16 | private static final Set<String> CACHE_URI_DENYLIST = Set.of("apple-touch-icon.png", "favicon.png", "favicon.svg", | 16 | private static final Set<String> CACHE_URI_DENYLIST = Set.of("apple-touch-icon.png", "config.json", "favicon.png", |
17 | "favicon-96x96.png", "icon-any.svg", "icon-192x192.png", "icon-512x512.png", "mask-icon.svg", "sw.js"); | 17 | "favicon.svg", "favicon-96x96.png", "icon-any.svg", "icon-192x192.png", "icon-512x512.png", "mask-icon.svg", |
18 | "sw.js"); | ||
18 | 19 | ||
19 | private static final Duration EXPIRY = Duration.ofDays(365); | 20 | private static final Duration EXPIRY = Duration.ofDays(365); |
20 | 21 | ||
diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java index ffa61321..58c8ea4e 100644 --- a/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java +++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/ServerLauncher.java | |||
@@ -14,6 +14,7 @@ import org.eclipse.jetty.util.resource.Resource; | |||
14 | import org.eclipse.jetty.websocket.server.config.JettyWebSocketServletContainerInitializer; | 14 | import org.eclipse.jetty.websocket.server.config.JettyWebSocketServletContainerInitializer; |
15 | import org.slf4j.Logger; | 15 | import org.slf4j.Logger; |
16 | import org.slf4j.LoggerFactory; | 16 | import org.slf4j.LoggerFactory; |
17 | import tools.refinery.language.web.config.BackendConfigServlet; | ||
17 | import tools.refinery.language.web.xtext.servlet.XtextWebSocketServlet; | 18 | import tools.refinery.language.web.xtext.servlet.XtextWebSocketServlet; |
18 | 19 | ||
19 | import java.io.File; | 20 | import java.io.File; |
@@ -41,11 +42,13 @@ public class ServerLauncher { | |||
41 | 42 | ||
42 | private final Server server; | 43 | private final Server server; |
43 | 44 | ||
44 | public ServerLauncher(InetSocketAddress bindAddress, Resource baseResource, String[] allowedOrigins) { | 45 | public ServerLauncher(InetSocketAddress bindAddress, Resource baseResource, String[] allowedOrigins, |
46 | String webSocketUrl) { | ||
45 | server = new Server(bindAddress); | 47 | server = new Server(bindAddress); |
46 | var handler = new ServletContextHandler(); | 48 | var handler = new ServletContextHandler(); |
47 | addSessionHandler(handler); | 49 | addSessionHandler(handler); |
48 | addProblemServlet(handler, allowedOrigins); | 50 | addProblemServlet(handler, allowedOrigins); |
51 | addBackendConfigServlet(handler, webSocketUrl); | ||
49 | if (baseResource != null) { | 52 | if (baseResource != null) { |
50 | handler.setBaseResource(baseResource); | 53 | handler.setBaseResource(baseResource); |
51 | handler.setWelcomeFiles(new String[]{"index.html"}); | 54 | handler.setWelcomeFiles(new String[]{"index.html"}); |
@@ -76,6 +79,12 @@ public class ServerLauncher { | |||
76 | JettyWebSocketServletContainerInitializer.configure(handler, null); | 79 | JettyWebSocketServletContainerInitializer.configure(handler, null); |
77 | } | 80 | } |
78 | 81 | ||
82 | private void addBackendConfigServlet(ServletContextHandler handler, String webSocketUrl) { | ||
83 | var backendConfigServletHolder = new ServletHolder(BackendConfigServlet.class); | ||
84 | backendConfigServletHolder.setInitParameter(BackendConfigServlet.WEBSOCKET_URL_INIT_PARAM, webSocketUrl); | ||
85 | handler.addServlet(backendConfigServletHolder, "/config.json"); | ||
86 | } | ||
87 | |||
79 | private void addDefaultServlet(ServletContextHandler handler) { | 88 | private void addDefaultServlet(ServletContextHandler handler) { |
80 | var defaultServletHolder = new ServletHolder(DefaultServlet.class); | 89 | var defaultServletHolder = new ServletHolder(DefaultServlet.class); |
81 | var isWindows = System.getProperty("os.name").toLowerCase().contains("win"); | 90 | var isWindows = System.getProperty("os.name").toLowerCase().contains("win"); |
@@ -97,7 +106,8 @@ public class ServerLauncher { | |||
97 | var bindAddress = getBindAddress(); | 106 | var bindAddress = getBindAddress(); |
98 | var baseResource = getBaseResource(); | 107 | var baseResource = getBaseResource(); |
99 | var allowedOrigins = getAllowedOrigins(); | 108 | var allowedOrigins = getAllowedOrigins(); |
100 | var serverLauncher = new ServerLauncher(bindAddress, baseResource, allowedOrigins); | 109 | var webSocketUrl = getWebSocketUrl(); |
110 | var serverLauncher = new ServerLauncher(bindAddress, baseResource, allowedOrigins, webSocketUrl); | ||
101 | serverLauncher.start(); | 111 | serverLauncher.start(); |
102 | } catch (Exception exception) { | 112 | } catch (Exception exception) { |
103 | LOG.error("Fatal server error", exception); | 113 | LOG.error("Fatal server error", exception); |
@@ -190,4 +200,19 @@ public class ServerLauncher { | |||
190 | } | 200 | } |
191 | return new String[]{urlWithPort}; | 201 | return new String[]{urlWithPort}; |
192 | } | 202 | } |
203 | |||
204 | private static String getWebSocketUrl() { | ||
205 | String host; | ||
206 | int port; | ||
207 | var publicHost = getPublicHost(); | ||
208 | if (publicHost == null) { | ||
209 | host = getListenAddress(); | ||
210 | port = getListenPort(); | ||
211 | } else { | ||
212 | host = publicHost; | ||
213 | port = getPublicPort(); | ||
214 | } | ||
215 | var scheme = port == HTTPS_DEFAULT_PORT ? "wss" : "ws"; | ||
216 | return String.format("%s://%s:%d/xtext-service", scheme, host, port); | ||
217 | } | ||
193 | } | 218 | } |
diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/config/BackendConfig.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/config/BackendConfig.java new file mode 100644 index 00000000..2e864998 --- /dev/null +++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/config/BackendConfig.java | |||
@@ -0,0 +1,20 @@ | |||
1 | package tools.refinery.language.web.config; | ||
2 | |||
3 | import com.google.gson.annotations.SerializedName; | ||
4 | |||
5 | public class BackendConfig { | ||
6 | @SerializedName("webSocketURL") | ||
7 | private String webSocketUrl; | ||
8 | |||
9 | public BackendConfig(String webSocketUrl) { | ||
10 | this.webSocketUrl = webSocketUrl; | ||
11 | } | ||
12 | |||
13 | public String getWebSocketUrl() { | ||
14 | return webSocketUrl; | ||
15 | } | ||
16 | |||
17 | public void setWebSocketUrl(String webSocketUrl) { | ||
18 | this.webSocketUrl = webSocketUrl; | ||
19 | } | ||
20 | } | ||
diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/config/BackendConfigServlet.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/config/BackendConfigServlet.java new file mode 100644 index 00000000..f314a9fa --- /dev/null +++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/config/BackendConfigServlet.java | |||
@@ -0,0 +1,39 @@ | |||
1 | package tools.refinery.language.web.config; | ||
2 | |||
3 | import com.google.gson.Gson; | ||
4 | import jakarta.servlet.ServletConfig; | ||
5 | import jakarta.servlet.ServletException; | ||
6 | import jakarta.servlet.http.HttpServlet; | ||
7 | import jakarta.servlet.http.HttpServletRequest; | ||
8 | import jakarta.servlet.http.HttpServletResponse; | ||
9 | import org.eclipse.jetty.http.HttpStatus; | ||
10 | |||
11 | import java.io.IOException; | ||
12 | |||
13 | public class BackendConfigServlet extends HttpServlet { | ||
14 | public static final String WEBSOCKET_URL_INIT_PARAM = "tools.refinery.language.web.config.BackendConfigServlet" + | ||
15 | ".webSocketUrl"; | ||
16 | |||
17 | private String serializedConfig; | ||
18 | |||
19 | @Override | ||
20 | public void init(ServletConfig config) throws ServletException { | ||
21 | super.init(config); | ||
22 | var webSocketUrl = config.getInitParameter(WEBSOCKET_URL_INIT_PARAM); | ||
23 | if (webSocketUrl == null) { | ||
24 | throw new IllegalArgumentException("Init parameter " + WEBSOCKET_URL_INIT_PARAM + " is mandatory"); | ||
25 | } | ||
26 | var backendConfig = new BackendConfig(webSocketUrl); | ||
27 | var gson = new Gson(); | ||
28 | serializedConfig = gson.toJson(backendConfig); | ||
29 | } | ||
30 | |||
31 | @Override | ||
32 | protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { | ||
33 | resp.setStatus(HttpStatus.OK_200); | ||
34 | resp.setContentType("application/json"); | ||
35 | var writer = resp.getWriter(); | ||
36 | writer.write(serializedConfig); | ||
37 | writer.flush(); | ||
38 | } | ||
39 | } | ||
diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/ResponseHandlerException.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/ResponseHandlerException.java index 34fcb546..b686d33a 100644 --- a/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/ResponseHandlerException.java +++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/ResponseHandlerException.java | |||
@@ -1,7 +1,10 @@ | |||
1 | package tools.refinery.language.web.xtext.server; | 1 | package tools.refinery.language.web.xtext.server; |
2 | 2 | ||
3 | import java.io.Serial; | ||
4 | |||
3 | public class ResponseHandlerException extends Exception { | 5 | public class ResponseHandlerException extends Exception { |
4 | 6 | ||
7 | @Serial | ||
5 | private static final long serialVersionUID = 3589866922420268164L; | 8 | private static final long serialVersionUID = 3589866922420268164L; |
6 | 9 | ||
7 | public ResponseHandlerException(String message, Throwable cause) { | 10 | public ResponseHandlerException(String message, Throwable cause) { |
diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/TransactionExecutor.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/TransactionExecutor.java index 0b417b06..7bb11d2e 100644 --- a/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/TransactionExecutor.java +++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/server/TransactionExecutor.java | |||
@@ -1,35 +1,25 @@ | |||
1 | package tools.refinery.language.web.xtext.server; | 1 | package tools.refinery.language.web.xtext.server; |
2 | 2 | ||
3 | import java.lang.ref.WeakReference; | 3 | import com.google.common.base.Strings; |
4 | import java.util.ArrayList; | 4 | import com.google.inject.Injector; |
5 | import java.util.HashMap; | ||
6 | import java.util.List; | ||
7 | import java.util.Map; | ||
8 | |||
9 | import org.eclipse.emf.common.util.URI; | 5 | import org.eclipse.emf.common.util.URI; |
10 | import org.eclipse.xtext.resource.IResourceServiceProvider; | 6 | import org.eclipse.xtext.resource.IResourceServiceProvider; |
11 | import org.eclipse.xtext.util.IDisposable; | 7 | import org.eclipse.xtext.util.IDisposable; |
12 | import org.eclipse.xtext.web.server.IServiceContext; | 8 | import org.eclipse.xtext.web.server.*; |
13 | import org.eclipse.xtext.web.server.IServiceResult; | ||
14 | import org.eclipse.xtext.web.server.ISession; | ||
15 | import org.eclipse.xtext.web.server.InvalidRequestException; | ||
16 | import org.eclipse.xtext.web.server.InvalidRequestException.UnknownLanguageException; | 9 | import org.eclipse.xtext.web.server.InvalidRequestException.UnknownLanguageException; |
17 | import org.eclipse.xtext.web.server.XtextServiceDispatcher; | ||
18 | import org.slf4j.Logger; | 10 | import org.slf4j.Logger; |
19 | import org.slf4j.LoggerFactory; | 11 | import org.slf4j.LoggerFactory; |
20 | 12 | import tools.refinery.language.web.xtext.server.message.*; | |
21 | import com.google.common.base.Strings; | ||
22 | import com.google.inject.Injector; | ||
23 | |||
24 | import tools.refinery.language.web.xtext.server.message.XtextWebErrorKind; | ||
25 | import tools.refinery.language.web.xtext.server.message.XtextWebErrorResponse; | ||
26 | import tools.refinery.language.web.xtext.server.message.XtextWebOkResponse; | ||
27 | import tools.refinery.language.web.xtext.server.message.XtextWebPushMessage; | ||
28 | import tools.refinery.language.web.xtext.server.message.XtextWebRequest; | ||
29 | import tools.refinery.language.web.xtext.server.push.PrecomputationListener; | 13 | import tools.refinery.language.web.xtext.server.push.PrecomputationListener; |
30 | import tools.refinery.language.web.xtext.server.push.PushWebDocument; | 14 | import tools.refinery.language.web.xtext.server.push.PushWebDocument; |
31 | import tools.refinery.language.web.xtext.servlet.SimpleServiceContext; | 15 | import tools.refinery.language.web.xtext.servlet.SimpleServiceContext; |
32 | 16 | ||
17 | import java.lang.ref.WeakReference; | ||
18 | import java.util.ArrayList; | ||
19 | import java.util.HashMap; | ||
20 | import java.util.List; | ||
21 | import java.util.Map; | ||
22 | |||
33 | public class TransactionExecutor implements IDisposable, PrecomputationListener { | 23 | public class TransactionExecutor implements IDisposable, PrecomputationListener { |
34 | private static final Logger LOG = LoggerFactory.getLogger(TransactionExecutor.class); | 24 | private static final Logger LOG = LoggerFactory.getLogger(TransactionExecutor.class); |
35 | 25 | ||
@@ -41,11 +31,11 @@ public class TransactionExecutor implements IDisposable, PrecomputationListener | |||
41 | 31 | ||
42 | private ResponseHandler responseHandler; | 32 | private ResponseHandler responseHandler; |
43 | 33 | ||
44 | private Object callPendingLock = new Object(); | 34 | private final Object callPendingLock = new Object(); |
45 | 35 | ||
46 | private boolean callPending; | 36 | private boolean callPending; |
47 | 37 | ||
48 | private List<XtextWebPushMessage> pendingPushMessages = new ArrayList<>(); | 38 | private final List<XtextWebPushMessage> pendingPushMessages = new ArrayList<>(); |
49 | 39 | ||
50 | public TransactionExecutor(ISession session, IResourceServiceProvider.Registry resourceServiceProviderRegistry) { | 40 | public TransactionExecutor(ISession session, IResourceServiceProvider.Registry resourceServiceProviderRegistry) { |
51 | this.session = session; | 41 | this.session = session; |
@@ -132,10 +122,9 @@ public class TransactionExecutor implements IDisposable, PrecomputationListener | |||
132 | 122 | ||
133 | /** | 123 | /** |
134 | * Get the injector to satisfy the request in the {@code serviceContext}. | 124 | * Get the injector to satisfy the request in the {@code serviceContext}. |
135 | * | ||
136 | * Based on {@link org.eclipse.xtext.web.servlet.XtextServlet#getInjector}. | 125 | * Based on {@link org.eclipse.xtext.web.servlet.XtextServlet#getInjector}. |
137 | * | 126 | * |
138 | * @param serviceContext the Xtext service context of the request | 127 | * @param context the Xtext service context of the request |
139 | * @return the injector for the Xtext language in the request | 128 | * @return the injector for the Xtext language in the request |
140 | * @throws UnknownLanguageException if the Xtext language cannot be determined | 129 | * @throws UnknownLanguageException if the Xtext language cannot be determined |
141 | */ | 130 | */ |
diff --git a/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/servlet/XtextWebSocket.java b/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/servlet/XtextWebSocket.java index fd41f213..82391d8b 100644 --- a/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/servlet/XtextWebSocket.java +++ b/subprojects/language-web/src/main/java/tools/refinery/language/web/xtext/servlet/XtextWebSocket.java | |||
@@ -1,31 +1,25 @@ | |||
1 | package tools.refinery.language.web.xtext.servlet; | 1 | package tools.refinery.language.web.xtext.servlet; |
2 | 2 | ||
3 | import java.io.IOException; | 3 | import com.google.gson.Gson; |
4 | import java.io.Reader; | 4 | import com.google.gson.JsonIOException; |
5 | 5 | import com.google.gson.JsonParseException; | |
6 | import org.eclipse.jetty.websocket.api.Session; | 6 | import org.eclipse.jetty.websocket.api.Session; |
7 | import org.eclipse.jetty.websocket.api.StatusCode; | 7 | import org.eclipse.jetty.websocket.api.StatusCode; |
8 | import org.eclipse.jetty.websocket.api.WriteCallback; | 8 | import org.eclipse.jetty.websocket.api.WriteCallback; |
9 | import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose; | 9 | import org.eclipse.jetty.websocket.api.annotations.*; |
10 | import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect; | ||
11 | import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError; | ||
12 | import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage; | ||
13 | import org.eclipse.jetty.websocket.api.annotations.WebSocket; | ||
14 | import org.eclipse.xtext.resource.IResourceServiceProvider; | 10 | import org.eclipse.xtext.resource.IResourceServiceProvider; |
15 | import org.eclipse.xtext.web.server.ISession; | 11 | import org.eclipse.xtext.web.server.ISession; |
16 | import org.slf4j.Logger; | 12 | import org.slf4j.Logger; |
17 | import org.slf4j.LoggerFactory; | 13 | import org.slf4j.LoggerFactory; |
18 | |||
19 | import com.google.gson.Gson; | ||
20 | import com.google.gson.JsonIOException; | ||
21 | import com.google.gson.JsonParseException; | ||
22 | |||
23 | import tools.refinery.language.web.xtext.server.ResponseHandler; | 14 | import tools.refinery.language.web.xtext.server.ResponseHandler; |
24 | import tools.refinery.language.web.xtext.server.ResponseHandlerException; | 15 | import tools.refinery.language.web.xtext.server.ResponseHandlerException; |
25 | import tools.refinery.language.web.xtext.server.TransactionExecutor; | 16 | import tools.refinery.language.web.xtext.server.TransactionExecutor; |
26 | import tools.refinery.language.web.xtext.server.message.XtextWebRequest; | 17 | import tools.refinery.language.web.xtext.server.message.XtextWebRequest; |
27 | import tools.refinery.language.web.xtext.server.message.XtextWebResponse; | 18 | import tools.refinery.language.web.xtext.server.message.XtextWebResponse; |
28 | 19 | ||
20 | import java.io.IOException; | ||
21 | import java.io.Reader; | ||
22 | |||
29 | @WebSocket | 23 | @WebSocket |
30 | public class XtextWebSocket implements WriteCallback, ResponseHandler { | 24 | public class XtextWebSocket implements WriteCallback, ResponseHandler { |
31 | private static final Logger LOG = LoggerFactory.getLogger(XtextWebSocket.class); | 25 | private static final Logger LOG = LoggerFactory.getLogger(XtextWebSocket.class); |
@@ -118,7 +112,7 @@ public class XtextWebSocket implements WriteCallback, ResponseHandler { | |||
118 | webSocketSession.getRemote().sendPartialString(responseString, true, this); | 112 | webSocketSession.getRemote().sendPartialString(responseString, true, this); |
119 | } catch (IOException e) { | 113 | } catch (IOException e) { |
120 | throw new ResponseHandlerException( | 114 | throw new ResponseHandlerException( |
121 | "Cannot initiaite async write to websocket " + webSocketSession.getRemoteAddress(), e); | 115 | "Cannot initiate async write to websocket " + webSocketSession.getRemoteAddress(), e); |
122 | } | 116 | } |
123 | } | 117 | } |
124 | 118 | ||