[Quantproject-developers] QuantDownloader/Downloader/OpenTickDownloader OTTickerDownloader.cs, 1.1, 1.2

[Glauco S. <gla...@us...>]

Update of /cvsroot/quantproject/QuantDownloader/Downloader/OpenTickDownloader
In directory sc8-pr-cvs16.sourceforge.net:/tmp/cvs-serv17790/Downloader/OpenTickDownloader

Modified Files:
	OTTickerDownloader.cs 
Log Message:
Now real downloading objects are used

Index: OTTickerDownloader.cs
===================================================================
RCS file: /cvsroot/quantproject/QuantDownloader/Downloader/OpenTickDownloader/OTTickerDownloader.cs,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** OTTickerDownloader.cs	1 Jul 2008 17:40:22 -0000	1.1
--- OTTickerDownloader.cs	9 Jul 2008 22:00:49 -0000	1.2
***************
*** 3,7 ****
  
  OTTickerDownloader.cs
! Copyright (C) 2008 
  Glauco Siliprandi
  
--- 3,7 ----
  
  OTTickerDownloader.cs
! Copyright (C) 2008
  Glauco Siliprandi
  
***************
*** 19,23 ****
  along with this program; if not, write to the Free Software
  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
! */
  using System;
  using System.Data;
--- 19,23 ----
  along with this program; if not, write to the Free Software
  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
!  */
  using System;
  using System.Data;
***************
*** 25,28 ****
--- 25,29 ----
  
  using QuantProject.ADT;
+ using QuantProject.Presentation;
  
  namespace QuantProject.Applications.Downloader.OpenTickDownloader
***************
*** 31,37 ****
  		object sender , DownloadingStartedEventArgs e );
  	
- 	public delegate void DatabaseUpdatedEventHandler(
- 		object sender , DatabaseUpdatedEventArgs e );
- 	
  	public delegate void DownloadingCompletedEventHandler(
  		object sender , DownloadingCompletedEventArgs e );
--- 32,35 ----
***************
*** 40,153 ****
  	/// Summary description for OTTickerDownloader.
  	/// </summary>
