import random
import re
import json
import cloudscraper

from streamlink.plugin import Plugin, pluginmatcher
from streamlink.plugin.api import validate
from streamlink.stream import HLSStream

_url_re = re.compile(r"http(s)?://(www\.)?camsoda\.com/(?P<username>[^\"\']+)")

_api_video_schema = validate.Schema(
    {
        "token": str,
        "edge_servers": [str],
        "stream_name": str
    }
)

scraper = cloudscraper.create_scraper()
headers = {
    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:135.0) Gecko/20100101 Firefox/135.0",
    "Referer": "https://www.camsoda.com",
    "Host": "www.camsoda.com"
}

@pluginmatcher(_url_re)
class Camsoda(Plugin):
    API_URL_VIDEO = "https://camsoda.com/api/v1/video/vtoken/{0}?username=guest_{1}"
    HLS_URL_VIDEO_EDGE = "https://{server}/{stream_name}_v1/index.m3u8?token={token}"
    HLS_URL_VIDEO = "https://{server}/mp4:{stream_name}_aac/playlist.m3u8?token={token}"

    def _get_api_video(self, username):
        url = self.API_URL_VIDEO.format(username, str(random.randint(1000, 99999)))
        response = scraper.get(url, headers=headers)

        if response.status_code != 200:
            self.logger.error(f"Failed to get video API data, status code: {response.status_code}")
            return None

        try:
            data_video = response.json()

            if "status" in data_video and data_video["status"] == 0:
                self.logger.info(f"Nickname '{username}' is invalid")
                return None

            if "edge_servers" in data_video and not data_video["edge_servers"]:
                if "stream_name" in data_video:
                    if not data_video["stream_name"]:
                        self.logger.info(f"OFFLINE")
                    else:
                        self.logger.info(f"*****PRIVATE*****")
                return None

            validate.validate(_api_video_schema, data_video)

        except Exception as e:
            self.logger.error(f"Error parsing API response: {e}")
            return None

        return data_video

    def _get_streams(self):
        match = _url_re.match(self.url)
        username = match.group("username").replace("/", "")

        data_video = self._get_api_video(username)

        if not data_video:
            return

        hls_url = self.HLS_URL_VIDEO.format(
            server=data_video["edge_servers"][0],
            stream_name=data_video["stream_name"],
            token=data_video["token"]
        )

        if "edge" in data_video["edge_servers"][0]:
            hls_url = self.HLS_URL_VIDEO_EDGE.format(
                server=data_video["edge_servers"][0],
                stream_name=data_video["stream_name"],
                token=data_video["token"]
            )

        for s in HLSStream.parse_variant_playlist(self.session, hls_url).items():
            yield s


__plugin__ = Camsoda

import random
import re
import json
import cloudscraper

from streamlink.plugin import Plugin, pluginmatcher
from streamlink.plugin.api import validate
from streamlink.stream import HLSStream

_url_re = re.compile(r"http(s)?://(www\.)?camsoda\.com/(?P<username>[^\"\']+)")

_api_video_schema = validate.Schema(
    {
        "token": str,
        "edge_servers": [str],
        "stream_name": str
    }
)

scraper = cloudscraper.create_scraper()
headers = {
    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:134.0) Gecko/20100101 Firefox/134.0",
    "Referer": "https://www.camsoda.com"
}

@pluginmatcher(_url_re)
class Camsoda(Plugin):
    API_URL_VIDEO = "https://www.camsoda.com/api/v1/video/vtoken/{0}?username=guest_{1}"
    HLS_URL_VIDEO_EDGE = "https://{server}/{stream_name}_v1/index.m3u8?token={token}"
    HLS_URL_VIDEO = "https://{server}/mp4:{stream_name}_aac/playlist.m3u8?token={token}"

    def _get_api_video(self, username):
        url = self.API_URL_VIDEO.format(username, str(random.randint(1000, 99999)))
        response = scraper.get(url, headers=headers)

        if response.status_code != 200:
            self.logger.error(f"Failed to get video API data, status code: {response.status_code}")
            return None

        try:
            data_video = response.json()

            if "status" in data_video and data_video["status"] == 0:
                self.logger.info(f"Nickname '{username}' is invalid")
                return None

            if "edge_servers" in data_video and not data_video["edge_servers"]:
                if "stream_name" in data_video:
                    if not data_video["stream_name"]:
                        self.logger.info(f"OFFLINE")
                    else:
                        self.logger.info(f"*****PRIVATE*****")
                return None

            validate.validate(_api_video_schema, data_video)

        except Exception as e:
            self.logger.error(f"Error parsing API response: {e}")
            return None

        return data_video

    def _get_streams(self):
        match = _url_re.match(self.url)
        username = match.group("username").replace("/", "")

        data_video = self._get_api_video(username)

        if not data_video:
            return

        hls_url = self.HLS_URL_VIDEO.format(
            server=data_video["edge_servers"][0],
            stream_name=data_video["stream_name"],
            token=data_video["token"]
        )

        if "edge" in data_video["edge_servers"][0]:
            hls_url = self.HLS_URL_VIDEO_EDGE.format(
                server=data_video["edge_servers"][0],
                stream_name=data_video["stream_name"],
                token=data_video["token"]
            )

        for s in HLSStream.parse_variant_playlist(self.session, hls_url).items():
            yield s


