def process_files()

in src/processLambda/app/app.py [0:0]

• 18 lines of code
• 3 McCabe index (conditional complexity)

def process_files(objs_keys, MEETING_ID, file_type, *attendee):
    if attendee:
        attendeeStr = "-" + attendee[0]
    else:
        attendeeStr = ""
        
    with open('/tmp/' + file_type +attendeeStr+'_list.txt', 'w') as f:
        for k in objs_keys:
            basename = os.path.splitext(k)[0]
            ffmpeg_cmd = "ffmpeg -i /tmp/" + k + " -bsf:v h264_mp4toannexb -f mpegts -framerate 15 -c copy /tmp/" + basename + attendeeStr + "-" + file_type + ".ts -y"
            command1 = shlex.split(ffmpeg_cmd)
            p1 = subprocess.run(command1, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
            f.write(f'file \'/tmp/{basename}{attendeeStr}-{file_type}.ts\'\n')

    ffmpeg_cmd = "ffmpeg -f concat -safe 0 -i /tmp/" + file_type + attendeeStr + "_list.txt  -c copy /tmp/"+file_type+attendeeStr+".mp4 -y"
    command1 = shlex.split(ffmpeg_cmd)
    p1 = subprocess.run(command1, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    s3.upload_file('/tmp/'+file_type+attendeeStr+'.mp4', SOURCE_BUCKET, "captures/" + MEETING_ID + "/processed" + '/processed-'+file_type+attendeeStr+'.mp4')
    processedUrl = s3.generate_presigned_url('get_object', Params={'Bucket': SOURCE_BUCKET, 'Key': "captures/" + MEETING_ID + "/processed" + '/processed'+attendeeStr+"-"+file_type+'.mp4' })
    
    return processedUrl