#!/usr/bin/env python3
import re
import subprocess

from src.engines.core.base_worker import BaseRenderWorker
from src.engines.ffmpeg.ffmpeg_engine import FFMPEG


class FFMPEGRenderWorker(BaseRenderWorker):

    engine = FFMPEG

    def __init__(self, input_path, output_path, engine_path, args=None, parent=None, name=None):
        super(FFMPEGRenderWorker, self).__init__(input_path=input_path, output_path=output_path,
                                                 engine_path=engine_path, args=args, parent=parent, name=name)
        self.current_frame = -1

    def generate_worker_subprocess(self):

        cmd = [self.engine.default_renderer_path(), '-y', '-stats', '-i', self.input_path]

        # Resize frame
        if self.args.get('x_resolution', None) and self.args.get('y_resolution', None):
            cmd.extend(['-vf', f"scale={self.args['x_resolution']}:{self.args['y_resolution']}"])

        # Convert raw args from string if available
        raw_args = self.args.get('raw', None)
        if raw_args:
            cmd.extend(raw_args.split(' '))

        # Close with output path
        cmd.append(self.output_path)
        return cmd

    def percent_complete(self):
        return max(float(self.current_frame) / float(self.total_frames), 0.0)

    def _parse_stdout(self, line):
        pattern = re.compile(r'frame=\s*(?P<current_frame>\d+)\s*fps.*time=(?P<time_elapsed>\S+)')
        found = pattern.search(line)
        if found:
            stats = found.groupdict()
            self.current_frame = stats['current_frame']
            time_elapsed = stats['time_elapsed']
        elif "not found" in line:
            self.log_error(line)