Changeset 3203 for trunk/sources/HeuristicLab.Hive.Client.Core/3.2/ConfigurationManager/UptimeManager.cs

Timestamp:

03/23/10 10:50:26 (14 years ago)

Author:

kgrading

Message:

implemented the server on the client, using push & force push, added refresh buttons, added auto calender methods that traverse the tree... (#908)

File:

• trunk/sources/HeuristicLab.Hive.Client.Core/3.2/ConfigurationManager/UptimeManager.cs (modified) (4 diffs)

trunk/sources/HeuristicLab.Hive.Client.Core/3.2/ConfigurationManager/UptimeManager.cs

@@ -7 +7 @@
 using System.IO;
 using HeuristicLab.Hive.Client.Common;
+using HeuristicLab.Hive.Contracts.BusinessObjects;
+using HeuristicLab.Hive.Contracts;
 
 namespace HeuristicLab.Hive.Client.Core.ConfigurationManager {
   public class UptimeManager {
 
-    private List<Appointment> appointments = null;
-    public List<Appointment> Appointments {
+    private AppointmentContainer _appContainer = null;
+    public AppointmentContainer AppContainer {
       get {
-        if (appointments == null)
+        if (_appContainer == null)
           RestoreFromHDD();
-        return appointments;
+        return _appContainer;
       }
-      set {
-        appointments = value;
-        PersistToHDD();
-      }
-    }
-    private static String path = System.IO.Directory.GetCurrentDirectory()+"\\plugins\\Hive.Client.Jobs\\";
+    }    
+    public bool CalendarAvailable { get; set; }
+
+    private static String path = System.IO.Directory.GetCurrentDirectory() + "\\plugins\\Hive.Client.Jobs\\";
 
     private static UptimeManager instance = null;
@@ -36 +36 @@
 
     private void PersistToHDD() {
-      XmlSerializer s = new XmlSerializer(typeof(List<Appointment>));
+      XmlSerializer s = new XmlSerializer(typeof(AppointmentContainer));
       if (!Directory.Exists(path))
         Directory.CreateDirectory(path);
@@ -42 +42 @@
       try {
         w = new StreamWriter(path + "calendar.xml");
-        s.Serialize(w, Appointments);  
-      } catch(Exception e) {
+        s.Serialize(w, AppContainer);
+      }
+      catch (Exception e) {
         Logging.Instance.Error(this.ToString(), "Persistance of the Calendar failed!", e);
-      } finally {
-        if(w!=null)
+      }
+      finally {
+        if (w != null)
           w.Close();
       }
@@ -52 +54 @@
 
     private void RestoreFromHDD() {
-      XmlSerializer s = new XmlSerializer(typeof(List<Appointment>));
-      if(File.Exists(Path.Combine(path, "calendar.xml"))) {
+      XmlSerializer s = new XmlSerializer(typeof(AppointmentContainer));
+      if (File.Exists(Path.Combine(path, "calendar.xml"))) {
         TextReader r = null;
-        
+
         try {
           r = new StreamReader(path + "calendar.xml");
-          Appointments = (List<Appointment>)s.Deserialize(r);        
-        } catch (Exception e) {
+          _appContainer = (AppointmentContainer)s.Deserialize(r);
+          CalendarAvailable = true;
+        }
+        catch (Exception e) {
           Logging.Instance.Error(this.ToString(), "Deserialization of Calendar failed", e);
           Logging.Instance.Info(this.ToString(), "Starting with a new one");
-          appointments = new List<Appointment>();
-        } finally {
-          if(r!=null)
-            r.Close();          
+          _appContainer = new AppointmentContainer();
+          CalendarAvailable = false;
+        }
+        finally {
+          if (r != null)
+            r.Close();
         }
       } else {
-        Appointments = new List<Appointment>();
+        _appContainer = new AppointmentContainer();
       }
     }
 
-    public bool isOnline() {
-      foreach (Appointment app in Appointments)
-        if ((DateTime.Now >= app.StartDate) &&
-            (DateTime.Now <= app.EndDate))
-          return true;
-      return false;
+    public bool IsOnline() {
+      return AppContainer.Appointments.Any(app => (DateTime.Now >= app.StartDate) && (DateTime.Now <= app.EndDate));
+    }
+
+    public bool SetAppointments(bool isLocal, bool isForced, IEnumerable<Appointment> appointments) {
+      if (!isForced && !isLocal && AppContainer.IsLocal)
+        return false;
+
+      AppContainer.Appointments = new List<Appointment>(appointments);
+      AppContainer.IsLocal = isLocal;
+      AppContainer.Updated = DateTime.Now;
+      CalendarAvailable = true;
+     
+      PersistToHDD();
+      
+      return true;
+    }
+
+    internal bool SetAppointments(bool isLocal, ResponseCalendar response) {
+      IList<Appointment> app = new List<Appointment>();
+      foreach (AppointmentDto appointmentDto in response.Appointments) {
+        app.Add(new Appointment {
+          AllDayEvent = appointmentDto.AllDayEvent,
+          EndDate = appointmentDto.EndDate,
+          StartDate = appointmentDto.StartDate,
+          Recurring = appointmentDto.Recurring,
+
+          RecurringId = appointmentDto.RecurringId,
+          Locked = true,
+          Subject = "Online",
+        });
+      }
+      return SetAppointments(isLocal, response.ForceFetch, app);
     }
   }