import re

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

_url_re = re.compile(r"https?://(\w+\.)?stripchat\.com/(?P<username>[a-zA-Z0-9_-]+)")

class Stripchat(Plugin):
    @classmethod
    def can_handle_url(cls, url):
        return _url_re.match(url)

    def _get_streams(self):
        match = _url_re.match(self.url)
        username = match.group("username")
        api_call1 = "https://de.stripchat.com/api/front/users/username/{0}/".format(username)
        api_call2 = "https://de.stripchat.com/api/front/models/username/{0}/cam".format(username)
        headers = {
            "Content-Type": "application/x-www-form-urlencoded",
            "X-Requested-With": "XMLHttpRequest",
            "Referer": self.url,
        }

        res1 = self.session.http.get(api_call1, headers=headers)
        data1 = self.session.http.json(res1)
        res2 = self.session.http.get(api_call2, headers=headers)
        data2 = self.session.http.json(res2)
        
        self.logger.info('Geo Ban: {0}'.format(data1["isGeoBanned"]))

        server = "https://b-{0}.doppiocdn.com/hls/{1}/master_{1}.m3u8".format(data2["viewServers"]["flashphoner-hls"],data2["streamName"])

        server0 = "https://b-{0}.doppiocdn.com/hls/{1}/{1}.m3u8".format(data2["viewServers"]["flashphoner-hls"],data2["streamName"])

        self.logger.info("Camera is Available: {0}".format(data2["isCamAvailable"]))

        if (data2["isCamAvailable"] is True and server):
            try:
                for s in HLSStream.parse_variant_playlist(self.session,server,headers={'Referer': self.url}).items():
                    yield s
            except IOError as err:
                stream = HLSStream(self.session, server0)
                yield "Auto", stream

__plugin__ = Stripchat

@echo off

:loop
set savedir=M:\rec
set nick=%1
set site=%2
set quality=best

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 random=%RANDOM%
set file=%savedir%\%nick%_%site%_%datetime%_%random%.ts

echo Запись начата: %file% >> "%savedir%\log.txt"
"C:\Program Files\Streamlink\bin\streamlink.exe" "https://%site%.com/%nick%" %quality% -o "%file%" --retry-streams 20 --retry-max 0 --retry-open 1 2>> "%savedir%\error.log"
echo Запись завершена: %file% >> "%savedir%\log.txt"
goto loop
call :setsize %file%
if %size%==0 del %file%

goto :eof
:setsize
set size=%~z1
goto :eof

@echo off
:: Задержка в 5 секунд, если стартует запись более одной модели

start /b recS.bat coyemoo stripchat
timeout /t 5 >nul
start /b recS.bat Baby_Tiny stripchat
timeout /t 5 >nul

@echo off
setlocal

set /p link=Address:
set /p name=Nickname:

set quality=best
set dir=M:\rec
set seconds=30

:loop
cls
echo Record %name%
echo ===========================================

:: Исправление формата даты и времени
for /f "tokens=2-4 delims=/ " %%a in ('date /t') do (set mydate=%%c-%%b-%%a)
for /f "tokens=1-2 delims=: " %%a in ('time /t') do (set mytime=%%a-%%b)
set datetime=%mydate%_%mytime%
set datetime=%datetime: =0%
set file=%name%_%datetime%.ts
title Record - %file%

:: Проверка существования директории
if not exist "%dir%" (
    echo Directory %dir% does not exist. Creating...
    mkdir "%dir%"
    if not exist "%dir%" (
        echo Failed to create directory %dir%
        pause
        goto end
    )
)

:: Запуск streamlink с правильным порядком аргументов
echo Running streamlink with parameters: "%link%" %quality% -o "%dir%\%file%"
streamlink --retry-streams 5 "%link%" %quality% -o "%dir%\%file%"
if %errorlevel% neq 0 (
    echo Error occurred during recording.
    pause
    goto end
)

:: Пауза перед следующим циклом
timeout /t %seconds% /nobreak >nul
goto loop

:end
pause
endlocal

error: No plugin can handle URL: https://stripchat.com/coyemoo
error: No plugin can handle URL: https://stripchat.com/coyemoo
error: No plugin can handle URL: https://stripchat.com/coyemoo
error: No plugin can handle URL: https://stripchat.com/coyemoo
error: No plugin can handle URL: https://stripchat.com/coyemoo
Процесс не может получить доступ к файлу, так как этот файл занят другим процессом.
Процесс не может получить доступ к файлу, так как этот файл занят другим процессом.
Процесс не может получить доступ к файлу, так как этот файл занят другим процессом.
Процесс не может получить доступ к файлу, так как этот файл занят другим процессом.
Процесс не может получить доступ к файлу, так как этот файл занят другим процессом.

Запись начата: M:\rec\coyemoo_stripchat_2025-02-08_06-28-07_1558.ts 
Запись завершена: M:\rec\coyemoo_stripchat_2025-02-08_06-28-07_1558.ts 
Запись начата: M:\rec\coyemoo_stripchat_2025-02-08_06-28-08_1558.ts 
Запись завершена: M:\rec\coyemoo_stripchat_2025-02-08_06-28-08_1558.ts 
Запись начата: M:\rec\coyemoo_stripchat_2025-02-08_06-28-09_1558.ts 
Запись завершена: M:\rec\coyemoo_stripchat_2025-02-08_06-28-09_1558.ts 
Запись начата: M:\rec\coyemoo_stripchat_2025-02-08_06-28-09_1558.ts 
Запись завершена: M:\rec\coyemoo_stripchat_2025-02-08_06-28-09_1558.ts 
Запись начата: M:\rec\coyemoo_stripchat_2025-02-08_06-28-10_1558.ts 
Запись завершена: M:\rec\coyemoo_stripchat_2025-02-08_06-28-10_1558.ts 
Запись начата: M:\rec\coyemoo_stripchat_2025-02-08_06-28-11_1558.ts 
Запись начата: M:\rec\Baby_Tiny_stripchat_2025-02-08_06-28-12_1574.ts 
Запись завершена: M:\rec\Baby_Tiny_stripchat_2025-02-08_06-28-12_1574.ts 
Запись начата: M:\rec\Baby_Tiny_stripchat_2025-02-08_06-28-12_1574.ts 
Запись завершена: M:\rec\Baby_Tiny_stripchat_2025-02-08_06-28-12_1574.ts 

Record coyemoo
===========================================
Running streamlink with parameters: "https://de.stripchat.com/coyemoo" best -o "M:\rec\coyemoo__06-55.ts"
error: No plugin can handle URL: https://de.stripchat.com/coyemoo
Error occurred during recording.
Для продолжения нажмите любую клавишу . . .

import random
import re
import json
import cloudscraper
import time

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

username = "katerinetailor"

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

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"
}

API_URL_VIDEO = "https://camsoda.com/api/v1/video/vtoken/{0}?username=guest_{1}"

url = API_URL_VIDEO.format(username, str(random.randint(1000, 99999)))
print("URL:", url)

response = scraper.get(url, headers=headers)

status = response.status_code
print("Status code:", status)

data_video = response.json()
print("Result:", data_video)

time.sleep(300)

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