update

app.py

@@ -27,52 +27,41 @@ from googleapiclient.http import MediaIoBaseDownload
 from googleapiclient.http import MediaIoBaseUpload
 
 from educational_material import EducationalMaterial
+from storage_service import GoogleCloudStorage
 
 
 
 
+is_env_local = os.getenv("IS_ENV_LOCAL", "false") == "true"
+print(f"is_env_local: {is_env_local}")
 
+if is_env_local:
+    with open("local_config.json") as f:
+        config = json.load(f)
+        PASSWORD = config["PASSWORD"] 
+        GCS_KEY = json.dumps(config["GOOGLE_APPLICATION_CREDENTIALS_JSON"])
+        DRIVE_KEY = json.dumps(config["GOOGLE_APPLICATION_CREDENTIALS_JSON"])
+        OPEN_AI_KEY = config["OPEN_AI_KEY"]
+        GROQ_API_KEY = config["GROQ_API_KEY"]
+        JUTOR_CHAT_KEY = config["JUTOR_CHAT_KEY"]
+        OUTPUT_PATH = config["OUTPUT_PATH"]
+else:
+    PASSWORD = os.getenv("PASSWORD")
+    GCS_KEY = os.getenv("GOOGLE_APPLICATION_CREDENTIALS_JSON")
+    DRIVE_KEY = os.getenv("GOOGLE_APPLICATION_CREDENTIALS_JSON")
+    OPEN_AI_KEY = os.getenv("OPEN_AI_KEY")
+    GROQ_API_KEY = os.getenv("GROQ_API_KEY")
+    JUTOR_CHAT_KEY = os.getenv("JUTOR_CHAT_KEY")
+    OUTPUT_PATH = 'videos'
 
-
-
-# 假设您的环境变量或Secret的名称是GOOGLE_APPLICATION_CREDENTIALS_JSON
-# credentials_json_string = os.getenv("GOOGLE_APPLICATION_CREDENTIALS_JSON")
-# credentials_dict = json.loads(credentials_json_string)
-# SCOPES = ['https://www.googleapis.com/auth/drive']
-# credentials = service_account.Credentials.from_service_account_info(
-#         credentials_dict, scopes=SCOPES)
-# service = build('drive', 'v3', credentials=credentials)
-# # 列出 Google Drive 上的前10個文件
-# results = service.files().list(pageSize=10, fields="nextPageToken, files(id, name)").execute()
-# items = results.get('files', [])
-
-# if not items:
-#     print('No files found.')
-# else:
-#     print("=====Google Drive 上的前10個文件=====")
-#     print('Files:')
-#     for item in items:
-#         print(u'{0} ({1})'.format(item['name'], item['id']))
-
-
-
-OUTPUT_PATH = 'videos'
 TRANSCRIPTS = []
 CURRENT_INDEX = 0
 VIDEO_ID = ""
 
-PASSWORD = os.getenv("PASSWORD")
-
-OPEN_AI_KEY = os.getenv("OPEN_AI_KEY")
 OPEN_AI_CLIENT = OpenAI(api_key=OPEN_AI_KEY)
-
-GROQ_API_KEY = os.getenv("GROQ_API_KEY")
 GROQ_CLIENT = Groq(api_key=GROQ_API_KEY)
-
-JUTOR_CHAT_KEY = os.getenv("JUTOR_CHAT_KEY")
-
-DRIVE_KEY = os.getenv("GOOGLE_APPLICATION_CREDENTIALS_JSON")
-GCS_KEY = os.getenv("GOOGLE_APPLICATION_CREDENTIALS_JSON")
+GCS_SERVICE = GoogleCloudStorage(GCS_KEY)
+GCS_CLIENT = GCS_SERVICE.client
 
 # 驗證 password
 def verify_password(password):
@@ -82,30 +71,6 @@ def verify_password(password):
         raise gr.Error("密碼錯誤")
 
 # ====gcs====
