from vnstock import Quote

# Basic usage - VCI source only
quote = Quote(symbol='VCI', source='VCI')
df = quote.history(start='2024-01-01', end='2024-12-31', interval='1D')

from vnstock import Quote

symbols = ['VCI', 'ACB', 'FPT']
quote = Quote(source='VCI', symbol='VCI')
results = {}

for symbol in symbols:
    quote.symbol = symbol
    results[symbol] = quote.history(start='2024-01-01', end='2024-12-31', interval='1D')

from tenacity import retry, stop_after_attempt, wait_exponential, retry_if_exception_type
import requests

@retry(
    retry=retry_if_exception_type((requests.RequestException, TimeoutError)),
    stop=stop_after_attempt(5),
    wait=wait_exponential(multiplier=1, min=2, max=10)
)
def fetch_with_retry(quote, start, end):
    return quote.history(start=start, end=end)

def get_price_with_fallback(symbol, start, end):
    sources = ['VCI', 'TCBS']  # VCI primary, TCBS backup
    for source in sources:
        try:
            quote = Quote(source=source, symbol=symbol)
            return quote.history(start=start, end=end)
        except Exception:
            continue
    raise Exception("All sources failed")

def validate_ohlc(df):
    issues = []
    required = ['time', 'open', 'high', 'low', 'close', 'volume']
    missing = [c for c in required if c not in df.columns]
    if missing:
        issues.append(f"Missing: {missing}")
    if df.isnull().any().any():
        issues.append(f"Nulls: {df.isnull().sum().sum()}")
    if (df['high'] < df['low']).any():
        issues.append("Invalid OHLC: high < low")
    return issues

import numpy as np

def detect_outliers(df, column='close', threshold=3):
    z = np.abs((df[column] - df[column].mean()) / df[column].std())
    return df[z > threshold]