|
58 | 58 | CONFIG_FILE = None
|
59 | 59 |
|
60 | 60 | # this is the version of the config we EXPECT to find
|
61 |
| -CONFIG_VERSION = 5 |
| 61 | +CONFIG_VERSION = 6 |
62 | 62 |
|
63 | 63 | PROG_DIR = '.'
|
64 | 64 | MY_FULLNAME = None
|
|
267 | 267 | NMJ_MOUNT = None
|
268 | 268 |
|
269 | 269 | USE_SYNOINDEX = False
|
| 270 | +SYNOINDEX_NOTIFY_ONSNATCH = False |
| 271 | +SYNOINDEX_NOTIFY_ONDOWNLOAD = False |
| 272 | +SYNOINDEX_UPDATE_LIBRARY = False |
270 | 273 |
|
271 | 274 | USE_NMJv2 = False
|
272 | 275 | NMJv2_HOST = None
|
@@ -341,7 +344,8 @@ def initialize(consoleLogging=True):
|
341 | 344 | EXTRA_SCRIPTS, USE_TWITTER, TWITTER_USERNAME, TWITTER_PASSWORD, TWITTER_PREFIX, \
|
342 | 345 | USE_BOXCAR, BOXCAR_USERNAME, BOXCAR_PASSWORD, BOXCAR_NOTIFY_ONDOWNLOAD, BOXCAR_NOTIFY_ONSNATCH, \
|
343 | 346 | USE_PUSHOVER, PUSHOVER_USERKEY, PUSHOVER_NOTIFY_ONDOWNLOAD, PUSHOVER_NOTIFY_ONSNATCH, \
|
344 |
| - USE_LIBNOTIFY, LIBNOTIFY_NOTIFY_ONSNATCH, LIBNOTIFY_NOTIFY_ONDOWNLOAD, USE_NMJ, NMJ_HOST, NMJ_DATABASE, NMJ_MOUNT, USE_NMJv2, NMJv2_HOST, NMJv2_DATABASE, NMJv2_DBLOC, USE_SYNOINDEX, \ |
| 347 | + USE_LIBNOTIFY, LIBNOTIFY_NOTIFY_ONSNATCH, LIBNOTIFY_NOTIFY_ONDOWNLOAD, USE_NMJ, NMJ_HOST, NMJ_DATABASE, NMJ_MOUNT, USE_NMJv2, NMJv2_HOST, NMJv2_DATABASE, NMJv2_DBLOC, \ |
| 348 | + USE_SYNOINDEX, SYNOINDEX_NOTIFY_ONSNATCH, SYNOINDEX_NOTIFY_ONDOWNLOAD, SYNOINDEX_UPDATE_LIBRARY, \ |
345 | 349 | USE_LISTVIEW, METADATA_XBMC, METADATA_XBMC_12PLUS, METADATA_MEDIABROWSER, METADATA_MEDE8ER, METADATA_PS3, metadata_provider_dict, \
|
346 | 350 | GIT_PATH, MOVE_ASSOCIATED_FILES, \
|
347 | 351 | COMING_EPS_LAYOUT, COMING_EPS_SORT, COMING_EPS_DISPLAY_PAUSED, METADATA_WDTV, METADATA_TIVO, IGNORE_WORDS, CREATE_MISSING_SHOW_DIRS, \
|
@@ -602,6 +606,9 @@ def initialize(consoleLogging=True):
|
602 | 606 |
|
603 | 607 | CheckSection(CFG, 'Synology')
|
604 | 608 | USE_SYNOINDEX = bool(check_setting_int(CFG, 'Synology', 'use_synoindex', 0))
|
| 609 | + SYNOINDEX_NOTIFY_ONSNATCH = bool(check_setting_int(CFG, 'Synology', 'synoindex_notify_onsnatch', 0)) |
| 610 | + SYNOINDEX_NOTIFY_ONDOWNLOAD = bool(check_setting_int(CFG, 'Synology', 'synoindex_notify_ondownload', 0)) |
| 611 | + SYNOINDEX_UPDATE_LIBRARY = bool(check_setting_int(CFG, 'Synology', 'synoindex_update_library', 0)) |
605 | 612 |
|
606 | 613 | CheckSection(CFG, 'Trakt')
|
607 | 614 | USE_TRAKT = bool(check_setting_int(CFG, 'Trakt', 'use_trakt', 0))
|
@@ -665,55 +672,66 @@ def initialize(consoleLogging=True):
|
665 | 672 | newznabProviderList = providers.getNewznabProviderList(NEWZNAB_DATA)
|
666 | 673 | providerList = providers.makeProviderList()
|
667 | 674 |
|
668 |
| - # initialize schedulars |
669 |
| - currentSearchScheduler = scheduler.Scheduler(searchCurrent.CurrentSearcher(), |
670 |
| - cycleTime=datetime.timedelta(minutes=SEARCH_FREQUENCY), |
671 |
| - threadName="SEARCH", |
672 |
| - runImmediately=True) |
673 |
| - |
674 |
| - # the interval for this is stored inside the ShowUpdater class |
675 |
| - showUpdaterInstance = showUpdater.ShowUpdater() |
676 |
| - showUpdateScheduler = scheduler.Scheduler(showUpdaterInstance, |
677 |
| - cycleTime=showUpdaterInstance.updateInterval, |
678 |
| - threadName="SHOWUPDATER", |
679 |
| - runImmediately=False) |
| 675 | + # initialize schedulers |
680 | 676 |
|
| 677 | + # updaters |
681 | 678 | versionCheckScheduler = scheduler.Scheduler(versionChecker.CheckVersion(),
|
682 |
| - cycleTime=datetime.timedelta(hours=12), |
683 |
| - threadName="CHECKVERSION", |
684 |
| - runImmediately=True) |
| 679 | + cycleTime=datetime.timedelta(hours=12), |
| 680 | + threadName="CHECKVERSION" |
| 681 | + ) |
685 | 682 |
|
686 | 683 | showQueueScheduler = scheduler.Scheduler(show_queue.ShowQueue(),
|
687 |
| - cycleTime=datetime.timedelta(seconds=3), |
688 |
| - threadName="SHOWQUEUE", |
689 |
| - silent=True) |
| 684 | + cycleTime=datetime.timedelta(seconds=3), |
| 685 | + threadName="SHOWQUEUE", |
| 686 | + silent=True) |
690 | 687 |
|
691 |
| - searchQueueScheduler = scheduler.Scheduler(search_queue.SearchQueue(), |
692 |
| - cycleTime=datetime.timedelta(seconds=3), |
693 |
| - threadName="SEARCHQUEUE", |
694 |
| - silent=True) |
| 688 | + showUpdaterInstance = showUpdater.ShowUpdater() # the interval for this is stored inside the class |
| 689 | + showUpdateScheduler = scheduler.Scheduler(showUpdaterInstance, |
| 690 | + cycleTime=showUpdaterInstance.updateInterval, |
| 691 | + threadName="SHOWUPDATER", |
| 692 | + run_delay=showUpdaterInstance.updateInterval, |
| 693 | + silent=True |
| 694 | + ) |
695 | 695 |
|
696 |
| - properFinderInstance = properFinder.ProperFinder() |
697 |
| - properFinderScheduler = scheduler.Scheduler(properFinderInstance, |
698 |
| - cycleTime=properFinderInstance.updateInterval, |
699 |
| - threadName="FINDPROPERS", |
700 |
| - runImmediately=False) |
701 |
| - if not DOWNLOAD_PROPERS: |
702 |
| - properFinderScheduler.silent = True |
| 696 | + # searchers |
| 697 | + searchQueueScheduler = scheduler.Scheduler(search_queue.SearchQueue(), |
| 698 | + cycleTime=datetime.timedelta(seconds=3), |
| 699 | + threadName="SEARCHQUEUE", |
| 700 | + silent=True |
| 701 | + ) |
703 | 702 |
|
704 |
| - autoPostProcesserScheduler = scheduler.Scheduler(autoPostProcesser.PostProcesser(), |
705 |
| - cycleTime=datetime.timedelta(minutes=10), |
706 |
| - threadName="POSTPROCESSER", |
707 |
| - runImmediately=True) |
708 |
| - if not PROCESS_AUTOMATICALLY: |
709 |
| - autoPostProcesserScheduler.silent = True |
| 703 | + currentSearchScheduler = scheduler.Scheduler(searchCurrent.CurrentSearcher(), |
| 704 | + cycleTime=datetime.timedelta(minutes=SEARCH_FREQUENCY), |
| 705 | + threadName="SEARCH", |
| 706 | + run_delay=datetime.timedelta(minutes=5) |
| 707 | + ) |
710 | 708 |
|
711 | 709 | backlogSearchScheduler = searchBacklog.BacklogSearchScheduler(searchBacklog.BacklogSearcher(),
|
712 | 710 | cycleTime=datetime.timedelta(minutes=get_backlog_cycle_time()),
|
713 | 711 | threadName="BACKLOG",
|
714 |
| - runImmediately=True) |
| 712 | + run_delay=datetime.timedelta(minutes=17) |
| 713 | + ) |
| 714 | + |
715 | 715 | backlogSearchScheduler.action.cycleTime = BACKLOG_SEARCH_FREQUENCY
|
716 | 716 |
|
| 717 | + properFinderInstance = properFinder.ProperFinder() # the interval for this is stored inside the class |
| 718 | + properFinderScheduler = scheduler.Scheduler(properFinderInstance, |
| 719 | + cycleTime=properFinderInstance.updateInterval, |
| 720 | + threadName="FINDPROPERS", |
| 721 | + run_delay=properFinderInstance.updateInterval, |
| 722 | + silent=True |
| 723 | + ) |
| 724 | + |
| 725 | + # processors |
| 726 | + autoPostProcesserScheduler = scheduler.Scheduler(autoPostProcesser.PostProcesser(), |
| 727 | + cycleTime=datetime.timedelta(minutes=10), |
| 728 | + threadName="POSTPROCESSER", |
| 729 | + run_delay=datetime.timedelta(minutes=5) |
| 730 | + ) |
| 731 | + |
| 732 | + if not PROCESS_AUTOMATICALLY: |
| 733 | + autoPostProcesserScheduler.silent = True |
| 734 | + |
717 | 735 | showList = []
|
718 | 736 | loadingShowList = {}
|
719 | 737 |
|
@@ -1114,6 +1132,9 @@ def save_config():
|
1114 | 1132 |
|
1115 | 1133 | new_config['Synology'] = {}
|
1116 | 1134 | new_config['Synology']['use_synoindex'] = int(USE_SYNOINDEX)
|
| 1135 | + new_config['Synology']['synoindex_notify_onsnatch'] = int(SYNOINDEX_NOTIFY_ONSNATCH) |
| 1136 | + new_config['Synology']['synoindex_notify_ondownload'] = int(SYNOINDEX_NOTIFY_ONDOWNLOAD) |
| 1137 | + new_config['Synology']['synoindex_update_library'] = int(SYNOINDEX_UPDATE_LIBRARY) |
1117 | 1138 |
|
1118 | 1139 | new_config['NMJv2'] = {}
|
1119 | 1140 | new_config['NMJv2']['use_nmjv2'] = int(USE_NMJv2)
|
|
0 commit comments