cphipps/watchstate
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Made backend:library:mismatch/unmatched for jellyfin/emby blazing fast.

Browse Source
This commit is contained in:
Abdulmhsen B. A. A
2022-06-09 15:01:58 +03:00
parent 9bf33576b9
commit f98685eaac
4 changed files with 37 additions and 74 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/Commands/Backend/Library/MismatchCommand.php
View File

@@ -82,17 +82,21 @@ final class MismatchCommand extends Command
}
try {
$serverOpts = $opts = $list = [];
$backendOpts = $opts = $list = [];
if ($input->getOption('timeout')) {
$serverOpts = ag_set($opts, 'client.timeout', (float)$input->getOption('timeout'));
$backendOpts = ag_set($opts, 'client.timeout', (float)$input->getOption('timeout'));
}
if ($input->getOption('trace')) {
$backendOpts = ag_set($opts, 'options.' . Options::DEBUG_TRACE, true);
}
if ($input->getOption('include-raw-response')) {
$opts[Options::RAW_RESPONSE] = true;
}
foreach ($this->getBackend($backend, $serverOpts)->getLibrary(id: $id, opts: $opts) as $item) {
foreach ($this->getBackend($backend, $backendOpts)->getLibrary(id: $id, opts: $opts) as $item) {
$processed = $this->compare(item: $item, method: $input->getOption('method'));
if (empty($processed) || $processed['percent'] >= (float)$percentage) {

10
src/Commands/Backend/Library/UnmatchedCommand.php
View File

@@ -68,17 +68,21 @@ final class UnmatchedCommand extends Command
}
try {
$serverOpts = $opts = $list = [];
$backendOpts = $opts = $list = [];
if ($input->getOption('timeout')) {
$serverOpts = ag_set($opts, 'client.timeout', (float)$input->getOption('timeout'));
$backendOpts = ag_set($opts, 'client.timeout', (float)$input->getOption('timeout'));
}
if ($input->getOption('trace')) {
$backendOpts = ag_set($opts, 'options.' . Options::DEBUG_TRACE, true);
}
if ($input->getOption('include-raw-response')) {
$opts[Options::RAW_RESPONSE] = true;
}
foreach ($this->getBackend($backend, $serverOpts)->getLibrary(id: $id, opts: $opts) as $item) {
foreach ($this->getBackend($backend, $backendOpts)->getLibrary(id: $id, opts: $opts) as $item) {
if (true === $showAll) {
$list[] = $item;
continue;

81
src/Libs/Servers/JellyfinServer.php
View File

@@ -669,9 +669,10 @@ class JellyfinServer implements ServerInterface
$url = $this->url->withPath(sprintf('/Users/%s/items/', $this->user))->withQuery(
http_build_query(
[
'Recursive' => 'false',
'recursive' => 'false',
'enableUserData' => 'false',
'enableImages' => 'false',
'fields' => implode(',', self::FIELDS),
]
)
);
@@ -742,6 +743,7 @@ class JellyfinServer implements ServerInterface
'enableImages' => 'false',
'excludeLocationTypes' => 'Virtual',
'include' => 'Series,Movie',
'fields' => implode(',', self::FIELDS)
]
)
);
@@ -770,10 +772,16 @@ class JellyfinServer implements ServerInterface
$url = $this->url->withPath(sprintf('/Users/%s/items/%s', $this->user, ag($item, 'Id')));
$possibleTitlesList = ['Name', 'OriginalTitle', 'SortName', 'ForcedSortName'];
$this->logger->debug('Processing [%(backend)] %(item.type) [%(item.title) (%(item.year))] response.', [
$data = [
'backend' => $this->getName(),
...$context,
]);
];
if (true === ag($this->options, Options::DEBUG_TRACE)) {
$data['trace'] = $item;
}
$this->logger->debug('Processing [%(backend)] %(item.type) [%(item.title) (%(item.year))].', $data);
$metadata = [
'id' => ag($item, 'Id'),
@@ -842,8 +850,6 @@ class JellyfinServer implements ServerInterface
]
);
$requests = [];
foreach ($it as $entity) {
if ($entity instanceof DecodingError) {
$this->logger->warning(
@@ -860,6 +866,7 @@ class JellyfinServer implements ServerInterface
continue;
}
$url = $this->url->withPath(sprintf('/Users/%s/items/%s', $this->user, ag($entity, 'Id')));
$context['item'] = [
@@ -870,66 +877,7 @@ class JellyfinServer implements ServerInterface
'url' => (string)$url,
];
$this->logger->debug('Requesting [%(backend)] %(item.type) [%(item.title) (%(item.year))] metadata.', [
'backend' => $this->getName(),
...$context,
]);
$requests[] = $this->http->request(
'GET',
(string)$url,
array_replace_recursive($this->getHeaders(), [
'user_data' => [
'context' => $context
]
])
);
}
if (empty($requests)) {
throw new RuntimeException(
sprintf(
'No requests were made [%s] library [%s] is empty.',
$this->getName(),
ag($context, 'library.title', $id)
)
);
}
$this->logger->info(
'Requesting [%(total)] items metadata from [%(backend)] library [%(library.title)].',
[
'backend' => $this->getName(),
'total' => number_format(count($requests)),
'library' => ag($context, 'library', []),
]
);
foreach ($requests as $response) {
$requestContext = ag($response->getInfo('user_data'), 'context', []);
if (200 !== $response->getStatusCode()) {
$this->logger->warning(
'Request for [%(backend)] %(item.type) [%(item.title)] metadata returned with unexpected [%(status_code)] status code.',
[
'backend' => $this->getName(),
'status_code' => $response->getStatusCode(),
...$requestContext
]
);
continue;
}
$json = json_decode(
json: $response->getContent(),
associative: true,
flags: JSON_THROW_ON_ERROR | JSON_INVALID_UTF8_IGNORE
);
yield $handleRequest(
item: $json,
context: $requestContext,
);
yield $handleRequest(item: $entity, context: $context);
}
}
@@ -1574,9 +1522,10 @@ class JellyfinServer implements ServerInterface
$url = $this->url->withPath(sprintf('/Users/%s/items/', $this->user))->withQuery(
http_build_query(
[
'Recursive' => 'false',
'recursive' => 'false',
'enableUserData' => 'false',
'enableImages' => 'false',
'fields' => implode(',', self::FIELDS),
]
)
);

10
src/Libs/Servers/PlexServer.php
View File

@@ -742,10 +742,16 @@ class PlexServer implements ServerInterface
$url = $this->url->withPath(sprintf('/library/metadata/%d', ag($item, 'ratingKey')));
$possibleTitlesList = ['title', 'originalTitle', 'titleSort'];
$this->logger->debug('Processing [%(backend)] %(item.type) [%(item.title) (%(item.year))] response.', [
$data = [
'backend' => $this->getName(),
...$context,
]);
];
if (true === ag($this->options, Options::DEBUG_TRACE)) {
$data['trace'] = $item;
}
$this->logger->debug('Processing [%(backend)] %(item.type) [%(item.title) (%(item.year))].', $data);
$metadata = [
'id' => (int)ag($item, 'ratingKey'),