Add Youtube Code

Author: ChickenDevs

code/scheduler/clerk_emails.json

@@ -0,0 +1,3 @@
+{
+	"wardname": "[email protected],[email protected],[email protected]"
+}

code/scheduler/monitor.py

@@ -0,0 +1,115 @@
+#!/usr/bin/python3
+import datetime
+import json
+
+import googleapiclient.discovery
+from google.oauth2.credentials import Credentials
+from googleapiclient.http import MediaFileUpload
+
+from smtplib import SMTP_SSL
+from email.message import EmailMessage
+
+NOW = datetime.datetime.now(tz=datetime.timezone.utc)
+with open('/opt/webcast/recurring.json') as f:
+    RECURRING = json.load(f)
+
+
+def convert_time(time: str):
+    if not time:
+        return ''
+
+    return datetime.datetime.fromisoformat(time.replace('Z', '-00:00'))
+
+stream_ids = {
+    "wardname": "STREAM_ID_FROM_GOOGLE_API"
+}
+
+for ward in stream_ids.keys():
+    creds = Credentials.from_authorized_user_file(f'/opt/webcast/auth/{ward}.json')
+    youtube = googleapiclient.discovery.build("youtube", "v3", credentials=creds)
+
+    broadcasts = youtube.liveBroadcasts().list(
+        part="id,snippet,contentDetails,status",
+        mine=True,
+        maxResults=50
+    ).execute()
+
+    for broadcast in broadcasts['items']:
+        if not broadcast['snippet'].get('scheduledStartTime', None):
+            youtube.liveBroadcasts().delete(id=broadcast['id']).execute()
+            continue
+
+        endTime = convert_time(broadcast['snippet'].get('scheduledEndTime', ''))
+        if not endTime:
+            endTime = convert_time(broadcast['snippet']['scheduledStartTime']) + datetime.timedelta(hours=1)
+
+        if NOW > endTime and broadcast['status']['lifeCycleStatus'] != 'complete':
+            stream_id = stream_ids.get(ward, None)
+            stream = youtube.liveStreams().list(
+                part="id,status",
+                id=stream_id
+            ).execute()['items'][0]
+            if (stream['status']['streamStatus'] == 'inactive') or (NOW > endTime + datetime.timedelta(minutes=15)):
+                youtube.liveBroadcasts().transition(part='id', id=broadcast['id'], broadcastStatus='complete').execute()
+                print(f"Marked broadcast for {ward} complete ({broadcast['id']})")
+                print(f"Reason: ", end='')
+                print(f"Stream status ({stream['status']['streamStatus']})" if stream['status']['streamStatus'] == 'inactive' else "Time exceeded 15 minutes past end time")
+
+        if broadcast['status']['lifeCycleStatus'] == 'complete' and datetime.datetime.now().day != endTime.day:
+            with open('/opt/webcast/clerk_emails.json') as f:
+                clerks = json.load(f)
+            viewers = round(int(youtube.videos().list(part='statistics', id=broadcast['id']).execute()['items'][0]['statistics']['viewCount']) * 2.1)
+            msg = EmailMessage()
+            msg["Subject"] = "Online YouTube Meeting Attendance"
+            msg["From"] = "Webcast <[email protected]>"
+            msg["To"] = clerks[ward]
+            msg.set_content(f"The number of individuals watching {broadcast['snippet']['title']} online on {convert_time(broadcast['snippet']['scheduledStartTime']).strftime('%d %b %Y')} was {viewers}.\n\n\nThis is an automated message. Please do not respond.")
+            with SMTP_SSL('SMTP_SERVER_HERE', 465) as smtp:
+                smtp.login('[email protected]', 'ITS_PASSWORD')
+                smtp.send_message(msg)
+                smtp.quit()
+            youtube.liveBroadcasts().delete(id=broadcast['id']).execute()
+            print(f"Deleted broadcast on {ward} ({broadcast['id']})")
+
+        if broadcast['contentDetails'].get("boundStreamId", "") != stream_ids.get(ward, "NOT FOUND"):
+            youtube.liveBroadcasts().bind(
+                id=broadcast['id'],
+                part="id",
+                streamId=stream_ids.get(ward, '')
+            ).execute()
+            print(f"Attempted to bind stream to broadcast for {ward}")
+
+    for event in RECURRING[ward]:
+        changeInDays = event['day'] - datetime.datetime.now().weekday()
+        if changeInDays < 0:
+            changeInDays += 7
+        recurringDate = datetime.datetime.now() + datetime.timedelta(days=changeInDays)
+        startTime = datetime.datetime.combine(recurringDate, datetime.time(*[int(x) for x in event['start'].split(':')]))
+        endTime = datetime.datetime.combine(recurringDate, datetime.time(*[int(x) for x in event['end'].split(':')]))
+        startTime = startTime.replace(tzinfo=NOW.astimezone().tzinfo)
+        endTime = endTime.replace(tzinfo=NOW.astimezone().tzinfo)
+
+        if startTime not in [convert_time(x['snippet']['scheduledStartTime']) for x in broadcasts['items']] and startTime > NOW:
+            new = youtube.liveBroadcasts().insert(
+                part='id,snippet,contentDetails,status',
+                body={
+                    'snippet': {
+                        'title': event['title'],
+                        'scheduledStartTime': startTime.isoformat(),
+                        'scheduledEndTime': endTime.isoformat(),
+                    },
+                    'contentDetails': {
+                        'enableAutoStart': 'true',
+                    },
+                    'status': {
+                        'privacyStatus': 'public',
+                        'selfDeclaredMadeForKids': 'true',
+                    },
+                }
+            ).execute()
+            youtube.liveBroadcasts().bind(
+                id=new['id'],
+                part="id",
+                streamId=stream_ids.get(ward, '')
+            ).execute()
+

