#include <iostream>
#include "../../shared/MiscSQL.h"
#include "../FieldLists.h"
#include "HistoryFileWriter.h"

std::string time3(time_t time)
{
  return TclList(time, timeTToMysql(time), ctimeString(time));
}

std::string summarize(Record::Ref const &record)
{
  if (!record)
    return "NULL";
  TclList result;
  bool success;
  int64_t id;
  record->lookUpValue(MainFields::id).getInt(success, id);
  if (success)
    result<<"id"<<id;
  std::string symbol;
  record->lookUpValue(MainFields::symbol).getString(success, symbol);
  if (success)
    result<<"symbol"<<symbol;
  time_t timestamp;
  record->lookUpValue(MainFields::timestamp).getInt(success, timestamp);
  if (success)
    result<<"timestamp"<<time3(timestamp);
  return result;
}

void timeAll(HistoryFileReader &reader)
{
  StopWatch stopWatch;
  int64_t position = reader.findFirst(0);
  int64_t sum = 0;
  int64_t count = 0;
  while (position != HistoryFileReader::INVALID)
  {
    Record::Ref record;
    reader.readForward(position, record);
    count++;
    bool success;
    int64_t id;
    record->lookUpValue(MainFields::id).getInt(success, id);
    if (success)
      sum += id;
    //if ((count % 1000) == 0)
    //  std::cout<<"["<<addCommas(count)<<"]";
  }
  const auto microSeconds = stopWatch.getMicroSeconds();  
  std::cout<<"timeAll():  "
	   <<"Time = "<<addCommas(microSeconds)<<", count = "<<count
	   <<", sum = "<<sum<<std::endl;
}

int main(int argc, char *argv[])
{
  if (argc < 2)
  {
    std::cerr<<"The input should be a list of 1 or more file names."
	     <<std::endl
	     <<"optional arg --time-all will do more testing on each file."
	     <<std::endl;
    return 1;
  }
  bool doTimeAll = false;
  for (int i = 1; i < argc; i++)
  {
    const std::string fileName(argv[i]);
    if (fileName == "--time-all")
      doTimeAll = true;
    else
    {
      if (argc > 2 + doTimeAll)
	std::cout<<"==== "<<fileName<<" ========"<<std::endl;
      HistoryFileReader reader(fileName);
      if (!reader.isGood())
	std::cout<<"Error:  "<<reader.getErrorMessage()<<std::endl;
      else
      {
	if (doTimeAll)
	  timeAll(reader);
	XmlNode dump;
	reader.dump(dump);
	std::cout<<"dump():  "<<dump.asString("DUMP")<<std::endl;
	std::cout<<"getStartTime():  "<<time3(reader.getStartTime())<<std::endl;
	// Note:  The first and last records are gaurenteed to the in the index.
	// So we can easily use findFirst() and findLast() to find those items.
	// In general these functions are only gaurenteed to get you close.  In
	// general you want HistoryFileIterator to take care of the details for
	// you.
	int64_t position = reader.findFirst(0);
	for (int r = 0; (r < 3) && (position != HistoryFileReader::INVALID); r++)
	{
	  Record::Ref record;
	  reader.readForward(position, record);
	  std::cout<<summarize(record)<<std::endl;
	}
	std::cout<<"..."<<std::endl;
	std::vector< Record::Ref > lastItems;
	position = reader.findLast(0x7fffffffffffffff);
	for (int r = 0; (r < 3) && (position != HistoryFileReader::INVALID); r++)
	{
	  Record::Ref record;
	  reader.readBackward(position, record);
	  lastItems.push_back(record);
	}
	for (auto it = lastItems.rbegin(); it != lastItems.rend(); it++)
	  std::cout<<summarize(*it)<<std::endl;
      }
    }
  }
}