improve: fix Mixcloud playback to use HLSHandler

Author: 1Lucas1apk

src/sources/mixcloud.js

@@ -2,10 +2,10 @@ import { PassThrough } from 'node:stream'
 import {
   encodeTrack,
   http1makeRequest,
-  loadHLSPlaylist,
   logger,
   makeRequest
 } from '../utils.js'
+import HLSHandler from '../playback/hls/HLSHandler.js'
 
 const DECRYPTION_KEY = 'IFYOUWANTTHEARTISTSTOGETPAIDDONOTDOWNLOADFROMMIXCLOUD'
 
@@ -335,19 +335,19 @@ export default class MixcloudSource {
       }
     }
 
-    if (encryptedUrl) {
+    if (encryptedHls) {
       return {
-        url: this._decrypt(encryptedUrl),
-        protocol: 'https',
-        format: 'aac'
+        url: this._decrypt(encryptedHls),
+        protocol: 'hls',
+        format: 'mpegts'
       }
     }
 
-    if (encryptedHls) {
+    if (encryptedUrl) {
       return {
-        url: this._decrypt(encryptedHls),
-        protocol: 'hls',
-        format: 'aac'
+        url: this._decrypt(encryptedUrl),
+        protocol: 'https',
+        format: 'm4a'
       }
     }
 
@@ -357,9 +357,16 @@ export default class MixcloudSource {
   async loadStream(_decodedTrack, url, protocol) {
     try {
       if (protocol === 'hls') {
-        const stream = new PassThrough()
-        loadHLSPlaylist(url, stream)
-        return { stream, type: 'aac' }
+        const stream = new HLSHandler(url, {
+          type: 'mpegts',
+          strategy: 'segmented',
+          localAddress: this.nodelink.routePlanner?.getIP(),
+          headers: {
+            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
+            'Referer': 'https://www.mixcloud.com/'
+          }
+        })
+        return { stream, type: 'mpegts' }
       }
 
       const options = {
@@ -380,14 +387,18 @@ export default class MixcloudSource {
 
       const stream = new PassThrough()
       response.stream.on('data', (chunk) => stream.write(chunk))
-      response.stream.on('end', () => stream.emit('finishBuffering'))
+      response.stream.on('end', () => {
+        if (!stream.writableEnded) {
+          stream.emit('finishBuffering')
+          stream.end()
+        }
+      })
       response.stream.on('error', (error) => {
         logger('error', 'Mixcloud', `Upstream stream error: ${error.message}`)
-        stream.emit('error', error)
-        stream.emit('finishBuffering')
+        if (!stream.destroyed) stream.destroy(error)
       })
 
-      return { stream, type: protocol === 'hls' ? 'aac' : 'm4a' }
+      return { stream, type: 'm4a' }
     } catch (e) {
       logger('error', 'Mixcloud', `Failed to load stream: ${e.message}`)
       return { exception: { message: e.message, severity: 'fault' } }