open-source-mirrors
/
syncarr
mirror of https://github.com/syncarr/syncarr
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

automated commit 27/01/2020 12:32:07

Browse Source
pull/21/head
Leonardo Merza 4 years ago
parent e0bf9490a2
commit c847b82caf
2 changed files with 29 additions and 37 deletions
Show Stats Download Patch File Download Diff File

20
config.py
Unescape View File

@ -9,13 +9,17 @@ import configparser
DEV = os.environ.get('DEV')
VER = '1.7.1'
VER = '1.7.2'
DEBUG_LINE = '-' * 20
V1_API_PATH = 'v1/'
V2_API_PATH = ''
V3_API_PATH = 'v3/'
# https://github.com/lidarr/Lidarr/wiki/Artist
# https://github.com/Radarr/Radarr/wiki/API:Movie
# https://github.com/Sonarr/Sonarr/wiki/Series
########################################################################################################################
# get docker based ENV vars
is_in_docker = os.environ.get('IS_IN_DOCKER')
@ -221,7 +225,6 @@ tested_api_version = False # only get api version once
api_content_path = '' # url path to add content
api_search_path = '' # url path to search for content on RSS feeds
api_profile_path = '' # url path to get quality profiles
api_status_path = '' # url path to check on server status
api_language_path = '' # url to get lanaguge profiles
@ -251,7 +254,6 @@ if radarrA_url and radarrB_url:
api_version = V2_API_PATH # radarr v2 doesnt have version in api url
api_content_path = 'movie'
api_search_path = 'command'
api_profile_path = 'profile'
api_status_path = 'system/status'
@ -277,7 +279,6 @@ elif lidarrA_url and lidarrB_url:
api_version = V1_API_PATH
api_content_path = 'artist'
api_search_path = 'command'
api_profile_path = 'qualityprofile'
api_status_path = 'system/status'
@ -307,7 +308,6 @@ elif sonarrA_url and sonarrB_url:
api_version = V3_API_PATH # for sonarr try v3 first
api_content_path = 'series'
api_search_path = 'command'
api_profile_path = 'qualityprofile'
api_status_path = 'system/status'
api_language_path = 'languageprofile'
@ -354,11 +354,6 @@ def get_content_path(instance_url, key):
logger.debug('get_content_path: {}'.format(url))
return url
def get_search_path(instance_url, key):
url = get_path(instance_url, api_search_path, key)
logger.debug('get_search_path: {}'.format(url))
return url
def get_language_path(instance_url, key):
url = get_path(instance_url, api_language_path, key)
logger.debug('get_language_path: {}'.format(url))
@ -381,7 +376,6 @@ logger.debug({
'instanceB_path': instanceB_path,
'api_content_path': api_content_path,
'api_profile_path': api_profile_path,
'api_search_path': api_search_path,
'api_language_path': api_language_path,
'is_sonarr': is_sonarr,
'is_lidarr': is_lidarr,
@ -409,10 +403,6 @@ if not api_content_path:
logger.error('missing api_content_path')
sys.exit(0)
if not api_search_path:
logger.error('missing api_search_path')
sys.exit(0)
if not content_id_key:
logger.error('missing content_id_key')
sys.exit(0)

46
index.py
Unescape View File

@ -18,7 +18,7 @@ from config import (
instanceB_language_id, instanceB_language,
content_id_key, logger, is_sonarr, is_radarr, is_lidarr,
get_status_path, get_content_path, get_search_path, get_profile_path, get_language_path,
get_status_path, get_content_path, get_profile_path, get_language_path,
is_in_docker, instance_sync_interval_seconds,
sync_bidirectionally, auto_search, monitor_new_content,
@ -27,7 +27,7 @@ from config import (
def get_new_content_payload(content, instance_path, instance_profile_id, instance_url, instance_language_id=None):
global monitor_new_content
global monitor_new_content, auto_search
images = content.get('images')
for image in images:
@ -45,6 +45,9 @@ def get_new_content_payload(content, instance_path, instance_profile_id, instanc
'images': images,
}
add_options = content.get('addOptions', {})
search_missing = True if auto_search else False
if is_sonarr:
payload['title'] = content.get('title')
payload['titleSlug'] = content.get('titleSlug')
@ -57,19 +60,32 @@ def get_new_content_payload(content, instance_path, instance_profile_id, instanc
payload['tags'] = content.get('tags')
payload['seriesType'] = content.get('seriesType')
payload['useSceneNumbering'] = content.get('useSceneNumbering')
payload['addOptions'] = content.get('addOptions')
payload['addOptions'] = {
**add_options,
**{'searchForMissingEpisodes': search_missing}
}
elif is_radarr:
payload['title'] = content.get('title')
payload['year'] = content.get('year')
payload['tmdbId'] = content.get('tmdbId')
payload['titleSlug'] = content.get('titleSlug')
payload['addOptions'] = {
**add_options,
**{'searchForMovie': search_missing}
}
elif is_lidarr:
payload['artistName'] = content.get('artistName')
payload['addOptions'] = content.get('addOptions', {})
payload['albumFolder'] = content.get('albumFolder')
payload['metadataProfileId'] = content.get('metadataProfileId')
payload['addOptions'] = {
**add_options,
**{
"monitor": monitored,
"searchForMissingAlbums": search_missing
}
}
logger.debug(payload)
return payload
@ -139,19 +155,9 @@ def get_language_from_id(instance_session, instance_url, instance_key, instance_
return instance_language_id
def search_synced(search_ids, instance_search_url, instance_session):
# now that we've synced all contents search for the newly synced contents
instance_search_url = get_search_path(instanceA_url, instanceA_key)
if len(search_ids):
payload = { 'name': 'contentsSearch', 'contentIds': search_ids }
instance_session.post(instance_search_url, data=json.dumps(payload))
def sync_servers(instanceA_contents, instanceB_language_id, instanceB_contentIds,
instanceB_path, instanceB_profile_id, instanceB_session,
instanceB_url, profile_filter_id, instanceB_key):
global auto_search
search_ids = []
# if given instance A profile id then we want to filter out content without that id
@ -167,7 +173,7 @@ def sync_servers(instanceA_contents, instanceB_language_id, instanceB_contentIds
if profile_filter_id != content.get('qualityProfileId'): continue
title = content.get('title') or content.get('artistName')
logging.info('syncing content title "{0}"'.format(title))
logging.info(f'syncing content title "title"')
# get the POST payload and sync content to instance B
payload = get_new_content_payload(
@ -180,9 +186,9 @@ def sync_servers(instanceA_contents, instanceB_language_id, instanceB_contentIds
instanceB_content_url = get_content_path(instanceB_url, instanceB_key)
sync_response = instanceB_session.post(instanceB_content_url, data=json.dumps(payload))
# check respons and save content id for searching later on if success
# check response and save content id for searching later on if success
if sync_response.status_code != 201 and sync_response.status_code != 200:
logger.error('server sync error for {} - response {}'.format(title, sync_response.status_code))
logger.error(f'server sync error for {title} - response {sync_response.status_code}')
else:
try:
search_ids.append(int(sync_response.json()['id']))
@ -190,11 +196,7 @@ def sync_servers(instanceA_contents, instanceB_language_id, instanceB_contentIds
logger.error(f'Could not decode sync response from {instanceB_content_url}')
logging.info('content title "{0}" synced successfully'.format(title))
logging.info('{0} contents synced successfully'.format(len(search_ids)))
instanceB_search_url = get_search_path(instanceB_url, instanceB_key)
if auto_search:
search_synced(search_ids, instanceB_search_url, instanceB_session)
logging.info(f'{len(search_ids)} contents synced successfully')
def get_instance_contents(instance_url, instance_key, instance_session, instance_name=''):

Write Preview
Loading…
Cancel
Save