diff --git a/assistant/src/module/assistant/proxy/ws-proxy-base.ts b/assistant/src/module/assistant/proxy/ws-proxy-base.ts deleted file mode 100644 index e69de29..0000000 diff --git a/assistant/src/services/proxy/proxy-page-index.ts b/assistant/src/services/proxy/proxy-page-index.ts index 106398d..100a048 100644 --- a/assistant/src/services/proxy/proxy-page-index.ts +++ b/assistant/src/services/proxy/proxy-page-index.ts @@ -175,9 +175,9 @@ export const proxyRoute = async (req: http.IncomingMessage, res: http.ServerResp export const proxyWs = () => { const apiProxy = assistantConfig.getCacheAssistantConfig()?.api?.proxy || []; + const registry = assistantConfig.getRegistry() const proxy = assistantConfig.getCacheAssistantConfig()?.proxy || []; const proxyApi = [...apiProxy, ...proxy].filter((item) => item.ws); - const demoProxy = [ { path: '/api/ws/demo', @@ -186,6 +186,15 @@ export const proxyWs = () => { ws: true, } ] + const pathRouter = proxyApi.find((item) => item.path === '/api/router'); + if (!pathRouter) { + proxyApi.push({ + path: '/api/router', + target: registry || 'https://kevisual.cn', + pathname: '/api/router', + ws: true, + }); + } return proxyApi.map(createProxyInfo); }; export const createProxyInfo = (proxyApiItem: ProxyInfo) => { diff --git a/assistant/src/test/ws-app.ts b/assistant/src/test/ws-app.ts index e5474ef..8473336 100644 --- a/assistant/src/test/ws-app.ts +++ b/assistant/src/test/ws-app.ts @@ -8,7 +8,8 @@ const testRouter = () => { // const ws = new WebSocket('ws://118.196.32.29:3005/api/router'); // const ws = new WebSocket('wss://kevisual.cn/api/router'); - const ws = new WebSocket('ws://localhost:51015/api/ws/demo?id=12345'); + // const ws = new WebSocket('ws://localhost:51015/api/ws/demo?id=12345'); + const ws = new WebSocket('ws://localhost:51015/api/router?id=12345'); console.log('Connecting to WebSocket server...'); ws.on('open', () => { console.log('WebSocket connection opened');