Skip to content

Commit

Permalink
fix: 🐛 only request thumb when it exists
Browse files Browse the repository at this point in the history
remove unused  Queue functions; use 3rd match group for author name sort
  • Loading branch information
djdembeck committed Oct 3, 2021
1 parent e6e616b commit 498bbb3
Showing 1 changed file with 19 additions and 48 deletions.
67 changes: 19 additions & 48 deletions Contents/Code/__init__.py
@@ -1,7 +1,6 @@
# Audnexus Agent
# coding: utf-8
import json
import Queue
import re
# Import internal tools
from logging import Logging
Expand Down Expand Up @@ -265,15 +264,22 @@ def compile_metadata(self, helper):
'^(.+?).([^\s,]+)(,?.(?:[JS]r\.?|III?|IV))?$',
helper.name,
)
helper.metadata.title_sort = (
split_author_surname.group(2) + ', ' +
split_author_surname.group(1)
helper.metadata.title_sort = ', '.join(
filter(
None,
[
(split_author_surname.group(2) + ', ' +
split_author_surname.group(1)),
split_author_surname.group(3)
]
)
)
# Thumb.
if helper.thumb not in helper.metadata.posters or helper.force:
helper.metadata.posters[helper.thumb] = Proxy.Media(
HTTP.Request(helper.thumb, timeout=15), sort_order=0
)
if helper.thumb:
if helper.thumb not in helper.metadata.posters or helper.force:
helper.metadata.posters[helper.thumb] = Proxy.Media(
HTTP.Request(helper.thumb, timeout=15), sort_order=0
)

helper.writeInfo()

Expand All @@ -294,22 +300,6 @@ def hasProxy(self):
def makeProxyUrl(self, url, referer):
return Prefs['imageproxyurl'] + ('?url=%s&referer=%s' % (url, referer))

def worker(self, queue, stoprequest):
while not stoprequest.isSet():
try:
func, args, kargs = queue.get(True, 0.05)
try:
func(*args, **kargs)
except Exception as e:
log.error(e)
queue.task_done()
except Queue.Empty:
continue

def addTask(self, queue, func, *args, **kargs):
queue.put((func, args, kargs))


class AudiobookAlbum(Agent.Album):
name = 'Audnexus Agent'
languages = [
Expand Down Expand Up @@ -710,10 +700,11 @@ def compile_metadata(self, helper):
if not helper.metadata.summary or helper.force:
helper.metadata.summary = helper.synopsis
# Thumb.
if helper.thumb not in helper.metadata.posters or helper.force:
helper.metadata.posters[helper.thumb] = Proxy.Media(
HTTP.Request(helper.thumb, timeout=15), sort_order=0
)
if helper.thumb:
if helper.thumb not in helper.metadata.posters or helper.force:
helper.metadata.posters[helper.thumb] = Proxy.Media(
HTTP.Request(helper.thumb, timeout=15), sort_order=0
)
# Rating.
# We always want to refresh the rating
if helper.rating:
Expand Down Expand Up @@ -790,26 +781,6 @@ def hasProxy(self):
def makeProxyUrl(self, url, referer):
return Prefs['imageproxyurl'] + ('?url=%s&referer=%s' % (url, referer))

"""
Queueing functions
"""

def worker(self, queue, stoprequest):
while not stoprequest.isSet():
try:
func, args, kargs = queue.get(True, 0.05)
try:
func(*args, **kargs)
except Exception as e:
log.error(e)
queue.task_done()
except Queue.Empty:
continue

def addTask(self, queue, func, *args, **kargs):
queue.put((func, args, kargs))


# Common helpers
def json_decode(output):
try:
Expand Down

0 comments on commit 498bbb3

Please sign in to comment.