RepositoryUpdater.h

/*
 *  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();

  void CheckForUpdates(const ADDON::RepositoryPtr& repo, bool showProgress=false);

  bool CheckForUpdates(bool showProgress=false);

  void Await();

  enum class UpdateScheduleType
  {
    First,
    Regular
  };

  void ScheduleUpdate(UpdateScheduleType scheduleType);

  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;
};
}