Spaces:
Configuration error
Configuration error
| /** | |
| * TradeSense AI — Authoritative Institutional API Client & Adapters (Milestone 23 Master) | |
| * Maps 1-to-1 with openapi/tradesense-openapi.json. | |
| * Strict zero-credential leakage; in-memory session handling. | |
| */ | |
| class TradeSenseAPIClient { | |
| constructor(baseUrl = '') { | |
| this.baseUrl = baseUrl; | |
| this.accessToken = null; | |
| this.tenantId = 'default_tenant'; | |
| this.onUnauthorizedCallback = null; | |
| } | |
| setToken(token) { | |
| this.accessToken = token; | |
| } | |
| setTenant(tenantId) { | |
| this.tenantId = tenantId; | |
| } | |
| onUnauthorized(callback) { | |
| this.onUnauthorizedCallback = callback; | |
| } | |
| async request(endpoint, options = {}) { | |
| const headers = options.headers || {}; | |
| if (this.accessToken) { | |
| headers['Authorization'] = `Bearer ${this.accessToken}`; | |
| } | |
| headers['X-Request-ID'] = `req_${Math.random().toString(36).substring(2, 10)}`; | |
| const config = { | |
| ...options, | |
| headers, | |
| }; | |
| try { | |
| const response = await fetch(`${this.baseUrl}${endpoint}`, config); | |
| if (response.status === 401) { | |
| if (this.onUnauthorizedCallback) { | |
| this.onUnauthorizedCallback(); | |
| } | |
| const errData = await response.json().catch(() => ({})); | |
| throw new Error(errData.detail || 'Authentication required or session expired.'); | |
| } | |
| if (!response.ok) { | |
| const errData = await response.json().catch(() => ({})); | |
| throw new Error(errData.detail || errData.error?.message || `HTTP ${response.status}: Request failed.`); | |
| } | |
| const contentType = response.headers.get('content-type'); | |
| if (contentType && contentType.includes('application/json')) { | |
| return await response.json(); | |
| } | |
| return await response.text(); | |
| } catch (err) { | |
| console.error(`API Error [${endpoint}]:`, err); | |
| throw err; | |
| } | |
| } | |
| // ── Authentication ──────────────────────────────────────────────────────── | |
| async login(username, password, tenantId = 'default_tenant') { | |
| const query = new URLSearchParams({ username, password, tenant_id: tenantId }); | |
| const res = await this.request(`/api/v1/auth/login?${query.toString()}`, { | |
| method: 'POST', | |
| }); | |
| this.setToken(res.access_token); | |
| this.setTenant(res.tenant_id); | |
| return res; | |
| } | |
| async logout() { | |
| try { | |
| await this.request('/api/v1/auth/logout', { method: 'POST' }); | |
| } finally { | |
| this.accessToken = null; | |
| } | |
| } | |
| // ── Research Plane: Runs, Specs, Evidence ───────────────────────────────── | |
| async listResearchRuns(experimentId = null, limit = 50, offset = 0) { | |
| const params = new URLSearchParams({ limit, offset }); | |
| if (experimentId) params.append('experiment_id', experimentId); | |
| return await this.request(`/api/v1/research/runs?${params.toString()}`); | |
| } | |
| async getResearchRun(runId) { | |
| return await this.request(`/api/v1/research/runs/${encodeURIComponent(runId)}`); | |
| } | |
| async submitResearchRun(config, experimentId, strategyId, idempotencyKey) { | |
| const params = new URLSearchParams({ experiment_id: experimentId, strategy_id: strategyId }); | |
| return await this.request(`/api/v1/research/runs?${params.toString()}`, { | |
| method: 'POST', | |
| headers: { | |
| 'Content-Type': 'application/json', | |
| 'Idempotency-Key': idempotencyKey || `idem_${Date.now()}`, | |
| }, | |
| body: JSON.stringify(config), | |
| }); | |
| } | |
| async getEvidencePackage(runId) { | |
| return await this.request(`/api/v1/research/runs/${encodeURIComponent(runId)}/evidence_package`); | |
| } | |
| async reproduceRun(runId) { | |
| return await this.request(`/api/v1/research/runs/${encodeURIComponent(runId)}/reproduce`, { | |
| method: 'POST', | |
| }); | |
| } | |
| async getStockResearch(ticker, horizonSessions = 21) { | |
| const params = new URLSearchParams({ horizon_sessions: horizonSessions }); | |
| return await this.request(`/api/v1/research/${encodeURIComponent(ticker)}?${params.toString()}`); | |
| } | |
| // ── Module 05: Asynchronous Compute Job Infrastructure ────────────────── | |
| async submitResearchJob(ticker, horizonSessions = 21, priority = 1, idempotencyKey = null) { | |
| return await this.request('/api/v1/jobs/research', { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify({ | |
| ticker, | |
| horizon_sessions: horizonSessions, | |
| priority, | |
| idempotency_key: idempotencyKey, | |
| }), | |
| }); | |
| } | |
| async getJobStatus(jobId) { | |
| return await this.request(`/api/v1/jobs/${encodeURIComponent(jobId)}`); | |
| } | |
| async cancelJob(jobId) { | |
| return await this.request(`/api/v1/jobs/${encodeURIComponent(jobId)}/cancel`, { | |
| method: 'POST', | |
| }); | |
| } | |
| async getJobResult(jobId) { | |
| return await this.request(`/api/v1/jobs/${encodeURIComponent(jobId)}/result`); | |
| } | |
| async listJobs(status = null, limit = 50, offset = 0) { | |
| const params = new URLSearchParams({ limit, offset }); | |
| if (status) params.append('status', status); | |
| return await this.request(`/api/v1/jobs?${params.toString()}`); | |
| } | |
| async getJobEvents(jobId) { | |
| return await this.request(`/api/v1/jobs/${encodeURIComponent(jobId)}/events`); | |
| } | |
| // ── Module 06: Independent Quant Validation & Reproducibility ──────────── | |
| async submitValidationJob(ticker, horizonSessions = 21, depth = 'FAST', randomSeed = 42) { | |
| return await this.request('/api/v1/jobs/validation', { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify({ | |
| ticker, | |
| horizon_sessions: horizonSessions, | |
| depth, | |
| random_seed: randomSeed, | |
| }), | |
| }); | |
| } | |
| async getValidationRun(validationId) { | |
| return await this.request(`/api/v1/validation/${encodeURIComponent(validationId)}`); | |
| } | |
| async getValidationReport(validationId) { | |
| return await this.request(`/api/v1/validation/${encodeURIComponent(validationId)}/report`); | |
| } | |
| async getValidationCertificate(validationId) { | |
| return await this.request(`/api/v1/validation/${encodeURIComponent(validationId)}/certificate`); | |
| } | |
| async replayValidation(validationId) { | |
| return await this.request(`/api/v1/validation/${encodeURIComponent(validationId)}/replay`, { | |
| method: 'POST', | |
| }); | |
| } | |
| // ── Governance & Control Benchmarks (Module 07 Lifecycle) ───────────────── | |
| async preRegisterResearch(researchId, protocolData) { | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/pre-register`, { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify(protocolData), | |
| }); | |
| } | |
| async startGovernanceResearch(researchId, version = 1) { | |
| const params = new URLSearchParams({ version }); | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/start?${params.toString()}`, { | |
| method: 'POST', | |
| }); | |
| } | |
| async submitResearchForReview(researchId, reviewData) { | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/submit-review`, { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify(reviewData), | |
| }); | |
| } | |
| async approveGovernanceDecision(researchId, approvalData) { | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/approve`, { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify(approvalData), | |
| }); | |
| } | |
| async rejectGovernanceDecision(researchId, rejectData) { | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/reject`, { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify(rejectData), | |
| }); | |
| } | |
| async revokeGovernanceApproval(researchId, revokeData) { | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/revoke`, { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify(revokeData), | |
| }); | |
| } | |
| async archiveGovernanceResearch(researchId, archiveData) { | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/archive`, { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify(archiveData), | |
| }); | |
| } | |
| async getGovernanceState(researchId, version = 1) { | |
| const params = new URLSearchParams({ version }); | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}?${params.toString()}`); | |
| } | |
| async getGovernanceHistory(researchId) { | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/history`); | |
| } | |
| async getGovernanceEvidence(researchId, version = 1) { | |
| const params = new URLSearchParams({ version }); | |
| return await this.request(`/api/v1/governance/${encodeURIComponent(researchId)}/evidence?${params.toString()}`); | |
| } | |
| async exportAuditPackage(researchId, version = 1) { | |
| const params = new URLSearchParams({ version }); | |
| return await this.request(`/api/v1/audit/export/${encodeURIComponent(researchId)}?${params.toString()}`); | |
| } | |
| async listGovernanceDecisions(experimentId = null, limit = 50, offset = 0) { | |
| const params = new URLSearchParams({ limit, offset }); | |
| if (experimentId) params.append('experiment_id', experimentId); | |
| return await this.request(`/api/v1/governance/decisions?${params.toString()}`); | |
| } | |
| async submitPeerReview(decisionId, verdict, comments) { | |
| return await this.request(`/api/v1/governance/decisions/${encodeURIComponent(decisionId)}/peer_review`, { | |
| method: 'POST', | |
| headers: { 'Content-Type': 'application/json' }, | |
| body: JSON.stringify({ verdict, comments }), | |
| }); | |
| } | |
| async getFamily1Archive() { | |
| return await this.request('/api/v1/governance/family_1_archive'); | |
| } | |
| // ── Cryptographic Audit Ledger ──────────────────────────────────────────── | |
| async listAuditEvents(limit = 100, offset = 0) { | |
| const params = new URLSearchParams({ limit, offset }); | |
| return await this.request(`/api/v1/audit/events?${params.toString()}`); | |
| } | |
| async verifyAuditLedger() { | |
| return await this.request('/api/v1/audit/verify'); | |
| } | |
| // ── Indian Market Endpoints (Live Ticker, Quotes, Charts, SEBI Friction) ─ | |
| async getLiveMarketTicker() { | |
| return await this.request('/api/v1/market/live_ticker'); | |
| } | |
| async getStockQuote(symbol, exchange = 'NSE') { | |
| const params = new URLSearchParams({ exchange }); | |
| return await this.request(`/api/v1/market/quote/${encodeURIComponent(symbol)}?${params.toString()}`); | |
| } | |
| async getStockChartBars(symbol, exchange = 'NSE', period = '1d', interval = '5m') { | |
| const params = new URLSearchParams({ exchange, period, interval }); | |
| return await this.request(`/api/v1/market/chart/${encodeURIComponent(symbol)}?${params.toString()}`); | |
| } | |
| async getCompanyOverview(exchange = 'NSE', refresh = false) { | |
| const params = new URLSearchParams({ exchange, refresh: refresh ? 'true' : 'false' }); | |
| return await this.request(`/api/v1/market/company_overview?${params.toString()}`); | |
| } | |
| async calculateStatutoryCosts(buyPrice, sellPrice, quantity = 10, segment = 'EQUITY_DELIVERY') { | |
| const params = new URLSearchParams({ buy_price: buyPrice, sell_price: sellPrice, quantity, segment }); | |
| return await this.request(`/api/v1/statutory/costs?${params.toString()}`); | |
| } | |
| async searchStocks(query, exchange = 'ALL', limit = 10) { | |
| const params = new URLSearchParams({ q: query, exchange, limit }); | |
| return await this.request(`/api/v1/market/search?${params.toString()}`); | |
| } | |
| // ── Operations & Telemetry ──────────────────────────────────────────────── | |
| async getHealth() { | |
| return await this.request('/api/v1/health'); | |
| } | |
| async getVersion() { | |
| return await this.request('/api/v1/version'); | |
| } | |
| async getTenantUsage() { | |
| return await this.request('/api/v1/observability/usage'); | |
| } | |
| async getObservabilityMetrics() { | |
| return await this.request('/api/v1/observability/metrics'); | |
| } | |
| } | |
| // Instantiate global singleton client | |
| window.TradeSenseAPI = new TradeSenseAPIClient(); | |
| // ============================================================================== | |
| // Domain Normalization Adapters (Decouples UI from raw backend JSON formats) | |
| // ============================================================================== | |
| window.TradeSenseAdapters = { | |
| /** | |
| * Normalizes raw backend ResearchRun into a structured client model with first-class human identity | |
| */ | |
| normalizeResearchRun(rawRun) { | |
| if (!rawRun) return null; | |
| const runId = rawRun.run_id || 'run_unknown'; | |
| const config = rawRun.configuration || {}; | |
| const custom = config.custom_parameters || {}; | |
| const prov = rawRun.provenance || {}; | |
| // 1. Determine human-readable research name and sanitize universe to Indian equities | |
| const rawUniverse = (config.universe_tickers && config.universe_tickers.length > 0) | |
| ? config.universe_tickers | |
| : ['RELIANCE', 'TCS']; | |
| // Sanitize any legacy foreign symbols to Indian equities | |
| const indianTickerMap = { | |
| 'AAPL': 'RELIANCE', | |
| 'MSFT': 'TCS', | |
| 'GOOG': 'INFY', | |
| 'AMZN': 'HDFCBANK', | |
| 'NVDA': 'TATAMOTORS', | |
| 'META': 'ICICIBANK', | |
| 'TSLA': 'JSWSTEEL', | |
| }; | |
| const universeList = rawUniverse.map(tk => indianTickerMap[tk.toUpperCase()] || tk.toUpperCase()); | |
| let researchName = custom.research_name || config.research_name || null; | |
| let isFallbackName = false; | |
| if (!researchName || researchName.includes('AAPL') || researchName.includes('MSFT')) { | |
| if (rawRun.experiment_id && rawRun.experiment_id.includes(' ') && !rawRun.experiment_id.includes('AAPL')) { | |
| researchName = rawRun.experiment_id; | |
| } else if (rawRun.experiment_id && !rawRun.experiment_id.startsWith('exp_') && !rawRun.experiment_id.includes('AAPL')) { | |
| researchName = rawRun.experiment_id.replace(/_/g, ' ').toUpperCase(); | |
| } else { | |
| // Deterministic Indian market research name | |
| const universeStr = universeList.join(', '); | |
| const horizon = config.holding_period_sessions || 21; | |
| const strat = (rawRun.strategy_id || 'Quantitative Strategy').replace(/^strat_/, '').replace(/_/g, ' '); | |
| const stratClean = strat.toLowerCase().includes('01') ? 'Alpha Factor Momentum' : (strat.charAt(0).toUpperCase() + strat.slice(1)); | |
| researchName = `${universeStr} ${stratClean} — ${horizon} Sessions`; | |
| isFallbackName = true; | |
| } | |
| } | |
| // 2. Extract hypothesis & methodology | |
| const hypothesis = custom.hypothesis || 'Investigate empirical predictability and factor contamination under Newey-West HAC covariance correction on NSE Indian equities.'; | |
| const methodology = custom.methodology || 'Conformal Prediction & Purged K-Fold Cross-Validation'; | |
| return { | |
| runId, | |
| researchName, | |
| isFallbackName, | |
| experimentId: rawRun.experiment_id || 'exp_general', | |
| strategyId: rawRun.strategy_id || 'strat_general', | |
| tenantId: rawRun.tenant_id || 'default_tenant', | |
| workflowState: rawRun.workflow_state || 'PRE_REGISTERED', | |
| status: rawRun.status || 'QUEUED', | |
| universe: universeList, | |
| horizonSessions: config.holding_period_sessions || 21, | |
| randomSeed: config.random_seed || 42, | |
| hypothesis, | |
| methodology, | |
| configuration: config, | |
| provenance: prov, | |
| createdAt: rawRun.created_at || '2026-09-02T09:00:00Z', | |
| }; | |
| }, | |
| /** | |
| * Normalizes raw backend stock research response into an authoritative DecisionEvidenceModel | |
| */ | |
| normalizeDecisionBrief(raw) { | |
| if (!raw) return null; | |
| if (window.TradeSenseDecisionEngine && window.TradeSenseDecisionEngine.buildDecisionEvidenceModel) { | |
| return window.TradeSenseDecisionEngine.buildDecisionEvidenceModel(raw); | |
| } | |
| return null; | |
| }, | |
| /** | |
| * Clipboard helper with toast feedback | |
| */ | |
| copyToClipboard(text, label = 'Identifier') { | |
| if (navigator.clipboard && navigator.clipboard.writeText) { | |
| navigator.clipboard.writeText(text).then(() => { | |
| if (window.AppState && window.AppState.showToast) { | |
| window.AppState.showToast(`✓ Copied ${label} to clipboard!`); | |
| } | |
| }).catch(() => this.fallbackCopy(text, label)); | |
| } else { | |
| this.fallbackCopy(text, label); | |
| } | |
| }, | |
| fallbackCopy(text, label) { | |
| const input = document.createElement('input'); | |
| input.value = text; | |
| document.body.appendChild(input); | |
| input.select(); | |
| document.execCommand('copy'); | |
| document.body.removeChild(input); | |
| if (window.AppState && window.AppState.showToast) { | |
| window.AppState.showToast(`✓ Copied ${label} to clipboard!`); | |
| } | |
| } | |
| }; | |