code/scheduler/recurring.json

@@ -0,0 +1,10 @@
+{
+  "wardname": [
+    {
+    	"title": "MEETING NAME HERE",
+    	"start": "10:00",
+    	"end": "11:00",
+    	"day": 6
+    }
+  ]
+}

code/webcast/Thumbs.db

@@ -29,36 +29,75 @@ def pred(*args, **kwargs):
 @app.route('/auth')
 @auth
 def authenticate():
+    print("/auth called")
     return {}
 
 import psutil
 import time
 @app.route('/pi/stats')
 @auth
 def pi_stats():
+    print("/pi/stats called")
     net = psutil.net_io_counters()
     return {'timestamp': time.time(), 'cpu': psutil.cpu_percent(), 'memory': psutil.virtual_memory().percent, 'net_sent': net.bytes_sent, 'net_recv': net.bytes_recv}
 
 
+@app.route('/webcast/pause/status')
+@auth
+def webcast_pause_status():
+    with open('/etc/webcast/webcast.conf') as f:
+        conf = json.load(f)
+    return {'paused': conf.get('shouldbepaused', False)}
+
+
+@app.route('/webcast/pause')
+@auth
+def webcast_pause():
+    with open('/etc/webcast/webcast.conf') as f:
+        conf = json.load(f)
+    conf['shouldbepaused'] = True
+    with open('/etc/webcast/webcast.conf', 'w') as f:
+        json.dump(conf, f)
+    os.system('sudo systemctl start webcast.service')
+    return {'paused': True}
+
+
+@app.route('/webcast/resume')
+@auth
+def webcast_resume():
+    with open('/etc/webcast/webcast.conf') as f:
+        conf = json.load(f)
+    conf['shouldbepaused'] = False
+    with open('/etc/webcast/webcast.conf', 'w') as f:
+        json.dump(conf, f)
+    os.system('sudo systemctl start webcast.service')
+    return {'paused': False}
+
+
 @app.route('/webcast/stop')
 @auth
 def webcast_stop():
