78 Commits

Author SHA1 Message Date
Luigi311
fd64088bde Merge pull request #51 from luigi311/dev
Add sync direction flags, seperate out functions, better logging for jellyfin queries
2023-03-09 12:52:24 -07:00
Luigi311
7832e41a3b Add sync from to to readme 2023-03-09 01:32:27 -07:00
Luigi311
cadd65d69b Update issue templates (#50)
* Update issue templates
2023-03-09 01:29:11 -07:00
Luigi311
9f004797fc Force format on save in vscode 2023-03-09 00:53:07 -07:00
Luigi311
9041fee7ad Format 2023-03-09 00:48:29 -07:00
Luigi311
9af6c9057c Simplify plex update_user_watched 2023-03-09 00:36:55 -07:00
Luigi311
757ce91138 Merge pull request #49 from luigi311/seperate_functions
Seperate functions
2023-03-08 23:55:53 -07:00
Luigi311
98f96ed5c7 Fix user being added when shouldnt. Add test_users 2023-03-08 23:48:54 -07:00
Luigi311
3e15120e2a Fix library whitelist, add library tests 2023-03-08 23:17:54 -07:00
Luigi311
5824e6c0cc cleanup 2023-03-08 22:21:40 -07:00
Luigi311
7087d75efb Fix exception 2023-03-08 22:15:03 -07:00
Luigi311
b2a06b8fd3 Add tests for black_white and watched 2023-03-08 22:05:32 -07:00
Luigi311
1ee055faf5 format 2023-03-08 22:05:32 -07:00
Luigi311
404089dfca Seperate generate_library_guids_dict 2023-03-08 22:05:32 -07:00
Luigi311
ed24948dee Better logging on library skip 2023-03-08 22:05:32 -07:00
Luigi311
1f16fcb8eb Seperate check_skip_logic, append reasons 2023-03-08 22:05:32 -07:00
Luigi311
03de3affd7 Cleanup, seperate black/white lists setup 2023-03-08 22:05:32 -07:00
Luigi311
2bad887659 Seperate out functions to seperate scripts. 2023-03-08 22:04:48 -07:00
Luigi311
796be47a63 Move lots of setup_users to functions 2023-03-08 22:03:48 -07:00
Luigi311
dc1fe11590 Check for response status 200 on jellyfin query 2023-03-08 21:49:56 -07:00
Luigi311
13b4ff3215 Merge pull request #48 from JChris246/main
[Feature] Add flags to control the direction of syncing between the servers
2023-03-08 20:46:57 -07:00
JChris246
dca54cf4fb feat:add flags to control the direction of syncing 2023-03-08 21:30:28 -04:00
Luigi311
a4365e59f3 Merge pull request #44 from luigi311/dev
Fix issues with certain libraries failing
2023-02-26 13:32:26 -07:00
Luigi311
b960bccb86 Plex: Fix guids error on mark 2023-02-25 18:42:07 -07:00
Luigi311
218037200c Jellyfin: Fix tv show searching for watched 2023-02-25 18:27:01 -07:00
Luigi311
4ac670e837 Plex: Do not error if guids can not be gathered. Parallelize show processing for get watched. 2023-02-25 16:58:57 -07:00
Luigi311
96eff65c3e Do not error if failed to get library watched 2023-02-25 15:03:27 -07:00
Luigi311
45471607c8 Merge pull request #43 from JChris246/chore/spelling
Correct some spelling issues
2023-02-22 09:51:42 -07:00
JChris246
14885744b1 fix: correct some spelling issues 2023-02-22 00:09:30 -04:00
Luigi311
d1fd61f1d1 Merge pull request #38 from luigi311/dev
Fix issue with nested folders
2023-01-31 16:27:54 -07:00
Luigi311
6c1ee4a7dc Log server users 2023-01-30 11:56:27 -07:00
Luigi311
9a8e799e68 Recursive all the things. Use includeItemType 2023-01-30 11:46:12 -07:00
Luigi311
ffec4e2f28 Support multiple library types 2023-01-28 16:33:36 -07:00
Luigi311
00102891a5 Catch None for types 2023-01-27 23:45:03 -07:00
Luigi311
aa76b83428 Use isinstance instead of type 2023-01-27 12:21:38 -07:00
Luigi311
a644189ea5 Use isinstance instead of type 2023-01-27 12:18:15 -07:00
Luigi311
c5d987a8c9 Update .env.sample and README 2023-01-27 11:23:58 -07:00
Luigi311
bdd68ad68d If user is type str get plex object 2023-01-27 11:02:15 -07:00
Luigi311
2d86bca781 Update github actions 2023-01-27 10:48:52 -07:00
Luigi311
1b01ff6ec2 Log if multiple types and continue instead of error 2023-01-27 10:45:46 -07:00
Luigi311
f08ec43507 Skip library before erroring for multiple types. 2023-01-27 10:43:50 -07:00
Luigi311
7f9424260a Format 2023-01-26 14:03:13 -07:00
Luigi311
5f21943353 Exclude folders, use recursive. 2023-01-26 13:55:50 -07:00
Luigi311
a5a795f43c Exclude Folders from list 2023-01-26 13:42:35 -07:00
Luigi311
fcb6d7625f Fix invalid library types, raise mixed types 2023-01-26 13:31:57 -07:00
Luigi311
fd2179998f Fix ssl_bypass for plex 2023-01-26 11:23:47 -07:00
Luigi311
654e7f20e1 Merge pull request #33 from luigi311/dev
Lots of fixes and simplification
2022-12-23 23:13:22 -07:00
Luigi311
1eb92cf7c1 black formatting 2022-12-23 23:11:38 -07:00
Luigi311
111e284cc8 Cleanup 2022-12-23 23:10:51 -07:00
Luigi311
1a4e3f4ec4 Move setup_black_white_list to functions. Fix trailing slash on jellyfin baseurl 2022-12-23 23:02:53 -07:00
Luigi311
4066228e57 Add more debug logging. Do not enable debug by default 2022-12-19 14:07:56 -07:00
Luigi311
59c6d278e3 Add more logging to debug 2022-12-19 13:57:20 -07:00
Luigi311
39b33f3d43 Fix missing logging when using debug level 2022-12-19 13:22:42 -07:00
Luigi311
e8faf52b2b Do not mark shows/movies that do not exist 2022-12-19 01:35:16 -07:00
Luigi311
370e9bac63 change get user watched name to avoid mistakes 2022-12-18 22:39:03 -07:00
Luigi311
d0746cec5a Fix server 2 always running async runner. Speedup plex get watched 2022-12-18 22:27:42 -07:00
Luigi311
251937431b Move cleanup_watched to functions and simplify 2022-12-18 01:50:45 -07:00
Luigi311
50faf061af Remove dockerfile defaults 2022-11-21 18:21:29 -07:00
Luigi311
9ffbc49ad3 Merge pull request #30 from luigi311/dev
Add ssl_bypass to skip hostname validation.
2022-11-21 17:39:00 -07:00
Luigi311
644dc8e3af Merge pull request #29 from lgtm-migrator/codeql
Add CodeQL workflow for GitHub code scanning
2022-11-21 17:38:45 -07:00
Luigi311
47bc4e94dc Fix dockerfile 2022-11-21 17:31:47 -07:00
LGTM Migrator
f17d39fe17 Add CodeQL workflow for GitHub code scanning 2022-11-10 14:41:07 +00:00
Luigi311
966dcacf8d Add ssl_bypass to skip hostname validation. 2022-09-25 14:16:01 -06:00
Luigi311
9afc00443c Merge pull request #27 from luigi311/dev
Cleanup issues
2022-08-18 00:46:00 -06:00
Luigi311
3ec177ea64 rename test_main 2022-08-18 00:17:32 -06:00
Luigi311
b360c9fd0b Remove unnecessary deepcopy 2022-08-18 00:15:42 -06:00
Luigi311
1ed791b1ed Fix jellyfin 2022-08-17 23:49:05 -06:00
Luigi311
f19b1a3063 Cleanup length and functions instead of methods 2022-08-17 23:34:45 -06:00
Luigi311
190a72bd3c Cleanup 2022-08-17 22:53:27 -06:00
Luigi311
c848106ce7 Black cleanup 2022-08-17 22:31:23 -06:00
Luigi311
dd319271bd Cleanup 2022-08-17 22:09:11 -06:00
Luigi311
16879cc728 Merge pull request #26 from luigi311/dev
Use async for jellyfin
2022-08-17 21:49:34 -06:00
Luigi311
942ec3533f Cleanup log file on runs 2022-08-17 21:43:51 -06:00
Luigi311
9f6edfc91a Merge branch 'main' into dev 2022-08-17 21:40:25 -06:00
Luigi311
827ace2e97 cleanup 2022-08-17 21:20:28 -06:00
Luigi311
f6b57a1b4d Update README.md 2022-07-10 01:38:42 -06:00
Luigi311
88a7526721 Use async for jellyfin (#23)
* Use async

* Massive jellyfin watched speedup

Co-authored-by: Luigi311 <luigi311.lg@gmail.com>
2022-07-10 01:30:12 -06:00
luigi311
1efb4d8543 Fix debug 2022-07-06 17:22:35 -06:00
29 changed files with 4482 additions and 2530 deletions

View File

@@ -1,42 +1,74 @@
## Do not mark any shows/movies as played and instead just output to log if they would of been marked. # Global Settings
DRYRUN = "True"
## Additional logging information ## Do not mark any shows/movies as played and instead just output to log if they would of been marked.
DEBUG = "True" DRYRUN = "True"
## Debugging level, "info" is default, "debug" is more verbose
DEBUG_LEVEL = "info" ## Additional logging information
## How often to run the script in seconds DEBUG = "False"
SLEEP_DURATION = "3600"
## Log file where all output will be written to ## Debugging level, "info" is default, "debug" is more verbose
LOGFILE = "log.log" DEBUG_LEVEL = "info"
## Map usernames between plex and jellyfin in the event that they are different, order does not matter
#USER_MAPPING = { "testuser2": "testuser3" } ## How often to run the script in seconds
## Map libraries between plex and jellyfin in the even that they are different, order does not matter SLEEP_DURATION = "3600"
#LIBRARY_MAPPING = { "Shows": "TV Shows" }
## Log file where all output will be written to
LOGFILE = "log.log"
## Recommended to use token as it is faster to connect as it is direct to the server instead of going through the plex servers
## URL of the plex server, use hostname or IP address if the hostname is not resolving correctly ## Map usernames between servers in the event that they are different, order does not matter
## Comma seperated list for multiple servers ## Comma separated for multiple options
PLEX_BASEURL = "http://localhost:32400" #USER_MAPPING = { "testuser2": "testuser3", "testuser1":"testuser4" }
## Plex token https://support.plex.tv/articles/204059436-finding-an-authentication-token-x-plex-token/
PLEX_TOKEN = "SuperSecretToken" ## Map libraries between servers in the even that they are different, order does not matter
## If not using plex token then use username and password of the server admin along with the servername ## Comma separated for multiple options
#PLEX_USERNAME = "" #LIBRARY_MAPPING = { "Shows": "TV Shows", "Movie": "Movies" }
#PLEX_PASSWORD = ""
#PLEX_SERVERNAME = "Plex Server" ## Blacklisting/Whitelisting libraries, library types such as Movies/TV Shows, and users. Mappings apply so if the mapping for the user or library exist then both will be excluded.
## Comma separated for multiple options
#BLACKLIST_LIBRARY = ""
## Jellyfin server URL, use hostname or IP address if the hostname is not resolving correctly #WHITELIST_LIBRARY = ""
## Comma seperated list for multiple servers #BLACKLIST_LIBRARY_TYPE = ""
JELLYFIN_BASEURL = "http://localhost:8096" #WHITELIST_LIBRARY_TYPE = ""
## Jellyfin api token, created manually by logging in to the jellyfin server admin dashboard and creating an api key #BLACKLIST_USERS = ""
JELLYFIN_TOKEN = "SuperSecretToken" WHITELIST_USERS = "testuser1,testuser2"
## Blacklisting/Whitelisting libraries, library types such as Movies/TV Shows, and users. Mappings apply so if the mapping for the user or library exist then both will be excluded.
#BLACKLIST_LIBRARY = "" # Plex
#WHITELIST_LIBRARY = ""
#BLACKLIST_LIBRARY_TYPE = "" ## Recommended to use token as it is faster to connect as it is direct to the server instead of going through the plex servers
#WHITELIST_LIBRARY_TYPE = "" ## URL of the plex server, use hostname or IP address if the hostname is not resolving correctly
#BLACKLIST_USERS = "" ## Comma separated list for multiple servers
WHITELIST_USERS = "testuser1,testuser2" PLEX_BASEURL = "http://localhost:32400, https://nas:32400"
## Plex token https://support.plex.tv/articles/204059436-finding-an-authentication-token-x-plex-token/
## Comma separated list for multiple servers
PLEX_TOKEN = "SuperSecretToken, SuperSecretToken2"
## If not using plex token then use username and password of the server admin along with the servername
## Comma separated for multiple options
#PLEX_USERNAME = "PlexUser, PlexUser2"
#PLEX_PASSWORD = "SuperSecret, SuperSecret2"
#PLEX_SERVERNAME = "Plex Server1, Plex Server2"
## Skip hostname validation for ssl certificates.
## Set to True if running into ssl certificate errors
SSL_BYPASS = "False"
## control the direction of syncing. e.g. SYNC_FROM_PLEX_TO_JELLYFIN set to true will cause the updates from plex
## to be updated in jellyfin. SYNC_FROM_PLEX_TO_PLEX set to true will sync updates between multiple plex servers
SYNC_FROM_PLEX_TO_JELLYFIN = "True"
SYNC_FROM_JELLYFIN_TO_PLEX = "True"
SYNC_FROM_PLEX_TO_PLEX = "True"
SYNC_FROM_JELLYFIN_TO_JELLYFIN = "True"
# Jellyfin
## Jellyfin server URL, use hostname or IP address if the hostname is not resolving correctly
## Comma separated list for multiple servers
JELLYFIN_BASEURL = "http://localhost:8096, http://nas:8096"
## Jellyfin api token, created manually by logging in to the jellyfin server admin dashboard and creating an api key
## Comma separated list for multiple servers
JELLYFIN_TOKEN = "SuperSecretToken, SuperSecretToken2"

31
.github/ISSUE_TEMPLATE/bug_report.md vendored Normal file
View File

@@ -0,0 +1,31 @@
---
name: Bug report
about: Create a report to help us improve
title: "[BUG]"
labels: ''
assignees: ''
---
**Describe the bug**
A clear and concise description of what the bug is.
**To Reproduce**
Steps to reproduce the behavior:
1. Go to '...'
2. Click on '....'
3. Scroll down to '....'
4. See error
**Expected behavior**
A clear and concise description of what you expected to happen.
**Logs**
If applicable, add logs to help explain your problem ideally with DEBUG set to true, be sure to remove sensitive information
**Type:**
- [ ] Docker
- [ ] Native
**Additional context**
Add any other context about the problem here.

View File

@@ -0,0 +1,20 @@
---
name: Feature request
about: Suggest an idea for this project
title: "[Feature Request]"
labels: ''
assignees: ''
---
**Is your feature request related to a problem? Please describe.**
A clear and concise description of what the problem is. Ex. I'm always frustrated when [...]
**Describe the solution you'd like**
A clear and concise description of what you want to happen.
**Describe alternatives you've considered**
A clear and concise description of any alternative solutions or features you've considered.
**Additional context**
Add any other context or screenshots about the feature request here.

View File

@@ -1,86 +1,86 @@
name: CI name: CI
on: on:
push: push:
paths-ignore: paths-ignore:
- .gitignore - .gitignore
- "*.md" - "*.md"
pull_request: pull_request:
paths-ignore: paths-ignore:
- .gitignore - .gitignore
- "*.md" - "*.md"
jobs: jobs:
pytest: pytest:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v3
- name: "Install dependencies" - name: "Install dependencies"
run: pip install -r requirements.txt && pip install -r test/requirements.txt run: pip install -r requirements.txt && pip install -r test/requirements.txt
- name: "Run tests" - name: "Run tests"
run: pytest -vvv run: pytest -vvv
docker: docker:
runs-on: ubuntu-latest runs-on: ubuntu-latest
needs: pytest needs: pytest
steps: steps:
- name: Checkout - name: Checkout
uses: actions/checkout@v2 uses: actions/checkout@v3
- name: Docker meta - name: Docker meta
id: docker_meta id: docker_meta
env: env:
DOCKER_USERNAME: ${{ secrets.DOCKER_USERNAME }} DOCKER_USERNAME: ${{ secrets.DOCKER_USERNAME }}
if: "${{ env.DOCKER_USERNAME != '' }}" if: "${{ env.DOCKER_USERNAME != '' }}"
uses: docker/metadata-action@v4 uses: docker/metadata-action@v4
with: with:
images: ${{ secrets.DOCKER_USERNAME }}/jellyplex-watched # list of Docker images to use as base name for tags images: ${{ secrets.DOCKER_USERNAME }}/jellyplex-watched # list of Docker images to use as base name for tags
tags: | tags: |
type=raw,value=latest,enable={{is_default_branch}} type=raw,value=latest,enable={{is_default_branch}}
type=ref,event=branch type=ref,event=branch
type=ref,event=pr type=ref,event=pr
type=semver,pattern={{version}} type=semver,pattern={{version}}
type=semver,pattern={{major}}.{{minor}} type=semver,pattern={{major}}.{{minor}}
type=sha type=sha
- name: Set up QEMU - name: Set up QEMU
uses: docker/setup-qemu-action@v1 uses: docker/setup-qemu-action@v2
- name: Set up Docker Buildx - name: Set up Docker Buildx
uses: docker/setup-buildx-action@v1 uses: docker/setup-buildx-action@v2
- name: Login to DockerHub - name: Login to DockerHub
if: "${{ steps.docker_meta.outcome == 'success' }}" if: "${{ steps.docker_meta.outcome == 'success' }}"
uses: docker/login-action@v1 uses: docker/login-action@v2
with: with:
username: ${{ secrets.DOCKER_USERNAME }} username: ${{ secrets.DOCKER_USERNAME }}
password: ${{ secrets.DOCKER_TOKEN }} password: ${{ secrets.DOCKER_TOKEN }}
- name: Build - name: Build
id: build id: build
if: "${{ steps.docker_meta.outcome == 'skipped' }}" if: "${{ steps.docker_meta.outcome == 'skipped' }}"
uses: docker/build-push-action@v2 uses: docker/build-push-action@v3
with: with:
context: . context: .
file: ./Dockerfile file: ./Dockerfile
platforms: linux/amd64,linux/arm64 platforms: linux/amd64,linux/arm64
push: false push: false
tags: jellyplex-watched:action tags: jellyplex-watched:action
- name: Build Push - name: Build Push
id: build_push id: build_push
if: "${{ steps.docker_meta.outcome == 'success' }}" if: "${{ steps.docker_meta.outcome == 'success' }}"
uses: docker/build-push-action@v2 uses: docker/build-push-action@v3
with: with:
context: . context: .
file: ./Dockerfile file: ./Dockerfile
platforms: linux/amd64,linux/arm64 platforms: linux/amd64,linux/arm64
push: true push: true
tags: ${{ steps.docker_meta.outputs.tags }} tags: ${{ steps.docker_meta.outputs.tags }}
labels: ${{ steps.docker_meta.outputs.labels }} labels: ${{ steps.docker_meta.outputs.labels }}
# Echo digest so users can validate their image # Echo digest so users can validate their image
- name: Image digest - name: Image digest
if: "${{ steps.docker_meta.outcome == 'success' }}" if: "${{ steps.docker_meta.outcome == 'success' }}"
run: echo "${{ steps.build_push.outputs.digest }}" run: echo "${{ steps.build_push.outputs.digest }}"

41
.github/workflows/codeql.yml vendored Normal file
View File

@@ -0,0 +1,41 @@
name: "CodeQL"
on:
push:
branches: [ "main" ]
pull_request:
branches: [ "main" ]
schedule:
- cron: "23 20 * * 6"
jobs:
analyze:
name: Analyze
runs-on: ubuntu-latest
permissions:
actions: read
contents: read
security-events: write
strategy:
fail-fast: false
matrix:
language: [ python ]
steps:
- name: Checkout
uses: actions/checkout@v3
- name: Initialize CodeQL
uses: github/codeql-action/init@v2
with:
languages: ${{ matrix.language }}
queries: +security-and-quality
- name: Autobuild
uses: github/codeql-action/autobuild@v2
- name: Perform CodeQL Analysis
uses: github/codeql-action/analyze@v2
with:
category: "/language:${{ matrix.language }}"

264
.gitignore vendored
View File

@@ -1,132 +1,132 @@
.env .env
*.prof *.prof
# Byte-compiled / optimized / DLL files # Byte-compiled / optimized / DLL files
__pycache__/ __pycache__/
*.py[cod] *.py[cod]
*$py.class *$py.class
# C extensions # C extensions
*.so *.so
# Distribution / packaging # Distribution / packaging
.Python .Python
build/ build/
develop-eggs/ develop-eggs/
dist/ dist/
downloads/ downloads/
eggs/ eggs/
.eggs/ .eggs/
lib/ lib/
lib64/ lib64/
parts/ parts/
sdist/ sdist/
var/ var/
wheels/ wheels/
pip-wheel-metadata/ pip-wheel-metadata/
share/python-wheels/ share/python-wheels/
*.egg-info/ *.egg-info/
.installed.cfg .installed.cfg
*.egg *.egg
MANIFEST MANIFEST
# PyInstaller # PyInstaller
# Usually these files are written by a python script from a template # Usually these files are written by a python script from a template
# before PyInstaller builds the exe, so as to inject date/other infos into it. # before PyInstaller builds the exe, so as to inject date/other infos into it.
*.manifest *.manifest
*.spec *.spec
# Installer logs # Installer logs
pip-log.txt pip-log.txt
pip-delete-this-directory.txt pip-delete-this-directory.txt
# Unit test / coverage reports # Unit test / coverage reports
htmlcov/ htmlcov/
.tox/ .tox/
.nox/ .nox/
.coverage .coverage
.coverage.* .coverage.*
.cache .cache
nosetests.xml nosetests.xml
coverage.xml coverage.xml
*.cover *.cover
*.py,cover *.py,cover
.hypothesis/ .hypothesis/
.pytest_cache/ .pytest_cache/
# Translations # Translations
*.mo *.mo
*.pot *.pot
# Django stuff: # Django stuff:
*.log *.log
local_settings.py local_settings.py
db.sqlite3 db.sqlite3
db.sqlite3-journal db.sqlite3-journal
# Flask stuff: # Flask stuff:
instance/ instance/
.webassets-cache .webassets-cache
# Scrapy stuff: # Scrapy stuff:
.scrapy .scrapy
# Sphinx documentation # Sphinx documentation
docs/_build/ docs/_build/
# PyBuilder # PyBuilder
target/ target/
# Jupyter Notebook # Jupyter Notebook
.ipynb_checkpoints .ipynb_checkpoints
# IPython # IPython
profile_default/ profile_default/
ipython_config.py ipython_config.py
# pyenv # pyenv
.python-version .python-version
# pipenv # pipenv
# According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control. # According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
# However, in case of collaboration, if having platform-specific dependencies or dependencies # However, in case of collaboration, if having platform-specific dependencies or dependencies
# having no cross-platform support, pipenv may install dependencies that don't work, or not # having no cross-platform support, pipenv may install dependencies that don't work, or not
# install all needed dependencies. # install all needed dependencies.
#Pipfile.lock #Pipfile.lock
# PEP 582; used by e.g. github.com/David-OConnor/pyflow # PEP 582; used by e.g. github.com/David-OConnor/pyflow
__pypackages__/ __pypackages__/
# Celery stuff # Celery stuff
celerybeat-schedule celerybeat-schedule
celerybeat.pid celerybeat.pid
# SageMath parsed files # SageMath parsed files
*.sage.py *.sage.py
# Environments # Environments
.env .env
.venv .venv
env/ env/
venv/ venv/
ENV/ ENV/
env.bak/ env.bak/
venv.bak/ venv.bak/
# Spyder project settings # Spyder project settings
.spyderproject .spyderproject
.spyproject .spyproject
# Rope project settings # Rope project settings
.ropeproject .ropeproject
# mkdocs documentation # mkdocs documentation
/site /site
# mypy # mypy
.mypy_cache/ .mypy_cache/
.dmypy.json .dmypy.json
dmypy.json dmypy.json
# Pyre type checker # Pyre type checker
.pyre/ .pyre/

32
.vscode/launch.json vendored
View File

@@ -1,16 +1,16 @@
{ {
// Use IntelliSense to learn about possible attributes. // Use IntelliSense to learn about possible attributes.
// Hover to view descriptions of existing attributes. // Hover to view descriptions of existing attributes.
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387 // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0", "version": "0.2.0",
"configurations": [ "configurations": [
{ {
"name": "Python: Main", "name": "Python: Main",
"type": "python", "type": "python",
"request": "launch", "request": "launch",
"program": "main.py", "program": "main.py",
"console": "integratedTerminal", "console": "integratedTerminal",
"justMyCode": true "justMyCode": true
} }
] ]
} }

7
.vscode/settings.json vendored Normal file
View File

@@ -0,0 +1,7 @@
{
"[python]" : {
"editor.formatOnSave": true,
},
"python.formatting.provider": "black",
}

View File

@@ -1,35 +1,41 @@
FROM python:3-slim FROM python:3-slim
ENV DRYRUN 'True' ENV DRYRUN 'True'
ENV DEBUG 'True' ENV DEBUG 'True'
ENV DEBUG_LEVEL 'INFO' ENV DEBUG_LEVEL 'INFO'
ENV SLEEP_DURATION '3600' ENV SLEEP_DURATION '3600'
ENV LOGFILE 'log.log' ENV LOGFILE 'log.log'
ENV USER_MAPPING '{ "User Test": "User Test2" }' ENV USER_MAPPING ''
ENV LIBRARY_MAPPING '{ "Shows Test": "TV Shows Test" }' ENV LIBRARY_MAPPING ''
ENV PLEX_BASEURL 'http://localhost:32400' ENV PLEX_BASEURL ''
ENV PLEX_TOKEN '' ENV PLEX_TOKEN ''
ENV PLEX_USERNAME '' ENV PLEX_USERNAME ''
ENV PLEX_PASSWORD '' ENV PLEX_PASSWORD ''
ENV PLEX_SERVERNAME '' ENV PLEX_SERVERNAME ''
ENV JELLYFIN_BASEURL 'http://localhost:8096' ENV JELLYFIN_BASEURL ''
ENV JELLYFIN_TOKEN '' ENV JELLYFIN_TOKEN ''
ENV BLACKLIST_LIBRARY '' ENV BLACKLIST_LIBRARY ''
ENV WHITELIST_LIBRARY '' ENV WHITELIST_LIBRARY ''
ENV BLACKLIST_LIBRARY_TYPE '' ENV BLACKLIST_LIBRARY_TYPE ''
ENV WHITELIST_LIBRARY_TYPE '' ENV WHITELIST_LIBRARY_TYPE ''
ENV BLACKLIST_USERS '' ENV BLACKLIST_USERS ''
ENV WHITELIST_USERS '' ENV WHITELIST_USERS ''
WORKDIR /app WORKDIR /app
COPY ./requirements.txt ./ RUN apt-get update && \
RUN pip install --no-cache-dir -r requirements.txt apt-get install -y --no-install-recommends \
build-essential && \
COPY . . apt-get clean && \
rm -rf /var/lib/apt/lists/*
CMD ["python", "-u", "main.py"]
COPY ./requirements.txt ./
RUN pip install --no-cache-dir -r requirements.txt
COPY . .
CMD ["python", "-u", "main.py"]

1348
LICENSE

File diff suppressed because it is too large Load Diff

222
README.md
View File

@@ -1,73 +1,149 @@
# JellyPlex-Watched # JellyPlex-Watched
[![Codacy Badge](https://app.codacy.com/project/badge/Grade/26b47c5db63942f28f02f207f692dc85)](https://www.codacy.com/gh/luigi311/JellyPlex-Watched/dashboard?utm_source=github.com&amp;utm_medium=referral&amp;utm_content=luigi311/JellyPlex-Watched&amp;utm_campaign=Badge_Grade) [![Codacy Badge](https://app.codacy.com/project/badge/Grade/26b47c5db63942f28f02f207f692dc85)](https://www.codacy.com/gh/luigi311/JellyPlex-Watched/dashboard?utm_source=github.com&amp;utm_medium=referral&amp;utm_content=luigi311/JellyPlex-Watched&amp;utm_campaign=Badge_Grade)
Sync watched between jellyfin and plex Sync watched between jellyfin and plex locally
## Description ## Description
Keep in sync all your users watched history between jellyfin and plex servers locally. This uses the imdb ids and any other matching id to find the correct episode/movie between the two. This is not perfect but it works for most cases. You can use this for as many servers as you want by enterying multiple options in the .env plex/jellyfin section seperated by commas. Keep in sync all your users watched history between jellyfin and plex servers locally. This uses file names and provider ids to find the correct episode/movie between the two. This is not perfect but it works for most cases. You can use this for as many servers as you want by entering multiple options in the .env plex/jellyfin section separated by commas.
## Configuration ## Configuration
```bash
# Global Settings
## Installation
## Do not mark any shows/movies as played and instead just output to log if they would of been marked.
### Baremetal DRYRUN = "True"
- Setup virtualenv of your choice ## Additional logging information
DEBUG = "False"
- Install dependencies
## Debugging level, "info" is default, "debug" is more verbose
```bash DEBUG_LEVEL = "info"
pip install -r requirements.txt
``` ## How often to run the script in seconds
SLEEP_DURATION = "3600"
- Create a .env file similar to .env.sample, uncomment whitelist and blacklist if needed, fill in baseurls and tokens
## Log file where all output will be written to
- Run LOGFILE = "log.log"
```bash ## Map usernames between servers in the event that they are different, order does not matter
python main.py ## Comma separated for multiple options
``` USER_MAPPING = { "testuser2": "testuser3", "testuser1":"testuser4" }
### Docker ## Map libraries between servers in the even that they are different, order does not matter
## Comma separated for multiple options
- Build docker image LIBRARY_MAPPING = { "Shows": "TV Shows", "Movie": "Movies" }
```bash ## Blacklisting/Whitelisting libraries, library types such as Movies/TV Shows, and users. Mappings apply so if the mapping for the user or library exist then both will be excluded.
docker build -t jellyplex-watched . ## Comma separated for multiple options
``` BLACKLIST_LIBRARY = ""
WHITELIST_LIBRARY = ""
- or use pre-built image BLACKLIST_LIBRARY_TYPE = ""
WHITELIST_LIBRARY_TYPE = ""
```bash BLACKLIST_USERS = ""
docker pull luigi311/jellyplex-watched:latest WHITELIST_USERS = "testuser1,testuser2"
```
#### With variables
# Plex
- Run
## Recommended to use token as it is faster to connect as it is direct to the server instead of going through the plex servers
```bash ## URL of the plex server, use hostname or IP address if the hostname is not resolving correctly
docker run --rm -it -e PLEX_TOKEN='SuperSecretToken' luigi311/jellyplex-watched:latest ## Comma separated list for multiple servers
``` PLEX_BASEURL = "http://localhost:32400, https://nas:32400"
#### With .env ## Plex token https://support.plex.tv/articles/204059436-finding-an-authentication-token-x-plex-token/
## Comma separated list for multiple servers
- Create a .env file similar to .env.sample and set the MNEMONIC variable to your seed phrase PLEX_TOKEN = "SuperSecretToken, SuperSecretToken2"
- Run ## If not using plex token then use username and password of the server admin along with the servername
## Comma separated for multiple options
```bash #PLEX_USERNAME = "PlexUser, PlexUser2"
docker run --rm -it -v "$(pwd)/.env:/app/.env" luigi311/jellyplex-watched:latest #PLEX_PASSWORD = "SuperSecret, SuperSecret2"
``` #PLEX_SERVERNAME = "Plex Server1, Plex Server2"
## Contributing ## Skip hostname validation for ssl certificates.
## Set to True if running into ssl certificate errors
I am open to recieving pull requests. If you are submitting a pull request, please make sure run it locally for a day or two to make sure it is working as expected and stable. Make all pull requests against the dev branch and nothing will be merged into the main without going through the lower branches. SSL_BYPASS = "False"
## License
## control the direction of syncing. e.g. SYNC_FROM_PLEX_TO_JELLYFIN set to true will cause the updates from plex
This is currently under the GNU General Public License v3.0. ## to be updated in jellyfin. SYNC_FROM_PLEX_TO_PLEX set to true will sync updates between multiple plex servers
SYNC_FROM_PLEX_TO_JELLYFIN = "True"
SYNC_FROM_JELLYFIN_TO_PLEX = "True"
SYNC_FROM_PLEX_TO_PLEX = "True"
SYNC_FROM_JELLYFIN_TO_JELLYFIN = "True"
# Jellyfin
## Jellyfin server URL, use hostname or IP address if the hostname is not resolving correctly
## Comma separated list for multiple servers
JELLYFIN_BASEURL = "http://localhost:8096, http://nas:8096"
## Jellyfin api token, created manually by logging in to the jellyfin server admin dashboard and creating an api key
## Comma separated list for multiple servers
JELLYFIN_TOKEN = "SuperSecretToken, SuperSecretToken2"
```
## Installation
### Baremetal
- Setup virtualenv of your choice
- Install dependencies
```bash
pip install -r requirements.txt
```
- Create a .env file similar to .env.sample, uncomment whitelist and blacklist if needed, fill in baseurls and tokens
- Run
```bash
python main.py
```
### Docker
- Build docker image
```bash
docker build -t jellyplex-watched .
```
- or use pre-built image
```bash
docker pull luigi311/jellyplex-watched:latest
```
#### With variables
- Run
```bash
docker run --rm -it -e PLEX_TOKEN='SuperSecretToken' luigi311/jellyplex-watched:latest
```
#### With .env
- Create a .env file similar to .env.sample and set the variables to match your setup
- Run
```bash
docker run --rm -it -v "$(pwd)/.env:/app/.env" luigi311/jellyplex-watched:latest
```
## Contributing
I am open to receiving pull requests. If you are submitting a pull request, please make sure run it locally for a day or two to make sure it is working as expected and stable. Make all pull requests against the dev branch and nothing will be merged into the main without going through the lower branches.
## License
This is currently under the GNU General Public License v3.0.

21
main.py
View File

@@ -1,10 +1,11 @@
import sys import sys
if __name__ == '__main__': if __name__ == "__main__":
# Check python version 3.6 or higher # Check python version 3.6 or higher
if not (3, 6) <= tuple(map(int, sys.version_info[:2])): if not (3, 6) <= tuple(map(int, sys.version_info[:2])):
print("This script requires Python 3.6 or higher") print("This script requires Python 3.6 or higher")
sys.exit(1) sys.exit(1)
from src.main import main from src.main import main
main()
main()

View File

@@ -1,3 +1,4 @@
plexapi plexapi
requests requests
python-dotenv python-dotenv
aiohttp

139
src/black_white.py Normal file
View File

@@ -0,0 +1,139 @@
from src.functions import logger, search_mapping
def setup_black_white_lists(
blacklist_library: str,
whitelist_library: str,
blacklist_library_type: str,
whitelist_library_type: str,
blacklist_users: str,
whitelist_users: str,
library_mapping=None,
user_mapping=None,
):
blacklist_library, blacklist_library_type, blacklist_users = setup_black_lists(
blacklist_library,
blacklist_library_type,
blacklist_users,
library_mapping,
user_mapping,
)
whitelist_library, whitelist_library_type, whitelist_users = setup_white_lists(
whitelist_library,
whitelist_library_type,
whitelist_users,
library_mapping,
user_mapping,
)
return (
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
blacklist_users,
whitelist_users,
)
def setup_black_lists(
blacklist_library,
blacklist_library_type,
blacklist_users,
library_mapping=None,
user_mapping=None,
):
if blacklist_library:
if len(blacklist_library) > 0:
blacklist_library = blacklist_library.split(",")
blacklist_library = [x.strip() for x in blacklist_library]
if library_mapping:
temp_library = []
for library in blacklist_library:
library_other = search_mapping(library_mapping, library)
if library_other:
temp_library.append(library_other)
blacklist_library = blacklist_library + temp_library
else:
blacklist_library = []
logger(f"Blacklist Library: {blacklist_library}", 1)
if blacklist_library_type:
if len(blacklist_library_type) > 0:
blacklist_library_type = blacklist_library_type.split(",")
blacklist_library_type = [x.lower().strip() for x in blacklist_library_type]
else:
blacklist_library_type = []
logger(f"Blacklist Library Type: {blacklist_library_type}", 1)
if blacklist_users:
if len(blacklist_users) > 0:
blacklist_users = blacklist_users.split(",")
blacklist_users = [x.lower().strip() for x in blacklist_users]
if user_mapping:
temp_users = []
for user in blacklist_users:
user_other = search_mapping(user_mapping, user)
if user_other:
temp_users.append(user_other)
blacklist_users = blacklist_users + temp_users
else:
blacklist_users = []
logger(f"Blacklist Users: {blacklist_users}", 1)
return blacklist_library, blacklist_library_type, blacklist_users
def setup_white_lists(
whitelist_library,
whitelist_library_type,
whitelist_users,
library_mapping=None,
user_mapping=None,
):
if whitelist_library:
if len(whitelist_library) > 0:
whitelist_library = whitelist_library.split(",")
whitelist_library = [x.strip() for x in whitelist_library]
if library_mapping:
temp_library = []
for library in whitelist_library:
library_other = search_mapping(library_mapping, library)
if library_other:
temp_library.append(library_other)
whitelist_library = whitelist_library + temp_library
else:
whitelist_library = []
logger(f"Whitelist Library: {whitelist_library}", 1)
if whitelist_library_type:
if len(whitelist_library_type) > 0:
whitelist_library_type = whitelist_library_type.split(",")
whitelist_library_type = [x.lower().strip() for x in whitelist_library_type]
else:
whitelist_library_type = []
logger(f"Whitelist Library Type: {whitelist_library_type}", 1)
if whitelist_users:
if len(whitelist_users) > 0:
whitelist_users = whitelist_users.split(",")
whitelist_users = [x.lower().strip() for x in whitelist_users]
if user_mapping:
temp_users = []
for user in whitelist_users:
user_other = search_mapping(user_mapping, user)
if user_other:
temp_users.append(user_other)
whitelist_users = whitelist_users + temp_users
else:
whitelist_users = []
else:
whitelist_users = []
logger(f"Whitelist Users: {whitelist_users}", 1)
return whitelist_library, whitelist_library_type, whitelist_users

View File

@@ -1,155 +1,77 @@
import os import os
from concurrent.futures import ThreadPoolExecutor from concurrent.futures import ThreadPoolExecutor
from dotenv import load_dotenv from dotenv import load_dotenv
load_dotenv(override=True) load_dotenv(override=True)
logfile = os.getenv("LOGFILE","log.log") logfile = os.getenv("LOGFILE", "log.log")
def logger(message: str, log_type=0):
debug = str_to_bool(os.getenv("DEBUG", "True")) def logger(message: str, log_type=0):
debug_level = os.getenv("DEBUG_LEVEL", "info").lower() debug = str_to_bool(os.getenv("DEBUG", "False"))
debug_level = os.getenv("DEBUG_LEVEL", "info").lower()
output = str(message)
if log_type == 0: output = str(message)
pass if log_type == 0:
elif log_type == 1 and (debug or debug_level == "info"): pass
output = f"[INFO]: {output}" elif log_type == 1 and (debug and debug_level in ("info", "debug")):
elif log_type == 2: output = f"[INFO]: {output}"
output = f"[ERROR]: {output}" elif log_type == 2:
elif log_type == 3 and (debug and debug_level == "debug"): output = f"[ERROR]: {output}"
output = f"[DEBUG]: {output}" elif log_type == 3 and (debug and debug_level == "debug"):
else: output = f"[DEBUG]: {output}"
output = None elif log_type == 4:
output = f"[WARNING]: {output}"
if output is not None: else:
print(output) output = None
file = open(logfile, "a", encoding="utf-8")
file.write(output + "\n") if output is not None:
print(output)
# Reimplementation of distutils.util.strtobool due to it being deprecated file = open(logfile, "a", encoding="utf-8")
# Source: https://github.com/PostHog/posthog/blob/01e184c29d2c10c43166f1d40a334abbc3f99d8a/posthog/utils.py#L668 file.write(output + "\n")
def str_to_bool(value: any) -> bool:
if not value:
return False # Reimplementation of distutils.util.strtobool due to it being deprecated
return str(value).lower() in ("y", "yes", "t", "true", "on", "1") # Source: https://github.com/PostHog/posthog/blob/01e184c29d2c10c43166f1d40a334abbc3f99d8a/posthog/utils.py#L668
def str_to_bool(value: any) -> bool:
# Get mapped value if not value:
def search_mapping(dictionary: dict, key_value: str): return False
if key_value in dictionary.keys(): return str(value).lower() in ("y", "yes", "t", "true", "on", "1")
return dictionary[key_value]
elif key_value.lower() in dictionary.keys():
return dictionary[key_value.lower()] # Get mapped value
elif key_value in dictionary.values(): def search_mapping(dictionary: dict, key_value: str):
return list(dictionary.keys())[list(dictionary.values()).index(key_value)] if key_value in dictionary.keys():
elif key_value.lower() in dictionary.values(): return dictionary[key_value]
return list(dictionary.keys())[list(dictionary.values()).index(key_value.lower())] elif key_value.lower() in dictionary.keys():
else: return dictionary[key_value.lower()]
return None elif key_value in dictionary.values():
return list(dictionary.keys())[list(dictionary.values()).index(key_value)]
elif key_value.lower() in dictionary.values():
def check_skip_logic(library_title, library_type, blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, library_mapping): return list(dictionary.keys())[
skip_reason = None list(dictionary.values()).index(key_value.lower())
]
if library_type.lower() in blacklist_library_type: else:
skip_reason = "is blacklist_library_type" return None
if library_title.lower() in [x.lower() for x in blacklist_library]:
skip_reason = "is blacklist_library" def future_thread_executor(args: list, workers: int = -1):
futures_list = []
library_other = None results = []
if library_mapping:
library_other = search_mapping(library_mapping, library_title) if workers == -1:
if library_other: workers = min(32, os.cpu_count() * 2)
if library_other.lower() in [x.lower() for x in blacklist_library]:
skip_reason = "is blacklist_library" with ThreadPoolExecutor(max_workers=workers) as executor:
for arg in args:
if len(whitelist_library_type) > 0: # * arg unpacks the list into actual arguments
if library_type.lower() not in whitelist_library_type: futures_list.append(executor.submit(*arg))
skip_reason = "is not whitelist_library_type"
for future in futures_list:
# if whitelist is not empty and library is not in whitelist try:
if len(whitelist_library) > 0: result = future.result()
if library_title.lower() not in [x.lower() for x in whitelist_library]: results.append(result)
skip_reason = "is not whitelist_library" except Exception as e:
raise Exception(e)
if library_other:
if library_other.lower() not in [x.lower() for x in whitelist_library]: return results
skip_reason = "is not whitelist_library"
return skip_reason
def generate_library_guids_dict(user_list: dict):
show_output_dict = {}
episode_output_dict = {}
movies_output_dict = {}
try:
show_output_keys = user_list.keys()
show_output_keys = ([ dict(x) for x in list(show_output_keys) ])
for show_key in show_output_keys:
for provider_key, provider_value in show_key.items():
# Skip title
if provider_key.lower() == "title":
continue
if provider_key.lower() not in show_output_dict:
show_output_dict[provider_key.lower()] = []
if provider_key.lower() == "locations":
for show_location in provider_value:
show_output_dict[provider_key.lower()].append(show_location)
else:
show_output_dict[provider_key.lower()].append(provider_value.lower())
except:
pass
try:
for show in user_list:
for season in user_list[show]:
for episode in user_list[show][season]:
for episode_key, episode_value in episode.items():
if episode_key.lower() not in episode_output_dict:
episode_output_dict[episode_key.lower()] = []
if episode_key == "locations":
for episode_location in episode_value:
episode_output_dict[episode_key.lower()].append(episode_location)
else:
episode_output_dict[episode_key.lower()].append(episode_value.lower())
except:
pass
try:
for movie in user_list:
for movie_key, movie_value in movie.items():
if movie_key.lower() not in movies_output_dict:
movies_output_dict[movie_key.lower()] = []
if movie_key == "locations":
for movie_location in movie_value:
movies_output_dict[movie_key.lower()].append(movie_location)
else:
movies_output_dict[movie_key.lower()].append(movie_value.lower())
except:
pass
return show_output_dict, episode_output_dict, movies_output_dict
def future_thread_executor(args: list, workers: int = -1):
futures_list = []
results = []
if workers == -1:
workers = min(32, os.cpu_count()*1.25)
with ThreadPoolExecutor(max_workers=workers) as executor:
for arg in args:
# * arg unpacks the list into actual arguments
futures_list.append(executor.submit(*arg))
for future in futures_list:
try:
result = future.result()
results.append(result)
except Exception as e:
raise Exception(e)
return results

File diff suppressed because it is too large Load Diff

212
src/library.py Normal file
View File

@@ -0,0 +1,212 @@
from src.functions import (
logger,
search_mapping,
)
def check_skip_logic(
library_title,
library_type,
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
library_mapping=None,
):
skip_reason = None
library_other = None
if library_mapping:
library_other = search_mapping(library_mapping, library_title)
skip_reason_black = check_blacklist_logic(
library_title,
library_type,
blacklist_library,
blacklist_library_type,
library_other,
)
skip_reason_white = check_whitelist_logic(
library_title,
library_type,
whitelist_library,
whitelist_library_type,
library_other,
)
# Combine skip reasons
if skip_reason_black:
skip_reason = skip_reason_black
if skip_reason_white:
if skip_reason:
skip_reason = skip_reason + " and " + skip_reason_white
else:
skip_reason = skip_reason_white
return skip_reason
def check_blacklist_logic(
library_title,
library_type,
blacklist_library,
blacklist_library_type,
library_other=None,
):
skip_reason = None
if isinstance(library_type, (list, tuple, set)):
for library_type_item in library_type:
if library_type_item.lower() in blacklist_library_type:
skip_reason = f"{library_type_item} is in blacklist_library_type"
else:
if library_type.lower() in blacklist_library_type:
skip_reason = f"{library_type} is in blacklist_library_type"
if library_title.lower() in [x.lower() for x in blacklist_library]:
if skip_reason:
skip_reason = (
skip_reason + " and " + f"{library_title} is in blacklist_library"
)
else:
skip_reason = f"{library_title} is in blacklist_library"
if library_other:
if library_other.lower() in [x.lower() for x in blacklist_library]:
if skip_reason:
skip_reason = (
skip_reason + " and " + f"{library_other} is in blacklist_library"
)
else:
skip_reason = f"{library_other} is in blacklist_library"
return skip_reason
def check_whitelist_logic(
library_title,
library_type,
whitelist_library,
whitelist_library_type,
library_other=None,
):
skip_reason = None
if len(whitelist_library_type) > 0:
if isinstance(library_type, (list, tuple, set)):
for library_type_item in library_type:
if library_type_item.lower() not in whitelist_library_type:
skip_reason = (
f"{library_type_item} is not in whitelist_library_type"
)
else:
if library_type.lower() not in whitelist_library_type:
skip_reason = f"{library_type} is not in whitelist_library_type"
# if whitelist is not empty and library is not in whitelist
if len(whitelist_library) > 0:
if library_other:
if library_title.lower() not in [
x.lower() for x in whitelist_library
] and library_other.lower() not in [x.lower() for x in whitelist_library]:
if skip_reason:
skip_reason = (
skip_reason
+ " and "
+ f"{library_title} is not in whitelist_library"
)
else:
skip_reason = f"{library_title} is not in whitelist_library"
else:
if library_title.lower() not in [x.lower() for x in whitelist_library]:
if skip_reason:
skip_reason = (
skip_reason
+ " and "
+ f"{library_title} is not in whitelist_library"
)
else:
skip_reason = f"{library_title} is not in whitelist_library"
return skip_reason
def show_title_dict(user_list: dict):
try:
show_output_dict = {}
show_output_keys = user_list.keys()
show_output_keys = [dict(x) for x in list(show_output_keys)]
for show_key in show_output_keys:
for provider_key, provider_value in show_key.items():
# Skip title
if provider_key.lower() == "title":
continue
if provider_key.lower() not in show_output_dict:
show_output_dict[provider_key.lower()] = []
if provider_key.lower() == "locations":
for show_location in provider_value:
show_output_dict[provider_key.lower()].append(show_location)
else:
show_output_dict[provider_key.lower()].append(
provider_value.lower()
)
return show_output_dict
except Exception:
logger("Generating show_output_dict failed, skipping", 1)
return {}
def episode_title_dict(user_list: dict):
try:
episode_output_dict = {}
for show in user_list:
for season in user_list[show]:
for episode in user_list[show][season]:
for episode_key, episode_value in episode.items():
if episode_key.lower() not in episode_output_dict:
episode_output_dict[episode_key.lower()] = []
if episode_key == "locations":
for episode_location in episode_value:
episode_output_dict[episode_key.lower()].append(
episode_location
)
else:
episode_output_dict[episode_key.lower()].append(
episode_value.lower()
)
return episode_output_dict
except Exception:
logger("Generating episode_output_dict failed, skipping", 1)
return {}
def movies_title_dict(user_list: dict):
try:
movies_output_dict = {}
for movie in user_list:
for movie_key, movie_value in movie.items():
if movie_key.lower() not in movies_output_dict:
movies_output_dict[movie_key.lower()] = []
if movie_key == "locations":
for movie_location in movie_value:
movies_output_dict[movie_key.lower()].append(movie_location)
else:
movies_output_dict[movie_key.lower()].append(movie_value.lower())
return movies_output_dict
except Exception:
logger("Generating movies_output_dict failed, skipping", 1)
return {}
def generate_library_guids_dict(user_list: dict):
# Handle the case where user_list is empty or does not contain the expected keys and values
if not user_list:
return {}, {}, {}
show_output_dict = show_title_dict(user_list)
episode_output_dict = episode_title_dict(user_list)
movies_output_dict = movies_title_dict(user_list)
return show_output_dict, episode_output_dict, movies_output_dict

View File

@@ -1,441 +1,397 @@
import copy, os, traceback, json import os, traceback, json, asyncio
from dotenv import load_dotenv from dotenv import load_dotenv
from time import sleep from time import sleep, perf_counter
from src.functions import logger, str_to_bool, search_mapping, generate_library_guids_dict, future_thread_executor from src.functions import (
from src.plex import Plex logger,
from src.jellyfin import Jellyfin str_to_bool,
)
load_dotenv(override=True) from src.users import (
generate_user_list,
def cleanup_watched(watched_list_1, watched_list_2, user_mapping=None, library_mapping=None): combine_user_lists,
modified_watched_list_1 = copy.deepcopy(watched_list_1) filter_user_lists,
generate_server_users,
# remove entries from plex_watched that are in jellyfin_watched )
for user_1 in watched_list_1: from src.watched import (
user_other = None cleanup_watched,
if user_mapping: )
user_other = search_mapping(user_mapping, user_1) from src.black_white import setup_black_white_lists
if user_1 in modified_watched_list_1:
if user_1 in watched_list_2: from src.plex import Plex
user_2 = user_1 from src.jellyfin import Jellyfin
elif user_other in watched_list_2:
user_2 = user_other load_dotenv(override=True)
else:
logger(f"User {user_1} and {user_other} not found in watched list 2", 1)
continue def setup_users(
server_1, server_2, blacklist_users, whitelist_users, user_mapping=None
for library_1 in watched_list_1[user_1]: ):
library_other = None server_1_users = generate_user_list(server_1)
if library_mapping: server_2_users = generate_user_list(server_2)
library_other = search_mapping(library_mapping, library_1)
if library_1 in modified_watched_list_1[user_1]: users = combine_user_lists(server_1_users, server_2_users, user_mapping)
if library_1 in watched_list_2[user_2]: logger(f"User list that exist on both servers {users}", 1)
library_2 = library_1
elif library_other in watched_list_2[user_2]: users_filtered = filter_user_lists(users, blacklist_users, whitelist_users)
library_2 = library_other logger(f"Filtered user list {users_filtered}", 1)
else:
logger(f"library {library_1} and {library_other} not found in watched list 2", 1) output_server_1_users = generate_server_users(server_1, users_filtered)
continue output_server_2_users = generate_server_users(server_2, users_filtered)
# Movies # Check if users is none or empty
if isinstance(watched_list_1[user_1][library_1], list): if output_server_1_users is None or len(output_server_1_users) == 0:
_, _, movies_watched_list_2_keys_dict = generate_library_guids_dict(watched_list_2[user_2][library_2]) raise Exception(
for movie in watched_list_1[user_1][library_1]: f"No users found for server 1 {server_1[0]}, users found {users}, filtered users {users_filtered}, server 1 users {server_1[1].users}"
movie_found = False )
for movie_key, movie_value in movie.items():
if movie_key == "locations": if output_server_2_users is None or len(output_server_2_users) == 0:
for location in movie_value: raise Exception(
if location in movies_watched_list_2_keys_dict["locations"]: f"No users found for server 2 {server_2[0]}, users found {users} filtered users {users_filtered}, server 2 users {server_2[1].users}"
movie_found = True )
break
else: logger(f"Server 1 users: {output_server_1_users}", 1)
if movie_key in movies_watched_list_2_keys_dict.keys(): logger(f"Server 2 users: {output_server_2_users}", 1)
if movie_value in movies_watched_list_2_keys_dict[movie_key]:
movie_found = True return output_server_1_users, output_server_2_users
if movie_found:
logger(f"Removing {movie} from {library_1}", 3) def generate_server_connections():
modified_watched_list_1[user_1][library_1].remove(movie) servers = []
break
plex_baseurl = os.getenv("PLEX_BASEURL", None)
plex_token = os.getenv("PLEX_TOKEN", None)
# TV Shows plex_username = os.getenv("PLEX_USERNAME", None)
elif isinstance(watched_list_1[user_1][library_1], dict): plex_password = os.getenv("PLEX_PASSWORD", None)
# Generate full list of provider ids for episodes in watch_list_2 to easily compare if they exist in watch_list_1 plex_servername = os.getenv("PLEX_SERVERNAME", None)
_, episode_watched_list_2_keys_dict, _ = generate_library_guids_dict(watched_list_2[user_2][library_2]) ssl_bypass = str_to_bool(os.getenv("SSL_BYPASS", "False"))
for show_key_1 in watched_list_1[user_1][library_1].keys(): if plex_baseurl and plex_token:
show_key_dict = dict(show_key_1) plex_baseurl = plex_baseurl.split(",")
for season in watched_list_1[user_1][library_1][show_key_1]: plex_token = plex_token.split(",")
for episode in watched_list_1[user_1][library_1][show_key_1][season]:
episode_found = False if len(plex_baseurl) != len(plex_token):
for episode_key, episode_value in episode.items(): raise Exception(
# If episode_key and episode_value are in episode_watched_list_2_keys_dict exactly, then remove from watch_list_1 "PLEX_BASEURL and PLEX_TOKEN must have the same number of entries"
if episode_key == "locations": )
for location in episode_value:
if location in episode_watched_list_2_keys_dict["locations"]: for i, url in enumerate(plex_baseurl):
episode_found = True servers.append(
break (
"plex",
else: Plex(
if episode_key in episode_watched_list_2_keys_dict.keys(): baseurl=url.strip(),
if episode_value in episode_watched_list_2_keys_dict[episode_key]: token=plex_token[i].strip(),
episode_found = True username=None,
password=None,
if episode_found: servername=None,
if episode in modified_watched_list_1[user_1][library_1][show_key_1][season]: ssl_bypass=ssl_bypass,
logger(f"Removing {episode} from {show_key_dict['title']}", 3) ),
modified_watched_list_1[user_1][library_1][show_key_1][season].remove(episode) )
break )
# Remove empty seasons if plex_username and plex_password and plex_servername:
if len(modified_watched_list_1[user_1][library_1][show_key_1][season]) == 0: plex_username = plex_username.split(",")
if season in modified_watched_list_1[user_1][library_1][show_key_1]: plex_password = plex_password.split(",")
logger(f"Removing {season} from {show_key_dict['title']} because it is empty", 3) plex_servername = plex_servername.split(",")
del modified_watched_list_1[user_1][library_1][show_key_1][season]
if len(plex_username) != len(plex_password) or len(plex_username) != len(
# If the show is empty, remove the show plex_servername
if len(modified_watched_list_1[user_1][library_1][show_key_1]) == 0: ):
if show_key_1 in modified_watched_list_1[user_1][library_1]: raise Exception(
logger(f"Removing {show_key_dict['title']} from {library_1} because it is empty", 1) "PLEX_USERNAME, PLEX_PASSWORD and PLEX_SERVERNAME must have the same number of entries"
del modified_watched_list_1[user_1][library_1][show_key_1] )
for user_1 in watched_list_1: for i, username in enumerate(plex_username):
for library_1 in watched_list_1[user_1]: servers.append(
if library_1 in modified_watched_list_1[user_1]: (
# If library is empty then remove it "plex",
if len(modified_watched_list_1[user_1][library_1]) == 0: Plex(
logger(f"Removing {library_1} from {user_1} because it is empty", 1) baseurl=None,
del modified_watched_list_1[user_1][library_1] token=None,
username=username.strip(),
if user_1 in modified_watched_list_1: password=plex_password[i].strip(),
# If user is empty delete user servername=plex_servername[i].strip(),
if len(modified_watched_list_1[user_1]) == 0: ssl_bypass=ssl_bypass,
logger(f"Removing {user_1} from watched list 1 because it is empty", 1) ),
del modified_watched_list_1[user_1] )
)
return modified_watched_list_1
jellyfin_baseurl = os.getenv("JELLYFIN_BASEURL", None)
def setup_black_white_lists(blacklist_library: str, whitelist_library: str, blacklist_library_type: str, whitelist_library_type: str, blacklist_users: str, whitelist_users: str, library_mapping=None, user_mapping=None): jellyfin_token = os.getenv("JELLYFIN_TOKEN", None)
if blacklist_library:
if len(blacklist_library) > 0: if jellyfin_baseurl and jellyfin_token:
blacklist_library = blacklist_library.split(",") jellyfin_baseurl = jellyfin_baseurl.split(",")
blacklist_library = [x.strip() for x in blacklist_library] jellyfin_token = jellyfin_token.split(",")
if library_mapping:
temp_library = [] if len(jellyfin_baseurl) != len(jellyfin_token):
for library in blacklist_library: raise Exception(
library_other = search_mapping(library_mapping, library) "JELLYFIN_BASEURL and JELLYFIN_TOKEN must have the same number of entries"
if library_other: )
temp_library.append(library_other)
for i, baseurl in enumerate(jellyfin_baseurl):
blacklist_library = blacklist_library + temp_library baseurl = baseurl.strip()
else: if baseurl[-1] == "/":
blacklist_library = [] baseurl = baseurl[:-1]
logger(f"Blacklist Library: {blacklist_library}", 1) servers.append(
(
if whitelist_library: "jellyfin",
if len(whitelist_library) > 0: Jellyfin(baseurl=baseurl, token=jellyfin_token[i].strip()),
whitelist_library = whitelist_library.split(",") )
whitelist_library = [x.strip() for x in whitelist_library] )
if library_mapping:
temp_library = [] return servers
for library in whitelist_library:
library_other = search_mapping(library_mapping, library)
if library_other: def get_server_watched(
temp_library.append(library_other) server_connection: list,
users: dict,
whitelist_library = whitelist_library + temp_library blacklist_library: list,
else: whitelist_library: list,
whitelist_library = [] blacklist_library_type: list,
logger(f"Whitelist Library: {whitelist_library}", 1) whitelist_library_type: list,
library_mapping: dict,
if blacklist_library_type: ):
if len(blacklist_library_type) > 0: if server_connection[0] == "plex":
blacklist_library_type = blacklist_library_type.split(",") return server_connection[1].get_watched(
blacklist_library_type = [x.lower().strip() for x in blacklist_library_type] users,
else: blacklist_library,
blacklist_library_type = [] whitelist_library,
logger(f"Blacklist Library Type: {blacklist_library_type}", 1) blacklist_library_type,
whitelist_library_type,
if whitelist_library_type: library_mapping,
if len(whitelist_library_type) > 0: )
whitelist_library_type = whitelist_library_type.split(",") elif server_connection[0] == "jellyfin":
whitelist_library_type = [x.lower().strip() for x in whitelist_library_type] return asyncio.run(
else: server_connection[1].get_watched(
whitelist_library_type = [] users,
logger(f"Whitelist Library Type: {whitelist_library_type}", 1) blacklist_library,
whitelist_library,
if blacklist_users: blacklist_library_type,
if len(blacklist_users) > 0: whitelist_library_type,
blacklist_users = blacklist_users.split(",") library_mapping,
blacklist_users = [x.lower().strip() for x in blacklist_users] )
if user_mapping: )
temp_users = []
for user in blacklist_users:
user_other = search_mapping(user_mapping, user) def update_server_watched(
if user_other: server_connection: list,
temp_users.append(user_other) server_watched_filtered: dict,
user_mapping: dict,
blacklist_users = blacklist_users + temp_users library_mapping: dict,
else: dryrun: bool,
blacklist_users = [] ):
logger(f"Blacklist Users: {blacklist_users}", 1) if server_connection[0] == "plex":
server_connection[1].update_watched(
if whitelist_users: server_watched_filtered, user_mapping, library_mapping, dryrun
if len(whitelist_users) > 0: )
whitelist_users = whitelist_users.split(",") elif server_connection[0] == "jellyfin":
whitelist_users = [x.lower().strip() for x in whitelist_users] asyncio.run(
if user_mapping: server_connection[1].update_watched(
temp_users = [] server_watched_filtered, user_mapping, library_mapping, dryrun
for user in whitelist_users: )
user_other = search_mapping(user_mapping, user) )
if user_other:
temp_users.append(user_other)
def should_sync_server(server_1_type, server_2_type):
whitelist_users = whitelist_users + temp_users sync_from_plex_to_jellyfin = str_to_bool(
else: os.getenv("SYNC_FROM_PLEX_TO_JELLYFIN", "True")
whitelist_users = [] )
else: sync_from_jelly_to_plex = str_to_bool(
whitelist_users = [] os.getenv("SYNC_FROM_JELLYFIN_TO_PLEX", "True")
logger(f"Whitelist Users: {whitelist_users}", 1) )
sync_from_plex_to_plex = str_to_bool(os.getenv("SYNC_FROM_PLEX_TO_PLEX", "True"))
return blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, blacklist_users, whitelist_users sync_from_jelly_to_jellyfin = str_to_bool(
os.getenv("SYNC_FROM_JELLYFIN_TO_JELLYFIN", "True")
def setup_users(server_1, server_2, blacklist_users, whitelist_users, user_mapping=None): )
# generate list of users from server 1 and server 2 if (
server_1_type = server_1[0] server_1_type == "plex"
server_1_connection = server_1[1] and server_2_type == "plex"
server_2_type = server_2[0] and not sync_from_plex_to_plex
server_2_connection = server_2[1] ):
logger("Sync between plex and plex is disabled", 1)
server_1_users = [] return False
if server_1_type == "plex":
server_1_users = [ x.title.lower() for x in server_1_connection.users ] if (
elif server_1_type == "jellyfin": server_1_type == "plex"
server_1_users = [ key.lower() for key in server_1_connection.users.keys() ] and server_2_type == "jellyfin"
and not sync_from_jelly_to_plex
server_2_users = [] ):
if server_2_type == "plex": logger("Sync from jellyfin to plex disabled", 1)
server_2_users = [ x.title.lower() for x in server_2_connection.users ] return False
elif server_2_type == "jellyfin":
server_2_users = [ key.lower() for key in server_2_connection.users.keys() ] if (
server_1_type == "jellyfin"
and server_2_type == "jellyfin"
# combined list of overlapping users from plex and jellyfin and not sync_from_jelly_to_jellyfin
users = {} ):
logger("Sync between jellyfin and jellyfin is disabled", 1)
for server_1_user in server_1_users: return False
if user_mapping:
jellyfin_plex_mapped_user = search_mapping(user_mapping, server_1_user) if (
if jellyfin_plex_mapped_user: server_1_type == "jellyfin"
users[server_1_user] = jellyfin_plex_mapped_user and server_2_type == "plex"
continue and not sync_from_plex_to_jellyfin
):
if server_1_user in server_2_users: logger("Sync from plex to jellyfin is disabled", 1)
users[server_1_user] = server_1_user return False
for server_2_user in server_2_users: return True
if user_mapping:
plex_jellyfin_mapped_user = search_mapping(user_mapping, server_2_user)
if plex_jellyfin_mapped_user: def main_loop():
users[plex_jellyfin_mapped_user] = server_2_user logfile = os.getenv("LOGFILE", "log.log")
continue # Delete logfile if it exists
if os.path.exists(logfile):
if server_2_user in server_1_users: os.remove(logfile)
users[server_2_user] = server_2_user
dryrun = str_to_bool(os.getenv("DRYRUN", "False"))
logger(f"User list that exist on both servers {users}", 1) logger(f"Dryrun: {dryrun}", 1)
users_filtered = {} user_mapping = os.getenv("USER_MAPPING")
for user in users: if user_mapping:
# whitelist_user is not empty and user lowercase is not in whitelist lowercase user_mapping = json.loads(user_mapping.lower())
if len(whitelist_users) > 0: logger(f"User Mapping: {user_mapping}", 1)
if user not in whitelist_users and users[user] not in whitelist_users:
logger(f"{user} or {users[user]} is not in whitelist", 1) library_mapping = os.getenv("LIBRARY_MAPPING")
continue if library_mapping:
library_mapping = json.loads(library_mapping)
if user not in blacklist_users and users[user] not in blacklist_users: logger(f"Library Mapping: {library_mapping}", 1)
users_filtered[user] = users[user]
# Create (black/white)lists
logger(f"Filtered user list {users_filtered}", 1) logger("Creating (black/white)lists", 1)
blacklist_library = os.getenv("BLACKLIST_LIBRARY", None)
if server_1_type == "plex": whitelist_library = os.getenv("WHITELIST_LIBRARY", None)
output_server_1_users = [] blacklist_library_type = os.getenv("BLACKLIST_LIBRARY_TYPE", None)
for plex_user in server_1_connection.users: whitelist_library_type = os.getenv("WHITELIST_LIBRARY_TYPE", None)
if plex_user.title.lower() in users_filtered.keys() or plex_user.title.lower() in users_filtered.values(): blacklist_users = os.getenv("BLACKLIST_USERS", None)
output_server_1_users.append(plex_user) whitelist_users = os.getenv("WHITELIST_USERS", None)
elif server_1_type == "jellyfin":
output_server_1_users = {} (
for jellyfin_user, jellyfin_id in server_1_connection.users.items(): blacklist_library,
if jellyfin_user.lower() in users_filtered.keys() or jellyfin_user.lower() in users_filtered.values(): whitelist_library,
output_server_1_users[jellyfin_user] = jellyfin_id blacklist_library_type,
whitelist_library_type,
if server_2_type == "plex": blacklist_users,
output_server_2_users = [] whitelist_users,
for plex_user in server_2_connection.users: ) = setup_black_white_lists(
if plex_user.title.lower() in users_filtered.keys() or plex_user.title.lower() in users_filtered.values(): blacklist_library,
output_server_2_users.append(plex_user) whitelist_library,
elif server_2_type == "jellyfin": blacklist_library_type,
output_server_2_users = {} whitelist_library_type,
for jellyfin_user, jellyfin_id in server_2_connection.users.items(): blacklist_users,
if jellyfin_user.lower() in users_filtered.keys() or jellyfin_user.lower() in users_filtered.values(): whitelist_users,
output_server_2_users[jellyfin_user] = jellyfin_id library_mapping,
user_mapping,
if len(output_server_1_users) == 0: )
raise Exception(f"No users found for server 1, users found {users} filtered users {users_filtered}")
# Create server connections
if len(output_server_2_users) == 0: logger("Creating server connections", 1)
raise Exception(f"No users found for server 2, users found {users} filtered users {users_filtered}") servers = generate_server_connections()
logger(f"Server 1 users: {output_server_1_users}", 1) for server_1 in servers:
logger(f"Server 2 users: {output_server_2_users}", 1) # If server is the final server in the list, then we are done with the loop
if server_1 == servers[-1]:
return output_server_1_users, output_server_2_users break
def generate_server_connections(): # Start server_2 at the next server in the list
servers = [] for server_2 in servers[servers.index(server_1) + 1 :]:
# Create users list
plex_baseurl = os.getenv("PLEX_BASEURL", None) logger("Creating users list", 1)
plex_token = os.getenv("PLEX_TOKEN", None) server_1_users, server_2_users = setup_users(
plex_username = os.getenv("PLEX_USERNAME", None) server_1, server_2, blacklist_users, whitelist_users, user_mapping
plex_password = os.getenv("PLEX_PASSWORD", None) )
plex_servername = os.getenv("PLEX_SERVERNAME", None)
logger("Creating watched lists", 1)
if plex_baseurl and plex_token: server_1_watched = get_server_watched(
plex_baseurl = plex_baseurl.split(",") server_1,
plex_token = plex_token.split(",") server_1_users,
blacklist_library,
if len(plex_baseurl) != len(plex_token): whitelist_library,
raise Exception("PLEX_BASEURL and PLEX_TOKEN must have the same number of entries") blacklist_library_type,
whitelist_library_type,
for i, url in enumerate(plex_baseurl): library_mapping,
servers.append(("plex", Plex(baseurl=url.strip(), token=plex_token[i].strip(), username=None, password=None, servername=None))) )
logger("Finished creating watched list server 1", 1)
if plex_username and plex_password and plex_servername: server_2_watched = get_server_watched(
plex_username = plex_username.split(",") server_2,
plex_password = plex_password.split(",") server_2_users,
plex_servername = plex_servername.split(",") blacklist_library,
whitelist_library,
if len(plex_username) != len(plex_password) or len(plex_username) != len(plex_servername): blacklist_library_type,
raise Exception("PLEX_USERNAME, PLEX_PASSWORD and PLEX_SERVERNAME must have the same number of entries") whitelist_library_type,
library_mapping,
for i, username in enumerate(plex_username): )
servers.append(("plex", Plex(baseurl=None, token=None, username=username.strip(), password=plex_password[i].strip(), servername=plex_servername[i].strip()))) logger("Finished creating watched list server 2", 1)
logger(f"Server 1 watched: {server_1_watched}", 3)
jellyfin_baseurl = os.getenv("JELLYFIN_BASEURL", None) logger(f"Server 2 watched: {server_2_watched}", 3)
jellyfin_token = os.getenv("JELLYFIN_TOKEN", None)
logger("Cleaning Server 1 Watched", 1)
if jellyfin_baseurl and jellyfin_token: server_1_watched_filtered = cleanup_watched(
jellyfin_baseurl = jellyfin_baseurl.split(",") server_1_watched, server_2_watched, user_mapping, library_mapping
jellyfin_token = jellyfin_token.split(",") )
if len(jellyfin_baseurl) != len(jellyfin_token): logger("Cleaning Server 2 Watched", 1)
raise Exception("JELLYFIN_BASEURL and JELLYFIN_TOKEN must have the same number of entries") server_2_watched_filtered = cleanup_watched(
server_2_watched, server_1_watched, user_mapping, library_mapping
for i, baseurl in enumerate(jellyfin_baseurl): )
servers.append(("jellyfin", Jellyfin(baseurl=baseurl.strip(), token=jellyfin_token[i].strip())))
logger(
return servers f"server 1 watched that needs to be synced to server 2:\n{server_1_watched_filtered}",
1,
def main_loop(): )
logfile = os.getenv("LOGFILE","log.log") logger(
# Delete logfile if it exists f"server 2 watched that needs to be synced to server 1:\n{server_2_watched_filtered}",
if os.path.exists(logfile): 1,
os.remove(logfile) )
dryrun = str_to_bool(os.getenv("DRYRUN", "False")) if should_sync_server(server_1[0], server_2[0]):
logger(f"Dryrun: {dryrun}", 1) update_server_watched(
server_1,
user_mapping = os.getenv("USER_MAPPING") server_2_watched_filtered,
if user_mapping: user_mapping,
user_mapping = json.loads(user_mapping.lower()) library_mapping,
logger(f"User Mapping: {user_mapping}", 1) dryrun,
)
library_mapping = os.getenv("LIBRARY_MAPPING")
if library_mapping: if should_sync_server(server_2[0], server_1[0]):
library_mapping = json.loads(library_mapping) update_server_watched(
logger(f"Library Mapping: {library_mapping}", 1) server_2,
server_1_watched_filtered,
# Create (black/white)lists user_mapping,
logger("Creating (black/white)lists", 1) library_mapping,
blacklist_library = os.getenv("BLACKLIST_LIBRARY", None) dryrun,
whitelist_library = os.getenv("WHITELIST_LIBRARY", None) )
blacklist_library_type = os.getenv("BLACKLIST_LIBRARY_TYPE", None)
whitelist_library_type = os.getenv("WHITELIST_LIBRARY_TYPE", None)
blacklist_users = os.getenv("BLACKLIST_USERS", None) def main():
whitelist_users = os.getenv("WHITELIST_USERS", None) sleep_duration = float(os.getenv("SLEEP_DURATION", "3600"))
times = []
blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, blacklist_users, whitelist_users = setup_black_white_lists(blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, blacklist_users, whitelist_users, library_mapping, user_mapping) while True:
try:
# Create server connections start = perf_counter()
logger("Creating server connections", 1) main_loop()
servers = generate_server_connections() end = perf_counter()
times.append(end - start)
for server_1 in servers:
# If server is the final server in the list, then we are done with the loop if len(times) > 0:
if server_1 == servers[-1]: logger(f"Average time: {sum(times) / len(times)}", 0)
break
logger(f"Looping in {sleep_duration}")
# Start server_2 at the next server in the list sleep(sleep_duration)
for server_2 in servers[servers.index(server_1) + 1:]:
except Exception as error:
server_1_connection = server_1[1] if isinstance(error, list):
server_2_connection = server_2[1] for message in error:
logger(message, log_type=2)
# Create users list else:
logger("Creating users list", 1) logger(error, log_type=2)
server_1_users, server_2_users = setup_users(server_1, server_2, blacklist_users, whitelist_users, user_mapping)
logger(traceback.format_exc(), 2)
logger("Creating watched lists", 1)
args = [[server_1_connection.get_watched, server_1_users, blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, library_mapping] logger(f"Retrying in {sleep_duration}", log_type=0)
, [server_2_connection.get_watched, server_2_users, blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, library_mapping]] sleep(sleep_duration)
results = future_thread_executor(args) except KeyboardInterrupt:
server_1_watched = results[0] logger("Exiting", log_type=0)
server_2_watched = results[1] os._exit(0)
logger(f"Server 1 watched: {server_1_watched}", 3)
logger(f"Server 2 watched: {server_2_watched}", 3)
# clone watched so it isnt modified in the cleanup function so all duplicates are actually removed
server_1_watched_filtered = copy.deepcopy(server_1_watched)
server_2_watched_filtered = copy.deepcopy(server_2_watched)
logger("Cleaning Server 1 Watched", 1)
server_1_watched_filtered = cleanup_watched(server_1_watched, server_2_watched, user_mapping, library_mapping)
logger("Cleaning Server 2 Watched", 1)
server_2_watched_filtered = cleanup_watched(server_2_watched, server_1_watched, user_mapping, library_mapping)
logger(f"server 1 watched that needs to be synced to server 2:\n{server_1_watched_filtered}", 1)
logger(f"server 2 watched that needs to be synced to server 1:\n{server_2_watched_filtered}", 1)
args= [[server_1_connection.update_watched, server_2_watched_filtered, user_mapping, library_mapping, dryrun]
, [server_2_connection.update_watched, server_1_watched_filtered, user_mapping, library_mapping, dryrun]]
future_thread_executor(args)
def main():
sleep_duration = float(os.getenv("SLEEP_DURATION", "3600"))
while(True):
try:
main_loop()
logger(f"Looping in {sleep_duration}")
sleep(sleep_duration)
except Exception as error:
if isinstance(error, list):
for message in error:
logger(message, log_type=2)
else:
logger(error, log_type=2)
logger(traceback.format_exc(), 2)
logger(f"Retrying in {sleep_duration}", log_type=0)
sleep(sleep_duration)
except KeyboardInterrupt:
logger("Exiting", log_type=0)
os._exit(0)

View File

@@ -1,312 +1,436 @@
import re, requests import re, requests, os, traceback
from urllib3.poolmanager import PoolManager
from plexapi.server import PlexServer
from plexapi.myplex import MyPlexAccount from plexapi.server import PlexServer
from plexapi.myplex import MyPlexAccount
from src.functions import logger, search_mapping, check_skip_logic, generate_library_guids_dict, future_thread_executor
from src.functions import (
logger,
# class plex accept base url and token and username and password but default with none search_mapping,
class Plex: future_thread_executor,
def __init__(self, baseurl=None, token=None, username=None, password=None, servername=None, ssl_bypass=False): )
self.baseurl = baseurl from src.library import (
self.token = token check_skip_logic,
self.username = username generate_library_guids_dict,
self.password = password )
self.servername = servername
self.plex = self.login()
self.admin_user = self.plex.myPlexAccount() # Bypass hostname validation for ssl. Taken from https://github.com/pkkid/python-plexapi/issues/143#issuecomment-775485186
self.users = self.get_users() class HostNameIgnoringAdapter(requests.adapters.HTTPAdapter):
def init_poolmanager(self, connections, maxsize, block=..., **pool_kwargs):
def login(self): self.poolmanager = PoolManager(
try: num_pools=connections,
if self.baseurl and self.token: maxsize=maxsize,
# Login via token block=block,
plex = PlexServer(self.baseurl, self.token) assert_hostname=False,
elif self.username and self.password and self.servername: **pool_kwargs,
# Login via plex account )
account = MyPlexAccount(self.username, self.password)
plex = account.resource(self.servername).connect()
else: def get_user_library_watched_show(show):
raise Exception("No complete plex credentials provided") try:
show_guids = {}
return plex for show_guid in show.guids:
except Exception as e: # Extract source and id from guid.id
if self.username or self.password: m = re.match(r"(.*)://(.*)", show_guid.id)
msg = f"Failed to login via plex account {self.username}" show_guid_source, show_guid_id = m.group(1).lower(), m.group(2)
logger(f"Plex: Failed to login, {msg}, Error: {e}", 2) show_guids[show_guid_source] = show_guid_id
else:
logger(f"Plex: Failed to login, Error: {e}", 2) show_guids["title"] = show.title
raise Exception(e) show_guids["locations"] = tuple([x.split("/")[-1] for x in show.locations])
show_guids = frozenset(show_guids.items())
def get_users(self): # Get all watched episodes for show
try: episode_guids = {}
users = self.plex.myPlexAccount().users() watched_episodes = show.watched()
for episode in watched_episodes:
# append self to users episode_guids_temp = {}
users.append(self.plex.myPlexAccount()) try:
if len(episode.guids) > 0:
return users for guid in episode.guids:
except Exception as e: # Extract after :// from guid.id
logger(f"Plex: Failed to get users, Error: {e}", 2) m = re.match(r"(.*)://(.*)", guid.id)
raise Exception(e) guid_source, guid_id = m.group(1).lower(), m.group(2)
episode_guids_temp[guid_source] = guid_id
def get_user_watched(self, user, user_plex, library): except Exception:
try: logger(
user_name = user.title.lower() f"Plex: Failed to get guids for {episode.title} in {show.title}, Using location only",
user_watched = {} 1,
user_watched[user_name] = {} )
logger(f"Plex: Generating watched for {user_name} in library {library.title}", 0) episode_guids_temp["locations"] = tuple(
[x.split("/")[-1] for x in episode.locations]
if library.type == "movie": )
user_watched[user_name][library.title] = []
if episode.parentTitle not in episode_guids:
library_videos = user_plex.library.section(library.title) episode_guids[episode.parentTitle] = []
for video in library_videos.search(unwatched=False):
movie_guids = {} episode_guids[episode.parentTitle].append(episode_guids_temp)
for guid in video.guids:
guid_source = re.search(r'(.*)://', guid.id).group(1).lower() return show_guids, episode_guids
guid_id = re.search(r'://(.*)', guid.id).group(1)
movie_guids[guid_source] = guid_id except Exception:
return {}, {}
movie_guids["title"] = video.title
movie_guids["locations"] = tuple([x.split("/")[-1] for x in video.locations])
def get_user_library_watched(user, user_plex, library):
user_watched[user_name][library.title].append(movie_guids) try:
user_name = user.title.lower()
elif library.type == "show": user_watched = {}
user_watched[user_name][library.title] = {} user_watched[user_name] = {}
library_videos = user_plex.library.section(library.title) logger(
for show in library_videos.search(unwatched=False): f"Plex: Generating watched for {user_name} in library {library.title}",
show_guids = {} 0,
for show_guid in show.guids: )
# Extract after :// from guid.id
show_guid_source = re.search(r'(.*)://', show_guid.id).group(1).lower() library_videos = user_plex.library.section(library.title)
show_guid_id = re.search(r'://(.*)', show_guid.id).group(1)
show_guids[show_guid_source] = show_guid_id if library.type == "movie":
user_watched[user_name][library.title] = []
show_guids["title"] = show.title
show_guids["locations"] = tuple([x.split("/")[-1] for x in show.locations]) for video in library_videos.search(unwatched=False):
show_guids = frozenset(show_guids.items()) logger(f"Plex: Adding {video.title} to {user_name} watched list", 3)
logger(f"Plex: {video.title} {video.guids} {video.locations}", 3)
for season in show.seasons():
episode_guids = [] movie_guids = {}
for episode in season.episodes(): for guid in video.guids:
if episode.viewCount > 0: # Extract source and id from guid.id
episode_guids_temp = {} m = re.match(r"(.*)://(.*)", guid.id)
for guid in episode.guids: guid_source, guid_id = m.group(1).lower(), m.group(2)
# Extract after :// from guid.id movie_guids[guid_source] = guid_id
guid_source = re.search(r'(.*)://', guid.id).group(1).lower()
guid_id = re.search(r'://(.*)', guid.id).group(1) movie_guids["title"] = video.title
episode_guids_temp[guid_source] = guid_id movie_guids["locations"] = tuple(
[x.split("/")[-1] for x in video.locations]
episode_guids_temp["locations"] = tuple([x.split("/")[-1] for x in episode.locations]) )
episode_guids.append(episode_guids_temp)
user_watched[user_name][library.title].append(movie_guids)
if episode_guids: logger(f"Plex: Added {movie_guids} to {user_name} watched list", 3)
# append show, season, episode
if show_guids not in user_watched[user_name][library.title]: elif library.type == "show":
user_watched[user_name][library.title][show_guids] = {} user_watched[user_name][library.title] = {}
if season.title not in user_watched[user_name][library.title][show_guids]: shows = library_videos.search(unwatched=False)
user_watched[user_name][library.title][show_guids][season.title] = {}
user_watched[user_name][library.title][show_guids][season.title] = episode_guids # Parallelize show processing
args = []
for show in shows:
return user_watched args.append([get_user_library_watched_show, show])
except Exception as e:
logger(f"Plex: Failed to get watched for {user_name} in library {library.title}, Error: {e}", 2) for show_guids, episode_guids in future_thread_executor(
raise Exception(e) args, workers=min(os.cpu_count(), 4)
):
if show_guids and episode_guids:
def get_watched(self, users, blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, library_mapping): # append show, season, episode
try: if show_guids not in user_watched[user_name][library.title]:
# Get all libraries user_watched[user_name][library.title][show_guids] = {}
users_watched = {}
args = [] user_watched[user_name][library.title][show_guids] = episode_guids
logger(
for user in users: f"Plex: Added {episode_guids} to {user_name} {show_guids} watched list",
if self.admin_user == user: 3,
user_plex = self.plex )
else:
user_plex = PlexServer(self.plex._baseurl, user.get_token(self.plex.machineIdentifier)) logger(f"Plex: Got watched for {user_name} in library {library.title}", 1)
if library.title in user_watched[user_name]:
libraries = user_plex.library.sections() logger(f"Plex: {user_watched[user_name][library.title]}", 3)
for library in libraries: return user_watched
library_title = library.title except Exception as e:
library_type = library.type logger(
f"Plex: Failed to get watched for {user_name} in library {library.title}, Error: {e}",
skip_reason = check_skip_logic(library_title, library_type, blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, library_mapping) 2,
)
if skip_reason: return {}
logger(f"Plex: Skipping library {library_title} {skip_reason}", 1)
continue
def find_video(plex_search, video_ids):
args.append([self.get_user_watched, user, user_plex, library]) try:
for location in plex_search.locations:
for user_watched in future_thread_executor(args): if location.split("/")[-1] in video_ids["locations"]:
for user, user_watched_temp in user_watched.items(): return True
if user not in users_watched:
users_watched[user] = {} for guid in plex_search.guids:
users_watched[user].update(user_watched_temp) guid_source = re.search(r"(.*)://", guid.id).group(1).lower()
guid_id = re.search(r"://(.*)", guid.id).group(1)
return users_watched
except Exception as e: # If show provider source and show provider id are in videos_shows_ids exactly, then the show is in the list
logger(f"Plex: Failed to get watched, Error: {e}", 2) if guid_source in video_ids.keys():
raise Exception(e) if guid_id in video_ids[guid_source]:
return True
def update_user_watched (self, user, user_plex, library, videos, dryrun): return False
try: except Exception:
logger(f"Plex: Updating watched for {user.title} in library {library}", 1) return False
videos_shows_ids, videos_episodes_ids, videos_movies_ids = generate_library_guids_dict(videos)
logger(f"Plex: mark list\nShows: {videos_shows_ids}\nEpisodes: {videos_episodes_ids}\nMovies: {videos_movies_ids}", 1)
def update_user_watched(user, user_plex, library, videos, dryrun):
library_videos = user_plex.library.section(library) try:
if videos_movies_ids: logger(f"Plex: Updating watched for {user.title} in library {library}", 1)
for movies_search in library_videos.search(unwatched=True): (
movie_found = False videos_shows_ids,
for movie_location in movies_search.locations: videos_episodes_ids,
if movie_location.split("/")[-1] in videos_movies_ids["locations"]: videos_movies_ids,
movie_found = True ) = generate_library_guids_dict(videos)
break logger(
f"Plex: mark list\nShows: {videos_shows_ids}\nEpisodes: {videos_episodes_ids}\nMovies: {videos_movies_ids}",
if not movie_found: 1,
for movie_guid in movies_search.guids: )
movie_guid_source = re.search(r'(.*)://', movie_guid.id).group(1).lower()
movie_guid_id = re.search(r'://(.*)', movie_guid.id).group(1) library_videos = user_plex.library.section(library)
if videos_movies_ids:
# If movie provider source and movie provider id are in videos_movie_ids exactly, then the movie is in the list for movies_search in library_videos.search(unwatched=True):
if movie_guid_source in videos_movies_ids.keys(): if find_video(movies_search, videos_movies_ids):
if movie_guid_id in videos_movies_ids[movie_guid_source]: msg = f"{movies_search.title} as watched for {user.title} in {library} for Plex"
movie_found = True if not dryrun:
break logger(f"Marked {msg}", 0)
movies_search.markWatched()
if movie_found: else:
msg = f"{movies_search.title} as watched for {user.title} in {library} for Plex" logger(f"Dryrun {msg}", 0)
if not dryrun: else:
logger(f"Marked {msg}", 0) logger(
movies_search.markWatched() f"Plex: Skipping movie {movies_search.title} as it is not in mark list for {user.title}",
else: 1,
logger(f"Dryrun {msg}", 0) )
else:
logger(f"Plex: Skipping movie {movies_search.title} as it is not in mark list for {user.title}", 1) if videos_shows_ids and videos_episodes_ids:
for show_search in library_videos.search(unwatched=True):
if find_video(show_search, videos_shows_ids):
if videos_shows_ids and videos_episodes_ids: for episode_search in show_search.episodes():
for show_search in library_videos.search(unwatched=True): if find_video(episode_search, videos_episodes_ids):
show_found = False msg = f"{show_search.title} {episode_search.title} as watched for {user.title} in {library} for Plex"
for show_location in show_search.locations: if not dryrun:
if show_location.split("/")[-1] in videos_shows_ids["locations"]: logger(f"Marked {msg}", 0)
show_found = True episode_search.markWatched()
break else:
logger(f"Dryrun {msg}", 0)
if not show_found: else:
for show_guid in show_search.guids: logger(
show_guid_source = re.search(r'(.*)://', show_guid.id).group(1).lower() f"Plex: Skipping episode {episode_search.title} as it is not in mark list for {user.title}",
show_guid_id = re.search(r'://(.*)', show_guid.id).group(1) 3,
)
# If show provider source and show provider id are in videos_shows_ids exactly, then the show is in the list else:
if show_guid_source in videos_shows_ids.keys(): logger(
if show_guid_id in videos_shows_ids[show_guid_source]: f"Plex: Skipping show {show_search.title} as it is not in mark list for {user.title}",
show_found = True 3,
break )
if show_found: if not videos_movies_ids and not videos_shows_ids and not videos_episodes_ids:
for episode_search in show_search.episodes(): logger(
episode_found = False f"Jellyfin: No videos to mark as watched for {user.title} in library {library}",
1,
for episode_location in episode_search.locations: )
if episode_location.split("/")[-1] in videos_episodes_ids["locations"]:
episode_found = True except Exception as e:
break logger(
f"Plex: Failed to update watched for {user.title} in library {library}, Error: {e}",
if not episode_found: 2,
for episode_guid in episode_search.guids: )
episode_guid_source = re.search(r'(.*)://', episode_guid.id).group(1).lower() logger(traceback.format_exc(), 2)
episode_guid_id = re.search(r'://(.*)', episode_guid.id).group(1)
# If episode provider source and episode provider id are in videos_episodes_ids exactly, then the episode is in the list # class plex accept base url and token and username and password but default with none
if episode_guid_source in videos_episodes_ids.keys(): class Plex:
if episode_guid_id in videos_episodes_ids[episode_guid_source]: def __init__(
episode_found = True self,
break baseurl=None,
token=None,
if episode_found: username=None,
msg = f"{show_search.title} {episode_search.title} as watched for {user.title} in {library} for Plex" password=None,
if not dryrun: servername=None,
logger(f"Marked {msg}", 0) ssl_bypass=False,
episode_search.markWatched() session=None,
else: ):
logger(f"Dryrun {msg}", 0) self.baseurl = baseurl
else: self.token = token
logger(f"Plex: Skipping episode {episode_search.title} as it is not in mark list for {user.title}", 1) self.username = username
else: self.password = password
logger(f"Plex: Skipping show {show_search.title} as it is not in mark list for {user.title}", 1) self.servername = servername
self.ssl_bypass = ssl_bypass
if not videos_movies_ids and not videos_shows_ids and not videos_episodes_ids: if ssl_bypass:
logger(f"Jellyfin: No videos to mark as watched for {user.title} in library {library}", 1) # Session for ssl bypass
session = requests.Session()
except Exception as e: # By pass ssl hostname check https://github.com/pkkid/python-plexapi/issues/143#issuecomment-775485186
logger(f"Plex: Failed to update watched for {user.title} in library {library}, Error: {e}", 2) session.mount("https://", HostNameIgnoringAdapter())
raise Exception(e) self.session = session
self.plex = self.login(self.baseurl, self.token)
self.admin_user = self.plex.myPlexAccount()
def update_watched(self, watched_list, user_mapping=None, library_mapping=None, dryrun=False): self.users = self.get_users()
try:
args = [] def login(self, baseurl, token):
try:
for user, libraries in watched_list.items(): if baseurl and token:
user_other = None plex = PlexServer(baseurl, token, session=self.session)
# If type of user is dict elif self.username and self.password and self.servername:
if user_mapping: # Login via plex account
if user in user_mapping.keys(): account = MyPlexAccount(self.username, self.password)
user_other = user_mapping[user] plex = account.resource(self.servername).connect()
elif user in user_mapping.values(): else:
user_other = search_mapping(user_mapping, user) raise Exception("No complete plex credentials provided")
for index, value in enumerate(self.users): return plex
if user.lower() == value.title.lower(): except Exception as e:
user = self.users[index] if self.username or self.password:
break msg = f"Failed to login via plex account {self.username}"
elif user_other and user_other.lower() == value.title.lower(): logger(f"Plex: Failed to login, {msg}, Error: {e}", 2)
user = self.users[index] else:
break logger(f"Plex: Failed to login, Error: {e}", 2)
raise Exception(e)
if self.admin_user == user:
user_plex = self.plex def get_users(self):
else: try:
user_plex = PlexServer(self.plex._baseurl, user.get_token(self.plex.machineIdentifier)) users = self.plex.myPlexAccount().users()
for library, videos in libraries.items(): # append self to users
library_other = None users.append(self.plex.myPlexAccount())
if library_mapping:
if library in library_mapping.keys(): return users
library_other = library_mapping[library] except Exception as e:
elif library in library_mapping.values(): logger(f"Plex: Failed to get users, Error: {e}", 2)
library_other = search_mapping(library_mapping, library) raise Exception(e)
# if library in plex library list def get_watched(
library_list = user_plex.library.sections() self,
if library.lower() not in [x.title.lower() for x in library_list]: users,
if library_other: blacklist_library,
if library_other.lower() in [x.title.lower() for x in library_list]: whitelist_library,
logger(f"Plex: Library {library} not found, but {library_other} found, using {library_other}", 1) blacklist_library_type,
library = library_other whitelist_library_type,
else: library_mapping,
logger(f"Plex: Library {library} or {library_other} not found in library list", 2) ):
continue try:
else: # Get all libraries
logger(f"Plex: Library {library} not found in library list", 2) users_watched = {}
continue args = []
for user in users:
args.append([self.update_user_watched, user, user_plex, library, videos, dryrun]) if self.admin_user == user:
user_plex = self.plex
future_thread_executor(args) else:
except Exception as e: user_plex = self.login(
logger(f"Plex: Failed to update watched, Error: {e}", 2) self.plex._baseurl,
raise Exception(e) user.get_token(self.plex.machineIdentifier),
)
libraries = user_plex.library.sections()
for library in libraries:
library_title = library.title
library_type = library.type
skip_reason = check_skip_logic(
library_title,
library_type,
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
library_mapping,
)
if skip_reason:
logger(
f"Plex: Skipping library {library_title}: {skip_reason}", 1
)
continue
args.append([get_user_library_watched, user, user_plex, library])
for user_watched in future_thread_executor(args):
for user, user_watched_temp in user_watched.items():
if user not in users_watched:
users_watched[user] = {}
users_watched[user].update(user_watched_temp)
return users_watched
except Exception as e:
logger(f"Plex: Failed to get watched, Error: {e}", 2)
raise Exception(e)
def update_watched(
self, watched_list, user_mapping=None, library_mapping=None, dryrun=False
):
try:
args = []
for user, libraries in watched_list.items():
user_other = None
# If type of user is dict
if user_mapping:
if user in user_mapping.keys():
user_other = user_mapping[user]
elif user in user_mapping.values():
user_other = search_mapping(user_mapping, user)
for index, value in enumerate(self.users):
if user.lower() == value.title.lower():
user = self.users[index]
break
elif user_other and user_other.lower() == value.title.lower():
user = self.users[index]
break
if self.admin_user == user:
user_plex = self.plex
else:
if isinstance(user, str):
logger(
f"Plex: {user} is not a plex object, attempting to get object for user",
4,
)
user = self.plex.myPlexAccount().user(user)
user_plex = PlexServer(
self.plex._baseurl,
user.get_token(self.plex.machineIdentifier),
session=self.session,
)
for library, videos in libraries.items():
library_other = None
if library_mapping:
if library in library_mapping.keys():
library_other = library_mapping[library]
elif library in library_mapping.values():
library_other = search_mapping(library_mapping, library)
# if library in plex library list
library_list = user_plex.library.sections()
if library.lower() not in [x.title.lower() for x in library_list]:
if library_other:
if library_other.lower() in [
x.title.lower() for x in library_list
]:
logger(
f"Plex: Library {library} not found, but {library_other} found, using {library_other}",
1,
)
library = library_other
else:
logger(
f"Plex: Library {library} or {library_other} not found in library list",
1,
)
continue
else:
logger(
f"Plex: Library {library} not found in library list",
1,
)
continue
args.append(
[
update_user_watched,
user,
user_plex,
library,
videos,
dryrun,
]
)
future_thread_executor(args)
except Exception as e:
logger(f"Plex: Failed to update watched, Error: {e}", 2)
raise Exception(e)

83
src/users.py Normal file
View File

@@ -0,0 +1,83 @@
from src.functions import (
logger,
search_mapping,
)
def generate_user_list(server):
# generate list of users from server 1 and server 2
server_type = server[0]
server_connection = server[1]
server_users = []
if server_type == "plex":
server_users = [x.title.lower() for x in server_connection.users]
elif server_type == "jellyfin":
server_users = [key.lower() for key in server_connection.users.keys()]
return server_users
def combine_user_lists(server_1_users, server_2_users, user_mapping):
# combined list of overlapping users from plex and jellyfin
users = {}
for server_1_user in server_1_users:
if user_mapping:
mapped_user = search_mapping(user_mapping, server_1_user)
if mapped_user in server_2_users:
users[server_1_user] = mapped_user
continue
if server_1_user in server_2_users:
users[server_1_user] = server_1_user
for server_2_user in server_2_users:
if user_mapping:
mapped_user = search_mapping(user_mapping, server_2_user)
if mapped_user in server_1_users:
users[mapped_user] = server_2_user
continue
if server_2_user in server_1_users:
users[server_2_user] = server_2_user
return users
def filter_user_lists(users, blacklist_users, whitelist_users):
users_filtered = {}
for user in users:
# whitelist_user is not empty and user lowercase is not in whitelist lowercase
if len(whitelist_users) > 0:
if user not in whitelist_users and users[user] not in whitelist_users:
logger(f"{user} or {users[user]} is not in whitelist", 1)
continue
if user not in blacklist_users and users[user] not in blacklist_users:
users_filtered[user] = users[user]
return users_filtered
def generate_server_users(server, users):
server_users = None
if server[0] == "plex":
server_users = []
for plex_user in server[1].users:
if (
plex_user.title.lower() in users.keys()
or plex_user.title.lower() in users.values()
):
server_users.append(plex_user)
elif server[0] == "jellyfin":
server_users = {}
for jellyfin_user, jellyfin_id in server[1].users.items():
if (
jellyfin_user.lower() in users.keys()
or jellyfin_user.lower() in users.values()
):
server_users[jellyfin_user] = jellyfin_id
return server_users

192
src/watched.py Normal file
View File

@@ -0,0 +1,192 @@
import copy
from src.functions import (
logger,
search_mapping,
)
from src.library import generate_library_guids_dict
def combine_watched_dicts(dicts: list):
combined_dict = {}
for single_dict in dicts:
for key, value in single_dict.items():
if key not in combined_dict:
combined_dict[key] = {}
for subkey, subvalue in value.items():
if subkey in combined_dict[key]:
# If the subkey already exists in the combined dictionary,
# check if the values are different and raise an exception if they are
if combined_dict[key][subkey] != subvalue:
raise ValueError(
f"Conflicting values for subkey '{subkey}' under key '{key}'"
)
else:
# If the subkey does not exist in the combined dictionary, add it
combined_dict[key][subkey] = subvalue
return combined_dict
def cleanup_watched(
watched_list_1, watched_list_2, user_mapping=None, library_mapping=None
):
modified_watched_list_1 = copy.deepcopy(watched_list_1)
# remove entries from watched_list_1 that are in watched_list_2
for user_1 in watched_list_1:
user_other = None
if user_mapping:
user_other = search_mapping(user_mapping, user_1)
user_2 = get_other(watched_list_2, user_1, user_other)
if user_2 is None:
continue
for library_1 in watched_list_1[user_1]:
library_other = None
if library_mapping:
library_other = search_mapping(library_mapping, library_1)
library_2 = get_other(watched_list_2[user_2], library_1, library_other)
if library_2 is None:
continue
(
_,
episode_watched_list_2_keys_dict,
movies_watched_list_2_keys_dict,
) = generate_library_guids_dict(watched_list_2[user_2][library_2])
# Movies
if isinstance(watched_list_1[user_1][library_1], list):
for movie in watched_list_1[user_1][library_1]:
if is_movie_in_dict(movie, movies_watched_list_2_keys_dict):
logger(f"Removing {movie} from {library_1}", 3)
modified_watched_list_1[user_1][library_1].remove(movie)
# TV Shows
elif isinstance(watched_list_1[user_1][library_1], dict):
for show_key_1 in watched_list_1[user_1][library_1].keys():
show_key_dict = dict(show_key_1)
for season in watched_list_1[user_1][library_1][show_key_1]:
for episode in watched_list_1[user_1][library_1][show_key_1][
season
]:
if is_episode_in_dict(
episode, episode_watched_list_2_keys_dict
):
if (
episode
in modified_watched_list_1[user_1][library_1][
show_key_1
][season]
):
logger(
f"Removing {episode} from {show_key_dict['title']}",
3,
)
modified_watched_list_1[user_1][library_1][
show_key_1
][season].remove(episode)
# Remove empty seasons
if (
len(
modified_watched_list_1[user_1][library_1][show_key_1][
season
]
)
== 0
):
if (
season
in modified_watched_list_1[user_1][library_1][
show_key_1
]
):
logger(
f"Removing {season} from {show_key_dict['title']} because it is empty",
3,
)
del modified_watched_list_1[user_1][library_1][
show_key_1
][season]
# Remove empty shows
if len(modified_watched_list_1[user_1][library_1][show_key_1]) == 0:
if show_key_1 in modified_watched_list_1[user_1][library_1]:
logger(
f"Removing {show_key_dict['title']} because it is empty",
3,
)
del modified_watched_list_1[user_1][library_1][show_key_1]
for user_1 in watched_list_1:
for library_1 in watched_list_1[user_1]:
if library_1 in modified_watched_list_1[user_1]:
# If library is empty then remove it
if len(modified_watched_list_1[user_1][library_1]) == 0:
logger(f"Removing {library_1} from {user_1} because it is empty", 1)
del modified_watched_list_1[user_1][library_1]
if user_1 in modified_watched_list_1:
# If user is empty delete user
if len(modified_watched_list_1[user_1]) == 0:
logger(f"Removing {user_1} from watched list 1 because it is empty", 1)
del modified_watched_list_1[user_1]
return modified_watched_list_1
def get_other(watched_list, object_1, object_2):
if object_1 in watched_list:
return object_1
elif object_2 in watched_list:
return object_2
else:
logger(f"{object_1} and {object_2} not found in watched list 2", 1)
return None
def is_movie_in_dict(movie, movies_watched_list_2_keys_dict):
# Iterate through the keys and values of the movie dictionary
for movie_key, movie_value in movie.items():
# If the key is "locations", check if the "locations" key is present in the movies_watched_list_2_keys_dict dictionary
if movie_key == "locations":
if "locations" in movies_watched_list_2_keys_dict.keys():
# Iterate through the locations in the movie dictionary
for location in movie_value:
# If the location is in the movies_watched_list_2_keys_dict dictionary, return True
if location in movies_watched_list_2_keys_dict["locations"]:
return True
# If the key is not "locations", check if the movie_key is present in the movies_watched_list_2_keys_dict dictionary
else:
if movie_key in movies_watched_list_2_keys_dict.keys():
# If the movie_value is in the movies_watched_list_2_keys_dict dictionary, return True
if movie_value in movies_watched_list_2_keys_dict[movie_key]:
return True
# If the loop completes without finding a match, return False
return False
def is_episode_in_dict(episode, episode_watched_list_2_keys_dict):
# Iterate through the keys and values of the episode dictionary
for episode_key, episode_value in episode.items():
# If the key is "locations", check if the "locations" key is present in the episode_watched_list_2_keys_dict dictionary
if episode_key == "locations":
if "locations" in episode_watched_list_2_keys_dict.keys():
# Iterate through the locations in the episode dictionary
for location in episode_value:
# If the location is in the episode_watched_list_2_keys_dict dictionary, return True
if location in episode_watched_list_2_keys_dict["locations"]:
return True
# If the key is not "locations", check if the episode_key is present in the episode_watched_list_2_keys_dict dictionary
else:
if episode_key in episode_watched_list_2_keys_dict.keys():
# If the episode_value is in the episode_watched_list_2_keys_dict dictionary, return True
if episode_value in episode_watched_list_2_keys_dict[episode_key]:
return True
# If the loop completes without finding a match, return False
return False

View File

@@ -1 +1 @@
pytest pytest

78
test/test_black_white.py Normal file
View File

@@ -0,0 +1,78 @@
import sys
import os
# getting the name of the directory
# where the this file is present.
current = os.path.dirname(os.path.realpath(__file__))
# Getting the parent directory name
# where the current directory is present.
parent = os.path.dirname(current)
# adding the parent directory to
# the sys.path.
sys.path.append(parent)
from src.black_white import setup_black_white_lists
def test_setup_black_white_lists():
# Simple
blacklist_library = "library1, library2"
whitelist_library = "library1, library2"
blacklist_library_type = "library_type1, library_type2"
whitelist_library_type = "library_type1, library_type2"
blacklist_users = "user1, user2"
whitelist_users = "user1, user2"
(
results_blacklist_library,
return_whitelist_library,
return_blacklist_library_type,
return_whitelist_library_type,
return_blacklist_users,
return_whitelist_users,
) = setup_black_white_lists(
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
blacklist_users,
whitelist_users,
)
assert results_blacklist_library == ["library1", "library2"]
assert return_whitelist_library == ["library1", "library2"]
assert return_blacklist_library_type == ["library_type1", "library_type2"]
assert return_whitelist_library_type == ["library_type1", "library_type2"]
assert return_blacklist_users == ["user1", "user2"]
assert return_whitelist_users == ["user1", "user2"]
# Library Mapping and user mapping
library_mapping = {"library1": "library3"}
user_mapping = {"user1": "user3"}
(
results_blacklist_library,
return_whitelist_library,
return_blacklist_library_type,
return_whitelist_library_type,
return_blacklist_users,
return_whitelist_users,
) = setup_black_white_lists(
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
blacklist_users,
whitelist_users,
library_mapping,
user_mapping,
)
assert results_blacklist_library == ["library1", "library2", "library3"]
assert return_whitelist_library == ["library1", "library2", "library3"]
assert return_blacklist_library_type == ["library_type1", "library_type2"]
assert return_whitelist_library_type == ["library_type1", "library_type2"]
assert return_blacklist_users == ["user1", "user2", "user3"]
assert return_whitelist_users == ["user1", "user2", "user3"]

302
test/test_library.py Normal file
View File

@@ -0,0 +1,302 @@
import sys
import os
# getting the name of the directory
# where the this file is present.
current = os.path.dirname(os.path.realpath(__file__))
# Getting the parent directory name
# where the current directory is present.
parent = os.path.dirname(current)
# adding the parent directory to
# the sys.path.
sys.path.append(parent)
from src.functions import (
search_mapping,
)
from src.library import (
check_skip_logic,
check_blacklist_logic,
check_whitelist_logic,
show_title_dict,
episode_title_dict,
movies_title_dict,
generate_library_guids_dict,
)
blacklist_library = ["TV Shows"]
whitelist_library = ["Movies"]
blacklist_library_type = ["episodes"]
whitelist_library_type = ["movies"]
library_mapping = {"Shows": "TV Shows", "Movie": "Movies"}
show_list = {
frozenset(
{
("locations", ("The Last of Us",)),
("tmdb", "100088"),
("imdb", "tt3581920"),
("tvdb", "392256"),
("title", "The Last of Us"),
}
): {
"Season 1": [
{
"imdb": "tt11957006",
"tmdb": "2181581",
"tvdb": "8444132",
"locations": (
"The Last of Us - S01E01 - When You're Lost in the Darkness WEBDL-1080p.mkv",
),
}
]
}
}
movie_list = [
{
"title": "Coco",
"imdb": "tt2380307",
"tmdb": "354912",
"locations": ("Coco (2017) Remux-2160p.mkv", "Coco (2017) Remux-1080p.mkv"),
}
]
show_titles = {
"imdb": ["tt3581920"],
"locations": ["The Last of Us"],
"tmdb": ["100088"],
"tvdb": ["392256"],
}
episode_titles = {
"imdb": ["tt11957006"],
"locations": [
"The Last of Us - S01E01 - When You're Lost in the Darkness WEBDL-1080p.mkv"
],
"tmdb": ["2181581"],
"tvdb": ["8444132"],
}
movie_titles = {
"imdb": ["tt2380307"],
"locations": ["Coco (2017) Remux-2160p.mkv", "Coco (2017) Remux-1080p.mkv"],
"title": ["coco"],
"tmdb": ["354912"],
}
def test_check_skip_logic():
# Failes
library_title = "Test"
library_type = "movies"
skip_reason = check_skip_logic(
library_title,
library_type,
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
library_mapping,
)
assert skip_reason == "Test is not in whitelist_library"
library_title = "Shows"
library_type = "episodes"
skip_reason = check_skip_logic(
library_title,
library_type,
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
library_mapping,
)
assert (
skip_reason
== "episodes is in blacklist_library_type and TV Shows is in blacklist_library and "
+ "episodes is not in whitelist_library_type and Shows is not in whitelist_library"
)
# Passes
library_title = "Movie"
library_type = "movies"
skip_reason = check_skip_logic(
library_title,
library_type,
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
library_mapping,
)
assert skip_reason == None
def test_check_blacklist_logic():
# Fails
library_title = "Shows"
library_type = "episodes"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_blacklist_logic(
library_title,
library_type,
blacklist_library,
blacklist_library_type,
library_other,
)
assert (
skip_reason
== "episodes is in blacklist_library_type and TV Shows is in blacklist_library"
)
library_title = "TV Shows"
library_type = "episodes"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_blacklist_logic(
library_title,
library_type,
blacklist_library,
blacklist_library_type,
library_other,
)
assert (
skip_reason
== "episodes is in blacklist_library_type and TV Shows is in blacklist_library"
)
# Passes
library_title = "Movie"
library_type = "movies"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_blacklist_logic(
library_title,
library_type,
blacklist_library,
blacklist_library_type,
library_other,
)
assert skip_reason == None
library_title = "Movies"
library_type = "movies"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_blacklist_logic(
library_title,
library_type,
blacklist_library,
blacklist_library_type,
library_other,
)
assert skip_reason == None
def test_check_whitelist_logic():
# Fails
library_title = "Shows"
library_type = "episodes"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_whitelist_logic(
library_title,
library_type,
whitelist_library,
whitelist_library_type,
library_other,
)
assert (
skip_reason
== "episodes is not in whitelist_library_type and Shows is not in whitelist_library"
)
library_title = "TV Shows"
library_type = "episodes"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_whitelist_logic(
library_title,
library_type,
whitelist_library,
whitelist_library_type,
library_other,
)
assert (
skip_reason
== "episodes is not in whitelist_library_type and TV Shows is not in whitelist_library"
)
# Passes
library_title = "Movie"
library_type = "movies"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_whitelist_logic(
library_title,
library_type,
whitelist_library,
whitelist_library_type,
library_other,
)
assert skip_reason == None
library_title = "Movies"
library_type = "movies"
library_other = search_mapping(library_mapping, library_title)
skip_reason = check_whitelist_logic(
library_title,
library_type,
whitelist_library,
whitelist_library_type,
library_other,
)
assert skip_reason == None
def test_show_title_dict():
show_titles_dict = show_title_dict(show_list)
assert show_titles_dict == show_titles
def test_episode_title_dict():
episode_titles_dict = episode_title_dict(show_list)
assert episode_titles_dict == episode_titles
def test_movies_title_dict():
movies_titles_dict = movies_title_dict(movie_list)
assert movies_titles_dict == movie_titles
def test_generate_library_guids_dict():
# Test with shows
(
show_titles_dict,
episode_titles_dict,
movies_titles_dict,
) = generate_library_guids_dict(show_list)
assert show_titles_dict == show_titles
assert episode_titles_dict == episode_titles
assert movies_titles_dict == {}
# Test with movies
(
show_titles_dict,
episode_titles_dict,
movies_titles_dict,
) = generate_library_guids_dict(movie_list)
assert show_titles_dict == {}
assert episode_titles_dict == {}
assert movies_titles_dict == movie_titles

78
test/test_main.py Normal file
View File

@@ -0,0 +1,78 @@
import sys
import os
# getting the name of the directory
# where the this file is present.
current = os.path.dirname(os.path.realpath(__file__))
# Getting the parent directory name
# where the current directory is present.
parent = os.path.dirname(current)
# adding the parent directory to
# the sys.path.
sys.path.append(parent)
from src.black_white import setup_black_white_lists
def test_setup_black_white_lists():
# Simple
blacklist_library = "library1, library2"
whitelist_library = "library1, library2"
blacklist_library_type = "library_type1, library_type2"
whitelist_library_type = "library_type1, library_type2"
blacklist_users = "user1, user2"
whitelist_users = "user1, user2"
(
results_blacklist_library,
return_whitelist_library,
return_blacklist_library_type,
return_whitelist_library_type,
return_blacklist_users,
return_whitelist_users,
) = setup_black_white_lists(
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
blacklist_users,
whitelist_users,
)
assert results_blacklist_library == ["library1", "library2"]
assert return_whitelist_library == ["library1", "library2"]
assert return_blacklist_library_type == ["library_type1", "library_type2"]
assert return_whitelist_library_type == ["library_type1", "library_type2"]
assert return_blacklist_users == ["user1", "user2"]
assert return_whitelist_users == ["user1", "user2"]
# Library Mapping and user mapping
library_mapping = {"library1": "library3"}
user_mapping = {"user1": "user3"}
(
results_blacklist_library,
return_whitelist_library,
return_blacklist_library_type,
return_whitelist_library_type,
return_blacklist_users,
return_whitelist_users,
) = setup_black_white_lists(
blacklist_library,
whitelist_library,
blacklist_library_type,
whitelist_library_type,
blacklist_users,
whitelist_users,
library_mapping,
user_mapping,
)
assert results_blacklist_library == ["library1", "library2", "library3"]
assert return_whitelist_library == ["library1", "library2", "library3"]
assert return_blacklist_library_type == ["library_type1", "library_type2"]
assert return_whitelist_library_type == ["library_type1", "library_type2"]
assert return_blacklist_users == ["user1", "user2", "user3"]
assert return_whitelist_users == ["user1", "user2", "user3"]

View File

@@ -1,47 +0,0 @@
import sys
import os
# getting the name of the directory
# where the this file is present.
current = os.path.dirname(os.path.realpath(__file__))
# Getting the parent directory name
# where the current directory is present.
parent = os.path.dirname(current)
# adding the parent directory to
# the sys.path.
sys.path.append(parent)
from src.main import setup_black_white_lists
def test_setup_black_white_lists():
# Simple
blacklist_library = 'library1, library2'
whitelist_library = 'library1, library2'
blacklist_library_type = 'library_type1, library_type2'
whitelist_library_type = 'library_type1, library_type2'
blacklist_users = 'user1, user2'
whitelist_users = 'user1, user2'
results_blacklist_library, return_whitelist_library, return_blacklist_library_type, return_whitelist_library_type, return_blacklist_users, return_whitelist_users = setup_black_white_lists(blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, blacklist_users, whitelist_users)
assert results_blacklist_library == ['library1', 'library2']
assert return_whitelist_library == ['library1', 'library2']
assert return_blacklist_library_type == ['library_type1', 'library_type2']
assert return_whitelist_library_type == ['library_type1', 'library_type2']
assert return_blacklist_users == ['user1', 'user2']
assert return_whitelist_users == ['user1', 'user2']
# Library Mapping and user mapping
library_mapping = { "library1": "library3" }
user_mapping = { "user1": "user3" }
results_blacklist_library, return_whitelist_library, return_blacklist_library_type, return_whitelist_library_type, return_blacklist_users, return_whitelist_users = setup_black_white_lists(blacklist_library, whitelist_library, blacklist_library_type, whitelist_library_type, blacklist_users, whitelist_users, library_mapping, user_mapping)
assert results_blacklist_library == ['library1', 'library2', 'library3']
assert return_whitelist_library == ['library1', 'library2', 'library3']
assert return_blacklist_library_type == ['library_type1', 'library_type2']
assert return_whitelist_library_type == ['library_type1', 'library_type2']
assert return_blacklist_users == ['user1', 'user2', 'user3']
assert return_whitelist_users == ['user1', 'user2', 'user3']

View File

@@ -1,176 +0,0 @@
import sys
import os
# getting the name of the directory
# where the this file is present.
current = os.path.dirname(os.path.realpath(__file__))
# Getting the parent directory name
# where the current directory is present.
parent = os.path.dirname(current)
# adding the parent directory to
# the sys.path.
sys.path.append(parent)
from src.main import cleanup_watched
tv_shows_watched_list_1 = {
frozenset({("tvdb", "75710"), ("title", "Criminal Minds"), ("imdb", "tt0452046"), ("locations", ("Criminal Minds",)), ("tmdb", "4057")}): {
"Season 1": [
{'imdb': 'tt0550489', 'tmdb': '282843', 'tvdb': '176357', 'locations': ('Criminal Minds S01E01 Extreme Aggressor WEBDL-720p.mkv',)},
{'imdb': 'tt0550487', 'tmdb': '282861', 'tvdb': '300385', 'locations': ('Criminal Minds S01E02 Compulsion WEBDL-720p.mkv',)}
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [
{'locations': ('Test S01E01.mkv',)},
{'locations': ('Test S01E02.mkv',)}
]
}
}
movies_watched_list_1 = [
{"imdb":"tt2380307", "tmdb":"354912", 'title': 'Coco', 'locations': ('Coco (2017) Remux-1080p.mkv',)},
{"tmdbcollection":"448150", "imdb":"tt1431045", "tmdb":"293660", 'title': 'Deadpool', 'locations': ('Deadpool (2016) Remux-1080p.mkv',)},
]
tv_shows_watched_list_2 = {
frozenset({("tvdb", "75710"), ("title", "Criminal Minds"), ("imdb", "tt0452046"), ("locations", ("Criminal Minds",)), ("tmdb", "4057")}): {
"Season 1": [
{'imdb': 'tt0550487', 'tmdb': '282861', 'tvdb': '300385', 'locations': ('Criminal Minds S01E02 Compulsion WEBDL-720p.mkv',)},
{'imdb': 'tt0550498', 'tmdb': '282865', 'tvdb': '300474', 'locations': ("Criminal Minds S01E03 Won't Get Fooled Again WEBDL-720p.mkv",)}
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [
{'locations': ('Test S01E02.mkv',)},
{'locations': ('Test S01E03.mkv',)}
]
}
}
movies_watched_list_2 = [
{"imdb":"tt2380307", "tmdb":"354912", 'title': 'Coco', 'locations': ('Coco (2017) Remux-1080p.mkv',)},
{'imdb': 'tt0384793', 'tmdb': '9788', 'tvdb': '9103', 'title': 'Accepted', 'locations': ('Accepted (2006) Remux-1080p.mkv',)}
]
# Test to see if objects get deleted all the way up to the root.
tv_shows_2_watched_list_1 = {
frozenset({("tvdb", "75710"), ("title", "Criminal Minds"), ("imdb", "tt0452046"), ("locations", ("Criminal Minds",)), ("tmdb", "4057")}): {
"Season 1": [
{'imdb': 'tt0550489', 'tmdb': '282843', 'tvdb': '176357', 'locations': ('Criminal Minds S01E01 Extreme Aggressor WEBDL-720p.mkv',)},
]
}
}
expected_tv_show_watched_list_1 = {
frozenset({("tvdb", "75710"), ("title", "Criminal Minds"), ("imdb", "tt0452046"), ("locations", ("Criminal Minds",)), ("tmdb", "4057")}): {
"Season 1": [
{'imdb': 'tt0550489', 'tmdb': '282843', 'tvdb': '176357', 'locations': ('Criminal Minds S01E01 Extreme Aggressor WEBDL-720p.mkv',)}
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [
{'locations': ('Test S01E01.mkv',)}
]
}
}
expected_movie_watched_list_1 = [
{"tmdbcollection":"448150", "imdb":"tt1431045", "tmdb":"293660", 'title': 'Deadpool', 'locations': ('Deadpool (2016) Remux-1080p.mkv',)}
]
expected_tv_show_watched_list_2 = {
frozenset({("tvdb", "75710"), ("title", "Criminal Minds"), ("imdb", "tt0452046"), ("locations", ("Criminal Minds",)), ("tmdb", "4057")}): {
"Season 1": [
{'imdb': 'tt0550498', 'tmdb': '282865', 'tvdb': '300474', 'locations': ("Criminal Minds S01E03 Won't Get Fooled Again WEBDL-720p.mkv",)}
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [
{'locations': ('Test S01E03.mkv',)}
]
}
}
expected_movie_watched_list_2 = [
{'imdb': 'tt0384793', 'tmdb': '9788', 'tvdb': '9103', 'title': 'Accepted', 'locations': ('Accepted (2006) Remux-1080p.mkv',)}
]
def test_simple_cleanup_watched():
user_watched_list_1 = {
"user1": {
"TV Shows": tv_shows_watched_list_1,
"Movies": movies_watched_list_1,
"Other Shows": tv_shows_2_watched_list_1
},
}
user_watched_list_2 = {
"user1": {
"TV Shows": tv_shows_watched_list_2,
"Movies": movies_watched_list_2,
"Other Shows": tv_shows_2_watched_list_1
}
}
expected_watched_list_1 = {
"user1": {
"TV Shows": expected_tv_show_watched_list_1
, "Movies": expected_movie_watched_list_1
}
}
expected_watched_list_2 = {
"user1": {
"TV Shows": expected_tv_show_watched_list_2
, "Movies": expected_movie_watched_list_2
}
}
return_watched_list_1 = cleanup_watched(user_watched_list_1, user_watched_list_2)
return_watched_list_2 = cleanup_watched(user_watched_list_2, user_watched_list_1)
assert return_watched_list_1 == expected_watched_list_1
assert return_watched_list_2 == expected_watched_list_2
def test_mapping_cleanup_watched():
user_watched_list_1 = {
"user1": {
"TV Shows": tv_shows_watched_list_1,
"Movies": movies_watched_list_1,
"Other Shows": tv_shows_2_watched_list_1
},
}
user_watched_list_2 = {
"user2": {
"Shows": tv_shows_watched_list_2,
"Movies": movies_watched_list_2,
"Other Shows": tv_shows_2_watched_list_1
}
}
expected_watched_list_1 = {
"user1": {
"TV Shows": expected_tv_show_watched_list_1
, "Movies": expected_movie_watched_list_1
}
}
expected_watched_list_2 = {
"user2": {
"Shows": expected_tv_show_watched_list_2
, "Movies": expected_movie_watched_list_2
}
}
user_mapping = { "user1": "user2" }
library_mapping = { "TV Shows": "Shows" }
return_watched_list_1 = cleanup_watched(user_watched_list_1, user_watched_list_2, user_mapping=user_mapping, library_mapping=library_mapping)
return_watched_list_2 = cleanup_watched(user_watched_list_2, user_watched_list_1, user_mapping=user_mapping, library_mapping=library_mapping)
assert return_watched_list_1 == expected_watched_list_1
assert return_watched_list_2 == expected_watched_list_2

39
test/test_users.py Normal file
View File

@@ -0,0 +1,39 @@
import sys
import os
# getting the name of the directory
# where the this file is present.
current = os.path.dirname(os.path.realpath(__file__))
# Getting the parent directory name
# where the current directory is present.
parent = os.path.dirname(current)
# adding the parent directory to
# the sys.path.
sys.path.append(parent)
from src.users import (
combine_user_lists,
filter_user_lists,
)
def test_combine_user_lists():
server_1_users = ["test", "test3", "luigi311"]
server_2_users = ["luigi311", "test2", "test3"]
user_mapping = {"test2": "test"}
combined = combine_user_lists(server_1_users, server_2_users, user_mapping)
assert combined == {"luigi311": "luigi311", "test": "test2", "test3": "test3"}
def test_filter_user_lists():
users = {"luigi311": "luigi311", "test": "test2", "test3": "test3"}
blacklist_users = ["test3"]
whitelist_users = ["test", "luigi311"]
filtered = filter_user_lists(users, blacklist_users, whitelist_users)
assert filtered == {"test": "test2", "luigi311": "luigi311"}

410
test/test_watched.py Normal file
View File

@@ -0,0 +1,410 @@
import sys
import os
# getting the name of the directory
# where the this file is present.
current = os.path.dirname(os.path.realpath(__file__))
# Getting the parent directory name
# where the current directory is present.
parent = os.path.dirname(current)
# adding the parent directory to
# the sys.path.
sys.path.append(parent)
from src.watched import cleanup_watched, combine_watched_dicts
tv_shows_watched_list_1 = {
frozenset(
{
("tvdb", "75710"),
("title", "Criminal Minds"),
("imdb", "tt0452046"),
("locations", ("Criminal Minds",)),
("tmdb", "4057"),
}
): {
"Season 1": [
{
"imdb": "tt0550489",
"tmdb": "282843",
"tvdb": "176357",
"locations": (
"Criminal Minds S01E01 Extreme Aggressor WEBDL-720p.mkv",
),
},
{
"imdb": "tt0550487",
"tmdb": "282861",
"tvdb": "300385",
"locations": ("Criminal Minds S01E02 Compulsion WEBDL-720p.mkv",),
},
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [
{"locations": ("Test S01E01.mkv",)},
{"locations": ("Test S01E02.mkv",)},
]
},
}
movies_watched_list_1 = [
{
"imdb": "tt2380307",
"tmdb": "354912",
"title": "Coco",
"locations": ("Coco (2017) Remux-1080p.mkv",),
},
{
"tmdbcollection": "448150",
"imdb": "tt1431045",
"tmdb": "293660",
"title": "Deadpool",
"locations": ("Deadpool (2016) Remux-1080p.mkv",),
},
]
tv_shows_watched_list_2 = {
frozenset(
{
("tvdb", "75710"),
("title", "Criminal Minds"),
("imdb", "tt0452046"),
("locations", ("Criminal Minds",)),
("tmdb", "4057"),
}
): {
"Season 1": [
{
"imdb": "tt0550487",
"tmdb": "282861",
"tvdb": "300385",
"locations": ("Criminal Minds S01E02 Compulsion WEBDL-720p.mkv",),
},
{
"imdb": "tt0550498",
"tmdb": "282865",
"tvdb": "300474",
"locations": (
"Criminal Minds S01E03 Won't Get Fooled Again WEBDL-720p.mkv",
),
},
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [
{"locations": ("Test S01E02.mkv",)},
{"locations": ("Test S01E03.mkv",)},
]
},
}
movies_watched_list_2 = [
{
"imdb": "tt2380307",
"tmdb": "354912",
"title": "Coco",
"locations": ("Coco (2017) Remux-1080p.mkv",),
},
{
"imdb": "tt0384793",
"tmdb": "9788",
"tvdb": "9103",
"title": "Accepted",
"locations": ("Accepted (2006) Remux-1080p.mkv",),
},
]
# Test to see if objects get deleted all the way up to the root.
tv_shows_2_watched_list_1 = {
frozenset(
{
("tvdb", "75710"),
("title", "Criminal Minds"),
("imdb", "tt0452046"),
("locations", ("Criminal Minds",)),
("tmdb", "4057"),
}
): {
"Season 1": [
{
"imdb": "tt0550489",
"tmdb": "282843",
"tvdb": "176357",
"locations": (
"Criminal Minds S01E01 Extreme Aggressor WEBDL-720p.mkv",
),
},
]
}
}
expected_tv_show_watched_list_1 = {
frozenset(
{
("tvdb", "75710"),
("title", "Criminal Minds"),
("imdb", "tt0452046"),
("locations", ("Criminal Minds",)),
("tmdb", "4057"),
}
): {
"Season 1": [
{
"imdb": "tt0550489",
"tmdb": "282843",
"tvdb": "176357",
"locations": (
"Criminal Minds S01E01 Extreme Aggressor WEBDL-720p.mkv",
),
}
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [{"locations": ("Test S01E01.mkv",)}]
},
}
expected_movie_watched_list_1 = [
{
"tmdbcollection": "448150",
"imdb": "tt1431045",
"tmdb": "293660",
"title": "Deadpool",
"locations": ("Deadpool (2016) Remux-1080p.mkv",),
}
]
expected_tv_show_watched_list_2 = {
frozenset(
{
("tvdb", "75710"),
("title", "Criminal Minds"),
("imdb", "tt0452046"),
("locations", ("Criminal Minds",)),
("tmdb", "4057"),
}
): {
"Season 1": [
{
"imdb": "tt0550498",
"tmdb": "282865",
"tvdb": "300474",
"locations": (
"Criminal Minds S01E03 Won't Get Fooled Again WEBDL-720p.mkv",
),
}
]
},
frozenset({("title", "Test"), ("locations", ("Test",))}): {
"Season 1": [{"locations": ("Test S01E03.mkv",)}]
},
}
expected_movie_watched_list_2 = [
{
"imdb": "tt0384793",
"tmdb": "9788",
"tvdb": "9103",
"title": "Accepted",
"locations": ("Accepted (2006) Remux-1080p.mkv",),
}
]
def test_simple_cleanup_watched():
user_watched_list_1 = {
"user1": {
"TV Shows": tv_shows_watched_list_1,
"Movies": movies_watched_list_1,
"Other Shows": tv_shows_2_watched_list_1,
},
}
user_watched_list_2 = {
"user1": {
"TV Shows": tv_shows_watched_list_2,
"Movies": movies_watched_list_2,
"Other Shows": tv_shows_2_watched_list_1,
}
}
expected_watched_list_1 = {
"user1": {
"TV Shows": expected_tv_show_watched_list_1,
"Movies": expected_movie_watched_list_1,
}
}
expected_watched_list_2 = {
"user1": {
"TV Shows": expected_tv_show_watched_list_2,
"Movies": expected_movie_watched_list_2,
}
}
return_watched_list_1 = cleanup_watched(user_watched_list_1, user_watched_list_2)
return_watched_list_2 = cleanup_watched(user_watched_list_2, user_watched_list_1)
assert return_watched_list_1 == expected_watched_list_1
assert return_watched_list_2 == expected_watched_list_2
def test_mapping_cleanup_watched():
user_watched_list_1 = {
"user1": {
"TV Shows": tv_shows_watched_list_1,
"Movies": movies_watched_list_1,
"Other Shows": tv_shows_2_watched_list_1,
},
}
user_watched_list_2 = {
"user2": {
"Shows": tv_shows_watched_list_2,
"Movies": movies_watched_list_2,
"Other Shows": tv_shows_2_watched_list_1,
}
}
expected_watched_list_1 = {
"user1": {
"TV Shows": expected_tv_show_watched_list_1,
"Movies": expected_movie_watched_list_1,
}
}
expected_watched_list_2 = {
"user2": {
"Shows": expected_tv_show_watched_list_2,
"Movies": expected_movie_watched_list_2,
}
}
user_mapping = {"user1": "user2"}
library_mapping = {"TV Shows": "Shows"}
return_watched_list_1 = cleanup_watched(
user_watched_list_1,
user_watched_list_2,
user_mapping=user_mapping,
library_mapping=library_mapping,
)
return_watched_list_2 = cleanup_watched(
user_watched_list_2,
user_watched_list_1,
user_mapping=user_mapping,
library_mapping=library_mapping,
)
assert return_watched_list_1 == expected_watched_list_1
assert return_watched_list_2 == expected_watched_list_2
def test_combine_watched_dicts():
input_watched = [
{
"test3": {
"Anime Movies": [
{
"title": "Ponyo",
"tmdb": "12429",
"imdb": "tt0876563",
"locations": ("Ponyo (2008) Bluray-1080p.mkv",),
},
{
"title": "Spirited Away",
"tmdb": "129",
"imdb": "tt0245429",
"locations": ("Spirited Away (2001) Bluray-1080p.mkv",),
},
{
"title": "Castle in the Sky",
"tmdb": "10515",
"imdb": "tt0092067",
"locations": ("Castle in the Sky (1986) Bluray-1080p.mkv",),
},
]
}
},
{"test3": {"Anime Shows": {}}},
{"test3": {"Cartoon Shows": {}}},
{
"test3": {
"Shows": {
frozenset(
{
("tmdb", "64464"),
("tvdb", "301824"),
("tvrage", "45210"),
("title", "11.22.63"),
("locations", ("11.22.63",)),
("imdb", "tt2879552"),
}
): {
"Season 1": [
{
"imdb": "tt4460418",
"title": "The Rabbit Hole",
"locations": (
"11.22.63 S01E01 The Rabbit Hole Bluray-1080p.mkv",
),
}
]
}
}
}
},
{"test3": {"Subbed Anime": {}}},
]
expected = {
"test3": {
"Anime Movies": [
{
"title": "Ponyo",
"tmdb": "12429",
"imdb": "tt0876563",
"locations": ("Ponyo (2008) Bluray-1080p.mkv",),
},
{
"title": "Spirited Away",
"tmdb": "129",
"imdb": "tt0245429",
"locations": ("Spirited Away (2001) Bluray-1080p.mkv",),
},
{
"title": "Castle in the Sky",
"tmdb": "10515",
"imdb": "tt0092067",
"locations": ("Castle in the Sky (1986) Bluray-1080p.mkv",),
},
],
"Anime Shows": {},
"Cartoon Shows": {},
"Shows": {
frozenset(
{
("tmdb", "64464"),
("tvdb", "301824"),
("tvrage", "45210"),
("title", "11.22.63"),
("locations", ("11.22.63",)),
("imdb", "tt2879552"),
}
): {
"Season 1": [
{
"imdb": "tt4460418",
"title": "The Rabbit Hole",
"locations": (
"11.22.63 S01E01 The Rabbit Hole Bluray-1080p.mkv",
),
}
]
}
},
"Subbed Anime": {},
}
}
assert combine_watched_dicts(input_watched) == expected