feat: 充值重构+AI图表修复+安全加固+路由清理

2026-04-29 02:10:00 +08:00
parent 1af9642513
commit 04eb812079
978 changed files with 184611 additions and 0 deletions
@@ -0,0 +1,51 @@
+import { getErrorMessage, logMessage, } from './helpers';
+var QuotesPulseProvider = /** @class */ (function () {
+    function QuotesPulseProvider(quotesProvider) {
+        this._subscribers = {};
+        this._requestsPending = 0;
+        this._quotesProvider = quotesProvider;
+        setInterval(this._updateQuotes.bind(this, 1 /* Fast */), 10000 /* Fast */);
+        setInterval(this._updateQuotes.bind(this, 0 /* General */), 60000 /* General */);
+    }
+    QuotesPulseProvider.prototype.subscribeQuotes = function (symbols, fastSymbols, onRealtimeCallback, listenerGuid) {
+        this._subscribers[listenerGuid] = {
+            symbols: symbols,
+            fastSymbols: fastSymbols,
+            listener: onRealtimeCallback,
+        };
+        logMessage("QuotesPulseProvider: subscribed quotes with #" + listenerGuid);
+    };
+    QuotesPulseProvider.prototype.unsubscribeQuotes = function (listenerGuid) {
+        delete this._subscribers[listenerGuid];
+        logMessage("QuotesPulseProvider: unsubscribed quotes with #" + listenerGuid);
+    };
+    QuotesPulseProvider.prototype._updateQuotes = function (updateType) {
+        var _this = this;
+        if (this._requestsPending > 0) {
+            return;
+        }
+        var _loop_1 = function (listenerGuid) {
+            this_1._requestsPending++;
+            var subscriptionRecord = this_1._subscribers[listenerGuid];
+            this_1._quotesProvider.getQuotes(updateType === 1 /* Fast */ ? subscriptionRecord.fastSymbols : subscriptionRecord.symbols)
+                .then(function (data) {
+                _this._requestsPending--;
+                if (!_this._subscribers.hasOwnProperty(listenerGuid)) {
+                    return;
+                }
+                subscriptionRecord.listener(data);
+                logMessage("QuotesPulseProvider: data for #" + listenerGuid + " (" + updateType + ") updated successfully, pending=" + _this._requestsPending);
+            })
+                .catch(function (reason) {
+                _this._requestsPending--;
+                logMessage("QuotesPulseProvider: data for #" + listenerGuid + " (" + updateType + ") updated with error=" + getErrorMessage(reason) + ", pending=" + _this._requestsPending);
+            });
+        };
+        var this_1 = this;
+        for (var listenerGuid in this._subscribers) {
+            _loop_1(listenerGuid);
+        }
+    };
+    return QuotesPulseProvider;
+}());
+export { QuotesPulseProvider };