From c49350da0d393ce6da6ff6ca14960cbc6b1e73aa Mon Sep 17 00:00:00 2001 From: Seven Date: Tue, 13 Jan 2026 23:43:08 +0700 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=9B=B4=E6=96=B0=20@riwa/api-types=20?= =?UTF-8?q?=E4=BE=9D=E8=B5=96=E7=89=88=E6=9C=AC=E8=87=B3=200.0.135?= =?UTF-8?q?=EF=BC=9B=E4=BC=98=E5=8C=96=20TradingView=20=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=BA=90=E5=92=8C=20WebSocket=20=E9=94=99=E8=AF=AF=E5=A4=84?= =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- package.json | 2 +- pnpm-lock.yaml | 12 ++++++------ src/tradingview/datafeed.ts | 1 + src/tradingview/websocket.ts | 7 +++++++ 4 files changed, 15 insertions(+), 7 deletions(-) diff --git a/package.json b/package.json index 9dee82d..e9a64b7 100644 --- a/package.json +++ b/package.json @@ -35,7 +35,7 @@ "@elysiajs/eden": "^1.4.5", "@ionic/vue": "^8.7.11", "@ionic/vue-router": "^8.7.11", - "@riwa/api-types": "http://192.168.1.7:9528/api/riwa-eden-0.0.133.tgz", + "@riwa/api-types": "http://192.168.1.7:9528/api/riwa-eden-0.0.135.tgz", "@tailwindcss/vite": "^4.1.18", "@vee-validate/zod": "^4.15.1", "@vueuse/core": "^14.1.0", diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml index f7a7632..d756c2b 100644 --- a/pnpm-lock.yaml +++ b/pnpm-lock.yaml @@ -69,8 +69,8 @@ importers: specifier: ^8.7.11 version: 8.7.11(@stencil/core@4.39.0)(vue-router@4.6.3(vue@3.5.25(typescript@5.9.3)))(vue@3.5.25(typescript@5.9.3)) '@riwa/api-types': - specifier: http://192.168.1.7:9528/api/riwa-eden-0.0.133.tgz - version: '@riwa/eden@http://192.168.1.7:9528/api/riwa-eden-0.0.133.tgz(@elysiajs/eden@1.4.5(elysia@1.4.18(@sinclair/typebox@0.34.41)(exact-mirror@0.2.5(@sinclair/typebox@0.34.41))(file-type@21.1.1)(openapi-types@12.1.3)(typescript@5.9.3)))' + specifier: http://192.168.1.7:9528/api/riwa-eden-0.0.135.tgz + version: '@riwa/eden@http://192.168.1.7:9528/api/riwa-eden-0.0.135.tgz(@elysiajs/eden@1.4.5(elysia@1.4.18(@sinclair/typebox@0.34.41)(exact-mirror@0.2.5(@sinclair/typebox@0.34.41))(file-type@21.1.1)(openapi-types@12.1.3)(typescript@5.9.3)))' '@tailwindcss/vite': specifier: ^4.1.18 version: 4.1.18(vite@7.2.7(@types/node@24.10.2)(jiti@2.6.1)(lightningcss@1.30.2)(terser@5.44.1)(yaml@2.8.2)) @@ -2804,9 +2804,9 @@ packages: '@remirror/core-constants@3.0.0': resolution: {integrity: sha512-42aWfPrimMfDKDi4YegyS7x+/0tlzaqwPQCULLanv3DMIlu96KTJR0fM5isWX2UViOqlGnX6YFgqWepcX+XMNg==} - '@riwa/eden@http://192.168.1.7:9528/api/riwa-eden-0.0.133.tgz': - resolution: {tarball: http://192.168.1.7:9528/api/riwa-eden-0.0.133.tgz} - version: 0.0.133 + '@riwa/eden@http://192.168.1.7:9528/api/riwa-eden-0.0.135.tgz': + resolution: {tarball: http://192.168.1.7:9528/api/riwa-eden-0.0.135.tgz} + version: 0.0.135 peerDependencies: '@elysiajs/eden': ^1.4.5 @@ -12161,7 +12161,7 @@ snapshots: '@remirror/core-constants@3.0.0': {} - '@riwa/eden@http://192.168.1.7:9528/api/riwa-eden-0.0.133.tgz(@elysiajs/eden@1.4.5(elysia@1.4.18(@sinclair/typebox@0.34.41)(exact-mirror@0.2.5(@sinclair/typebox@0.34.41))(file-type@21.1.1)(openapi-types@12.1.3)(typescript@5.9.3)))': + '@riwa/eden@http://192.168.1.7:9528/api/riwa-eden-0.0.135.tgz(@elysiajs/eden@1.4.5(elysia@1.4.18(@sinclair/typebox@0.34.41)(exact-mirror@0.2.5(@sinclair/typebox@0.34.41))(file-type@21.1.1)(openapi-types@12.1.3)(typescript@5.9.3)))': dependencies: '@elysiajs/eden': 1.4.5(elysia@1.4.18(@sinclair/typebox@0.34.41)(exact-mirror@0.2.5(@sinclair/typebox@0.34.41))(file-type@21.1.1)(openapi-types@12.1.3)(typescript@5.9.3)) diff --git a/src/tradingview/datafeed.ts b/src/tradingview/datafeed.ts index b5b2603..81ab90e 100644 --- a/src/tradingview/datafeed.ts +++ b/src/tradingview/datafeed.ts @@ -212,6 +212,7 @@ export class RWADatafeed extends Datafeeds.UDFCompatibleDatafeed { channels: [{ name: "bar", symbol: symbolInfo.name, + resolution, }], }); diff --git a/src/tradingview/websocket.ts b/src/tradingview/websocket.ts index 4f9a9c5..c10fd09 100644 --- a/src/tradingview/websocket.ts +++ b/src/tradingview/websocket.ts @@ -7,6 +7,13 @@ export class TradeWebSocket { if (!this.socket) { this.socket = client.api.market_data.streaming.subscribe(); } + this.socket.on("error", () => { + this.socket = null; + this.socket = client.api.market_data.streaming.subscribe(); + }); + this.socket.on("open", () => { + console.log("TradeWebSocket connected"); + }); } public getSocket(): MarketDataStreaming {