fixes to media -> video on cut

Author: Stephen G. Pope

app.py

@@ -168,7 +168,7 @@ def wrapper(*args, **kwargs):
     from routes.v1.media.convert.media_convert import v1_media_convert_bp
     from routes.v1.audio.concatenate import v1_audio_concatenate_bp
     from routes.v1.media.silence import v1_media_silence_bp
-    from routes.v1.media.cut import v1_media_cut_bp
+    from routes.v1.video.cut import v1_video_cut_bp
 
     app.register_blueprint(v1_ffmpeg_compose_bp)
     app.register_blueprint(v1_media_transcribe_bp)
@@ -191,7 +191,7 @@ def wrapper(*args, **kwargs):
     app.register_blueprint(v1_media_convert_bp)
     app.register_blueprint(v1_audio_concatenate_bp)
     app.register_blueprint(v1_media_silence_bp)
-    app.register_blueprint(v1_media_cut_bp)
+    app.register_blueprint(v1_video_cut_bp)
 
     return app
 

routes/v1/video/cut.py

@@ -0,0 +1,102 @@
+# Copyright (c) 2025 Stephen G. Pope
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License along
+# with this program; if not, write to the Free Software Foundation, Inc.,
+# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+
+
+
+from flask import Blueprint
+from app_utils import *
+import logging
+from services.v1.video.cut import cut_media
+from services.authentication import authenticate
+
+v1_video_cut_bp = Blueprint('v1_video_cut', __name__)
+logger = logging.getLogger(__name__)
+
+@v1_video_cut_bp.route('/v1/video/cut', methods=['POST'])
+@authenticate
+@validate_payload({
+    "type": "object",
+    "properties": {
+        "video_url": {"type": "string", "format": "uri"},
+        "cuts": {
+            "type": "array",
+            "items": {
+                "type": "object",
+                "properties": {
+                    "start": {"type": "string"},
+                    "end": {"type": "string"}
+                },
+                "required": ["start", "end"],
+                "additionalProperties": False
+            },
+            "minItems": 1
+        },
+        "video_codec": {"type": "string"},
+        "video_preset": {"type": "string"},
+        "video_crf": {"type": "number", "minimum": 0, "maximum": 51},
+        "audio_codec": {"type": "string"},
+        "audio_bitrate": {"type": "string"},
+        "webhook_url": {"type": "string", "format": "uri"},
+        "id": {"type": "string"}
+    },
+    "required": ["video_url", "cuts"],
+    "additionalProperties": False
+})
+@queue_task_wrapper(bypass_queue=False)
+def video_cut(job_id, data):
+    """Cut specified segments from a video file with optional encoding settings."""
+    video_url = data['video_url']
+    cuts = data['cuts']
+    
+    # Extract encoding settings with defaults
+    video_codec = data.get('video_codec', 'libx264')
+    video_preset = data.get('video_preset', 'medium')
+    video_crf = data.get('video_crf', 23)
+    audio_codec = data.get('audio_codec', 'aac')
+    audio_bitrate = data.get('audio_bitrate', '128k')
+    
+    logger.info(f"Job {job_id}: Received video cut request for {video_url}")
+    
+    try:
+        # Process the video file and get local file paths
+        output_filename, input_filename = cut_media(
+            video_url=video_url,
+            cuts=cuts,
+            job_id=job_id,
+            video_codec=video_codec,
+            video_preset=video_preset,
+            video_crf=video_crf,
+            audio_codec=audio_codec,
+            audio_bitrate=audio_bitrate
+        )
+        
+        # Upload the processed file to cloud storage
+        from services.cloud_storage import upload_file
+        cloud_url = upload_file(output_filename)
+        logger.info(f"Job {job_id}: Uploaded output to cloud: {cloud_url}")
+        
+        # Clean up temporary files
+        import os
+        os.remove(input_filename)
+        os.remove(output_filename)
+        logger.info(f"Job {job_id}: Removed temporary files")
+        
+        logger.info(f"Job {job_id}: Video cut operation completed successfully")
+        return cloud_url, "/v1/video/cut", 200
+        
+    except Exception as e:
+        logger.error(f"Job {job_id}: Error during video cut process - {str(e)}")
+        return str(e), "/v1/video/cut", 500

services/v1/media/cut.py services/v1/video/cut.pyservices/v1/media/cut.py renamed to services/v1/video/cut.py

@@ -52,13 +52,13 @@ def time_to_seconds(time_str):
     except ValueError:
         raise ValueError(f"Invalid time format: {time_str}. Expected HH:MM:SS[.mmm]")
 
-def cut_media(media_url, cuts, job_id=None, video_codec='libx264', video_preset='medium', 
+def cut_media(video_url, cuts, job_id=None, video_codec='libx264', video_preset='medium', 
            video_crf=23, audio_codec='aac', audio_bitrate='128k'):
     """
-    Cuts specified segments from a media file with customizable encoding settings.
+    Cuts specified segments from a video file with customizable encoding settings.
     
     Args:
-        media_url (str): URL of the media file to cut
+        video_url (str): URL of the video file to cut
         cuts (list): List of dictionaries with 'start' and 'end' timestamps
         job_id (str, optional): Unique job identifier
         video_codec (str, optional): Video codec to use for encoding (default: 'libx264')
@@ -70,9 +70,9 @@ def cut_media(media_url, cuts, job_id=None, video_codec='libx264', video_preset=
     Returns:
         str: Path to the processed local file
     """
-    logger.info(f"Starting media cut operation for {media_url}")
-    input_filename = download_file(media_url, os.path.join(LOCAL_STORAGE_PATH, f"{job_id}_input"))
-    logger.info(f"Downloaded media to local file: {input_filename}")
+    logger.info(f"Starting video cut operation for {video_url}")
+    input_filename = download_file(video_url, os.path.join(LOCAL_STORAGE_PATH, f"{job_id}_input"))
+    logger.info(f"Downloaded video to local file: {input_filename}")
 
     try:
         # Get the file extension
@@ -182,7 +182,7 @@ def cut_media(media_url, cuts, job_id=None, video_codec='libx264', video_preset=
         return output_filename, input_filename
 
     except Exception as e:
-        logger.error(f"Media cut operation failed: {str(e)}")
+        logger.error(f"Video cut operation failed: {str(e)}")
         # Clean up all temporary files if they exist
         if 'input_filename' in locals() and os.path.exists(input_filename):
             os.remove(input_filename)