using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using Android.Util;
using LumenWorks.Framework.IO.Csv;
using MonoStockPortfolio.Entities;

namespace MonoStockPortfolio.Core.StockData
{
    public class YahooStockDataProvider : IStockDataProvider
    {
        private const string LAST_TRADE_PRICE_ONLY = "l1";
        private const string NAME = "n";
        private const string VOLUME = "v";
        private const string TICKER_SYMBOL = "s";
        private const string CHANGE = "c1";
        private const string LAST_TRADE_TIME = "t1";
        private const string REAL_TIME_LAST_TRADE_WITH_TIME = "k1";
        private const string REAL_TIME_CHANGE = "c6";

        // http://www.gummy-stuff.org/Yahoo-data.htm
        // http://finance.yahoo.com/d/quotes.csv?s= a BUNCH of 
        // STOCK SYMBOLS separated by "+" &f=a bunch of special tags
        public IEnumerable<StockQuote> GetStockQuotes(IEnumerable<string> tickers)
        {
            string url = "http://finance.yahoo.com/d/quotes.csv?s=";
            url += string.Join("+", tickers.ToArray());
            url += "&f=";

            // the ordering is important, if it's changed here, it should be changed
            // in the ParseCsvIntoStockQuotes method too
            url += TICKER_SYMBOL;
            url += LAST_TRADE_PRICE_ONLY;
            url += NAME;
            url += VOLUME;
            url += CHANGE;
            url += LAST_TRADE_TIME;
            url += REAL_TIME_LAST_TRADE_WITH_TIME;
            url += REAL_TIME_CHANGE;

            string resultCsv = ScrapeUrl(url);

            var yahooQuoteData = ParseCsvIntoStockQuotes(resultCsv);

            return yahooQuoteData.Select(MapYahooData);
        }

        // Yahoo API will return a stock with price of 0.00
        // if it can't find the ticker
        public bool IsValidTicker(string ticker)
        {
            var quote = GetStockQuotes(new[] {ticker}).Single();
            return quote.LastTradePrice > 0.0M;
        }

        private static StockQuote MapYahooData(YahooFinanceStockData data)
        {
            if (data == null)
            {
                return null;
            }
            var stock = new StockQuote();
            stock.Name = data.Name;
            stock.LastTradePrice = data.LastTradePrice;
            stock.Ticker = data.Ticker;
            stock.Volume = data.Volume;
            stock.Change = data.Change;
            stock.LastTradeTime = data.LastTradeTime;
            stock.RealTimeLastTradePrice = decimal.Parse(data.RealTimeLastTradeWithTime
                .Replace("<b>", "")
                .Replace("</b>", "")
                .Replace("N/A -", "")
                .Trim()
            );
            stock.ChangeRealTime = data.ChangeRealTime;
            return stock;
        }

        private static IEnumerable<YahooFinanceStockData> ParseCsvIntoStockQuotes(string csv)
        {
            using(var csvReader = new CsvReader(new StringReader(csv),false))
            {
                while(csvReader.ReadNextRecord())
                {
                    var d = new YahooFinanceStockData();
                    d.Ticker = csvReader[0];
                    decimal.TryParse(csvReader[1], out d.LastTradePrice);
                    //d.LastTradePrice = decimal.Parse(csvReader[1]);
                    d.Name = csvReader[2];
                    d.Volume = csvReader[3];
                    decimal.TryParse(csvReader[4], out d.Change);
                    //d.Change = decimal.Parse(csvReader[4]);
                    d.LastTradeTime = csvReader[5];
                    d.RealTimeLastTradeWithTime = csvReader[6];
                    d.ChangeRealTime = csvReader[7];
                    yield return d;
                }
            }
        }

        private static string ScrapeUrl(string url)
        {
            try
            {
                string resultCsv;
                var req = WebRequest.Create(url);
                var resp = req.GetResponse();
                using (var sr = new StreamReader(resp.GetResponseStream()))
                {
                    resultCsv = sr.ReadToEnd();
                    sr.Close();
                }
                return resultCsv;
            }
            catch (Exception ex)
            {
                Log.Error("ScrapeUrlException", ex.ToString());
                throw;
            }
        }
    }
}