!   public class OTTickerDownloader
!   {
!   	private string[] tickersToDownload;
! 	  private DateTime startingNewYorkDateTime;
! 	  private DateTime dateTimeForOverWritingQuotes;//before this
! 	  //date quotes should be overwritten automatically
!     private bool checkForMissingQuotes;//it downloads and writes
!     //to db all the missing quotes 
!     private bool overwriteAllQuotesInDatabase;//for overWriting quotes
!     //also after dateTimeForOverWritingQuotes
!     private bool downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase;
!     //the starting date for download is just the next day to the
!     //last one stored in database. If no quote is stored,
!     //the starting date for download is startingNewYorkDateTime
!     private string openTickUser;
!     private string openTickPassword;
!         
!     private void otTickerDownloader_checkParameters( string[] tickersToDownload,
!                                											 DateTime startingNewYorkDateTime,
! 	  													 											 DateTime dateTimeForOverWritingQuotes,
! 	  													 											 bool checkForMissingQuotes,
! 	  													 											 bool overwriteAllQuotesInDatabase,
! 	  													 											 bool downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase,
! 	  													 											 string openTickUser,
! 	  													 											 string openTickPassword )
!     {
!     	if(tickersToDownload == null)
!     		throw new Exception("No ticker has been indicated for download!");
!     	if( !downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase && 
!     	    dateTimeForOverWritingQuotes.CompareTo(startingNewYorkDateTime) < 0 )
!     	//the user has not requested only quotes successive to the last 
!     	//stored in the DB and date time for overwriting quotes precedes
!     	//the date time for the first quote to download
!     		throw new Exception("Date Time for OverWriting Quotes can't precede " +
!     		                    "starting Date for download!");
!     	if( checkForMissingQuotes && downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase  )
!     	//the two options have to be different in value or both false
!     		throw new Exception("Downloading only quotes successive to the last quote in the DB " + 
!     		                    "implies that missing quotes will not be checked" );
!     	if( ( openTickUser == null || openTickUser == "" ) || 
!     	    ( openTickPassword == null || openTickPassword == "" ) )
!     		throw new Exception("Type in user and password for logging to OpenTick" );
!     }
!     
!   	public OTTickerDownloader( string[] tickersToDownload,
!                                DateTime startingNewYorkDateTime,
! 	  													 DateTime dateTimeForOverWritingQuotes,
! 	  													 bool checkForMissingQuotes,
! 	  													 bool overwriteAllQuotesInDatabase,
! 	  													 bool downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase,
! 	  													 string openTickUser,
! 	  													 string openTickPassword)
!     {
!     	this.otTickerDownloader_checkParameters(tickersToDownload,
!                                startingNewYorkDateTime,
! 	  													 dateTimeForOverWritingQuotes,
! 	  													 checkForMissingQuotes,
! 	  													 overwriteAllQuotesInDatabase,
! 	  													 downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase,
! 	  													 openTickUser,
! 	  													 openTickPassword);
!     	this.tickersToDownload = tickersToDownload;
!       this.startingNewYorkDateTime = startingNewYorkDateTime;
!       this.dateTimeForOverWritingQuotes = dateTimeForOverWritingQuotes;
!       this.checkForMissingQuotes = checkForMissingQuotes;
!       this.overwriteAllQuotesInDatabase = overwriteAllQuotesInDatabase;
!       this.downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase = downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase;
!       this.openTickUser = openTickUser;
!       this.openTickPassword = openTickPassword;
!     }
  		
!     public event DownloadingStartedEventHandler DownloadingStarted;
!   	public event DatabaseUpdatedEventHandler DatabaseUpdated;
!   	public event DownloadingCompletedEventHandler DownloadingCompleted;
!   	
!   	private void downloadTickers_dummyDatabaseUpdatedEventRiser()
!   	{
!   		DateTime dateTimeOfLastBarUpdated = DateTime.Now;
!   		foreach(string ticker in this.tickersToDownload)
!   		{
!   			Thread.Sleep(500);
!   			DatabaseUpdatedEventArgs databaseUpdatedEventArgs =
!   				new DatabaseUpdatedEventArgs(ticker, dateTimeOfLastBarUpdated);
!   			if(this.DatabaseUpdated != null)
!   				this.DatabaseUpdated(this, databaseUpdatedEventArgs);
!   		}
!   	}
!   	
!   	private void downloadTickers_dummyDownloadingStartedEventRiser()
!   	{
!   		DownloadingStartedEventArgs eventArgs = 
!   			new DownloadingStartedEventArgs(DateTime.Now);
!   		if(this.DownloadingStarted != null)
!   			this.DownloadingStarted( this, eventArgs );
!    	}
!   	
!   	private void downloadTickers_dummyDownloadingCompletedEventRiser()
!   	{
!   		DownloadingCompletedEventArgs eventArgs = 
!   			new DownloadingCompletedEventArgs(DateTime.Now);
!   		if(this.DownloadingCompleted != null)
!   			this.DownloadingCompleted( this, eventArgs );
!    	}
!   	
!   	public void DownloadTickers()
!   	{
!   		this.downloadTickers_dummyDownloadingStartedEventRiser();
!   		this.downloadTickers_dummyDatabaseUpdatedEventRiser();
!   		this.downloadTickers_dummyDownloadingCompletedEventRiser();
!   	}
!   }  
  }
--- 38,291 ----
  	/// Summary description for OTTickerDownloader.
  	/// </summary>
