From a3653bc34618f1f1fa859ca040bc469e10343b15 Mon Sep 17 00:00:00 2001
From: phunkyfish <phunkyfish@gmail.com>
Date: Sun, 25 Feb 2024 08:41:54 +0000
Subject: [PATCH] Always request EPG update from Kodi on startup if it has not
 happened

---
 src/OctonetData.cpp | 22 +++++++++++++++-------
 src/OctonetData.h   |  1 +
 2 files changed, 16 insertions(+), 7 deletions(-)

diff --git a/src/OctonetData.cpp b/src/OctonetData.cpp
index 2bd242c..4590c8c 100644
--- a/src/OctonetData.cpp
+++ b/src/OctonetData.cpp
@@ -35,22 +35,16 @@ OctonetData::OctonetData(const std::string& octonetAddress,
     kodi::QueueFormattedNotification(QUEUE_ERROR, kodi::addon::GetLocalizedString(30001).c_str(),
                                      m_channels.size());
 
-  /*
-  // Currently unused, as thread was already present before with
-  // p8platform, by remove of them was it added as C++11 thread way.
   kodi::Log(ADDON_LOG_INFO, "%s Starting separate client update thread...", __func__);
   m_running = true;
   m_thread = std::thread([&] { Process(); });
-  */
 }
 
 OctonetData::~OctonetData(void)
 {
-  /*
   m_running = false;
   if (m_thread.joinable())
     m_thread.join();
-  */
 }
 
 PVR_ERROR OctonetData::GetCapabilities(kodi::addon::PVRCapabilities& capabilities)
@@ -256,7 +250,19 @@ bool OctonetData::LoadEPG(void)
 
 void OctonetData::Process()
 {
-  return;
+  // If we have not loaded EPG prior to a 10 second delay after startup
+  // then request and update from Kodi for each channel
+  std::this_thread::sleep_for(std::chrono::milliseconds(10000));
+
+  if (!m_readInitialEPG)
+  {
+    kodi::Log(ADDON_LOG_INFO, "No request detected from Kodi to load EPG, so requesting now");
+
+    for (const auto& myChannel : m_channels)
+      TriggerEpgUpdate(myChannel.id);
+  }
+
+  m_running = false;
 }
 
 PVR_ERROR OctonetData::GetChannelsAmount(int& amount)
@@ -292,6 +298,8 @@ PVR_ERROR OctonetData::GetEPGForChannel(int channelUid,
                                         time_t end,
                                         kodi::addon::PVREPGTagsResultSet& results)
 {
+  m_readInitialEPG = true;
+
   for (unsigned int i = 0; i < m_channels.size(); i++)
   {
     OctonetChannel& chan = m_channels.at(i);
diff --git a/src/OctonetData.h b/src/OctonetData.h
index f67931f..a283c8d 100644
--- a/src/OctonetData.h
+++ b/src/OctonetData.h
@@ -97,5 +97,6 @@ private:
   time_t m_lastEpgLoad;
 
   std::atomic<bool> m_running = {false};
+  std::atomic<bool> m_readInitialEPG = {false};
   std::thread m_thread;
 };