xbmc/addons/Service.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 #include "Service.h"
   9
  10 #include "addons/AddonManager.h"
  11 #include "addons/addoninfo/AddonType.h"
  12 #include "interfaces/generic/ScriptInvocationManager.h"
  13 #include "utils/StringUtils.h"
  14 #include "utils/log.h"
  15
  16 #include <mutex>
  17
  18
  19 namespace ADDON
  20 {
  21
  22 CService::CService(const AddonInfoPtr& addonInfo) : CAddon(addonInfo, AddonType::SERVICE)
  23 {
  24 }
  25
  26 CServiceAddonManager::CServiceAddonManager(CAddonMgr& addonMgr) :
  27     m_addonMgr(addonMgr)
  28 {
  29 }
  30
  31 CServiceAddonManager::~CServiceAddonManager()
  32 {
  33   m_addonMgr.Events().Unsubscribe(this);
  34   m_addonMgr.UnloadEvents().Unsubscribe(this);
  35 }
  36
  37 void CServiceAddonManager::OnEvent(const ADDON::AddonEvent& event)
  38 {
  39   if (typeid(event) == typeid(ADDON::AddonEvents::Enabled))
  40   {
  41     Start(event.addonId);
  42   }
  43   else if (typeid(event) == typeid(ADDON::AddonEvents::ReInstalled))
  44   {
  45     Stop(event.addonId);
  46     Start(event.addonId);
  47   }
  48   else if (typeid(event) == typeid(ADDON::AddonEvents::Disabled) ||
  49            typeid(event) == typeid(ADDON::AddonEvents::Unload))
  50   {
  51     Stop(event.addonId);
  52   }
  53 }
  54
  55 void CServiceAddonManager::Start()
  56 {
  57   m_addonMgr.Events().Subscribe(this, &CServiceAddonManager::OnEvent);
  58   m_addonMgr.UnloadEvents().Subscribe(this, &CServiceAddonManager::OnEvent);
  59   VECADDONS addons;
  60   if (m_addonMgr.GetAddons(addons, AddonType::SERVICE))
  61   {
  62     for (const auto& addon : addons)
  63     {
  64       Start(addon);
  65     }
  66   }
  67 }
  68
  69 void CServiceAddonManager::Start(const std::string& addonId)
  70 {
  71   AddonPtr addon;
  72   if (m_addonMgr.GetAddon(addonId, addon, AddonType::SERVICE, OnlyEnabled::CHOICE_YES))
  73   {
  74     Start(addon);
  75   }
  76 }
  77
  78 void CServiceAddonManager::Start(const AddonPtr& addon)
  79 {
  80   std::unique_lock<CCriticalSection> lock(m_criticalSection);
  81   if (m_services.find(addon->ID()) != m_services.end())
  82   {
  83     CLog::Log(LOGDEBUG, "CServiceAddonManager: {} already started.", addon->ID());
  84     return;
  85   }
  86
  87   if (StringUtils::EndsWith(addon->LibPath(), ".py"))
  88   {
  89     CLog::Log(LOGDEBUG, "CServiceAddonManager: starting {}", addon->ID());
  90     auto handle = CScriptInvocationManager::GetInstance().ExecuteAsync(addon->LibPath(), addon);
  91     if (handle == -1)
  92     {
  93       CLog::Log(LOGERROR, "CServiceAddonManager: {} failed to start", addon->ID());
  94       return;
  95     }
  96     m_services[addon->ID()] = handle;
  97   }
  98 }
  99
 100 void CServiceAddonManager::Stop()
 101 {
 102   m_addonMgr.Events().Unsubscribe(this);
 103   m_addonMgr.UnloadEvents().Unsubscribe(this);
 104   std::unique_lock<CCriticalSection> lock(m_criticalSection);
 105   for (const auto& service : m_services)
 106   {
 107     Stop(service);
 108   }
 109   m_services.clear();
 110 }
 111
 112 void CServiceAddonManager::Stop(const std::string& addonId)
 113 {
 114   std::unique_lock<CCriticalSection> lock(m_criticalSection);
 115   auto it = m_services.find(addonId);
 116   if (it != m_services.end())
 117   {
 118     Stop(*it);
 119     m_services.erase(it);
 120   }
 121 }
 122
 123 void CServiceAddonManager::Stop(const std::map<std::string, int>::value_type& service)
 124 {
 125   CLog::Log(LOGDEBUG, "CServiceAddonManager: stopping {}.", service.first);
 126   if (!CScriptInvocationManager::GetInstance().Stop(service.second))
 127   {
 128     CLog::Log(LOGINFO, "CServiceAddonManager: failed to stop {} (may have ended)", service.first);
 129   }
 130 }
 131 }