__plugin__ = Camsoda

import random
import re
import json
import cloudscraper

from streamlink.plugin import Plugin, pluginmatcher
from streamlink.plugin.api import validate
from streamlink.stream import HLSStream

_url_re = re.compile(r"http(s)?://(www\.)?camsoda\.com/(?P<username>[^\"\']+)")

_api_video_schema = validate.Schema(
    {
        "token": str,
        "edge_servers": [str],
        "stream_name": str
    }
)

scraper = cloudscraper.create_scraper()
headers = {
    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:134.0) Gecko/20100101 Firefox/134.0",
    "Referer": "https://www.camsoda.com"
}
proxies = {
    "http": "http://127.0.0.1:2080",
    "https": "http://127.0.0.1:2080"
}

@pluginmatcher(_url_re)
class Camsoda(Plugin):
    API_URL_VIDEO = "https://www.camsoda.com/api/v1/video/vtoken/{0}?username=guest_{1}"
    HLS_URL_VIDEO_EDGE = "https://{server}/{stream_name}_v1/index.m3u8?token={token}"
    HLS_URL_VIDEO = "https://{server}/mp4:{stream_name}_aac/playlist.m3u8?token={token}"

    def _get_api_video(self, username):
        url = self.API_URL_VIDEO.format(username, str(random.randint(1000, 99999)))
        response = scraper.get(url, headers=headers, proxies=proxies)

        if response.status_code != 200:
            self.logger.error(f"Failed to get video API data, status code: {response.status_code}")
            return None

        try:
            data_video = response.json()

            if "status" in data_video and data_video["status"] == 0:
                self.logger.info(f"Nickname '{username}' is invalid")
                return None

            if "edge_servers" in data_video and not data_video["edge_servers"]:
                if "stream_name" in data_video:
                    if not data_video["stream_name"]:
                        self.logger.info(f"OFFLINE")
                    else:
                        self.logger.info(f"*****PRIVATE*****")
                return None

            validate.validate(_api_video_schema, data_video)

        except Exception as e:
            self.logger.error(f"Error parsing API response: {e}")
            return None

        return data_video

    def _get_streams(self):
        match = _url_re.match(self.url)
        username = match.group("username").replace("/", "")

        data_video = self._get_api_video(username)

        if not data_video:
            return

        hls_url = self.HLS_URL_VIDEO.format(
            server=data_video["edge_servers"][0],
            stream_name=data_video["stream_name"],
            token=data_video["token"]
        )

        if "edge" in data_video["edge_servers"][0]:
            hls_url = self.HLS_URL_VIDEO_EDGE.format(
                server=data_video["edge_servers"][0],
                stream_name=data_video["stream_name"],
                token=data_video["token"]
            )

        for s in HLSStream.parse_variant_playlist(self.session, hls_url).items():
            yield s


__plugin__ = Camsoda

@echo off
setlocal enabledelayedexpansion

set /p line_source=Enter URL or nickname: 

if "%line_source:~-3%"=="#!/" set "line_source=%line_source:~0,-3%"
for %%a in ("%line_source:/=" "%") do set "name=%%~a"

set dir=D:\Records

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"
set "header=X-Requested-With: XMLHttpRequest"
set "data=method=getRoomData&args%%5B%%5D=%name%&args%%5B%%5D=false"
set quality=1080p,best
set waiting=30

::NekoBox
set proxy=127.0.0.1:2080

::::::::::::::::::::Преобразование (при необходимости) букв в строчные для предотвращения получения кода 301

for %%# in (a b c d e f g h i j k l m n o p q r s t u v w x y z) do set "name=!name:%%#=%%#!"

::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::

