1 files changed, 98 insertions, 0 deletions
diff --git a/xbmc/addons/RepositoryUpdater.h b/xbmc/addons/RepositoryUpdater.h
new file mode 100644
index 0000000..e5550c7
--- /dev/null
+++ b/xbmc/addons/RepositoryUpdater.h
@@ -0,0 +1,98 @@
+/*
+ *  Copyright (C) 2015-2018 Team Kodi
+ *  This file is part of Kodi - https://kodi.tv
+ *
+ *  SPDX-License-Identifier: GPL-2.0-or-later
+ *  See LICENSES/README.md for more information.
+ */
+
+#pragma once
+
+#include "settings/lib/ISettingCallback.h"
+#include "threads/CriticalSection.h"
+#include "threads/Timer.h"
+#include "utils/EventStream.h"
+#include "utils/Job.h"
+
+#include <memory>
+#include <vector>
+
+class CDateTime;
+
+namespace ADDON
+{
+
+class CAddonMgr;
+
+class CRepository;
+using RepositoryPtr = std::shared_ptr<CRepository>;
+
+class CRepositoryUpdateJob;
+
+struct AddonEvent;
+
+class CRepositoryUpdater : private ITimerCallback, private IJobCallback, public ISettingCallback
+{
+public:
+  explicit CRepositoryUpdater(CAddonMgr& addonMgr);
+  ~CRepositoryUpdater() override;
+
+  void Start();
+
+  /**
+   * Check a single repository for updates.
+   */
+  void CheckForUpdates(const ADDON::RepositoryPtr& repo, bool showProgress=false);
+
+  /**
+   * Check all repositories for updates.
+   */
+  bool CheckForUpdates(bool showProgress=false);
+
+  /**
+   * Wait for any pending/in-progress updates to complete.
+   */
+  void Await();
+
+  /**
+   * Schedule an automatic update to run based on settings and previous update
+   * times. May be called when there are external changes this updater must know
+   * about. Any previously scheduled update will be cancelled.
+   */
+  void ScheduleUpdate();
+
+  /**
+   * Returns the time of the last check (oldest). Invalid time if never checked.
+   */
+  CDateTime LastUpdated() const;
+
+
+  void OnSettingChanged(const std::shared_ptr<const CSetting>& setting) override;
+
+  struct RepositoryUpdated { };
+
+  CEventStream<RepositoryUpdated>& Events() { return m_events; }
+
+private:
+  CRepositoryUpdater(const CRepositoryUpdater&) = delete;
+  CRepositoryUpdater(CRepositoryUpdater&&) = delete;
+  CRepositoryUpdater& operator=(const CRepositoryUpdater&) = delete;
+  CRepositoryUpdater& operator=(CRepositoryUpdater&&) = delete;
+
+  void OnJobComplete(unsigned int jobID, bool success, CJob *job) override;
+
+  void OnTimeout() override;
+
+  void OnEvent(const ADDON::AddonEvent& event);
+
+  CDateTime ClosestNextCheck() const;
+
+  CCriticalSection m_criticalSection;
+  CTimer m_timer;
+  CEvent m_doneEvent;
+  std::vector<CRepositoryUpdateJob*> m_jobs;
+  CAddonMgr& m_addonMgr;
+
+  CEventSource<RepositoryUpdated> m_events;
+};
+}