| | |
| | | import json |
| | | import re |
| | | import requests |
| | | import unicodedata |
| | | import sys |
| | | from querysubsonic import findalbumbyname |
| | | from queryAudiobookServer import findalbumbyname |
| | | |
| | | # arguments |
| | | # activation_key, file name, codec(default to mp3) |
| | | |
| | | parser = argparse.ArgumentParser() |
| | | parser.add_argument("-s", "--single", help="Use this option to create a single file. This is false by default", action="store_true") |
| | | parser.add_argument("-d", "--dpath", help="Use this to set the destination path. Otherwise I will use the current directory") |
| | | parser.add_argument("-v", "--verbose", help="Send output to stdout", action="store_true") |
| | | parser.add_argument("filename", help="Filename to convert, or directory to look in") |
| | | parser.add_argument("-s", "--single", help="Use this option to create a single\ |
| | | file. This is false by default", action="store_true") |
| | | parser.add_argument("-d", "--dpath", help="Use this to set the destination\ |
| | | path. Otherwise I will use the current directory") |
| | | parser.add_argument("-v", "--verbose", help="Send output to stdout", |
| | | action="store_true") |
| | | parser.add_argument("filename", help="Filename to convert, or directory to\ |
| | | look in") |
| | | |
| | | args = parser.parse_args() |
| | | |
| | |
| | | |
| | | def getmetadata(aaxfile): |
| | | # Returns the metadata from an aax file |
| | | ret = subprocess.run(["ffprobe", "-v", "info", "-hide_banner", "-show_format", "-show_chapters", |
| | | "-print_format", "json", os.path.abspath(aaxfile)], capture_output=True) |
| | | ret = subprocess.run(["ffprobe", "-v", "info", "-hide_banner", |
| | | "-show_format", "-show_chapters", |
| | | "-print_format", "json", |
| | | os.path.abspath(aaxfile)], capture_output=True) |
| | | |
| | | mdata = json.loads(ret.stdout) |
| | | aret = ret.stderr.decode().split('\n')[0] |
| | |
| | | |
| | | def reencode(aaxfile, outpath): |
| | | # decrypt and reencode to mp3 |
| | | command = ("ffmpeg -loglevel error {} -activation_bytes {} -i {} -vn -codec:a libmp3lame -ab {}k -map_metadata -1 " |
| | | "-metadata \"title={}\" -metadata 'artist={}' -metadata 'album_artist={}' -metadata \"album={}\" -metadata 'date={}' " |
| | | "-metadata track=1/1 -metadata 'genre={}' -metadata 'copyright={}' \"{}\" ").format(stats, act_byte, aaxfile, getmetabitrate(), |
| | | getmetadatatags('title'), getmetadatatags('artist'), |
| | | getmetadatatags('album_artist'), getmetadatatags('album'), |
| | | getmetadatatags('date'), getmetadatatags('genre'), |
| | | getmetacopyright(), outpath) |
| | | command = ( |
| | | "ffmpeg -loglevel error {} -activation_bytes {} -i" |
| | | " {} -vn -codec:a libmp3lame -ab {}k -map_metadata -1" |
| | | "-metadata \"title={}\" -metadata 'artist={}' -metadata" |
| | | " 'album_artist={}' -metadata \"album={}\" -metadata 'date={}' " |
| | | "-metadata track=1/1 -metadata 'genre={}' -metadata " |
| | | "'copyright={}' \"{}\" ").format( |
| | | stats, act_byte, aaxfile, getmetabitrate(), |
| | | getmetadatatags('title'), getmetadatatags('artist'), |
| | | getmetadatatags('album_artist'), getmetadatatags('album'), |
| | | getmetadatatags('date'), getmetadatatags('genre'), |
| | | getmetacopyright(), outpath) |
| | | if args.verbose: |
| | | print(command) |
| | | process = subprocess.run(command, shell=True, capture_output=True) |
| | |
| | | def movetochapters(path, outpath, chapter, title, start, end): |
| | | # Creating individual chapters |
| | | |
| | | outfile = "{}/Ch-{}_{}.mp3".format(outpath, chapter, title.replace(' ', '_')) |
| | | outfile = "{}/Ch-{}_{}.mp3".format( |
| | | outpath, chapter, title.replace(' ', '_') |
| | | ) |
| | | command = "ffmpeg -loglevel error {} -i \"{}\" -ss {} -to {} -codec:a copy -metadata 'track={}' \"{}\"".format(stats, path, |
| | | start, end, |
| | | chapter, outfile) |
| | |
| | | def getcorrectkey(): |
| | | # request the key for the checksum |
| | | try: |
| | | r = requests.post('http://prod-faas-gw.darkurthe.net:8080/function/checkkey', metadata['checksum'], verify=False, timeout=None) |
| | | r = requests.post('http://faas.darkurthe.net/function/checkkey', |
| | | metadata['checksum'], verify=False, timeout=None) |
| | | return r.text.strip() |
| | | except requests.exceptions.HTTPError as err: |
| | | raise err |
| | | return None |
| | | |
| | | def findalbumbyname_stub(album): |
| | | return False |
| | | |
| | | |
| | | for rfile in glob.glob(args.filename): |
| | | if rfile.find("aax") != -1 and os.path.isfile(rfile): |
| | | metadata = getmetadata(rfile) |
| | | album = getmetadatatags('album') |
| | | # See if we got it already |
| | | if not findalbumbyname(album): |
| | | artist = normalize_data(getmetadatatags('artist')) |
| | | title = normalize_data(getmetadatatags('title')) |
| | | act_byte = getcorrectkey() |
| | | if act_byte is None: |
| | | sys.exit("Can't continue with this file {rfile}") |
| | | else: |
| | | ddir = "%s/%s/%s" % (path, artist, title) |
| | | single_file_path = "/processing/%s.mp3" % (title) |
| | | if not os.path.exists(ddir): |
| | | os.makedirs(ddir) |
| | | print(ddir) |
| | | reencode(rfile, single_file_path) |
| | | if mode == 'chapter': |
| | | chapter = 0 |
| | | numchapters = getchaptercount() |
| | | while (numchapters > 0): |
| | | cstart = getchaptermetadata(chapter, 'start_time') |
| | | cend = getchaptermetadata(chapter, 'end_time') |
| | | chapter += 1 |
| | | numchapters -= 1 |
| | | schap = str(chapter).zfill(2) |
| | | movetochapters(single_file_path, ddir, schap, title, cstart, cend) |
| | | os.remove(single_file_path) |
| | | getcoverart(rfile, ddir) |
| | | if args.filename.find("aax"): |
| | | rfile = args.filename |
| | | metadata = getmetadata(rfile) |
| | | album = getmetadatatags('album') |
| | | # See if we got it already |
| | | if not findalbumbyname(album): |
| | | artist = normalize_data(getmetadatatags('artist')) |
| | | title = normalize_data(getmetadatatags('title')) |
| | | act_byte = getcorrectkey() |
| | | if act_byte is None or act_byte == '': |
| | | sys.exit(f"Can't continue with this file {rfile}") |
| | | else: |
| | | print('We have that book already') |
| | | ddir = "%s/%s/%s" % (path, artist, title) |
| | | single_file_path = "/processing/%s.mp3" % (title) |
| | | if not os.path.exists(ddir): |
| | | os.makedirs(ddir) |
| | | print(ddir) |
| | | reencode(rfile, single_file_path) |
| | | if mode == 'chapter': |
| | | chapter = 0 |
| | | numchapters = getchaptercount() |
| | | while (numchapters > 0): |
| | | cstart = getchaptermetadata(chapter, 'start_time') |
| | | cend = getchaptermetadata(chapter, 'end_time') |
| | | chapter += 1 |
| | | numchapters -= 1 |
| | | schap = str(chapter).zfill(2) |
| | | movetochapters(single_file_path, ddir, schap, title, |
| | | cstart, cend) |
| | | os.remove(single_file_path) |
| | | getcoverart(rfile, ddir) |
| | | else: |
| | | print('We have that book already') |