:: ВНИМАНИЕ.
:: url_2 должен иметь адрес, доступный с вашего реального IP. Иначе будет ошибка - Error 000
:: url_2 должен иметь адрес, который не редиректит на другой адрес. Иначе переменная 'http_code' будет принимать неверные значения. Например, нельзя такой: https://bongacams.com/profile/%name%
:: url_2 должен иметь адрес, не начинающийся с https://rus.bongacams...

set url_1=https://bongacams.com/%name%
set url_2=https://rt.bongacams99.com/profile/%name%
set url_3=https://bongacams.com/get-member-chat-data?username=%name%
set url_4=https://bongacams.com/tools/amf.php

:loop

cls
title %name% on BongaCams
echo nickname: %name%

::::::::::::::::::::Check if the account has been deleted

for /f "delims=" %%a in ('curl -ksS --location --head --user-agent "%user_agent%" --connect-timeout 10 --write-out %%{url_effective} --url %url_1% --output nul') do set "effective=%%a"

echo %effective%| find "_del" > nul

if "!errorlevel!" equ "0" (
    echo *** Account %name% - deleted
    echo.
    pause
    exit
)

::::::::::::::::::::Check if is geoblock

for /f "delims=" %%a in ('curl -ksS --user-agent "%user_agent%" --connect-timeout 10 --write-out %%{http_code} --url %url_2% --output nul') do set "http_code=%%a"

if "%http_code%" equ "404" (
    echo Error %http_code%
    echo %name% - nickname is incorrect
    echo.
    pause
    exit
) else if "%http_code%" equ "301" (
    echo Error %http_code%
    echo %name% - nickname is incorrect
    echo.
    pause
    exit
) else if "%http_code%" equ "000" (
    title Error %http_code%
    echo Error %http_code%
    echo No response received from site - check internet
    timeout %waiting%
    goto loop
) else if "%http_code%" neq "200" if "%http_code%" neq "302" (
    echo Error %http_code%
    echo.
    pause
    exit
)

::::::::::::::::::::Check if is redirect to profile page

curl -ksS --user-agent "%user_agent%" --connect-timeout 10 --header "%header%" --url %url_3% > %name%_temp_file.json

for /f %%a in ('jq ".status" -r ^< %name%_temp_file.json') do set "status=%%a"

if %status%==error (del %name%_temp_file.json)

if %status%==error (
    echo %effective% | find "/profile/" > nul
    if "!errorlevel!" equ "0" (
        if "%http_code%" equ "200" (
            echo    GeoBlock - false
            echo.
            title %name% - offline
            echo               offline
            echo      ^(from profile page^)
            timeout %waiting%
            goto loop
        )
        if "%http_code%" equ "302" (
            echo           GeoBlock - TRUE    / %name% uses GeoBlock /
            echo.
            title %name% - offline
            echo               offline
            echo      ^(from profile page^)
            timeout %waiting%
            goto loop
        )
    )
    if "!errorlevel!" neq "0" (
        if "%http_code%" equ "200" (
            echo #####
            echo Error. This is a viewer's nickname.
            echo.
            pause
            exit
        )
        if "%http_code%" equ "302" (
            echo #####
            echo Error. This is a viewer's nickname. His account has been deleted.
            echo.
            pause
            exit
        )
    )
)

::::::::::::::::::::Work (status - success)

if "%http_code%" equ "200" (
    echo    GeoBlock - false
    echo.
)

if "%http_code%" equ "302" (
    echo           GeoBlock - TRUE    / %name% uses GeoBlock /
    echo.
)

for /f %%a in ('jq ".result.awayLayoutOptions.displayName" -r ^< %name%_temp_file.json') do set "display_name=%%a"
for /f %%a in ('jq ".result.awayLayoutOptions.username" -r ^< %name%_temp_file.json') do set "username=%%a"
for /f %%a in ('jq ".result.chatShowStatusOptions.isOffline" -r ^< %name%_temp_file.json') do set "is_offline=%%a"
for /f %%a in ('jq ".result.chatShowStatusOptions.isPublicChat" -r ^< %name%_temp_file.json') do set "is_public=%%a"
for /f %%a in ('jq ".result.chatShowStatusOptions.isPrivateChat" -r ^< %name%_temp_file.json') do set "is_private_chat=%%a"
for /f %%a in ('jq ".result.chatShowStatusOptions.isFullPrivateChat" -r ^< %name%_temp_file.json') do set "is_full_private_chat=%%a"
for /f %%a in ('jq ".result.chatShowStatusOptions.isGroupChat" -r ^< %name%_temp_file.json') do set "is_group_chat=%%a"
for /f %%a in ('jq ".result.chatShowStatusOptions.isVoyeurChat" -r ^< %name%_temp_file.json') do set "is_voyeur_chat=%%a"
for /f %%a in ('jq ".result.chatShowStatusOptions.isVipShow" -r ^< %name%_temp_file.json') do set "is_vip_show=%%a"

