From 00edf409b22bc878db1bbabf683a47ca040857af Mon Sep 17 00:00:00 2001
From: Nicolas Dato <nicolas.dato@gmail.com>
Date: Sun, 26 Nov 2023 19:50:35 -0300
Subject: [PATCH] [rudovideo] Add rudo.video extractor

---
 yt_dlp/extractor/_extractors.py |  1 +
 yt_dlp/extractor/rudovideo.py   | 31 +++++++++++++++++++++++++++++++
 2 files changed, 32 insertions(+)
 create mode 100644 yt_dlp/extractor/rudovideo.py

diff --git a/yt_dlp/extractor/_extractors.py b/yt_dlp/extractor/_extractors.py
index 9b96bd5b45..0a97125369 100644
--- a/yt_dlp/extractor/_extractors.py
+++ b/yt_dlp/extractor/_extractors.py
@@ -1643,6 +1643,7 @@ from .rumble import (
     RumbleIE,
     RumbleChannelIE,
 )
+from .rudovideo import RudoVideoIE
 from .rutube import (
     RutubeIE,
     RutubeChannelIE,
diff --git a/yt_dlp/extractor/rudovideo.py b/yt_dlp/extractor/rudovideo.py
new file mode 100644
index 0000000000..b512b7103e
--- /dev/null
+++ b/yt_dlp/extractor/rudovideo.py
@@ -0,0 +1,31 @@
+from .common import InfoExtractor
+from ..utils import js_to_json, ExtractorError, traverse_obj
+from urllib.parse import urlencode
+
+class RudoVideoIE(InfoExtractor):
+    _VALID_URL = r'https?://rudo\.video/live/(?P<id>[^/]+)'
+
+    def _real_extract(self, url):
+        video_id = self._match_id(url)
+        webpage = self._download_webpage(url, video_id)
+
+        if "Streaming is not available in your area." in webpage:
+            self.raise_geo_restricted()
+
+        stream_url = self._search_regex(r'var\s+streamURL\s*=\s*\'([^?\']+)', webpage, "streamUrl")
+        token_array_string = self._search_regex(r'<script>var\s+_\$_[a-zA-Z0-9]+\s*=\s*(\[[^]]+\])', webpage, 'token_array', default=None)
+        if token_array_string:
+            token_array_string = token_array_string.replace("x", "u00")
+            token_array = self._parse_json(token_array_string, video_id)
+            if len(token_array) != 9:
+                raise ExtractorError('Couldnt get access token array', video_id=video_id)
+            access_token_webpage = self._download_webpage(token_array[0], video_id)
+            access_token = self._parse_json(access_token_webpage, video_id)
+            if "data" not in access_token or token_array[3] not in access_token.get("data"):
+                raise ExtractorError('Couldnt get access token', video_id=video_id)
+            query_string = token_array[5] + traverse_obj(access_token, ("data", token_array[3]))
+            stream_url = f'{stream_url}{query_string}'
+
+        return self.url_result(
+            stream_url,
+            display_id=video_id, url_transparent=True)