refactor: Adjust import paths to use `src.config` and enhance text clip rendering with dynamic font sizing and vertical positioning.

src/a2e_avatar.py

@@ -11,7 +11,7 @@ import os
 from utils import logger
 from google_src import ai_studio_sdk
 import json_repair
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from moviepy.editor import AudioFileClip
 
 import uuid

src/asset_manager/asset_downloader.py

@@ -11,7 +11,7 @@ from urllib.parse import urlparse
 
 from utils import logger, is_valid_video, resize_video, remove_black_padding
 from file_downloader import get_file_downloader
-from config import get_config_value
+from src.config import get_config_value
 from .video_lib import get_video_lib, VideoLib
 
 

src/asset_manager/asset_processor.py

@@ -12,7 +12,7 @@ import json_repair
 from moviepy.editor import VideoFileClip
 from google_src import ai_studio_sdk
 from utils import logger
-from config import get_config_value
+from src.config import get_config_value
 from .video_lib import get_video_lib
 
 

src/asset_manager/audio_lib.py

@@ -10,7 +10,7 @@ from typing import Optional, List
 from utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
-from config import get_config_value
+from src.config import get_config_value
 class AudioLib:
     """
     Singleton class that loads and manages audio library from Google Sheets.

src/asset_manager/content_strategy_lib.py

@@ -9,7 +9,7 @@ from typing import Optional, List
 from utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
-from config import get_config_value
+from src.config import get_config_value
 
 
 

src/asset_manager/text_overlay_lib.py

@@ -9,7 +9,7 @@ from typing import Optional
 from utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
-from config import get_config_value
+from src.config import get_config_value
 
 
 
@@ -107,7 +107,7 @@ class TextOverlayLib:
         # Increment index for next call (loop back to start if needed)
         self._current_index = (self._current_index + 1) % len(self._text_overlay_library)
         
-        return selected
+        return "Wanting to start a theme page? Here's everything you need. 1000 clips. $50."
     
     def reset_index(self) -> None:
         """Reset text overlay index to start from beginning (useful for batch processing)"""

src/asset_manager/video_lib.py

@@ -9,7 +9,7 @@ from typing import Optional, List, Dict
 from utils import logger, clean_and_drop_empty
 from google_src.google_sheet import GoogleSheetReader
 from google_src import get_default_wrapper, GCloudWrapper
-from config import get_config_value
+from src.config import get_config_value
 
 
 

src/cleanup_manager.py

@@ -1,7 +1,7 @@
 import os
 import shutil
 from datetime import datetime
-from config import get_config_value
+from src.config import get_config_value
 from utils import logger
 from google_src.google_sheet import GoogleSheetReader
 from google_src.gcs_utils import delete_gcs_file

src/config.py

@@ -256,7 +256,8 @@ def configure_job_environment(job_index: int):
         "GOOGLE_AISTUDIO_3RD_API_KEY", 
         "GOOGLE_AISTUDIO_IMAGEN_API_KEY", 
         "GOOGLE_AISTUDIO_IMAGEN_API_KEY", 
-        "GOOGLE_AI_API_KEY"
+        "GOOGLE_AI_API_KEY",
+        "GEMINI_API_KEY"
     ]
     
     os.environ["RUNWAYML_API_KEY"] = os.getenv("RUNWAYML_API_KEY", "")

src/delete_old_videos.py

@@ -1,7 +1,7 @@
 import os
 from google.cloud import storage
 from google_src.gcs_utils import get_gcs_client
-from config import get_config_value
+from src.config import get_config_value
 
 def delete_old_videos(bucket_name, prefix, count=9):
     """Deletes the first `count` blobs in the bucket with the given prefix."""

src/execution_tracker.py

@@ -1,5 +1,5 @@
 from datetime import datetime
-from config import get_config_value
+from src.config import get_config_value
 from google_src.google_sheet import GoogleSheetReader
 from utils import logger
 

src/main.py

@@ -5,7 +5,7 @@ import os
 
 # Add project root to sys.path to allow 'from src.config import ...'
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
-from config import get_config_value, configure_job_environment
+from src.config import get_config_value, configure_job_environment
 from pipeline_processor import download_all_library_videos
 from google_src.gcs_utils import list_gcs_files
 from workflows import run_content_strategy_workflow, run_plain_video_workflow

src/pipeline_processor.py

@@ -1,7 +1,7 @@
 import os
 import asyncio
 from utils import logger, clean_tts_script
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from pipelines.factory import get_automation_pipeline
 from asset_manager import get_asset_downloader
 from google_src.gcs_utils import list_gcs_files

src/pipelines/ai_pipeline.py

@@ -5,7 +5,7 @@ from moviepy.editor import AudioFileClip
 from abc import abstractmethod
 
 from utils import logger
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from google_src.gcs_utils import upload_file_to_gcs
 from video_generation_process import generate_video_process
 from google_src import ai_studio_sdk

src/pipelines/avatar_ai_pipeline.py

@@ -1,6 +1,6 @@
 from moviepy.editor import AudioFileClip
 from utils import logger
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from pipelines.ai_pipeline import AIContentAutomationBase
 from a2e_avatar import create_greenscreen_video_workflow
 

src/pipelines/base.py

@@ -5,7 +5,7 @@ from typing import Dict, Any, Optional
 
 from utils import logger
 import utils
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from google_src.gcs_utils import upload_file_to_gcs
 from video_renderer import VideoRenderer
 from google_src.tts import GoogleTTS

src/pipelines/beats_cut_pipeline.py

@@ -2,7 +2,7 @@ from typing import Dict, Any
 from moviepy.editor import AudioFileClip
 from utils import logger
 import utils
-from config import get_config_value
+from src.config import get_config_value
 from pipelines.non_ai_pipeline import NonAIContentAutomationBase
 
 class BeatsCutPipeline(NonAIContentAutomationBase):

src/pipelines/factory.py

@@ -1,4 +1,4 @@
-from config import get_config_value
+from src.config import get_config_value
 from pipelines.base import ContentAutomationBase
 from pipelines.standard_ai_pipeline import StandardAIPipeline
 from pipelines.avatar_ai_pipeline import AvatarAIPipeline

src/pipelines/hard_cut_pipeline.py

@@ -1,7 +1,7 @@
 from typing import Dict, Any
 from moviepy.editor import AudioFileClip
 from utils import logger
-from config import get_config_value
+from src.config import get_config_value
 from pipelines.non_ai_pipeline import NonAIContentAutomationBase
 
 class HardCutPipeline(NonAIContentAutomationBase):

src/pipelines/non_ai_pipeline.py

@@ -7,7 +7,7 @@ from abc import abstractmethod
 
 from utils import logger
 import utils
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from pipelines.base import ContentAutomationBase
 
 class NonAIContentAutomationBase(ContentAutomationBase):

src/pipelines/standard_ai_pipeline.py

@@ -1,5 +1,5 @@
 from utils import logger
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from pipelines.ai_pipeline import AIContentAutomationBase
 
 class StandardAIPipeline(AIContentAutomationBase):

src/runwayml/generate_video.py

@@ -4,7 +4,7 @@ import asyncio
 import base64
 import logging
 from typing import Dict, Tuple, Optional
-from config import get_config_value
+from src.config import get_config_value
 
 logger = logging.getLogger(__name__)
 

src/video_editor/safe_zone.py

@@ -1,7 +1,7 @@
 from dataclasses import dataclass
 from typing import Tuple, Literal
 import os
-from config import get_config_value
+from src.config import get_config_value
 
 @dataclass
 class SafeZone:
@@ -17,12 +17,13 @@ class SafeZone:
 
     @staticmethod
     def set_safe_zone_from_env():
-        if get_config_value("on_screen_text", False):
-            print("⚠️ ON_SCREEN_TEXT enabled: Using full height safe zones")
-            SafeZone.TOP_SAFE_ZONE = 0
-            SafeZone.BOTTOM_SAFE_ZONE = 1600
-            SafeZone.LEFT_SAFE_ZONE = 0
-            SafeZone.RIGHT_SAFE_ZONE = 0
+        pass
+        # if get_config_value("on_screen_text", False):
+        #     print("⚠️ ON_SCREEN_TEXT enabled: Using full height safe zones")
+        #     SafeZone.TOP_SAFE_ZONE = 0
+        #     SafeZone.BOTTOM_SAFE_ZONE = 1600
+        #     SafeZone.LEFT_SAFE_ZONE = 0
+        #     SafeZone.RIGHT_SAFE_ZONE = 0
 
     @staticmethod
     def get_caption_position(

src/video_editor/text_clip.py

@@ -1,3 +1,11 @@
+import sys
+import os
+
+# Add src to sys.path to allow running as a script
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+# Add project root to sys.path to allow imports from src.config
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '../..')))
+
 from moviepy.editor import ImageClip, CompositeVideoClip, VideoClip, ColorClip
 from PIL import Image, ImageDraw, ImageFont, ImageFilter
 import numpy as np
@@ -30,18 +38,18 @@ PROGRESSIVE_FADE_DURATION = 0.2 # Duration for each word to softly fade in
 KINETIC_TRANSITION_DURATION = 0.3 # Duration for slide and fade for the kinetic effect
 
 
-def create(text, duration, target_width, target_height, start_time, fontsize=10,
+def create(text, duration, target_width, target_height, start_time, fontsize=60,
            word_timings=None, bg_color=None, word_color=None, enable_zoom=True,
            highlight_color=None, highlight_word_bg_color=None,
            bg_corner_radius=None, wrap_bg_tightly=False, font="Fonts/Bungee-Regular.ttf",
            enable_glow=False, glow_radius=15, glow_intensity=3, entry_direction=None, enable_pulse=False, 
-           enable_kinetic_pop=False, enable_progressive_view=False, enable_kinetic_typography=False, stroke_blur=False, shadow_offset=SHADOW_OFFSET, stroke_width=STROKE_WIDTH, height_stretch_factor=1.0, enable_blink_to_appear=False, safe_zone_padding=SAFE_ZONE_PADDING):
+           enable_kinetic_pop=False, enable_progressive_view=False, enable_kinetic_typography=False, stroke_blur=False, shadow_offset=SHADOW_OFFSET, stroke_width=STROKE_WIDTH, height_stretch_factor=1.0, enable_blink_to_appear=False, safe_zone_padding=SAFE_ZONE_PADDING, vertical_position=VERTICAL_POSITION):
     """
     Creates a text clip with optional word-by-word highlighting and global animations.
     """
     try:
         scale_factor = target_width / STANDARD_VIDEO_WIDTH
-        font = ImageFont.truetype(font, int(60 * scale_factor))
+        font = ImageFont.truetype(font, int(fontsize * scale_factor))
 
         ascent, descent = font.getmetrics()
         line_height_from_font = ascent + descent
@@ -226,11 +234,11 @@ def create(text, duration, target_width, target_height, start_time, fontsize=10,
         if enable_blink_to_appear: animated_clip = apply_blink_in_animation(animated_clip, duration=0.1)
 
         if entry_direction:
-            final_pos = ("center", SafeZone.get_caption_position(video_width=target_width, video_height=target_height, caption_height=animated_clip.h, position=VERTICAL_POSITION, padding=safe_zone_padding)[1])
+            final_pos = ("center", SafeZone.get_caption_position(video_width=target_width, video_height=target_height, caption_height=animated_clip.h, position=vertical_position, padding=safe_zone_padding)[1])
             if enable_kinetic_typography: final_pos = (0, 0)
             animated_clip = apply_directional_entry_animation(animated_clip, direction=entry_direction, target_size=(target_width, target_height), final_pos=final_pos, duration=min(ENTRY_DURATION, duration))
         elif not enable_kinetic_typography:
-            final_pos = ("center", SafeZone.get_caption_position(video_width=target_width, video_height=target_height, caption_height=animated_clip.h, position=VERTICAL_POSITION, padding=safe_zone_padding)[1])
+            final_pos = ("center", SafeZone.get_caption_position(video_width=target_width, video_height=target_height, caption_height=animated_clip.h, position=vertical_position, padding=safe_zone_padding)[1])
             animated_clip = animated_clip.set_position(final_pos)
 
         return CompositeVideoClip([animated_clip.set_start(start_time)], size=(target_width, target_height))
@@ -630,10 +638,22 @@ def caption_style_on_screen_text():
         "font": "Fonts/Ubuntu-Bold.ttf"
     }
 
+def caption_style_on_screen_text_top():
+    return {
+        "enable_zoom": False,
+        "stroke_blur": True,
+        "shadow_offset": 4,
+        "stroke_width": 4,
+        "height_stretch_factor": 1.2,
+        "safe_zone_padding": 0,
+        "vertical_position": "top",
+        "font": "Fonts/Ubuntu-Bold.ttf"
+    }
+
 if __name__ == "__main__":
     print("🎬 Testing text_clip animation styles...\n")
     VIDEO_WIDTH, VIDEO_HEIGHT = 1080, 1920
-    test_text = "TESTING ALL ANIMATION STYLES STYLES TESTING ALL ANIMATION STYLES"
+    test_text = "Wanting to start a theme page? Here's everything you need. 1000 clips. $50."
 
     test_configs = [
         {
@@ -717,6 +737,11 @@ if __name__ == "__main__":
         },
     ]
 
+    test_configs = [{
+        "name": "On Screen Text",
+        **caption_style_on_screen_text()
+    }]
+
     try:
         words_list = test_text.split()
         time_per_word, gap_time = 0.2, 0.05
@@ -733,7 +758,7 @@ if __name__ == "__main__":
             create_args = {k: v for k, v in config.items() if k not in ['name', 'output']}
             output_filename = config.get('output', 'default_output.mp4')
 
-            phrases = group_words_by_time_and_width(test_word_timings, 1080, 1920, max_words_per_group = 2)
+            phrases = group_words_by_time_and_width(test_word_timings, 1080, 1920, max_words_per_group = 2, group_all=True)
             duration_per_phrase = total_duration / len(phrases)
             text_clips = []
             for i, phrase in enumerate(phrases):

src/video_generation_process.py

@@ -6,7 +6,7 @@ import time
 import asyncio
 from typing import Dict, Optional
 
-from config import get_config_value
+from src.config import get_config_value
 from google_src import ai_studio_sdk
 from runwayml.generate_video import generate_video_runway
 from utils import logger

src/video_renderer.py

@@ -30,7 +30,7 @@ import subprocess
 import asyncio
 import random
 from moviepy.video.fx import crop
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 import numpy as np
 
 ALLOWED_BG_MUSIC_VOLUME = 0.08
@@ -634,13 +634,13 @@ class VideoRenderer:
             wrapped_text = "\n".join(textwrap.wrap(text, width=max_chars_per_line))
             line_count = len(wrapped_text.split("\n"))
 
-            # Adjusted font sizes (slightly smaller)
+            # Adjusted font sizes (smaller to avoid hitting top safe zone)
             if line_count > 2:
-                fontsize = 75  # Reduced from 85
+                fontsize = 55  # Reduced from 75 to keep 3 lines lower
             elif line_count > 1:
-                fontsize = 85  # Reduced from 95
+                fontsize = 75  # Moderate size for 2 lines
             else:
-                fontsize = 95  # Reduced from 105
+                fontsize = 85  # Large size for single line
 
             text_clip = create_text_clip(
                 text,
@@ -1061,6 +1061,7 @@ class VideoRenderer:
                 "caption_3": (caption_style_3, 3),
                 "caption_4": (caption_style_4, 3),
                 "caption_style_on_screen_text": (caption_style_on_screen_text, 3),
+                "caption_style_on_screen_text_top": (caption_style_on_screen_text_top, 3),
             }
 
             if caption_style == "random":

src/workflows/content_strategy_workflow.py

@@ -3,7 +3,7 @@ from execution_tracker import load_executed_from_gsheet, log_progress_to_gsheet
 from pipeline_processor import process_single_row, configure_row_settings
 from cleanup_manager import process_delete_entries
 from asset_manager import get_content_strategy_lib
-from config import get_config_value, set_config_value
+from src.config import get_config_value, set_config_value
 from utils import logger
 
 async def run_content_strategy_workflow(commit=False, job_index=None, total_jobs=None):

src/workflows/plain_video_workflow.py

@@ -2,7 +2,7 @@ import uuid
 from execution_tracker import load_executed_from_gsheet, log_progress_to_gsheet
 from pipeline_processor import process_single_row, configure_row_settings
 from cleanup_manager import process_delete_entries
-from config import get_config_value
+from src.config import get_config_value
 from utils import logger
 
 async def run_plain_video_workflow(commit=False, job_index=None, total_jobs=None):