del %name%_temp_file.json

echo displayname: %display_name%
echo username: %username%
echo --------------------

if "%is_offline%"=="true" (
    title %name% - offline
    echo               offline
    timeout %waiting%
    goto loop
) else if "%is_public%"=="true" (
    title %name% - public
    echo               public
    echo.
) else if "%is_private_chat%"=="true" (
    title %name% - private
    echo               private
    timeout %waiting%
    goto loop
) else if "%is_full_private_chat%"=="true" (
    title %name% - fullprivate
    echo               fullprivate
    timeout %waiting%
    goto loop
) else if "%is_group_chat%"=="true" (
    title %name% - group chat
    echo               group chat
    timeout %waiting%
    goto loop
) else if "%is_voyeur_chat%"=="true" (
    title %name% - voyeur chat
    echo               voyeur chat
    timeout %waiting%
    goto loop
) else if "%is_vip_show%"=="true" (
    title %name% - vipshow
    echo               vipshow
    timeout %waiting%
    goto loop
) else (
    title %name% - status unknown
    echo               status unknown
    timeout %waiting%
    goto loop
)

::::::::::::::::::::Stream capture

set page_stream=

if "%http_code%" equ "200" (
    for /f "delims=" %%a in ('curl -ksS --user-agent "%user_agent%" --connect-timeout 10 --header "%header%" --data "%data%" --url %url_4%') do set page_stream=%%a
    if not defined page_stream (
        echo.
        echo Problem...
        echo.
        timeout %waiting%
        goto loop
    )
)

if "%http_code%" equ "302" (
    for /f "delims=" %%a in ('curl -x %proxy% -ksS --user-agent "%user_agent%" --connect-timeout 10 --header "%header%" --data "%data%" --url %url_4%') do set page_stream=%%a
    if not defined page_stream (
        echo.
        echo /////   You have a PROXY problem   /////
        echo.
        timeout %waiting%
        goto loop
    )
)

for /f "delims=" %%a in ('echo %%page_stream%% ^| jq -r .performerData.isAway') do set is_away=%%a

if "%is_away%"=="true" (
    title %name% - is away
    echo               is away
    timeout %waiting%
    goto loop
)

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

set stream_url=https:%videoServerUrl%/hls/stream_%username%/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%_BongaCams_%datetime%.ts
title %name% - rec
echo Rec - %file%
echo.

streamlink --stream-segment-threads 3 --url %stream_url% --default-stream %quality% -o "%dir%\%file%"

timeout %waiting%
goto loop

set name=sochnayaaa
set user_agent="Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:47.0) Gecko/20100101 Firefox/62.0"
set header="X-Requested-With: XMLHttpRequest"
set url_request="https://bongacams.com/tools/listing_v3.php?online_only=true&offset=0&model_search%5Bdisplay_name%5D%5Btext%5D=%name%&_online_filter=0&can_pin_models=false&limit=1"
curl -ksS --user-agent %user_agent% --header %header% --url %url_request%

set name=sochnayaaa
set user_agent="Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:47.0) Gecko/20100101 Firefox/62.0"
set header="X-Requested-With: XMLHttpRequest"
set url_request="https://bongacams.com/tools/listing_v3.php?online_only=true&offset=0&model_search%5Bdisplay_name%5D%5Btext%5D=%name%&_online_filter=0&can_pin_models=false&limit=1"
curl -ksS --user-agent %user_agent% --header %header% --url %url_request% > %name%_listing.json
jq -r .models["0"].esid %name%_listing.json

set name=sochnayaaa
set user_agent="Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:47.0) Gecko/20100101 Firefox/62.0"
set header="X-Requested-With: XMLHttpRequest"
set url_request="https://bongacams.com/tools/listing_v3.php?online_only=true&offset=0&model_search%5Bdisplay_name%5D%5Btext%5D=%name%&_online_filter=0&can_pin_models=false&limit=1"
for /f "delims=" %a in ('curl -ksS --user-agent %user_agent% --header %header% --url %url_request% ^| jq -r .models["0"].esid') do set esid=%a
echo %esid%

@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