xbmc/utils/AlarmClock.cpp

   1 /*
   2  *  Copyright (C) 2005-2018 Team Kodi
   3  *  This file is part of Kodi - https://kodi.tv
   4  *
   5  *  SPDX-License-Identifier: GPL-2.0-or-later
   6  *  See LICENSES/README.md for more information.
   7  */
   8
   9 #include "AlarmClock.h"
  10
  11 #include "ServiceBroker.h"
  12 #include "dialogs/GUIDialogKaiToast.h"
  13 #include "events/EventLog.h"
  14 #include "events/NotificationEvent.h"
  15 #include "guilib/LocalizeStrings.h"
  16 #include "log.h"
  17 #include "messaging/ApplicationMessenger.h"
  18 #include "utils/StringUtils.h"
  19
  20 #include <mutex>
  21 #include <utility>
  22
  23 using namespace std::chrono_literals;
  24
  25 CAlarmClock::CAlarmClock() : CThread("AlarmClock")
  26 {
  27 }
  28
  29 CAlarmClock::~CAlarmClock() = default;
  30
  31 void CAlarmClock::Start(const std::string& strName, float n_secs, const std::string& strCommand, bool bSilent /* false */, bool bLoop /* false */)
  32 {
  33   // make lower case so that lookups are case-insensitive
  34   std::string lowerName(strName);
  35   StringUtils::ToLower(lowerName);
  36   Stop(lowerName);
  37   SAlarmClockEvent event;
  38   event.m_fSecs = static_cast<double>(n_secs);
  39   event.m_strCommand = strCommand;
  40   event.m_loop = bLoop;
  41   if (!m_bIsRunning)
  42   {
  43     StopThread();
  44     Create();
  45     m_bIsRunning = true;
  46   }
  47
  48   uint32_t labelAlarmClock;
  49   uint32_t labelStarted;
  50   if (StringUtils::EqualsNoCase(strName, "shutdowntimer"))
  51   {
  52     labelAlarmClock = 20144;
  53     labelStarted = 20146;
  54   }
  55   else
  56   {
  57     labelAlarmClock = 13208;
  58     labelStarted = 13210;
  59   }
  60
  61   EventPtr alarmClockActivity(new CNotificationEvent(
  62       labelAlarmClock,
  63       StringUtils::Format(g_localizeStrings.Get(labelStarted), static_cast<int>(event.m_fSecs) / 60,
  64                           static_cast<int>(event.m_fSecs) % 60)));
  65
  66   auto eventLog = CServiceBroker::GetEventLog();
  67   if (eventLog)
  68   {
  69     if (bSilent)
  70       eventLog->Add(alarmClockActivity);
  71     else
  72       eventLog->AddWithNotification(alarmClockActivity);
  73   }
  74
  75   event.watch.StartZero();
  76   std::unique_lock<CCriticalSection> lock(m_events);
  77   m_event.insert(make_pair(lowerName,event));
  78   CLog::Log(LOGDEBUG, "started alarm with name: {}", lowerName);
  79 }
  80
  81 void CAlarmClock::Stop(const std::string& strName, bool bSilent /* false */)
  82 {
  83   std::unique_lock<CCriticalSection> lock(m_events);
  84
  85   std::string lowerName(strName);
  86   StringUtils::ToLower(lowerName);          // lookup as lowercase only
  87   std::map<std::string,SAlarmClockEvent>::iterator iter = m_event.find(lowerName);
  88
  89   if (iter == m_event.end())
  90     return;
  91
  92   uint32_t labelAlarmClock;
  93   if (StringUtils::EqualsNoCase(strName, "shutdowntimer"))
  94     labelAlarmClock = 20144;
  95   else
  96     labelAlarmClock = 13208;
  97
  98   std::string strMessage;
  99   float       elapsed     = 0.f;
 100
 101   if (iter->second.watch.IsRunning())
 102     elapsed = iter->second.watch.GetElapsedSeconds();
 103
 104   if (elapsed > static_cast<float>(iter->second.m_fSecs))
 105     strMessage = g_localizeStrings.Get(13211);
 106   else
 107   {
 108     float remaining = static_cast<float>(iter->second.m_fSecs) - elapsed;
 109     strMessage = StringUtils::Format(g_localizeStrings.Get(13212), static_cast<int>(remaining) / 60,
 110                                      static_cast<int>(remaining) % 60);
 111   }
 112
 113   if (iter->second.m_strCommand.empty() || static_cast<float>(iter->second.m_fSecs) > elapsed)
 114   {
 115     EventPtr alarmClockActivity(new CNotificationEvent(labelAlarmClock, strMessage));
 116     auto eventLog = CServiceBroker::GetEventLog();
 117     if (eventLog)
 118     {
 119       if (bSilent)
 120         eventLog->Add(alarmClockActivity);
 121       else
 122         eventLog->AddWithNotification(alarmClockActivity);
 123     }
 124   }
 125   else
 126   {
 127     CServiceBroker::GetAppMessenger()->PostMsg(TMSG_EXECUTE_BUILT_IN, -1, -1, nullptr,
 128                                                iter->second.m_strCommand);
 129     if (iter->second.m_loop)
 130     {
 131       iter->second.watch.Reset();
 132       return;
 133     }
 134   }
 135
 136   iter->second.watch.Stop();
 137   m_event.erase(iter);
 138 }
 139
 140 void CAlarmClock::Process()
 141 {
 142   while( !m_bStop)
 143   {
 144     std::string strLast;
 145     {
 146       std::unique_lock<CCriticalSection> lock(m_events);
 147       for (std::map<std::string,SAlarmClockEvent>::iterator iter=m_event.begin();iter != m_event.end(); ++iter)
 148         if (iter->second.watch.IsRunning() &&
 149             iter->second.watch.GetElapsedSeconds() >= static_cast<float>(iter->second.m_fSecs))
 150         {
 151           Stop(iter->first);
 152           if ((iter = m_event.find(strLast)) == m_event.end())
 153             break;
 154         }
 155         else
 156           strLast = iter->first;
 157     }
 158     CThread::Sleep(100ms);
 159   }
 160 }
 161