@echo off

set /p name=nickname: 

set dir=D:\Records
set quality=best
set "user_agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36"

::443 - default port for HTTPS
set server=https://diana.dreamdares.com

set address=https://dreamdares.com
set waiting_time=30

set url_api=https://dreamdares.com/api/%name%/stream

:loop
cls
echo Dreamdares
echo %name%
echo ====================
title %name% (DreamDares)

ping -n 1 8.8.8.8 >nul 2>nul
if errorlevel 1 (
    title %name% ^(DreamDares^) - No Internet
    echo No internet connection
    timeout %waiting_time%
    goto loop
)

for /f "delims=" %%a in ('curl -ksS --user-agent "%user_agent%" --url %url_api%') do set page=%%a

if not defined page (
    title %name% ^(DreamDares^) - API Error
    echo No response received from site
    timeout %waiting_time%
    goto loop
)

for /f "delims=" %%a in ('echo %%page%% ^| jq -r .key') do set key=%%a

if "%key%"=="" (
    title %name% ^(DreamDares^) - invalid nickname
    echo Nickname "%name%" is invalid
    echo.
    pause
    exit
)

if "%key%"=="null" (
    title %name% ^(DreamDares^) - invalid nickname
    echo Nickname "%name%" is invalid
    echo.
    pause
    exit
)

for /f "delims=" %%a in ('echo %%page%% ^| jq -r .active') do set active=%%a

if "%active%"=="false" (
    title %name% ^(DreamDares^) - offline
    echo %name% is offline
    timeout %waiting_time%
    goto loop
)

set stream_url=%server%/publish/%key%/playlist.m3u8

set datetime=%date:~6,4%-%date:~3,2%-%date:~0,2%_%time:~0,2%-%time:~3,2%-%time:~6,2%
set datetime=%datetime: =0%
set file=%name%_Dreamdares_%datetime%.ts
title %name% (DreamDares) - recording
echo Rec - %file%
echo.

streamlink --http-header "User-Agent=%user_agent%" --http-header "Referer=%address%" --stream-segment-threads 3 --url %stream_url% --default-stream %quality% -o "%dir%\%file%"

timeout %waiting_time%
goto loop

@echo off

echo Dreamdares
set /p "line=Enter URL or nickname: "

for /f "tokens=1 delims=?" %%a in ("%line%") do set "line=%%a"    #for example https://dreamdares.com/kroshka_kartoshka?tab=chat
for %%a in ("%line:/=" "%") do set "name=%%~a"

set dir=D:\Records
set quality=best
set "user_agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/134.0.0.0 Safari/537.36"

::443 - default port for HTTPS
set server=https://diana.dreamdares.com

set address=https://dreamdares.com
set waiting=30

set url_api=https://dreamdares.com/api/%name%/stream

:loop
cls
title Request...
echo Dreamdares - %name%
echo ====================

set "key=_escaped_into_jungle_"

for /f "delims=" %%a in ('curl -ksS --user-agent "%user_agent%" --url %url_api%') do (
    for /f %%i in ('echo %%a ^| jq -r .key') do set key=%%i
    for /f %%i in ('echo %%a ^| jq -r .active') do set active=%%i
)

if "%key%"=="_escaped_into_jungle_" (
    echo no response
    timeout %waiting%
    goto loop
)

if "%active%"=="false" (
    title %name% - offline
    echo %name% is OFFLINE
    timeout %waiting%
    goto loop
) else if not "%active%"=="true" (
    title %name% - nickname invalid
    echo %name% - nickname invalid
    echo.
    pause
    exit
)

set stream_url=%server%/publish/%key%/playlist.m3u8

set datetime=%date:~6,4%-%date:~3,2%-%date:~0,2%_%time:~0,2%-%time:~3,2%-%time:~6,2%
set datetime=%datetime: =0%
set file=%name%_DD_%datetime%.ts
title %name% - rec
echo.

streamlink --http-header "User-Agent=%user_agent%" --http-header "Referer=%address%" --stream-segment-threads 3 --url %stream_url% --default-stream %quality% -o "%dir%\%file%"