-    os.system('sudo pkill ffmpeg')
+    print("/webcast/stop called")
     os.system('sudo systemctl stop webcast.timer')
+    os.system('sudo systemctl stop webcast.service')
+    os.system('sudo pkill ffmpeg')
     output = os.popen('sudo systemctl status webcast.service').read()
     return {'response': output}
 
 @app.route('/webcast/start')
 @auth
 def webcast_start():
+    print("/webcast/start called")
     os.system('sudo systemctl start webcast.timer')
+    os.system('sudo systemctl start webcast.service')
     output = os.popen('sudo systemctl status webcast.service').read()
     return {'response': output}
 
 
 @app.route('/webcast/restart')
 @auth
 def webcast_restart():
+    print("/webcast/restart called")
     os.system('sudo pkill ffmpeg')
     os.system('sudo systemctl restart webcast.service')
     output = os.popen('sudo systemctl status webcast.service').read()
@@ -67,6 +106,7 @@ def webcast_restart():
 @app.route('/webcast/status')
 @auth
 def webcast_status():
+    print("/webcast/status called")
     output = os.popen('sudo systemctl status webcast.service').read()
     return {'response': output}
 
@@ -75,6 +115,8 @@ def webcast_status():
 @auth
 @pi_stopped
 def webcast_settings():
+    print("/webcast/settings called")
+    print("Method:", request.method)
     with open('/etc/webcast/webcast.conf') as f:
         conf = json.load(f)
 

code/webcast/api/app.py

@@ -0,0 +1 @@
+{"json": "DOWNLOADED FROM GOOGLE API CONSOLE"}

code/webcast/auth/wardname.json

@@ -1,31 +1,15 @@
 #!/usr/bin/python3
+import datetime
+import os
 
-import json
-from os import path, system
-import requests
+output = os.popen('sudo systemctl status webcast.timer').read()
+output = output.split('\n')
+output = [x for x in output if 'Active:' in x][0]
+output = output.split()
+dead_since = datetime.datetime.strptime(f'{output[5]} {output[6]}', '%Y-%m-%d %H:%M:%S')
 
-try:
-    with open('/etc/webcast/webcast.key') as f:
-        old_key = f.read()
-except FileNotFoundError:
-    old_key = ''
-
-if not path.isfile('/etc/webcast/webcast.conf'):
-    exit(1)
-
-with open('/etc/webcast/webcast.conf') as f:
-    config = json.load(f)
-
-if config.get('auto', 'false') != 'true':
-    exit(1)
-
-url = config.get('url')
-xml = requests.get(url).text
-
-_, key = xml.split('<stream>')
-key, _ = key.split('</stream>')
-
-if key != old_key:
-    system(f'echo {key} > /etc/webcast/webcast.key')
-    system('sudo systemctl start webcast.timer')
+print(f"Webcast has been {output[1]} since {dead_since}")
 
+if datetime.datetime.utcnow() > dead_since + datetime.timedelta(hours=1) and output[1] == 'inactive':
+    print("Restarting timer.")
+    os.system("sudo systemctl start webcast.timer")

code/webcast/sacrament.png

@@ -1 +1 @@
-{"auto":"true","url":"https://raw.githubusercontent.com/ChickenDevs/webcast/main/test-off.xml","rtmpurl":"","rtmpkey":"","vbitrate":1250000,"abitrate":48000,"resolution":"1280x720","videoDelay":0,"audioDelay":1,"volume":0,"preset":"veryfast"}
+{"auto":"false","url":"https://raw.githubusercontent.com/ChickenDevs/webcast/main/test-off.xml","rtmpurl":"RTMPURL_HERE","rtmpkey":"RTMPKEY_HERE","vbitrate":1250000,"abitrate":48000,"resolution":"1920x1080","videoDelay":0,"audioDelay":0.77,"volume":0,"preset":"superfast","shouldbepaused":false,"wards":["wardname"]}