-def init_gcs_client(service_account_key_string):
-    """使用服务账号密钥文件创建 GCS 客户端"""
-    credentials_json_string = service_account_key_string
-    credentials_dict = json.loads(credentials_json_string)
-    credentials = service_account.Credentials.from_service_account_info(credentials_dict)
-    gcs_client = storage.Client(credentials=credentials, project=credentials_dict['project_id'])
-    return gcs_client
-
-def gcs_create_bucket_folder_if_not_exists(gcs_client, bucket_name, folder_name):
-    """检查是否存在特定名称的文件夹（前缀），如果不存在则创建一个标记文件来模拟文件夹"""
-    bucket = gcs_client.bucket(bucket_name)
-    blob = bucket.blob(folder_name)
-    if not blob.exists():
-        blob.upload_from_string('', content_type='application/x-www-form-urlencoded;charset=UTF-8')
-        print(f"GCS Folder '{folder_name}' created.")
-    else:
-        print(f"GCS Folder '{folder_name}' already exists.")
-
-def gcs_check_folder_exists(gcs_client, bucket_name, folder_name):
-    """检查 GCS 存储桶中是否存在指定的文件夹"""
-    bucket = gcs_client.bucket(bucket_name)
-    blobs = list(bucket.list_blobs(prefix=folder_name))
-    return len(blobs) > 0
-
 def gcs_check_file_exists(gcs_client, bucket_name, file_name):
     """
     检查 GCS 存储桶中是否存在指定的文件
@@ -388,6 +353,7 @@ def get_transcript(video_id):
 def generate_transcription(video_id):
     youtube_url = f'https://www.youtube.com/watch?v={video_id}'
     codec_name = "mp3"
+    outtmpl = f"{OUTPUT_PATH}/{video_id}.%(ext)s"
     ydl_opts = {
         'format': 'bestaudio/best',
         'postprocessors': [{
@@ -395,14 +361,13 @@ def generate_transcription(video_id):
             'preferredcodec': codec_name,
             'preferredquality': '192'
         }],
-        'outtmpl': f'{video_id}.%(ext)s',
+        'outtmpl': outtmpl,
     }
     print("===download video mp3===")
     with yt_dlp.YoutubeDL(ydl_opts) as ydl:
         ydl.download([youtube_url])
 
-    audio_path = f'{video_id}.{codec_name}'
-
+    audio_path = f"{OUTPUT_PATH}/{video_id}.{codec_name}"
     print("===transcription by open ai===")
     with open(audio_path, "rb") as audio_file:
         srt_content = OPEN_AI_CLIENT.audio.transcriptions.create(
@@ -410,7 +375,7 @@ def generate_transcription(video_id):
             file=audio_file,
             response_format="verbose_json",
             timestamp_granularities=["segment"],
-            prompt="Transcribe the following audio file. if chinese, please using 'language: zh-TW' in the prompt.",
+            prompt="如果影片有中文，請使用繁體中文，這對於我很重要"
         )
 
     # get segments
@@ -467,39 +432,18 @@ def process_transcript_and_screenshots(video_id):
     updated_transcript_text = json.dumps(transcript, ensure_ascii=False, indent=2)
     update_file_on_drive(service, file_id, updated_transcript_text)
     print("逐字稿已更新，包括截图链接")
-
-    # init gcs client
-    gcs_client = init_gcs_client(GCS_KEY)
-    bucket_name = 'video_ai_assistant'
-    # 检查 folder 是否存在
-    is_gcs_exists = gcs_check_folder_exists(gcs_client, bucket_name, video_id)
-    if not is_gcs_exists:
-        gcs_create_bucket_folder_if_not_exists(gcs_client, bucket_name, video_id)
-        copy_all_files_from_drive_to_gcs(service, gcs_client, folder_id, bucket_name, video_id)
-        print("Drive file 已上传到GCS")
-    else:
-        print("GCS folder:{video_id} 已存在")
-
     return transcript
 
 def process_transcript_and_screenshots_on_gcs(video_id):
     print("====process_transcript_and_screenshots_on_gcs====")
     # GCS
-    gcs_client = init_gcs_client(GCS_KEY)
+    gcs_client = GCS_CLIENT
     bucket_name = 'video_ai_assistant'
-    # 检查 folder 是否存在
-    # is_gcs_exists = gcs_check_folder_exists(gcs_client, bucket_name, video_id)
-    # if not is_gcs_exists:
-    #     gcs_create_bucket_folder_if_not_exists(gcs_client, bucket_name, video_id)
-    #     print("GCS folder:{video_id} 已创建")
-    # else:
-    #     print("GCS folder:{video_id} 已存在")
-
     # 逐字稿文件名
     transcript_file_name = f'{video_id}_transcript.json'
     transcript_blob_name = f"{video_id}/{transcript_file_name}"
     # 检查逐字稿是否存在
-    is_transcript_exists = gcs_check_file_exists(gcs_client, bucket_name, transcript_blob_name)
+    is_transcript_exists = GCS_SERVICE.check_file_exists(bucket_name, transcript_blob_name)
     if not is_transcript_exists:
         # 从YouTube获取逐字稿并上传
         try:
@@ -701,12 +645,12 @@ def process_web_link(link):
 def get_reading_passage(video_id, df_string, source):
     if source == "gcs":
         print("===get_reading_passage on gcs===")
-        gcs_client = init_gcs_client(GCS_KEY)
+        gcs_client = GCS_CLIENT
         bucket_name = 'video_ai_assistant'
         file_name = f'{video_id}_reading_passage.json'
         blob_name = f"{video_id}/{file_name}"
         # 检查 reading_passage 是否存在
-        is_file_exists = gcs_check_file_exists(gcs_client, bucket_name, blob_name)
+        is_file_exists = GCS_SERVICE.check_file_exists(bucket_name, blob_name)
         if not is_file_exists:
             reading_passage = generate_reading_passage(df_string)
             reading_passage_json = {"reading_passage": str(reading_passage)}
@@ -749,7 +693,8 @@ def generate_reading_passage(df_string):
         文本自行判斷資料的種類
         幫我組合成 Reading Passage
         並潤稿讓文句通順
-        請一定要使用 zh-TW
+        請一定要使用繁體中文 zh-TW，並用台灣人的口語
+        產生的結果不要前後文解釋，只需要專注提供 Reading Passage
     """
     messages = [
         {"role": "system", "content": sys_content},
@@ -773,12 +718,12 @@ def generate_reading_passage(df_string):
 def get_mind_map(video_id, df_string, source):
     if source == "gcs":
         print("===get_mind_map on gcs===")
-        gcs_client = init_gcs_client(GCS_KEY)
+        gcs_client = GCS_CLIENT
         bucket_name = 'video_ai_assistant'
         file_name = f'{video_id}_mind_map.json'
         blob_name = f"{video_id}/{file_name}"
         # 检查檔案是否存在
-        is_file_exists = gcs_check_file_exists(gcs_client, bucket_name, blob_name)
+        is_file_exists = GCS_SERVICE.check_file_exists(bucket_name, blob_name)
         if not is_file_exists:
             mind_map = generate_mind_map(df_string)
             mind_map_json = {"mind_map": str(mind_map)}
@@ -856,12 +801,12 @@ def get_mind_map_html(mind_map):
 def get_video_id_summary(video_id, df_string, source):
     if source == "gcs":
         print("===get_video_id_summary on gcs===")
-        gcs_client = init_gcs_client(GCS_KEY)
+        gcs_client = GCS_CLIENT
         bucket_name = 'video_ai_assistant'
         file_name = f'{video_id}_summary.json'
         summary_file_blob_name = f"{video_id}/{file_name}"
         # 检查 summary_file 是否存在
-        is_summary_file_exists = gcs_check_file_exists(gcs_client, bucket_name, summary_file_blob_name)
+        is_summary_file_exists = GCS_SERVICE.check_file_exists(bucket_name, summary_file_blob_name)
         if not is_summary_file_exists:
             summary = generate_summarise(df_string)
             summary_json = {"summary": str(summary)}
@@ -988,12 +933,12 @@ def get_questions(video_id, df_string, source="gcs"):
     if source == "gcs":
         # 去 gcs 確認是有有 video_id_questions.json
         print("===get_questions on gcs===")
-        gcs_client = init_gcs_client(GCS_KEY)
+        gcs_client = GCS_CLIENT
         bucket_name = 'video_ai_assistant'
         file_name = f'{video_id}_questions.json'
         blob_name = f"{video_id}/{file_name}"
         # 检查檔案是否存在
-        is_questions_exists = gcs_check_file_exists(gcs_client, bucket_name, blob_name)
+        is_questions_exists = GCS_SERVICE.check_file_exists(bucket_name, blob_name)
         if not is_questions_exists:
             questions = generate_questions(df_string)
             questions_text = json.dumps(questions, ensure_ascii=False, indent=2)
@@ -1675,9 +1620,9 @@ with gr.Blocks() as demo:
                     with gr.Accordion("prompt", open=False):
                         worksheet_prompt = gr.Textbox(label="worksheet_prompt", show_copy_button=True, lines=40)
                 with gr.Tab("課程計畫"):
-                    lesson_plan_content_type_name = gr.Textbox(value="lesson_plan", visible=False)
+                    lesson_plan_content_type_name = gr.Textbox(value="lesson_plan", visible=False)                    
                     lesson_plan_time = gr.Slider(label="選擇課程時間(分鐘)", minimum=10, maximum=120, step=5, value=40)
-                    lesson_plan_btn = gr.Button("生成課程計畫")
+                    lesson_plan_btn = gr.Button("生成課程計畫 📕")
                     with gr.Accordion("prompt", open=False):
                         lesson_plan_prompt = gr.Textbox(label="worksheet_prompt", show_copy_button=True, lines=40)
 

educational_material.py

@@ -189,60 +189,141 @@ class EducationalMaterial:
         return worksheet_prompt
 
     def _generate_lesson_plan_prompt(self):
-        lesson_plan_prompt = """
-        你是一位專業教師，
-        請根據以上要教學的項目細節
-        幫我安排一個 lesson plan
-
-        規則如下，請嚴格遵守
-        1. 請使用 zh-TW
-        2. 該換行就換行，盡量滿足 word .doc 的格式 
-        3. 【課程大綱】的工作項目請嚴格遵守【課程時間】的時間長度，總和時間不要超過或不足
-        4. 時間安排盡量以五分鐘的倍數為一個單位
-        5. 並且根據課程目標安排教學內容
+        # lesson_plan_prompt = """
+        # 你是一位專業教師，
+        # 請根據以上要教學的項目細節
+        # 幫我安排一個 lesson plan
+
+        # 規則如下，請嚴格遵守
+        # 1. 請使用 zh-TW
+        # 2. 該換行就換行，盡量滿足 word .doc 的格式 
+        # 3. 【課程大綱】的工作項目請嚴格遵守【課程時間】的時間長度，總和時間不要超過或不足
+        # 4. 時間安排盡量以五分鐘的倍數為一個單位
+        # 5. 並且根據課程目標安排教學內容
         
-        範例：
-        【課程主題】計算面積的創意設計
+        # 範例：
+        # 【課程主題】計算面積的創意設計
 
-        【課程目標】
-        - 理解不同形狀（正方形、長方形、三角形）的面積計算方法。
-        - 學會如何通過對摺改變形狀並計算新形狀的面積。
-        - 鼓勵創造力和實際操作，將數學知識應用於創作中。
+        # 【課程目標】
+        # - 理解不同形狀（正方形、長方形、三角形）的面積計算方法。
+        # - 學會如何通過對摺改變形狀並計算新形狀的面積。
+        # - 鼓勵創造力和實際操作，將數學知識應用於創作中。
 
-        【年級】國小三年級
+        # 【年級】國小三年級
 
-        【難度】基礎
+        # 【難度】基礎
 
-        【課程時間】60 分鐘
+        # 【課程時間】60 分鐘
         
-        【課程大綱】
-        - 開場介紹 (5 分鐘)
-        簡短介紹今天的課程主題和目標。
+        # 【課程大綱】
+        # - 開場介紹 (5 分鐘)
+        # 簡短介紹今天的課程主題和目標。
         
-        -  講解與示範 (15 分鐘)
-        形狀與面積：介紹基本幾何形狀（正方形、長方形、三角形）的面積計算公式。
-        對摺技巧：示範如何通過對摺正方形貼紙創造新的形狀（半正方形、三角形）並解釋面積如何改變。
-        應用討論：討論如何使用這些形狀創造不同的圖案或設計，特別是斜屋頂的設計。
+        # -  講解與示範 (15 分鐘)
+        # 形狀與面積：介紹基本幾何形狀（正方形、長方形、三角形）的面積計算公式。
+        # 對摺技巧：示範如何通過對摺正方形貼紙創造新的形狀（半正方形、三角形）並解釋面積如何改變。
+        # 應用討論：討論如何使用這些形狀創造不同的圖案或設計，特別是斜屋頂的設計。
         
-        - 實作活動 (25 分鐘)
-        材料準備：每位學生發放正方形貼紙、剪刀、膠水和紙張。
-        創意剪貼：學生使用對摺技巧製作不同的幾何形狀，並將它們組合成一個有關斜屋頂的圖案或其他創意設計。
-        面積計算：學生計算他們設計中每種形狀的面積，以及整體設計的總面積。
-
-        - 分享與討論 (10 分鐘)
-        學生展示他們的創作並分享他們的設計過程，包括面積如何影響他們的設計選擇。
-        討論學生在創作過程中遇到的挑戰和他們如何解決。
+        # - 實作活動 (25 分鐘)
+        # 材料準備：每位學生發放正方形貼紙、剪刀、膠水和紙張。
+        # 創意剪貼：學生使用對摺技巧製作不同的幾何形狀，並將它們組合成一個有關斜屋頂的圖案或其他創意設計。
+        # 面積計算：學生計算他們設計中每種形狀的面積，以及整體設計的總面積。
+
+        # - 分享與討論 (10 分鐘)
+        # 學生展示他們的創作並分享他們的設計過程，包括面積如何影響他們的設計選擇。
+        # 討論學生在創作過程中遇到的挑戰和他們如何解決。
         
-        - 總結 (5 分鐘)
-        回顧課程學到的主要概念。
-        鼓勵學生在家中嘗試更多的創意組合和面積計算。
+        # - 總結 (5 分鐘)
+        # 回顧課程學到的主要概念。
+        # 鼓勵學生在家中嘗試更多的創意組合和面積計算。
         
-        - 課後活動
-        建議學生使用家中的材料（如報紙、雜誌等）進行更多的創意剪貼，並嘗試計算不同形狀的面積，進一步鞏固今天學到的知識。
+        # - 課後���動
+        # 建議學生使用家中的材料（如報紙、雜誌等）進行更多的創意剪貼，並嘗試計算不同形狀的面積，進一步鞏固今天學到的知識。
         
-        【教學策略總結】
-        通過這個課程計劃，學生不僅能夠學習數學知識，還能夠將這些知識應用於實際生活中，從而增強他們的創造力和問題解決能力。
+        # 【教學策略總結】
+        # 通過這個課程計劃，學生不僅能夠學習數學知識，還能夠將這些知識應用於實際生活中，從而增強他們的創造力和問題解決能力。
+        # """
+
+        lesson_plan_5E_prompt = """
+            你是一位專業教師，
+            請根據以上要教學的項目細節(主題、年級、課程時間、課程目標)
+            幫我安排一個 lesson plan
+
+            規則如下，請嚴格遵守
+            1. 請使用繁體中文溝通 zh-TW，並使用台灣人的用語
+            2. 該換行就換行，盡量滿足 word .doc 的格式 
+            3. 【課程大綱】的工作項目請嚴格遵守【課程時間】的時間長度，總和時間不要超過或不足
+            4. 時間安排盡量以五分鐘的倍數為一個單位
+            5. 並且根據課程目標安排教學內容
+            
+            Lesson Planner 5E is specialized in developing lesson plans for various subjects including Mathematics, Physics, Chemistry, and Biology, using the 5E instructional model. Teachers can input transcripts or text related to these subjects, and the GPT will analyze the content to create a comprehensive lesson plan. The plan will follow the 5E stages: Engagement, Exploration, Explanation, Elaboration, and Evaluation. Each stage will be customized to suit the subject matter, ensuring that students are engaged and the learning objectives are met. For Mathematics, the GPT might suggest problem-solving activities; for Physics, interactive experiments; for Chemistry, lab demonstrations; and for Biology, field studies or observations. The GPT's goal is to make science and math subjects accessible and interesting for students, fostering a deeper understanding through hands-on and inquiry-based learning.
+
+            Step1：理解什麼是 5E 教學模式，請閱讀以下文字：
+            5E教學模式：
+            由Trowbridge和Bybee (1990)提出以探究為基礎的5E教學模式，將教學過程劃分為五個緊密相連的階段，包括：
+            參與(engagement)、探索(exploration)、解釋(explanation)、精緻化(elaboration)與評量(evaluation)等五個階段，
+            各階段的內容如下：
+            1.參與：以學生的學習為主體，設計活動引發學生的學習興趣，使學生願意主動參與教學活動，並能將學生的舊經驗與課程內容相連結，經由提問、定義問題與呈現矛盾的結果等方式，引出探討主題的方向。
+            2.探索：學生參與活動，並給予足夠時間與機會進行探索任務，經由動手操作，建構共同的、具體的經驗。
+            3.解釋：先請學生提出解釋，教師再以學生的想法為基礎，並運用口頭、影片或教學媒體等方式，對學生的解釋加以闡述確認，使學生能確實理解學科知識，再引導學生進入下一階段的教學流程。
+            4.學習共同體 (精緻化)：重視學生之間的互動，營造能促使學生討論以及互相合作的學習環境，分享想法並給予回饋，以建構個人的理解。此外，此階段亦重視學生是否能將其所形成的解釋，應用於新的情境或問題中，以延伸更加一般化的概念理解，進而獲取高層次的知識。
+            5.評量：此階段的主要目的為鼓勵學生評估自己的理解力與能力，同時老師也藉由評量確認學生是否達成教學目標該有的程度。在學生進行探索與提出解釋後，給予回饋是相當重要的，因而教師在階段活動後應進行形成性評量
+
+            Step2：請根據逐字稿的內容描述，以 5E 架構來創建一份 Lesson Plan (課程計畫)。請依循並參考以下輸出範例來設計課程計畫)，需使用 markdown 語法：
+
+            ## 輸出範例：
+
+            課程主題：同分母分數的加減 (使用影片或逐字稿的標題)
+            課程重點：(列出逐字稿內容的重要概念或教學重點)
+            年級：四年級 (依據詢問的年齡或年級填入)
+            課程長度：45-50 分鐘（根據課程數入時間訂定）
+
+            【參與】（5 分鐘）
+
+            - 透過在黑板或投影機上顯示切成不同部分的披薩的圖片來開始課程。
+            - 讓學生與夥伴討論他們注意到分數的什麼以及如何將它們加在一起或減在一起。
+            - 幾分鐘後，請幾位學生與全班分享他們的觀察和想法。
+
+            【探索】（10 分鐘）
+
+            - 發給每位學生分數操作工具���例如分數條、分數圓）。
+            - 為每個學生提供一份工作表，其中包含幾個涉及具有相同分母的分數的加法和減法問題。
+            - 指導學生使用操作工具解決工作表上的問題。
+            - 在房間裡走動，觀察學生的理解情況，並根據需要提供指導。
+
+            【解釋】（10 分鐘）
+
+            - 讓全班同學重新聚集在一起，討論相同分母分數加法和減法的策略和方法。
+            - 介紹關鍵詞彙：分子、分母、分數、同分母。
+            - 顯示並解釋公式：如果兩個分數具有相同的分母，則將分子相加或相減，然後寫出公分母的和或差。
+            - 提供同分母分數加減法的例子，示範步驟和計算。
+
+            【學習共同體】（15 分鐘）
+
+            - 將學生分成兩人一組或小組。
+            - 向每組分發一組分數加法和減法任務卡。
+            - 指導學生使用前面討論的方法一起解決任務卡上的問題。
+            - 鼓勵學生互相解釋他們的想法和推理。
+            - 在教室裡走動以了解學生的進度並在需要時提供支持或澄清。
+
+            【評估】（10 分鐘）
+
+            - 要求每個小組選擇一張任務卡並向全班展示他們的解決方案。
+            - 作為一個班級，討論各小組使用的不同策略並評估他們解決方案的正確性。
+            - 提供回饋並澄清討論期間出現的任何誤解。
+            - 收集學生的工作表和任務卡，作為他們理解的形成性評估。
+
+            【總結】
+
+            - 總結課程中討論的重點，強調分數加減法時分母相同的重要性。
+            - 請學生反思他們的學習，並寫一兩句話來說明他們認為今天的課程有挑戰性或有趣的地方。
+
+            【學習評估】
+
+            - 形成性評估：探索和細化階段的觀察以及討論和演示將深入了解學生對相同分母分數加法和減法的理解。
+            - 總結性評估：收集並審查學生的工作表和任務卡，以評估他們解決涉及具有相同分母的分數的加法和減法問題的能力。
         """
+        lesson_plan_prompt = lesson_plan_5E_prompt
 
         return lesson_plan_prompt
 

local_config.json

@@ -0,0 +1,23 @@
+{
+    "OUTPUT_PATH": "/Users/young/Downloads",
+    "TRANSCRIPTS": [],
+    "CURRENT_INDEX": 0,
+    "VIDEO_ID": "",
+    "PASSWORD": "6161",
+    "OPEN_AI_KEY": "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",
+    "GROQ_API_KEY": "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",
+    "JUTOR_CHAT_KEY": "b4c318b8d6f770e10163436e0e868b806f50f34ae57f378e78956fb76b41fd27",
+    "GOOGLE_APPLICATION_CREDENTIALS_JSON": {
+        "type": "service_account",
+        "project_id": "junyiacademy",
+        "private_key_id": "95d4580de7518ff96be219626c58b23f1754ec6a",
+        "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQCmo3M8Ix46FLNS\nX8NGnEMiZBomXQOEfKCRUy0khm5IKgu5RUIWSF/0UuZeWXG93a1PMarBWokTTIpo\njtRNuEAh+H8lbacJ/G6EH5PxyMjPAOROXLvSJUg4c6lOFp/WoFlnirSPsD/YHL3l\nKKm6//h/tN7GDhaqOKrf9xJ1IlSt7odhCgcR7r3dF/+pbZ2UMDA0rmNmj2aJq7rl\n1qOD/8yC3ainledRRSt8oE7t4w+3eqI5GO7OdLiNwSxGGBNx9IiJln6TFC7frvET\nzr2ZUVLL7jFdWNyfXPU3/B+7JwyXgFGfHpiyQ2xyFAUR62HkpVxs0bKNbnLLmKoL\nIXCQ+lB9AgMBAAECggEAAJLA1C/E7E46SeEqdP3o/TbAwy+Ro4dnUaRNbaK9HmJv\nXymcYJc/JfxjBcRu0qV6wyaeaH1UVZJ67TtWX6JvuPQDWQ2dVX5eovW42aks/AlR\n1wSgeA5rr7pkrZ6jZWa2XGNfOLxpwaGpIqrcx7T/ija/Qc8qmShnSyx+awi9YdX4\n/ih1Ug1fqHPQ1j3Xx23J/S4Wb6eamJZ1BW+txZUUVD2KFnw7iJWR81ceTIuoSY4R\na3Vd8yB1Ri9iVaP6pe0WeA14VfU1d3tbO0GRF6XsEtdRynVXA17nO6okc3yV0bOQ\nnWqibtfT6AWmJFIyya3DrZDxKqSFNuVfHaJrO2LvwQKBgQDRGUzCYJpGw6NAQuKw\n3egfBoTjozZxjykZb0GFFRCIIE9AmX0PkCbz9bxjjMtb9pTH3aVIiv8mL3rfqzdK\nEPEfyC5TntWqahqBW+fOMrpnU54o4Ji1TlFuSBMRBxqIPcJnKFuttkfPZiHbxe3i\nkeqBbJ4HafH5ZNAV+pHwQKSXDwKBgQDMBAbxvSKgYXxeGMOs62rK6y9NeZlKpRUJ\nORdBv+3sLTwSjlpEPwn/KgMXHaHnpDXhtTDP0ad9nLOKnZ5k8dRNcpyUEXVC2WTD\nDHd37lChG0XRnfGuxIvfr5ZYajN/sIgV8WuNpFuWnFj+mGdi+OpzS+KG3J2rMx/k\n4jl1l8g/swKBgQCYJCVyxSFb3dt51XDmKgBMGs00aLwjcnwAErCEqagGtCOWKFgT\nq9p75dA2SupotojYyBAMMX6nBSMNfaHUFXGso1X55/clcOBqQTnwEX8J0ZChw5G5\nUgv0ByNAX3/Ro8ZAkt/qDFhBstlt9J07HtqXYzW0xUSYJt81LsVjH1XixwKBgDF6\nUIzUB8/JlLXlX59SQMYRn5k0gl6+BooEFIXXnEYI+matq2qdtzjw4Wr7vsZE5uRk\nYwAjonEuTcSyUTW+CHT39M1cJood2vgKz/aAD4Hi8V3S5kgyVpHbLaUnrHGtSHO5\n5xGk6KlwJY0pPPmd0I5BuyBl5L8eWP/TdYf1VZVNAoGAUEMSVxBd/onX5LXrzkR7\nOS8w6L+YL68yWCFs1pocfY+cZfkBpteLXzqOMKN2Xc3C7TGGySnEaQlG8bF1P00E\nW9HZvrSYbhsZwEKiIxY3suWRMPRlbeHU9hxt7rYPM+kwl8zy+Z/UtE28Zwhcr0+r\n7EkfwiOEvYStw0mJ9xwhiwU=\n-----END PRIVATE KEY-----\n",
+        "client_email": "[email protected]",
+        "client_id": "113360448655635325414",
+        "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+        "token_uri": "https://oauth2.googleapis.com/token",
+        "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+        "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/analytics-api%40junyiacademy.iam.gserviceaccount.com",
+        "universe_domain": "googleapis.com"
+      }
+}

local_config_example.json

@@ -0,0 +1,12 @@
+{
+    "OUTPUT_PATH": "/Users/young/Downloads",
+    "TRANSCRIPTS": [],
+    "CURRENT_INDEX": 0,
+    "VIDEO_ID": "",
+    "PASSWORD": "1234",
+    "OPEN_AI_KEY": "sk-",
+    "GROQ_API_KEY": "",
+    "JUTOR_CHAT_KEY": "",
+    "GOOGLE_APPLICATION_CREDENTIALS_JSON": {
+      }
+}

storage_service.py

@@ -0,0 +1,44 @@
+import json
+from google.cloud import storage
+from google.oauth2 import service_account
+from googleapiclient.http import MediaIoBaseDownload
+
+
+class GoogleCloudStorage:
+    def __init__(self, service_account_key_string):
+        credentials_dict = json.loads(service_account_key_string)
+        credentials = service_account.Credentials.from_service_account_info(credentials_dict)
+        self.client = storage.Client(credentials=credentials, project=credentials_dict['project_id'])
+
+    def check_file_exists(self, bucket_name, file_name):
+        blob = self.client.bucket(bucket_name).blob(file_name)
+        return blob.exists()
+
+    def upload_file(self, bucket_name, destination_blob_name, file_path):
+        blob = self.client.bucket(bucket_name).blob(destination_blob_name)
+        blob.upload_from_filename(file_path)
+        print(f"File {file_path} uploaded to {destination_blob_name} in GCS.")
+
+    def upload_file_as_string(self, bucket_name, destination_blob_name, content):
+        blob = self.client.bucket(bucket_name).blob(destination_blob_name)
+        blob.upload_from_string(content)
+        print(f"String content uploaded to {destination_blob_name} in GCS.")
+        return None
+
+    def download_as_string(self, bucket_name, source_blob_name):
+        blob = self.client.bucket(bucket_name).blob(source_blob_name)
+        return blob.download_as_text()
+
+    def make_blob_public(self, bucket_name, blob_name):
+        blob = self.client.bucket(bucket_name).blob(blob_name)
+        blob.make_public()
+        print(f"Blob {blob_name} is now publicly accessible at {blob.public_url}")
+
+    def get_public_url(self, bucket_name, blob_name):
+        blob = self.client.bucket(bucket_name).blob(blob_name)
+        return blob.public_url
+
+    def upload_image_and_get_public_url(self, bucket_name, file_name, file_path):
+        self.upload_file(bucket_name, file_name, file_path)
+        self.make_blob_public(bucket_name, file_name)
+        return self.get_public_url(bucket_name, file_name)