- removed cue_file because it's handled by liquidsoap itself.
This commit is contained in:
parent
107c100cc4
commit
cef2361bc2
7 changed files with 2 additions and 142 deletions
|
@ -1,5 +1,5 @@
|
||||||
[loggers]
|
[loggers]
|
||||||
keys=root,fetch,push,cue_file
|
keys=root,fetch,push
|
||||||
|
|
||||||
[handlers]
|
[handlers]
|
||||||
keys=fileOutHandler
|
keys=fileOutHandler
|
||||||
|
@ -23,12 +23,6 @@ handlers=fileOutHandler
|
||||||
qualname=push
|
qualname=push
|
||||||
propagate=0
|
propagate=0
|
||||||
|
|
||||||
[logger_cue_file]
|
|
||||||
level=DEBUG
|
|
||||||
handlers=fileOutHandler
|
|
||||||
qualname=push
|
|
||||||
propagate=0
|
|
||||||
|
|
||||||
[handler_fileOutHandler]
|
[handler_fileOutHandler]
|
||||||
class=logging.handlers.RotatingFileHandler
|
class=logging.handlers.RotatingFileHandler
|
||||||
level=DEBUG
|
level=DEBUG
|
||||||
|
|
|
@ -56,7 +56,6 @@ except Exception, e:
|
||||||
class Global:
|
class Global:
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self.api_client = api_client.api_client_factory(config)
|
self.api_client = api_client.api_client_factory(config)
|
||||||
self.cue_file = CueFile()
|
|
||||||
self.set_export_source('scheduler')
|
self.set_export_source('scheduler')
|
||||||
|
|
||||||
def selfcheck(self):
|
def selfcheck(self):
|
||||||
|
|
|
@ -59,7 +59,6 @@ class PypoFetch(Thread):
|
||||||
Thread.__init__(self)
|
Thread.__init__(self)
|
||||||
logger = logging.getLogger('fetch')
|
logger = logging.getLogger('fetch')
|
||||||
self.api_client = api_client.api_client_factory(config)
|
self.api_client = api_client.api_client_factory(config)
|
||||||
self.cue_file = CueFile()
|
|
||||||
self.set_export_source('scheduler')
|
self.set_export_source('scheduler')
|
||||||
self.queue = q
|
self.queue = q
|
||||||
logger.info("PypoFetch: init complete")
|
logger.info("PypoFetch: init complete")
|
||||||
|
|
|
@ -35,7 +35,6 @@ class PypoPush(Thread):
|
||||||
def __init__(self, q):
|
def __init__(self, q):
|
||||||
Thread.__init__(self)
|
Thread.__init__(self)
|
||||||
self.api_client = api_client.api_client_factory(config)
|
self.api_client = api_client.api_client_factory(config)
|
||||||
self.cue_file = CueFile()
|
|
||||||
self.set_export_source('scheduler')
|
self.set_export_source('scheduler')
|
||||||
self.queue = q
|
self.queue = q
|
||||||
|
|
||||||
|
|
|
@ -1,42 +0,0 @@
|
||||||
import unittest
|
|
||||||
|
|
||||||
from util.cue_file import CueFile
|
|
||||||
|
|
||||||
from mutagen.mp3 import MP3
|
|
||||||
from mutagen.oggvorbis import OggVorbis
|
|
||||||
import random
|
|
||||||
import string
|
|
||||||
|
|
||||||
class test(unittest.TestCase):
|
|
||||||
|
|
||||||
"""
|
|
||||||
|
|
||||||
A test class for the cue_in module.
|
|
||||||
|
|
||||||
"""
|
|
||||||
|
|
||||||
def setUp(self):
|
|
||||||
self.cue_file = CueFile()
|
|
||||||
|
|
||||||
def test_cue_mp3(self):
|
|
||||||
src = '../audio_samples/OpSound/Peter_Rudenko_-_Opening.mp3'
|
|
||||||
dst = '/tmp/' + "".join([random.choice(string.letters) for i in xrange(10)]) + '.mp3'
|
|
||||||
self.cue_file.cue(src, dst, 5, 5)
|
|
||||||
src_length = MP3(src).info.length
|
|
||||||
dst_length = MP3(dst).info.length
|
|
||||||
print src + " " + str(src_length)
|
|
||||||
print dst + " " + str(dst_length)
|
|
||||||
self.assertTrue(dst_length < src_length)
|
|
||||||
|
|
||||||
def test_cue_ogg(self):
|
|
||||||
src = '../audio_samples/OpSound/ACDC_-_Back_In_Black-sample.ogg'
|
|
||||||
dst = '/tmp/' + "".join([random.choice(string.letters) for i in xrange(10)]) + '.ogg'
|
|
||||||
self.cue_file.cue(src, dst, 5, 5)
|
|
||||||
src_length = OggVorbis(src).info.length
|
|
||||||
dst_length = OggVorbis(dst).info.length
|
|
||||||
print src + " " + str(src_length)
|
|
||||||
print dst + " " + str(dst_length)
|
|
||||||
self.assertTrue(dst_length < src_length)
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
unittest.main()
|
|
|
@ -1,5 +1,4 @@
|
||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
|
|
||||||
from json import *
|
from json import *
|
||||||
from status import *
|
from status import *
|
||||||
from cue_file import *
|
|
|
@ -1,88 +0,0 @@
|
||||||
#!/usr/bin/env python
|
|
||||||
# -*- coding: utf-8 -*-
|
|
||||||
|
|
||||||
import sys
|
|
||||||
import shutil
|
|
||||||
import random
|
|
||||||
import string
|
|
||||||
import time
|
|
||||||
from datetime import timedelta
|
|
||||||
import os
|
|
||||||
import logging
|
|
||||||
|
|
||||||
from mutagen.mp3 import MP3
|
|
||||||
from mutagen.oggvorbis import OggVorbis
|
|
||||||
|
|
||||||
class CueFile():
|
|
||||||
|
|
||||||
def __init__(self):
|
|
||||||
logger = logging.getLogger("cue_file")
|
|
||||||
logger.debug("init")
|
|
||||||
|
|
||||||
def cue(self, src, dst, cue_in, cue_out):
|
|
||||||
|
|
||||||
logger = logging.getLogger("cue_file")
|
|
||||||
logger.debug("cue file: %s %s %s %s", src, dst, cue_in, cue_out)
|
|
||||||
|
|
||||||
if src.lower().endswith('.mp3'):
|
|
||||||
# mutagen
|
|
||||||
audio = MP3(src)
|
|
||||||
dur = round(audio.info.length, 3)
|
|
||||||
|
|
||||||
logger.debug("duration by mutagen: %s", dur)
|
|
||||||
|
|
||||||
cue_out = round(float(dur) - cue_out, 3)
|
|
||||||
|
|
||||||
str_cue_in = str(timedelta(seconds=cue_in)).replace(".", "+") # hh:mm:ss+mss, eg 00:00:20+000
|
|
||||||
str_cue_out = str(timedelta(seconds=cue_out)).replace(".", "+") #
|
|
||||||
|
|
||||||
"""
|
|
||||||
now a bit a hackish part, don't know how to do this better...
|
|
||||||
need to cut the digits after the "+"
|
|
||||||
"""
|
|
||||||
ts = str_cue_in.split("+")
|
|
||||||
try:
|
|
||||||
if len(ts[1]) == 6:
|
|
||||||
ts[1] = ts[1][0:3]
|
|
||||||
str_cue_in = "%s+%s" % (ts[0], ts[1])
|
|
||||||
except Exception, e:
|
|
||||||
pass
|
|
||||||
|
|
||||||
ts = str_cue_out.split("+")
|
|
||||||
try:
|
|
||||||
if len(ts[1]) == 6:
|
|
||||||
ts[1] = ts[1][0:3]
|
|
||||||
str_cue_out = "%s+%s" % (ts[0], ts[1])
|
|
||||||
except Exception, e:
|
|
||||||
pass
|
|
||||||
|
|
||||||
logger.debug("in: %s", str_cue_in)
|
|
||||||
logger.debug("out: %s", str(str_cue_out) )
|
|
||||||
|
|
||||||
command = 'mp3cut -o %s -t %s-%s %s' % (dst + '.tmp.mp3', str_cue_in, str_cue_out, src);
|
|
||||||
logger.info("command: %s", command)
|
|
||||||
os.system(command + ' > /dev/null 2>&1')
|
|
||||||
|
|
||||||
command = 'lame -b 128 %s %s' % (dst + '.tmp.mp3', dst);
|
|
||||||
logger.info("command: %s", command)
|
|
||||||
os.system(command + ' > /dev/null 2>&1')
|
|
||||||
elif src.lower().endswith('.ogg'):
|
|
||||||
audio = OggVorbis(src)
|
|
||||||
dur = audio.info.length
|
|
||||||
sys.stderr.write('duration: ' + str(dur) + '\n')
|
|
||||||
|
|
||||||
cue_out = float(dur) - cue_out
|
|
||||||
|
|
||||||
#convert input format of ss.mmm to milliseconds and to string<
|
|
||||||
str_cue_in = str(int(round(cue_in*1000)))
|
|
||||||
|
|
||||||
#convert input format of ss.mmm to milliseconds and to string
|
|
||||||
str_cue_out = str(int(round(cue_out*1000)))
|
|
||||||
|
|
||||||
command = 'oggCut -s %s -e %s %s %s' % (str_cue_in, str_cue_out, src, dst)
|
|
||||||
logger.info("command: %s", command)
|
|
||||||
os.system(command + ' > /dev/null 2>&1')
|
|
||||||
else:
|
|
||||||
logger.debug("in: %s", 'File name with invalid extension. File will not be cut\n')
|
|
||||||
|
|
||||||
return dst
|
|
Loading…
Add table
Add a link
Reference in a new issue