#define OVERRIDE_COMMANDLINE_ARGUMENTS // when defined will override supplied commandline args using System; using System.Collections.Generic; using System.Text; using System.Linq; using Enterprise.Logging; using System.Windows.Forms; using System.Diagnostics; using System.IO; using libxmltv.Core; using libxmltv.Interfaces; using libxmltv; namespace GBPVRProgramDatabaseFixer { class Program { static SQLLITE sqlite; static string XMLTV_FILE = ""; static string GBPVR_DATABASE = ""; static bool LOADING_XMLTV_FILE = false; static bool XMLTV_INSTANCE_CREATED = false; static int LAST_REPORTED_XMLTV_PROGRESS = 0; static bool LOADING_GBPVR_DATABASE = false; static bool SQLLIST_INSTANCE_CREATED = false; static int LAST_REPORTED_SQLLITE_PROGRESS = 0; static FileInfo fi_XMLTVFILE; static FileInfo fi_GBPVRDATABASE; static void CreateLog() { string log_path = Application.StartupPath; string log_filename = string.Format("{0}.log", typeof(Program).Assembly.GetName().Name); gLog.CreateLog(string.Format(@"{0}\{1}", log_path, log_filename), false, LogLevel.kLogLevel_All); #if DEBUG LogLevel gLevel = gLog.LogLevel; gLevel |= LogLevel.kLogLevel_VerboseDebug; gLevel |= LogLevel.kLogLevel_Debug; gLog.SetLogLevel(gLevel); #else LogLevel gLevel = LogLevel.kLogLevel_Default; // set the default log level: Info, Warn, Error, Debug // it is OK for kLogLevel_Debug to be set in Release mode ... must of the chatty messages are from kLogLevel_VerboseDebug gLevel &= ~LogLevel.kLogLevel_Debug; // ensure this is not set, ever in release mode gLevel &= ~LogLevel.kLogLevel_VerboseDebug; // ensure this is not set, ever in release mode gLog.SetLogLevel(gLevel); #endif gLog.ReportProgressEvent += new EventHandler(gLog_ReportProgress); } [Conditional("OVERRIDE_COMMANDLINE_ARGUMENTS")] static void CreateDebugCommandlineArgs(ref List cargs) { cargs = new List(); cargs.Add(string.Format("--xmltv_file=\"{0}\"", @"c:\EPG Guide\Guide\tvguide.xml")); cargs.Add(string.Format("--gbprv_db=\"{0}\"", @"c:\Program Files (x86)\Devnz\GBPVR\gbpvr.db3")); } static List CreateCommandlineArgs(string[] args) { List cargs = new List(args); CreateDebugCommandlineArgs(ref cargs); return cargs; } static void Main(string[] args) { CreateLog(); var cargs = CreateCommandlineArgs(args); foreach (var carg in cargs) { if (carg.ToLower().Contains("--xmltv_file=")) { XMLTV_FILE = carg.Replace("--xmltv_file=", "").Replace("\"",""); gLog.Info.WriteLine("XMLTV FILE: '{0}'", XMLTV_FILE); } else if (carg.ToLower().Contains("--gbprv_db=")) { GBPVR_DATABASE = carg.Replace("--gbprv_db=", "").Replace("\"", ""); gLog.Info.WriteLine("GBPVR DATABASE: '{0}'", GBPVR_DATABASE); } else { gLog.Warn.WriteLine("Unknown commandline option: {0}", carg); } } LoadXMLTVFile(); LoadGBPVRDatabase(); PerformDatabaseProcessing(); } static void ConsoleOverwritePreviosLine(string format, params object[] args) { Console.WriteLine(format,args); Console.SetCursorPosition(0, Console.CursorTop - 1); } static void gLog_ReportProgress(object sender, ReportProgressEventArgs e) { if (!XMLTV_INSTANCE_CREATED && LOADING_XMLTV_FILE) { if (LAST_REPORTED_XMLTV_PROGRESS != e.Progress) { ConsoleOverwritePreviosLine("XMLTV: {0} Loading: {1:00}%", fi_XMLTVFILE.Name, e.Progress); LAST_REPORTED_XMLTV_PROGRESS = e.Progress; if (e.Progress == 100) { Console.WriteLine("XMLTV: {0} Loading: {1:00}%", fi_XMLTVFILE.Name, e.Progress); } } } if (!SQLLIST_INSTANCE_CREATED && LOADING_GBPVR_DATABASE) { if (LAST_REPORTED_SQLLITE_PROGRESS != e.Progress) { ConsoleOverwritePreviosLine("SQLLITE: {0} Loading: {1:00}%", fi_XMLTVFILE.Name, e.Progress); LAST_REPORTED_SQLLITE_PROGRESS = e.Progress; if (e.Progress == 100) { Console.WriteLine("SQLLITE: {0} Loading: {1:00}%", fi_XMLTVFILE.Name, e.Progress); } } } } static void LoadXMLTVFile() { LOADING_XMLTV_FILE = true; if (string.IsNullOrEmpty(XMLTV_FILE)) { gLog.Error.WriteLine("XMLTV File is either a null or empty string."); LOADING_XMLTV_FILE = false; return; } fi_XMLTVFILE = new FileInfo(XMLTV_FILE); if (!fi_XMLTVFILE.Exists) { gLog.Error.WriteLine("Could not find XMLTV File: {0}", fi_XMLTVFILE.FullName); LOADING_XMLTV_FILE = false; return; } XMLTV.Create(fi_XMLTVFILE.FullName, new EventHandler(XMLTV_OnInstanceCreated)); while (!XMLTV_INSTANCE_CREATED) { Application.DoEvents(); } LOADING_XMLTV_FILE = false; } static void XMLTV_OnInstanceCreated(object sender, EventArgs e) { XMLTV_INSTANCE_CREATED = true; } static void LoadGBPVRDatabase() { LOADING_GBPVR_DATABASE = true; if (string.IsNullOrEmpty(GBPVR_DATABASE)) { gLog.Error.WriteLine("GBPVR Datbase is either a null or empty string."); LOADING_GBPVR_DATABASE = false; return; } fi_GBPVRDATABASE = new FileInfo(GBPVR_DATABASE); if (!fi_GBPVRDATABASE.Exists) { gLog.Error.WriteLine("Could not find GBPVR Database: {0}", fi_GBPVRDATABASE.FullName); LOADING_GBPVR_DATABASE = false; return; } sqlite = new SQLLITE(fi_GBPVRDATABASE.FullName, new EventHandler(SQLLITE_OnInstanceCreated)); while (!SQLLIST_INSTANCE_CREATED) { Application.DoEvents(); } LOADING_GBPVR_DATABASE = false; } static void SQLLITE_OnInstanceCreated(object sender, EventArgs e) { SQLLIST_INSTANCE_CREATED = true; } static List gbpvr_programs; static List gbpvr_channels; static List gbpvr_recordings; static IProgramDefinitionList xmltv_programs; static void PerformDatabaseProcessing() { gbpvr_channels = sqlite.Channels; gbpvr_programs = sqlite.Programs; gbpvr_recordings = sqlite.Recordings; Type datatype; xmltv_programs = (IProgramDefinitionList)XMLTV.CreateBindingSourceFromData(XMLTV.GetPrograms(), out datatype); CheckScheduledRecordingsForDiscrepancies(); CheckProgramsForDiscrepancies(); } static void CheckScheduledRecordingsForDiscrepancies() { //gLog.Warn.WriteLine("CheckScheduledRecordingsForDiscrepancies() has not been implemented"); var manual_gbpvr_recordings = gbpvr_recordings.FindAll(p => p.recording_type == 0).ToList(); foreach (var manual_recording in manual_gbpvr_recordings) { string title = manual_recording.filename; DateTime start = manual_recording.manual_start_time; DateTime end = manual_recording.manual_end_time; var found_program = xmltv_programs.ToList().Find(p => p.Title.ToLower() == title.ToLower() && p.Start == start.ToDateTimeString() && p.Stop == end.ToDateTimeString() ); if (found_program != null) { gLog.Info.WriteLine("Recording might be valid: oid='{0}' programme_oid='{1}' title='{2}' start='{3}', end='{4}'", manual_recording.oid, manual_recording.programme_oid, title, start.ToDateTimeString(), end.ToDateTimeString()); } else { gLog.Warn.WriteLine("Recording may not be valid: oid='{0}' programme_oid='{1}' title='{2}' start='{3}', end='{4}'", manual_recording.oid, manual_recording.programme_oid, title, start.ToDateTimeString(), end.ToDateTimeString()); } //bool entry_valid = false; //if (found_programs.Count == 0) //{ // gLog.Warn.WriteLine("Could not find an XMLTV Program with title: '{0}'", title); //} //foreach (var found_program in found_programs) //{ // entry_valid = (found_program.Start == start.ToDateTimeString()); // entry_valid = (found_program.Stop == end.ToDateTimeString()); //} //if (!entry_valid) //{ // gLog.Warn.WriteLine("Recording: oid='{0}' programme_oid='{1}' title='{2}' start='{3}', end='{4}' may not be valid", manual_recording.oid, manual_recording.programme_oid, title, start.ToDateTimeString(), end.ToDateTimeString()); //} } } static void CheckProgramsForDiscrepancies() { gLog.Warn.WriteLine("CheckProgramsForDiscrepancies() has not been implemented"); } } }