1. added youtube functionalities

handleChats.py

@@ -0,0 +1,17 @@
+from helpers.youtubeFunctionalities.client import getClient
+from helpers.youtubeFunctionalities.stream import getStreamChatId
+from appUtils import log
+import os
+from dotenv import load_dotenv
+load_dotenv()
+
+streamId = os.environ.get("STREAM_ID", "")
+nextPageToken = ""
+
+youtube = getClient()
+
+chatId = getStreamChatId(youtube, streamId)
+if chatId != "":
+    print(chatId)
+else:
+    log.info("Received empty chat ID")

helpers/youtubeFunctionalities/chat.py

@@ -0,0 +1,5 @@
+from appUtils import log
+
+def getLiveChats(client, liveChatId: str,  pageToken: str = "", part: str = "snippet"):
+    # client.liveBroadcasts().list(part=part, ).execute()
+    return

helpers/youtubeFunctionalities/client.py

@@ -0,0 +1,16 @@
+from helpers.youtubeFunctionalities.credentials import write as writeCred, read as readCred
+from appUtils import log
+import googleapiclient.discovery as discovery
+from googleapiclient.discovery import Resource
+
+API_SERVICE_NAME = 'youtube'
+API_VERSION = 'v3'
+
+def getClient() -> Resource:
+    try:
+        credentials = readCred()
+        youtube = discovery.build(API_SERVICE_NAME, API_VERSION, credentials= credentials)
+        writeCred(creds= credentials) # in case credentials were refreshed
+        return youtube
+    except Exception as e:
+        log.error("Error in building client: {}".format(e))

helpers/youtubeFunctionalities/credentials.py

@@ -0,0 +1,16 @@
+from appUtils import log, writeJson, readJson, configuration, json
+from google.oauth2.credentials import Credentials
+
+def write(creds: Credentials):
+    try:
+        writeJson(configuration["GCP"]["OAuthToken"], json.loads(creds.to_json()))
+    except Exception as e:
+        log.error("Error in writing credentials: {}".format(e))
+
+def read() -> Credentials:
+    try:
+        tokenJson = readJson(configuration["GCP"]["OAuthToken"])
+        credentials = Credentials.from_authorized_user_info(tokenJson)
+        return credentials
+    except Exception as e:
+        log.error("Error in reading credentials: {}".format(e))

helpers/youtubeFunctionalities/stream.py

@@ -0,0 +1,16 @@
+from appUtils import log
+from googleapiclient.discovery import Resource
+
+def getStreamChatId(client: Resource, streamId: str, part: str = "liveStreamingDetails"):
+    response = ""
+    try:
+        ytResponse = client.videos().list(
+            part=part,
+            id= streamId
+        ).execute()
+        items = ytResponse.get("items", [])
+        if len(items) > 0:
+            response = items[0].get("liveStreamingDetails", {}).get("activeLiveChatId", "")
+    except Exception as e:
+        log.error("Error in getting stream ID: {}".format(e))
+    return response

sample-env.txt

@@ -0,0 +1 @@
+STREAM_ID=""

services/auth/routeDetails.py

@@ -1,5 +1,6 @@
-from flask import Blueprint, redirect, request, session
-from appUtils import configuration, writeJson, json
+from flask import Blueprint, redirect, request
+from appUtils import configuration
+from helpers.youtubeFunctionalities.credentials import write as writeCred
 from google_auth_oauthlib.flow import Flow
 
 blueprint = Blueprint('authRoutes', __name__, template_folder= 'templates')
@@ -19,5 +20,5 @@ def login():
 def callback():
     flow.fetch_token(authorization_response= request.url)
     credentials = flow.credentials
-    writeJson(configuration["GCP"]["OAuthToken"], json.loads(credentials.to_json()))
+    writeCred(creds= credentials)
     return redirect('/home')