Force delete streams, when decrypter is not initialized

src/Session.cpp

@@ -65,7 +65,7 @@ CSession::CSession(const std::string& manifestUrl) : m_manifestUrl(manifestUrl)
 CSession::~CSession()
 {
   LOG::Log(LOGDEBUG, "CSession::~CSession()");
-  m_streams.clear();
+  DeleteStreams();
   DisposeDecrypter();
 
   if (m_adaptiveTree)
@@ -79,6 +79,12 @@ CSession::~CSession()
   m_reprChooser = nullptr;
 }
 
+void SESSION::CSession::DeleteStreams()
+{
+  LOG::Log(LOGDEBUG, "CSession::DeleteStreams()");
+  m_streams.clear();
+}
+
 void CSession::SetSupportedDecrypterURN(std::vector<std::string_view>& keySystems)
 {
   std::string decrypterPath = CSrvBroker::GetSettings().GetDecrypterPath();

src/Session.h

@@ -30,6 +30,8 @@ class ATTR_DLL_LOCAL CSession : public adaptive::AdaptiveStreamObserver
   CSession(const std::string& manifestUrl);
   virtual ~CSession();
 
+  void DeleteStreams();
+
   /*! \brief Initialize the session
    *  \return True if has success, false otherwise
    */

src/main.cpp

@@ -136,6 +136,27 @@ bool CInputStreamAdaptive::GetStream(int streamid, kodi::addon::InputstreamInfo&
 
   if (stream)
   {
+    // If the stream is encrypted, verify if the decrypter has been initialized
+    // this is important for HLS because the DRM it is initialized at later time
+    // so on the OpenStream, instead of CSession::Initialize->InitializePeriod->InitializeDRM
+    // Since kodi initialize one single stream at time, can happens that or another stream
+    // has been opened before this one, or another stream will be opened after this one (e.g. unencrypted)
+    // so if you dont delete all streams, the kodi demux reader still starts
+    // and a corrupted playback will starts.
+    // NOTE: GetStream is called by Kodi twice times, before and after OpenStream, on HLS
+    // the first time all streams are unencrypted because child manifest has not been downloaded
+    const uint16_t psshSetPos = stream->m_adStream.getRepresentation()->m_psshSetPos;
+    if (psshSetPos != PSSHSET_POS_DEFAULT ||
+        stream->m_adStream.getPeriod()->GetEncryptionState() == EncryptionState::NOT_SUPPORTED)
+    {
+      if (!m_session->GetSingleSampleDecryptor(psshSetPos))
+      {
+        LOG::Log(LOGERROR, "GetStream(%d): Decrypter for the stream not found");
+        m_session->DeleteStreams();
+        return false;
+      }
+    }
+
     info = stream->m_info;
     return true;
   }