timeout %waiting%
goto loop

import json
import re

from urllib.parse import urlparse, urlunparse, urljoin
from streamlink.exceptions import PluginError, NoStreamsError
from streamlink.plugin.api import validate, useragents
from streamlink.plugin import Plugin, pluginmatcher
from streamlink.stream import HLSStream
from streamlink.utils import update_scheme

CONST_AMF_GATEWAY_LOCATION = '/tools/amf.php'
CONST_HEADERS = {'User-Agent': useragents.CHROME}

url_re = re.compile(r"(http(s)?://)?(([\w\-_]+)\.)?bongacams(\d*)\.com/([\w\-_]+)")

amf_msg_schema = validate.Schema({
    "status": "success",
    "userData": {"username": str},
    "localData": {"videoServerUrl": str},
    "performerData": {"username": str}
})

@pluginmatcher(url_re)
class bongacams(Plugin):
    def _get_streams(self):
        match = url_re.match(self.url)

        if not match:
            raise PluginError("Invalid URL format")

        stream_page_scheme = 'https'
        subdomain = match.group(4)
        base_domain = "bongacams99.com"
        stream_page_path = match.group(6)

        full_domain = f"{subdomain}.{base_domain}" if subdomain else base_domain
        initial_url = urlunparse((stream_page_scheme, full_domain, stream_page_path, '', '', ''))

        http_session = self.session.http
        http_session.headers.update(CONST_HEADERS)

        r = http_session.get(initial_url)

        if '/profile/' in r.url:
            raise NoStreamsError(self.url)
        if not r.ok:
            self.logger.debug("Status code for {0}: {1}", r.url, r.status_code)
            raise NoStreamsError(self.url)
        if len(http_session.cookies) == 0:
            raise PluginError("Can't get cookies")

        baseurl = urlunparse((stream_page_scheme, full_domain, '', '', '', ''))
        amf_gateway_url = urljoin(baseurl, CONST_AMF_GATEWAY_LOCATION)
        stream_page_url = urljoin(baseurl, stream_page_path)

        headers = {
            'User-Agent': useragents.CHROME,
            'Referer': stream_page_url,
            'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
            'X-Requested-With': 'XMLHttpRequest'
        }

        data = f'method=getRoomData&args%5B%5D={stream_page_path}&args%5B%5D=false'
        self.logger.debug('DATA: {0}'.format(str(data)))
        r = http_session.post(url=amf_gateway_url, headers=headers, data=data)
        http_session.close()

        if r.status_code != 200:
            raise PluginError("Unexpected status code for {0}: {1}".format(r.url, r.status_code))

        try:
            response_json = json.loads(r.text)

            if response_json.get("status") == "error":
                self.logger.error("----- GEOBLOCK -----")
                return

            stream_source_info = amf_msg_schema.validate(response_json)
        except Exception as e:
            if 'videoServerUrl' not in r.text:
                self.logger.error("Stream is currently offline")
                return
            raise PluginError(f"Failed to validate response: {e}")

        self.logger.debug("Source stream info:\n{0}".format(stream_source_info))

        if not stream_source_info:
            return

        urlnoproto = stream_source_info['localData'].get('videoServerUrl')
        if not urlnoproto:
            self.logger.error("Stream is currently offline")
            return

        urlnoproto = update_scheme('https://', urlnoproto)
        performer = stream_source_info['performerData']['username']

        hls_url = f'{urlnoproto}/hls/stream_{performer}/playlist.m3u8'

        if hls_url:
            self.logger.debug('HLS URL: {0}'.format(hls_url))
            print('   HLS URL:', hls_url)
            print()
            try:
                for s in HLSStream.parse_variant_playlist(self.session, hls_url, headers=headers).items():
                    yield s
            except Exception as e:
                if '404' in str(e):
                    self.logger.error('Stream is currently offline or private')
                else:
                    self.logger.error(str(e))
                return


__plugin__ = bongacams