+ AI explanations (Ollama, cloud keys, or Ditectrev AI) unlock
+ after you subscribe to an AI plan — Ads-free and Free tiers do
+ not include server-side AI.
+
+ )}
{PROVIDER_OPTIONS.map((provider) => {
const allowed = provider.allowedTiers.includes(tier);
diff --git a/lib/ai-subscription-ux.ts b/lib/ai-subscription-ux.ts
new file mode 100644
index 0000000..946ba39
--- /dev/null
+++ b/lib/ai-subscription-ux.ts
@@ -0,0 +1,13 @@
+import type { PricingTier } from "@/types";
+
+/**
+ * Copy for AI-gated panels when the user has no AI-enabled subscription.
+ */
+export function getAiSubscriptionGateMessage(
+ tier: PricingTier | null | undefined
+): string {
+ if (tier === "FREE" || tier === "ADS_FREE") {
+ return "Your current plan does not include AI. Upgrade to Local AI for Ollama on your machine, Bring Your Own Key for OpenAI/Gemini/Mistral/DeepSeek, or Ditectrev AI for managed AI.";
+ }
+ return "Enable a Local AI, Bring Your Own Key, or Ditectrev AI subscription to unlock this section.";
+}
diff --git a/lib/env.ts b/lib/env.ts
index 64851ec..d8dd2b6 100644
--- a/lib/env.ts
+++ b/lib/env.ts
@@ -28,10 +28,13 @@ interface EnvConfig {
};
}
+const defaultYahooFinanceUrl = "https://query2.finance.yahoo.com";
+
export const env: EnvConfig = {
apis: {
cnnDatavizUrl: "https://production.dataviz.cnn.io",
- yahooFinanceUrl: "https://query1.finance.yahoo.com",
+ yahooFinanceUrl:
+ process.env.YAHOO_FINANCE_API_URL?.trim() || defaultYahooFinanceUrl,
},
cache: {
ttlSeconds: 300,
diff --git a/lib/resolve-market-ai-llm-config.ts b/lib/resolve-market-ai-llm-config.ts
new file mode 100644
index 0000000..1b8d33e
--- /dev/null
+++ b/lib/resolve-market-ai-llm-config.ts
@@ -0,0 +1,72 @@
+import { appwriteAIKeyStoreService } from "@/services/appwrite-ai-key-store.service";
+import type { BYOKProvider } from "@/services/api-key-manager.service";
+import type { AIProvider } from "@/types";
+
+export type MarketRouteLLMConfig = {
+ provider: AIProvider;
+ apiKey?: string;
+ model?: string;
+};
+
+function isBYOKCloudProvider(value: string): value is BYOKProvider {
+ return ["OPENAI", "GEMINI", "MISTRAL", "DEEPSEEK"].includes(value);
+}
+
+/**
+ * Resolves LLM config for market AI routes (BYOK can use Ollama without a stored API key).
+ */
+export async function resolveMarketRouteLLMConfig(opts: {
+ tier: string;
+ userId: string;
+ requestedProviderRaw: string;
+}): Promise<
+ | { ok: true; llmConfig: MarketRouteLLMConfig | undefined }
+ | { ok: false; error: string }
+> {
+ const model = process.env.AI_MODEL;
+ const ollamaModel = process.env.OLLAMA_MODEL ?? model;
+
+ if (opts.tier === "LOCAL") {
+ return {
+ ok: true,
+ llmConfig: { provider: "OLLAMA", model: ollamaModel },
+ };
+ }
+
+ if (opts.tier === "BYOK") {
+ const header = opts.requestedProviderRaw.trim().toUpperCase();
+ if (header === "OLLAMA") {
+ return {
+ ok: true,
+ llmConfig: { provider: "OLLAMA", model: ollamaModel },
+ };
+ }
+
+ const requested = isBYOKCloudProvider(header) ? header : null;
+ const provider =
+ requested ??
+ (await appwriteAIKeyStoreService.getPreferredProvider(opts.userId));
+ if (!provider) {
+ return {
+ ok: false,
+ error:
+ "No cloud API key on file. Add an OpenAI, Gemini, Mistral, or DeepSeek key under Profile, or select Ollama (Local) to use your machine without a provider key.",
+ };
+ }
+
+ const apiKey = await appwriteAIKeyStoreService.getDecryptedKey(
+ opts.userId,
+ provider
+ );
+ if (!apiKey) {
+ return {
+ ok: false,
+ error: `No API key stored for provider ${provider}. Change provider in profile or save a key for ${provider}.`,
+ };
+ }
+
+ return { ok: true, llmConfig: { provider, apiKey, model } };
+ }
+
+ return { ok: true, llmConfig: undefined };
+}
diff --git a/services/yahoo-finance.service.ts b/services/yahoo-finance.service.ts
index b43c81a..7b3e007 100644
--- a/services/yahoo-finance.service.ts
+++ b/services/yahoo-finance.service.ts
@@ -31,7 +31,23 @@ export class YahooFinanceService {
private crumbExpiry: number = 0;
constructor() {
- this.baseUrl = env.apis.yahooFinanceUrl;
+ this.baseUrl = env.apis.yahooFinanceUrl.replace(/\/$/, "");
+ }
+
+ /** Yahoo exposes query1/query2; some datacenters get 5xx on one host only. */
+ private alternateYahooOrigin(): string | null {
+ if (this.baseUrl.includes("query1.finance.yahoo.com")) {
+ return "https://query2.finance.yahoo.com";
+ }
+ if (this.baseUrl.includes("query2.finance.yahoo.com")) {
+ return "https://query1.finance.yahoo.com";
+ }
+ return null;
+ }
+
+ private yahooChartBases(): string[] {
+ const alt = this.alternateYahooOrigin();
+ return alt ? [this.baseUrl, alt] : [this.baseUrl];
}
/**
@@ -127,15 +143,31 @@ export class YahooFinanceService {
async getSymbolQuote(symbol: string): Promise {
return retryWithBackoff(async () => {
try {
- const response = await fetch(
- `${this.baseUrl}/v8/finance/quote?symbols=${symbol}`,
- {
- headers: {
- Accept: "application/json",
- "User-Agent": "Mozilla/5.0",
- },
- }
- );
+ const ua = "Mozilla/5.0 (compatible; StockExchangeApp/1.0)";
+ let response: Response | undefined;
+ for (const base of this.yahooChartBases()) {
+ response = await fetch(
+ `${base}/v8/finance/quote?symbols=${encodeURIComponent(symbol)}`,
+ {
+ headers: {
+ Accept: "application/json",
+ "User-Agent": ua,
+ },
+ }
+ );
+ if (response.ok) break;
+ const retryable = [429, 500, 502, 503, 504].includes(response.status);
+ if (!retryable) break;
+ logger.warn("Yahoo quote: transient error, trying alternate host", {
+ symbol,
+ status: response.status,
+ base,
+ });
+ }
+
+ if (!response) {
+ throw new Error("Yahoo Finance quote: empty response");
+ }
if (!response.ok) {
throw new Error(
@@ -171,15 +203,32 @@ export class YahooFinanceService {
try {
const { interval, period } = this.getTimeRangeParams(range);
- const response = await fetch(
- `${this.baseUrl}/v8/finance/chart/${symbol}?interval=${interval}&range=${period}`,
- {
- headers: {
- Accept: "application/json",
- "User-Agent": "Mozilla/5.0",
- },
- }
- );
+ const ua = "Mozilla/5.0 (compatible; StockExchangeApp/1.0)";
+ let response: Response | undefined;
+ for (const base of this.yahooChartBases()) {
+ response = await fetch(
+ `${base}/v8/finance/chart/${encodeURIComponent(symbol)}?interval=${interval}&range=${period}`,
+ {
+ headers: {
+ Accept: "application/json",
+ "User-Agent": ua,
+ },
+ }
+ );
+ if (response.ok) break;
+ const retryable = [429, 500, 502, 503, 504].includes(response.status);
+ if (!retryable) break;
+ logger.warn("Yahoo chart: transient error, trying alternate host", {
+ symbol,
+ range,
+ status: response.status,
+ base,
+ });
+ }
+
+ if (!response) {
+ throw new Error("Yahoo Finance chart: empty response");
+ }
if (!response.ok) {
throw new Error(