Compare commits
5 Commits
81a8e3a56b
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| 03e8019f0d | |||
| 00e03209de | |||
| d343375790 | |||
| 01469f9b77 | |||
| 0801a3413d |
24
README.md
24
README.md
@@ -1,5 +1,17 @@
|
||||
# YouTube Live Chat in Terminal
|
||||
|
||||
---
|
||||
|
||||
> **ARCHIVED PROJECT**
|
||||
>
|
||||
> This project is considered archived and is no longer in active development.
|
||||
>
|
||||
> **Reason:** It relies on the YouTube Data API v3, which has significant quota limitations (10,000 points/day). Continuous polling for live chat messages quickly exhausts this quota, making this approach unsustainable for long-term or frequent use.
|
||||
>
|
||||
> **Recommendation:** For a more sustainable and quota-friendly solution, please refer to the **`youtube-chat-webhook-v2`** project. That project explores alternative methods for fetching YouTube live chat data that do not rely on the official API and its restrictive quotas.
|
||||
|
||||
---
|
||||
|
||||
## Project Description
|
||||
This project aims to provide a customizable way to view YouTube Live Chat directly in your terminal. It is implemented in `main.py`.
|
||||
|
||||
@@ -16,15 +28,15 @@ This project aims to provide a customizable way to view YouTube Live Chat direct
|
||||
|
||||
## Setup Instructions
|
||||
|
||||
### 1. Clone the Repository (Future Step)
|
||||
Once this project is on GitHub, you would clone it using:
|
||||
### 1. Clone the Repository
|
||||
Clone the project from your Gitea instance:
|
||||
```bash
|
||||
git clone [repository-url]
|
||||
cd youtube_chat_terminal
|
||||
git clone https://gitea.ramforth.net/RamTech/youtube-chat-terminal.git
|
||||
cd youtube-chat-terminal
|
||||
```
|
||||
|
||||
### 2. Create and Activate a Python Virtual Environment
|
||||
It's highly recommended to use a virtual environment to manage project dependencies.
|
||||
### 2. Gitea Repository
|
||||
This project is hosted on your Gitea instance at: `https://gitea.ramforth.net/RamTech/youtube-chat-terminal`
|
||||
|
||||
```bash
|
||||
cd /home/joe/Cloud9/Documents/Obisdian/youtube_chat_terminal
|
||||
|
||||
82
main.py
82
main.py
@@ -45,33 +45,53 @@ def get_authenticated_service():
|
||||
API_SERVICE_NAME, API_VERSION, credentials=credentials)
|
||||
|
||||
def get_live_chat_id(youtube, video_id):
|
||||
try:
|
||||
response = youtube.videos().list(
|
||||
part='liveStreamingDetails',
|
||||
id=video_id
|
||||
).execute()
|
||||
retries = 0
|
||||
max_retries = 5
|
||||
while retries < max_retries:
|
||||
try:
|
||||
response = youtube.videos().list(
|
||||
part='liveStreamingDetails',
|
||||
id=video_id
|
||||
).execute()
|
||||
|
||||
if 'items' in response and response['items']:
|
||||
video = response['items'][0]
|
||||
if 'liveStreamingDetails' in video and 'activeLiveChatId' in video['liveStreamingDetails']:
|
||||
return video['liveStreamingDetails']['activeLiveChatId']
|
||||
return None
|
||||
except googleapiclient.errors.HttpError as e:
|
||||
console.print(f"[red]An HTTP error {e.resp.status} occurred: {e.content}[/red]")
|
||||
return None
|
||||
if 'items' in response and response['items']:
|
||||
video = response['items'][0]
|
||||
if 'liveStreamingDetails' in video and 'activeLiveChatId' in video['liveStreamingDetails']:
|
||||
return video['liveStreamingDetails']['activeLiveChatId']
|
||||
return None
|
||||
except googleapiclient.errors.HttpError as e:
|
||||
if e.resp.status == 403 and "quotaExceeded" in str(e.content):
|
||||
console.print(f"[red]Quota exceeded. Retrying in {2**retries} seconds...[/red]")
|
||||
time.sleep(2**retries)
|
||||
retries += 1
|
||||
else:
|
||||
console.print(f"[red]An HTTP error {e.resp.status} occurred: {e.content}[/red]")
|
||||
return None
|
||||
console.print(f"[red]Failed to get live chat ID after {max_retries} retries due to quota issues.[/red]")
|
||||
return None
|
||||
|
||||
def fetch_live_chat_messages(youtube, live_chat_id, page_token=None):
|
||||
try:
|
||||
request = youtube.liveChatMessages().list(
|
||||
liveChatId=live_chat_id,
|
||||
part='snippet,authorDetails',
|
||||
pageToken=page_token
|
||||
)
|
||||
response = request.execute()
|
||||
return response
|
||||
except googleapiclient.errors.HttpError as e:
|
||||
console.print(f"[red]An HTTP error {e.resp.status} occurred: {e.content}[/red]")
|
||||
return None
|
||||
retries = 0
|
||||
max_retries = 5
|
||||
while retries < max_retries:
|
||||
try:
|
||||
request = youtube.liveChatMessages().list(
|
||||
liveChatId=live_chat_id,
|
||||
part='snippet,authorDetails',
|
||||
pageToken=page_token
|
||||
)
|
||||
response = request.execute()
|
||||
return response
|
||||
except googleapiclient.errors.HttpError as e:
|
||||
if e.resp.status == 403 and "quotaExceeded" in str(e.content):
|
||||
console.print(f"[red]Quota exceeded. Retrying in {2**retries} seconds...[/red]")
|
||||
time.sleep(2**retries)
|
||||
retries += 1
|
||||
else:
|
||||
console.print(f"[red]An HTTP error {e.resp.status} occurred: {e.content}[/red]")
|
||||
return None
|
||||
console.print(f"[red]Failed to fetch live chat messages after {max_retries} retries due to quota issues.[/red]")
|
||||
return None
|
||||
|
||||
def main():
|
||||
youtube = get_authenticated_service()
|
||||
@@ -87,17 +107,19 @@ def main():
|
||||
console.print("[red]Could not find an active live chat for the given video ID.[/red]")
|
||||
return
|
||||
|
||||
console.print(f"[green]Found live chat ID: {live_chat_id}[/green]")
|
||||
|
||||
# Setup chat logging
|
||||
log_dir = "chat_logs"
|
||||
os.makedirs(log_dir, exist_ok=True)
|
||||
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
|
||||
log_filename = os.path.join(log_dir, f"chat_{video_id}_{timestamp}.log")
|
||||
log_file = open(log_filename, "w", encoding="utf-8")
|
||||
console.print(f"[green]Chat will be logged to {log_filename}[/green]")
|
||||
|
||||
# Display initial messages using rich.Live for a few seconds
|
||||
with Live(console=console, screen=True, refresh_per_second=4) as live:
|
||||
live.update(Text(f"[green]Found live chat ID: {live_chat_id}[/green]\n[green]Chat will be logged to {log_filename}[/green]", justify="center"))
|
||||
time.sleep(5)
|
||||
# Wait for 5 seconds, then clear the screen again
|
||||
time.sleep(5)
|
||||
os.system('clear')
|
||||
|
||||
next_page_token = None
|
||||
message_count = 0
|
||||
@@ -160,7 +182,9 @@ def main():
|
||||
|
||||
next_page_token = response.get('nextPageToken')
|
||||
polling_interval_millis = response['pollingIntervalMillis']
|
||||
time.sleep(polling_interval_millis / 1000.0)
|
||||
# Ensure a minimum sleep duration to conserve API quota
|
||||
sleep_time = max(5, polling_interval_millis / 1000.0)
|
||||
time.sleep(sleep_time)
|
||||
else:
|
||||
console.print("[yellow]No new messages or an error occurred. Retrying...[/yellow]")
|
||||
time.sleep(5) # Wait 5 seconds before retrying on error
|
||||
|
||||
Reference in New Issue
Block a user