! 	public class OTTickerDownloader
! 	{
! 		private string[] tickersToDownload;
! 		private DateTime firstDate;
! 		/// <summary>
! 		/// time (date doesn't matter for this member) for the first
! 		/// bar to be downloaded, each day
! 		/// </summary>
! 		private DateTime firstBarOpenTimeInNewYorkTimeZone;
! 		/// <summary>
! 		/// number of seconds in each bar
! 		/// </summary>
! 		private int barInterval;
! 		/// <summary>
! 		/// number of bars to be downloaded for each day
! 		/// </summary>
! 		private int numberOfDailyBars;
! 		private DateTime dateTimeForOverWritingQuotes;//before this
! 		//date quotes should be overwritten automatically
! 		private bool checkForMissingQuotes;//it downloads and writes
! 		//to db all the missing quotes
! 		private bool overwriteAllQuotesInDatabase;//for overWriting quotes
! 		//also after dateTimeForOverWritingQuotes
! 		private bool downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase;
! 		//the starting date for download is just the next day to the
! 		//last one stored in database. If no quote is stored,
! 		//the starting date for download is startingNewYorkDateTime
! 		private string openTickUser;
! 		private string openTickPassword;
  		
! 		private IExchangeSelector exchangeSelector;
! 		private IBarsSelector barsSelector;
! 		private BarsDownloader barsDownloader;
! 		private MessageManager messageManager;
! 		
! 		private Thread downloadBarsThread;
! 		
! 		private void otTickerDownloader_checkParameters( string[] tickersToDownload,
! 		                                                DateTime startingNewYorkDateTime,
! 		                                                DateTime dateTimeForOverWritingQuotes,
! 		                                                bool checkForMissingQuotes,
! 		                                                bool overwriteAllQuotesInDatabase,
! 		                                                bool downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase,
! 		                                                string openTickUser,
! 		                                                string openTickPassword )
! 		{
! 			if(tickersToDownload == null)
! 				throw new Exception("No ticker has been indicated for download!");
! 			if( !downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase &&
! 			   dateTimeForOverWritingQuotes.CompareTo(startingNewYorkDateTime) < 0 )
! 				//the user has not requested only quotes successive to the last
! 				//stored in the DB and date time for overwriting quotes precedes
! 				//the date time for the first quote to download
! 				throw new Exception("Date Time for OverWriting Quotes can't precede " +
! 				                    "starting Date for download!");
! 			if( checkForMissingQuotes && downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase  )
! 				//the two options have to be different in value or both false
! 				throw new Exception("Downloading only quotes successive to the last quote in the DB " +
! 				                    "implies that missing quotes will not be checked" );
! 			if( ( openTickUser == null || openTickUser == "" ) ||
! 			   ( openTickPassword == null || openTickPassword == "" ) )
! 				throw new Exception("Type in user and password for logging to OpenTick" );
! 		}
! 		
! 		public OTTickerDownloader(
! 			string[] tickersToDownload,
! 			DateTime firstDate,
! 			int fromHour ,
! 			int fromMinute ,
! 			int fromSecond ,
! 			int barInterval ,
! 			int numberOfDailyBars ,
! 			DateTime dateTimeForOverWritingQuotes,
! 			bool checkForMissingQuotes,
! 			bool overwriteAllQuotesInDatabase,
! 			bool downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase,
! 			string openTickUser,
! 			string openTickPassword)
! 		{
! 			this.otTickerDownloader_checkParameters(tickersToDownload,
! 			                                        firstDate,
! 			                                        dateTimeForOverWritingQuotes,
! 			                                        checkForMissingQuotes,
! 			                                        overwriteAllQuotesInDatabase,
! 			                                        downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase,
! 			                                        openTickUser,
! 			                                        openTickPassword);
! 			this.tickersToDownload = tickersToDownload;
! 			this.firstDate = firstDate;
! 			this.firstBarOpenTimeInNewYorkTimeZone =
! 				new DateTime(
! 					1 , 1 , 1 , fromHour , fromMinute , fromSecond );
! 			this.barInterval = barInterval;
! 			this.numberOfDailyBars = numberOfDailyBars;
! 			this.dateTimeForOverWritingQuotes = dateTimeForOverWritingQuotes;
! 			this.checkForMissingQuotes = checkForMissingQuotes;
! 			this.overwriteAllQuotesInDatabase = overwriteAllQuotesInDatabase;
! 			this.downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase =
! 				downloadOnlySuccessiveQuotesToTheLastQuoteInDatabase;
! 			this.openTickUser = openTickUser;
! 			this.openTickPassword = openTickPassword;
! 		}
! 		
! 		public event DownloadingStartedEventHandler DownloadingStarted;
! 		public event DatabaseUpdatedEventHandler DatabaseUpdated;
! 		public event DownloadingCompletedEventHandler DownloadingCompleted;
! 		
! 		#region DownloadTickers
! 		private void downloadTickers_dummyDatabaseUpdatedEventRiser()
! 		{
! 			DateTime dateTimeOfLastBarUpdated = DateTime.Now;
! 			foreach(string ticker in this.tickersToDownload)
! 			{
! 				Thread.Sleep(500);
! 				DatabaseUpdatedEventArgs databaseUpdatedEventArgs =
! 					new DatabaseUpdatedEventArgs(ticker, dateTimeOfLastBarUpdated);
! 				if(this.DatabaseUpdated != null)
! 					this.DatabaseUpdated(this, databaseUpdatedEventArgs);
! 			}
! 		}
! 		
! 		private void downloadTickers_dummyDownloadingStartedEventRiser()
! 		{
! 			DownloadingStartedEventArgs eventArgs =
! 				new DownloadingStartedEventArgs(DateTime.Now);
! 			if(this.DownloadingStarted != null)
! 				this.DownloadingStarted( this, eventArgs );
! 		}
! 		
! 		private void downloadTickers_dummyDownloadingCompletedEventRiser()
! 		{
! 			DownloadingCompletedEventArgs eventArgs =
! 				new DownloadingCompletedEventArgs(DateTime.Now);
! 			if(this.DownloadingCompleted != null)
! 				this.DownloadingCompleted( this, eventArgs );
! 		}
! 
! 		#region downloadTickersActually
! 		private DateTime setBarsSelector_getDate( DateTime dateTime )
! 		{
! 			DateTime date = new DateTime(
! 				dateTime.Year , dateTime.Month , dateTime.Day );
! 			return date;
! 		}
! 		private void setBarsSelector()
! 		{
! 			this.barsSelector =
! 				new DailyBarsSelector(
! 					this.tickersToDownload ,
! 					this.setBarsSelector_getDate( this.firstDate ) ,
! 					this.setBarsSelector_getDate( DateTime.Now ) ,
! 					this.barInterval ,
! 					this.firstBarOpenTimeInNewYorkTimeZone ,
! 					this.numberOfDailyBars );
! 		}
! 		private void setExchangeSelector()
! 		{
!         	this.exchangeSelector =
!         		new MostLiquidExchangeSelector();
! 		}
! 		#region setBarsDownloaderAndRunIt
! 		
! 		#region setBarsDownloader
! 		
! 		#region setBarsDownloader_setEventHandlers
! 		private void databaseUpdatedEventHandler(
! 			object sender , DatabaseUpdatedEventArgs eventArgs )
! 		{
! 			if ( this.DatabaseUpdated != null )
! 				this.DatabaseUpdated( this , eventArgs );
! 		}
! 		private void setBarsDownloader_setEventHandlers()
! 		{
! 			this.barsDownloader.DatabaseUpdated +=
! 				new DatabaseUpdatedEventHandler(
! 					this.databaseUpdatedEventHandler );
! 		}
! 		#endregion setBarsDownloader_setEventHandlers
! 
! 		private void setBarsDownloader()
! 		{
! //			DailyBarsSelector barsSelector =
! //				new DailyBarsSelector(
! //					new string[]{ "GE" , "MSFT" } ,
! //					new DateTime( 2002 , 3 , 1 ) ,
! //					new DateTime( 2002 , 4 , 30 ) ,
! //					60 ,
! //					new DateTime( 1 , 1 , 1 , 9 , 29 , 0 ) ,
! //					3 );
! 			this.barsDownloader =
! 				new BarsDownloader(
! 					this.barsSelector ,
! 					this.exchangeSelector ,
! 					this.openTickUser ,
! 					this.openTickPassword );
! 			this.setBarsDownloader_setEventHandlers();
! //			this.barsDownloader.NewOHLCRequest +=
! //				new NewOHLCRequestEventHandler (
! //					this.newOHLCRequestEventHandler );
! 		}
! 		#endregion setBarsDownloader
! 		
! 		#region setMessageManager
! 		private string getLogFileName()
! 		{
! 			string logFileName =
! 				@"C:\QuantProject\OpenTickDownloader\textFilesForLoggingNotification\textFileForLoggingNotification";
! 			logFileName = logFileName + "_" +
! 				ExtendedDateTime.GetCompleteShortDescriptionForFileName(
! 					DateTime.Now ) + ".txt";
! 			return logFileName;
! 		}
! 		private void setMessageManager()
! 		{
! 			this.messageManager =
! 				new MessageManager( this.getLogFileName() );
! 			this.messageManager.Monitor(
! 				this.barsDownloader );
! 		}
! 		#endregion setMessageManager
! 		
! 		private void downloadBarsInANewThread()
! 		{
! 			this.downloadBarsThread = new Thread(
! 				new ThreadStart( this.barsDownloader.DownloadBars ) );
! 			this.downloadBarsThread.Start();
! 		}
! 		private void setBarsDownloaderAndRunIt()
! 		{
! 			this.setBarsDownloader();
! 			this.setMessageManager();
! 			this.downloadBarsInANewThread();
! 		}
! 		#endregion setBarsDownloaderAndRunIt
! 		private void downloadTickersActually()
! 		{
! 			this.setBarsSelector();
! 			this.setExchangeSelector();
! 			this.setBarsDownloaderAndRunIt();
! 		}
! 		#endregion downloadTickersActually
! 		
! 		public void DownloadTickers()
! 		{
! 			this.downloadTickersActually();
! //			this.downloadTickers_dummyDownloadingStartedEventRiser();
! //			this.downloadTickers_dummyDatabaseUpdatedEventRiser();
! //			this.downloadTickers_dummyDownloadingCompletedEventRiser();
! 		}
! 		#endregion DownloadTickers
! 	}
  }