Add encode profile for radarr

ansible/roles/beets/files/config.yaml

@@ -12,11 +12,13 @@ item_fields:
         
 import:
     write: yes
-    move: no
+    move: yes
-    quiet: yes
+    resume: ask
+    incremental: yes
+    quiet_fallback: skip
     timid: no
+    log: /config/beet.log
     languages: "en jp es"
-    autotag: yes
 
 asciify_paths: yes
 
@@ -37,8 +39,7 @@ match:
     ignored_media: ['12" Vinyl']
 
 lyrics:
-    auto: yes
+    sources: [lrclib, genius, tekstowo]
-    sources: [lrcmux]
     
 scrub:
     auto: yes

ansible/roles/lidarr/files/scripts_init.bash

@@ -0,0 +1,5 @@
+#!/usr/bin/with-contenv bash
+set -euo pipefail
+
+curl -sfL https://raw.githubusercontent.com/RandomNinjaAtk/arr-scripts/main/lidarr/setup.bash | bash
+exit

ansible/roles/lidarr/tasks/main.yml

@@ -26,12 +26,29 @@
 
 - name: Create data directory
   ansible.builtin.file:
-    path: "{{ data_dir }}/{{ role_name }}/config"
+    path: "{{ data_dir }}/{{ item }}"
     state: directory
     owner: "{{ service_user.uid }}"
     group: "{{ primary_gid }}"
     mode: "{{ docker_compose_directory_mask }}"
   become: true
+  loop:
+    - "{{ role_name }}/config"
+    - "{{ role_name }}/custom-services"
+    - "{{ role_name }}/custom-cont"
+
+- name: Copy arr-scripts init script
+  ansible.builtin.copy:
+    src: "scripts_init.bash"
+    dest: "{{ data_dir }}/{{ role_name }}/custom-cont"
+    owner: "{{ service_user.uid }}"
+    mode: 0564
+  become: true
+
+- name: Copy extended.conf
+  ansible.builtin.template:
+    src: "extended.conf"
+    dest: "{{ data_dir }}/{{ role_name }}/config"
 
 - name: Start docker container
   community.docker.docker_compose_v2:

ansible/roles/lidarr/templates/docker-compose.yml

@@ -17,6 +17,9 @@ services:
     volumes:
       - "{{ data_dir }}/{{ role_name }}/config:/config"
       - "{{ media_storage_mnt }}/data:/data"
+    # arr-scripts - https://github.com/RandomNinjaAtk/arr-scripts/blob/main/lidarr/readme.md
+      - "{{ data_dir }}/{{ role_name }}/custom-services:/custom-services.d"
+      - "{{ data_dir }}/{{ role_name }}/custom-cont:/custom-cont-init.d"
     labels:
       traefik.enable: true
       traefik.http.routers.{{ role_name }}.rule: "Host(`{{ role_name }}.local.{{ personal_domain }}`)"

ansible/roles/lidarr/templates/extended.conf

@@ -0,0 +1,89 @@
+##### LIDARR EXTENDED SCRIPTS SETTINGS #####
+
+##### PATHS
+downloadPath="/config/extended/downloads" # OPTIONAL, only change if needed.... Temporary Download Location for incoming Audio files from included clients
+importPath="/config/extended/import"      # OPTIONAL, only change if needed.... Completed downloads are stored here for the Usenet Blackhole client to import from. When Using queue cleaner, failed imports will be automatically cleaned up.
+videoPath=""                              # Final destination/location of completed Videos
+
+##### SCRIPT ENABLEMENT
+enableAutoConfig="true"            # true = enabled :: Automatically configures Lidarr with optimal settings
+enableAudio="true"                 # true = enabled :: Enables the Audio script to run automatically
+enableVideo="false"                 # true = enabled :: Enables the Video script to run automatically
+enableUnmappedFilesCleaner="false" # true = enabled :: Enables the UnmappedFilesCleaner script to run automatically
+enableQueueCleaner="true"          # true = enabled :: Enables the QueueCleaner script to run automatically
+
+##### SCRIPT INTERVALS
+audioScriptInterval=15m                 #s or #m or #h or #d :: s = seconds, m = minutes, h = hours, d = days :: Amount of time between each script run, when script is enabled
+videoScriptInterval=15m                 #s or #m or #h or #d :: s = seconds, m = minutes, h = hours, d = days :: Amount of time between each script run, when script is enabled
+autoArtistAdderInterval=12h             #s or #m or #h or #d :: s = seconds, m = minutes, h = hours, d = days :: Amount of time between each script run, when script is enabled
+unmappedFolderCleanerScriptInterval=15m #s or #m or #h or #d :: s = seconds, m = minutes, h = hours, d = days :: Amount of time between each script run, when script is enabled
+queueCleanerScriptInterval=15m          #s or #m or #h or #d :: s = seconds, m = minutes, h = hours, d = days :: Amount of time between each script run, when script is enabled
+
+##### AUTOCONFIG SCRIPT SETTINGS
+configureMediaManagement="true"               # Configures Lidarr Media Management Settings
+configureMetadataConsumerSettings="false"      # Configures Lidarr Metadata Consumer Settings
+configureMetadataProviderSettings="false"      # Configures Lidarr Metadata Provider Settings
+configureCustomScripts="true"                  # Adds custom scripts to Lidarr
+configureLidarrUiSettings="true"              # Configures Lidarr UI Settings
+configureMetadataProfileSettings="false"       # Configures Lidarr Metadata Profile Settings
+configureTrackNamingSettings="true"           # Configures Lidarr Track Naming Settings
+
+##### AUDIO SCRIPT
+# SEARCH
+searchSort="date"                 # date or album :: Sorts the missing/cutoff list by release date (newest -> oldest) or album type (album -> single) for processing the list
+matchDistance="3"                 # The number of changes required to transform the searched album title into a possible found album title match... (0, requires a perfect match)
+lidarrSearchForMissing="false"     # true = enabled :: When artists are added, search for them using Lidarr's built in functionality
+retryNotFound="90"                ## :: Number of days between re-attempting the download of previously notfound albums
+ignoreInstrumentalRelease="false" # true = enabled :: Skips albums releases that have the word "instrumental" in either the title or disambiguation
+preferSpecialEditions="true"      # true = enabled :: This changes the release title sort order, when true, it will search for releases with longest release names first, which are more likely to be deluxe/special versions...
+
+# CLIENT
+dlClientSource="deezer"                # deezer, tidal or both :: set to both, to use both clients, tidal requires extra steps, view logging output
+arlToken="{{ deezer_arl }}"                            # OPTIONAL (fallback using Freyr) - User ARL token for deemix client
+tidalCountryCode="US"                  # Country Code required for tidal
+failedDownloadAttemptThreshold="6"     # Maximum number of attempts to download a particular album ID from the service before considering it a failed download...
+deezerClientTestDownloadId="197472472" # A known good deezer track id that is used to test/verify the client is functioning in the event all download attempts have failed. Prevents the script from exiting...
+tidalClientTestDownloadId="166356219"  # A known good tidal track id that is used to test/verify the client is functioning in the event all download attempts have failed. Prevents the script from exiting...
+downloadClientTimeOut="10m"            # 's' for seconds (the default), 'm' for minutes, 'h' for hours or 'd' for days :: Kills freyr download client after the set timeout period, prevents lock ups...
+
+# QUALITY
+audioLyricType="both"   # both or explicit or clean :: both, is explicit preferred matching, explicit is explicit releases only matching and clean is clean releases only matching
+audioFormat="native"    # native or alac or mp3 or aac or opus :: native is the native download client file type, selected by the matching audio bit-rate
+audioBitrate="lossless" # master or lossless or high or low or ### :: master = MQA/lossless flac files, lossless = flac files, high = 320K, low = 128k/96k, ### = the output bit-rate of converted lossless files to selected audioFormat that is not native, example: 192...
+requireQuality="true"  # true = enabled :: Downloads will be checked for quality and require to have the requested file format & quality
+
+# POST PROCESSING
+enableBeetsTagging="true"   # true = enabled :: Downloads will be processed and tagged by Beets
+beetsMatchPercentage="90"   # 1-100 :: Set this to the minimum percentage required for Beets to match the downloaded album to a musicbrainz release :: Lower percentage is less restrictive
+enableReplaygainTags="true" # true = enabled :: Downloads will be tagged with ReplayGain Metadata
+
+# ADD ARTIST AUTOMATION
+addDeezerTopArtists="false"              # true = enabled :: Enabling this will enable the extended script to automatically add artists that are on the Deezer Top Artist Chart to your existing Lidarr instance
+addDeezerTopAlbumArtists="false"         # true = enabled :: Enabling this will enable the extended script to automatically add artists that are on the Deezer Top Album Chart to your existing Lidarr instance
+addDeezerTopTrackArtists="false"         # true = enabled :: Enabling this will enable the extended script to automatically add artists that are on the Deezer Top Track Chart to your existing Lidarr instance
+topLimit="3"                             # This setting controls the amount of Top Artist (Albums/Tracks/Artists) to add to Lidarr from Deezer
+addRelatedArtists="false"                # true = enabled :: WARNING !!! WARNING !!! Enabling this can cause an endless loop of additional artists.... Enabling this will enable the extended script to automatically add artists that are related to your existing Lidarr artists from Tidal & Deezer
+numberOfRelatedArtistsToAddPerArtist="1" # 1-20 :: This will limit the number of related artists to add per artist in your library :: Minimum is 1, Maximum is 20
+autoArtistAdderMonitored="true"          # true or false :: If true, artists that are added automatically are monitored, when false they are added in an unmonitored state
+preventRelatedArtistsLoop="true"         # true = enabled :: This will prevent added related artists from adding additional related artists, thus killing an endless loop. This works by using the Lidarr's tag system (arr-extended), Remove tag from artist to allow it to be proessed for related artists...
+
+##### VIDEO SCRIPT
+addFeaturedVideoArtists="false"  # true = enabled :: WARNING !!! WARNING !!! Enabling this can cause an endless loop of additional artists.... Enabling this will enable the extended Video script to automatically add Music Video Featured Artists to your existing Lidarr artists from IMVDB
+videoFormat="bv[width>=1920]+ba" # ONLY CHANGE if you know what your doing, for guidence, please see yt-dlp documentation.
+videoInfoJson="false"            # true = enabled :: Stores yt-dlp info-json files alongside video files.
+youtubeSubtitleLanguage="en"     # Desired Language Code :: For guidence, please see yt-dlp documentation.
+disableImvd="false"              # true = enabled :: Use this to disable IMVDB as a source, will result in only tidal videos
+
+##### DEEZER ARLCHECKER
+arlUpdateInterval="24h"   # Interval to check ARL Validity (default 24 hours). Reboot container after changing. s = seconds, m = minutes, h = hours, d = days
+telegramBotEnable="false" # Enable/Disable  Telegram Bot to notify if ARL expires. Otherwise check text file in custom-services.d/python for status.
+telegramBotToken=""       # Get token from BotFather during bot creation. If you use a notify channel for Lidarr, you can probably use the same bot, as this script only takes temporary control.
+telegramUserChatID=""     # Get your userid by chatting: t.me/userinfobot
+pushoverEnable="false"    # Pushover Notification Support
+pushoverUserKey=""
+pushoverAppAPIKey=""
+ntfyEnable="false"        # ntfy Notification Support
+ntfyServerTopic=""        # Put your server + topic address ex: https://ntfy.mydomain.com/lidarr
+ntfyUserToken=""          # create a new user token using the ntfy cli commands. See ntfy documentation on how to do that.
+
+

ansible/roles/qbittorrent/templates/docker-compose.yml

@@ -5,7 +5,7 @@ networks:
 services:
   qbittorrent:
     container_name: qbittorrent
-    image: lscr.io/linuxserver/qbittorrent:5.2.3
+    image: lscr.io/linuxserver/qbittorrent:5.1.4
     restart: unless-stopped
     network_mode: "container:gluetun"
     environment:

ansible/roles/recyclarr/files/includes/sonarr-web-qualities.yml

@@ -8,24 +8,12 @@ quality_profiles:
     score_set: default
     quality_sort: top
     qualities:
-      - name: 'WEB 2160p'
+      - name: WEB 2160p
         qualities:
           - WEBDL-2160p
           - WEBRip-2160p
-      - name: 'WEB 1080p'
+      - name: Bluray-1080p
+      - name: WEB 1080p
         qualities:
           - WEBDL-1080p
           - WEBRip-1080p
-      - name: HDTV-2160p
-      - name: Bluray-720p
-      - name: 'WEB 720p' 
-        qualities:
-          - WEBDL-720p
-          - WEBRip-720p
-      - name: HDTV-1080p
-      - name: HDTV-720p
-      - name: 'WEB 480p'
-        qualities:
-          - WEBDL-480p
-          - WEBRip-480p
-      - name: SDTV

ansible/roles/recyclarr/files/includes/sonarr-web_season_pack-qualities.yml

@@ -8,24 +8,12 @@ quality_profiles:
     score_set: default
     quality_sort: top
     qualities:
-      - name: 'WEB 2160p'
+      - name: WEB 2160p
         qualities:
           - WEBDL-2160p
           - WEBRip-2160p
-      - name: 'WEB 1080p'
+      - name: Bluray-1080p
+      - name: WEB 1080p
         qualities:
           - WEBDL-1080p
           - WEBRip-1080p
-      - name: HDTV-2160p
-      - name: Bluray-720p
-      - name: 'WEB 720p' 
-        qualities:
-          - WEBDL-720p
-          - WEBRip-720p
-      - name: HDTV-1080p
-      - name: HDTV-720p
-      - name: 'WEB 480p'
-        qualities:
-          - WEBDL-480p
-          - WEBRip-480p
-      - name: SDTV

ansible/roles/recyclarr/templates/docker-compose.yml

@@ -6,7 +6,7 @@ networks:
 services:
   recyclarr:
     container_name: recyclarr
-    image: ghcr.io/recyclarr/recyclarr:8
+    image: ghcr.io/recyclarr/recyclarr:7
     restart: unless-stopped
     security_opt: ['no-new-privileges:true'] # Prevents privilege escalation - https://recyclarr.dev/wiki/installation/docker/#prevent-in-container-privilege-escalation
     user: "{{ service_user.uid }}:{{ service_user.uid }}"

ansible/roles/recyclarr/templates/radarr.yml

@@ -17,10 +17,6 @@ radarr:
       # Remux
       - config: radarr-remux-qualities.yml
       - config: radarr-remux-custom_formats.yml
-    
-      # Encode
-      - config: radarr-encode-qualities.yml
-      - config: radarr-encode-custom_formats.yml
 
       # Web
       - config: radarr-web-qualities.yml

ansible/roles/searxng/files/hostnames/blacklist.yml

@@ -1 +0,0 @@
-'(.*\.)?pinterest.com$'

ansible/roles/searxng/tasks/main.yml

@@ -23,14 +23,6 @@
   become: true
   notify: restart searxng
 
-- name: Copy hostname lists to destination
-  copy:
-    src: hostnames/
-    dest: "{{ data_dir }}/{{ role_name }}/"
-    owner: "{{ docker_user }}"
-  become: true
-  notify: restart searxng
-
 - name: Start docker container
   community.docker.docker_compose_v2:
     project_src: "{{ install_directory }}/{{ role_name }}"

ansible/roles/searxng/templates/docker-compose.yml

@@ -6,11 +6,10 @@ networks:
 services:
   searxng:
     container_name: searxng
-    image: ghcr.io/searxng/searxng
+    image: searxng/searxng
     restart: unless-stopped
     networks:
       - traefik
-      - default
     volumes:
       - "{{ data_dir }}/{{ role_name }}:/etc/searxng"
     cap_drop:
@@ -22,7 +21,7 @@ services:
     labels:
       traefik.enable: true
       traefik.http.routers.searxng.rule: "Host(`search.{{ personal_domain }}`)"
-      traefik.http.routers.searxng.middlewares: lan-whitelist@file
+        #traefik.http.routers.searxng.middlewares: lan-whitelist@file
 
   redis:
     image: redis:alpine

ansible/roles/tautulli/files/kill_stream.py

@@ -0,0 +1,639 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+"""
+Description: Use conditions to kill a stream
+Author: Blacktwin, Arcanemagus, Samwiseg0, JonnyWong16, DirtyCajunRice
+
+Adding the script to Tautulli:
+Tautulli > Settings > Notification Agents > Add a new notification agent >
+ Script
+
+Configuration:
+Tautulli > Settings > Notification Agents > New Script > Configuration:
+
+ Script Folder: /path/to/your/scripts
+ Script File: ./kill_stream.py (Should be selectable in a dropdown list)
+ Script Timeout: {timeout}
+ Description: Kill stream(s)
+ Save
+
+Triggers:
+Tautulli > Settings > Notification Agents > New Script > Triggers:
+
+ Check: Playback Start and/or Playback Pause
+ Save
+
+Conditions:
+Tautulli > Settings > Notification Agents > New Script > Conditions:
+
+ Set Conditions: [{condition} | {operator} | {value} ]
+ Save
+
+Script Arguments:
+Tautulli > Settings > Notification Agents > New Script > Script Arguments:
+
+ Select: Playback Start, Playback Pause
+ Arguments: --jbop SELECTOR --userId {user_id} --username {username}
+            --sessionId {session_id} --notify notifierID
+            --interval 30 --limit 1200
+            --richMessage RICH_TYPE --serverName {server_name}
+            --plexUrl {plex_url} --posterUrl {poster_url}
+            --richColor '#E5A00D'
+            --killMessage 'Your message here.'
+
+ Save
+ Close
+"""
+from __future__ import print_function
+from __future__ import unicode_literals
+
+
+from builtins import object
+from builtins import str
+import os
+import sys
+import json
+import time
+import argparse
+from datetime import datetime
+from requests import Session
+from requests.adapters import HTTPAdapter
+from requests.exceptions import RequestException
+
+
+TAUTULLI_URL = ''
+TAUTULLI_APIKEY = ''
+TAUTULLI_PUBLIC_URL = ''
+TAUTULLI_URL = os.getenv('TAUTULLI_URL', TAUTULLI_URL)
+TAUTULLI_PUBLIC_URL = os.getenv('TAUTULLI_PUBLIC_URL', TAUTULLI_PUBLIC_URL)
+TAUTULLI_APIKEY = os.getenv('TAUTULLI_APIKEY', TAUTULLI_APIKEY)
+TAUTULLI_ENCODING = os.getenv('TAUTULLI_ENCODING', 'UTF-8')
+VERIFY_SSL = False
+
+if TAUTULLI_PUBLIC_URL != '/':
+    # Check to see if there is a public URL set in Tautulli
+    TAUTULLI_LINK = TAUTULLI_PUBLIC_URL
+else:
+    TAUTULLI_LINK = TAUTULLI_URL
+
+SUBJECT_TEXT = "Tautulli has killed a stream."
+BODY_TEXT = "Killed session ID '{id}'. Reason: {message}"
+BODY_TEXT_USER = "Killed {user}'s stream. Reason: {message}."
+
+
+SELECTOR = ['stream', 'allStreams', 'paused']
+
+RICH_TYPE = ['discord', 'slack']
+
+TAUTULLI_ICON = 'https://github.com/Tautulli/Tautulli/raw/master/data/interfaces/default/images/logo-circle.png'
+
+
+def utc_now_iso():
+    """Get current time in ISO format"""
+    utcnow = datetime.utcnow()
+
+    return utcnow.isoformat()
+
+
+def hex_to_int(value):
+    """Convert hex value to integer"""
+    try:
+        return int(value, 16)
+    except (ValueError, TypeError):
+        return 0
+
+
+def arg_decoding(arg):
+    """Decode args, encode UTF-8"""
+    if sys.version_info[0] < 3:
+        return arg.decode(TAUTULLI_ENCODING).encode('UTF-8')
+    else:
+        return arg
+
+
+def debug_dump_vars():
+    """Dump parameters for debug"""
+    print('Tautulli URL - ' + TAUTULLI_URL)
+    print('Tautulli Public URL - ' + TAUTULLI_PUBLIC_URL)
+    print('Verify SSL - ' + str(VERIFY_SSL))
+    print('Tautulli API key - ' + TAUTULLI_APIKEY[-4:]
+          .rjust(len(TAUTULLI_APIKEY), "x"))
+
+
+def get_all_streams(tautulli, user_id=None):
+    """Get a list of all current streams.
+
+    Parameters
+    ----------
+    user_id : int
+        The ID of the user to grab sessions for.
+    tautulli : obj
+        Tautulli object.
+    Returns
+    -------
+    objects
+        The of stream objects.
+    """
+    sessions = tautulli.get_activity()['sessions']
+
+    if user_id:
+        streams = [Stream(session=s) for s in sessions if s['user_id'] == user_id]
+    else:
+        streams = [Stream(session=s) for s in sessions]
+
+    return streams
+
+
+def notify(all_opts, message, kill_type=None, stream=None, tautulli=None):
+    """Decides which notifier type to use"""
+    if all_opts.notify and all_opts.richMessage:
+        rich_notify(all_opts.notify, all_opts.richMessage, all_opts.richColor, kill_type,
+                    all_opts.serverName, all_opts.plexUrl, all_opts.posterUrl, message, stream, tautulli)
+    elif all_opts.notify:
+        basic_notify(all_opts.notify, all_opts.sessionId, all_opts.username, message, stream, tautulli)
+
+
+def rich_notify(notifier_id, rich_type, color=None, kill_type=None, server_name=None,
+                plex_url=None, poster_url=None, message=None, stream=None, tautulli=None):
+    """Decides which rich notifier type to use. Set default values for empty variables
+
+    Parameters
+    ----------
+    notifier_id : int
+        The ID of the user to grab sessions for.
+    rich_type : str
+        Contains 'discord' or 'slack'.
+    color : Union[int, str]
+        Hex string or integer representation of color.
+    kill_type : str
+        The kill type used.
+    server_name : str
+        The name of the plex server.
+    plex_url : str
+        Plex media URL.
+    poster_url : str
+        The media poster URL.
+    message : str
+        Message sent to the client.
+    stream : obj
+        Stream object.
+    tautulli : obj
+        Tautulli object.
+    """
+    notification = Notification(notifier_id, None, None, tautulli, stream)
+    # Initialize Variables
+    title = ''
+    footer = ''
+    # Set a default server_name if none is provided
+    if server_name is None:
+        server_name = 'Plex Server'
+
+    # Set a default color if none is provided
+    if color is None:
+        color = '#E5A00D'
+
+    # Set a default plexUrl if none is provided
+    if plex_url is None:
+        plex_url = 'https://app.plex.tv'
+
+    # Set a default posterUrl if none is provided
+    if poster_url is None:
+        poster_url = TAUTULLI_ICON
+
+    # Set a default message if none is provided
+    if message is None:
+        message = 'The server owner has ended the stream.'
+
+    if kill_type == 'Stream':
+        title = "Killed {}'s stream.".format(stream.friendly_name)
+        footer = '{} | Kill {}'.format(server_name, kill_type)
+
+    elif kill_type == 'Paused':
+        title = "Killed {}'s paused stream.".format(stream.friendly_name)
+        footer = '{} | Kill {}'.format(server_name, kill_type)
+
+    elif kill_type == 'All Streams':
+        title = "Killed {}'s stream.".format(stream.friendly_name)
+        footer = '{} | Kill {}'.format(server_name, kill_type)
+        poster_url = TAUTULLI_ICON
+        plex_url = 'https://app.plex.tv'
+
+    if rich_type == 'discord':
+        color = hex_to_int(color.lstrip('#'))
+        notification.send_discord(title, color, poster_url, plex_url, message, footer)
+
+    elif rich_type == 'slack':
+        notification.send_slack(title, color, poster_url, plex_url, message, footer)
+
+
+def basic_notify(notifier_id, session_id, username=None, message=None, stream=None, tautulli=None):
+    """Basic notifier"""
+    notification = Notification(notifier_id, SUBJECT_TEXT, BODY_TEXT, tautulli, stream)
+
+    if username:
+        body = BODY_TEXT_USER.format(user=username,
+                                     message=message)
+    else:
+        body = BODY_TEXT.format(id=session_id, message=message)
+    notification.send(SUBJECT_TEXT, body)
+
+
+class Tautulli(object):
+    def __init__(self, url, apikey, verify_ssl=False, debug=None):
+        self.url = url
+        self.apikey = apikey
+        self.debug = debug
+
+        self.session = Session()
+        self.adapters = HTTPAdapter(max_retries=3,
+                                    pool_connections=1,
+                                    pool_maxsize=1,
+                                    pool_block=True)
+        self.session.mount('http://', self.adapters)
+        self.session.mount('https://', self.adapters)
+
+        # Ignore verifying the SSL certificate
+        if verify_ssl is False:
+            self.session.verify = False
+            # Disable the warning that the request is insecure, we know that...
+            import urllib3
+            urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
+
+    def _call_api(self, cmd, payload, method='GET'):
+        payload['cmd'] = cmd
+        payload['apikey'] = self.apikey
+
+        try:
+            response = self.session.request(method, self.url + '/api/v2', params=payload)
+        except RequestException as e:
+            print("Tautulli request failed for cmd '{}'. Invalid Tautulli URL? Error: {}".format(cmd, e))
+            if self.debug:
+                traceback.print_exc()
+            return
+
+        try:
+            response_json = response.json()
+        except ValueError:
+            print(
+                "Failed to parse json response for Tautulli API cmd '{}': {}"
+                .format(cmd, response.content))
+            return
+
+        if response_json['response']['result'] == 'success':
+            if self.debug:
+                print("Successfully called Tautulli API cmd '{}'".format(cmd))
+            return response_json['response']['data']
+        else:
+            error_msg = response_json['response']['message']
+            print("Tautulli API cmd '{}' failed: {}".format(cmd, error_msg))
+            return
+
+    def get_activity(self, session_key=None, session_id=None):
+        """Call Tautulli's get_activity api endpoint"""
+        payload = {}
+
+        if session_key:
+            payload['session_key'] = session_key
+        elif session_id:
+            payload['session_id'] = session_id
+
+        return self._call_api('get_activity', payload)
+
+    def notify(self, notifier_id, subject, body):
+        """Call Tautulli's notify api endpoint"""
+        payload = {'notifier_id': notifier_id,
+                   'subject': subject,
+                   'body': body}
+
+        return self._call_api('notify', payload)
+
+    def terminate_session(self, session_key=None, session_id=None, message=''):
+        """Call Tautulli's terminate_session api endpoint"""
+        payload = {}
+
+        if session_key:
+            payload['session_key'] = session_key
+        elif session_id:
+            payload['session_id'] = session_id
+
+        if message:
+            payload['message'] = message
+
+        return self._call_api('terminate_session', payload)
+
+
+class Stream(object):
+    def __init__(self, session_id=None, user_id=None, username=None, tautulli=None, session=None):
+        self.state = None
+        self.ip_address = None
+        self.session_id = session_id
+        self.user_id = user_id
+        self.username = username
+        self.session_exists = False
+        self.tautulli = tautulli
+
+        if session is not None:
+            self._set_stream_attributes(session)
+
+    def _set_stream_attributes(self, session):
+        for k, v in session.items():
+            setattr(self, k, v)
+
+    def get_all_stream_info(self):
+        """Get all stream info from Tautulli."""
+        session = self.tautulli.get_activity(session_id=self.session_id)
+        if session:
+            self._set_stream_attributes(session)
+            self.session_exists = True
+        else:
+            self.session_exists = False
+
+    def terminate(self, message=''):
+        """Calls Tautulli to terminate the session.
+
+        Parameters
+        ----------
+        message : str
+            The message to use if the stream is terminated.
+        """
+        self.tautulli.terminate_session(session_id=self.session_id, message=message)
+
+    def terminate_long_pause(self, message, limit, interval):
+        """Kills the session if it is paused for longer than <limit> seconds.
+
+        Parameters
+        ----------
+        message : str
+            The message to use if the stream is terminated.
+        limit : int
+            The number of seconds the session is allowed to remain paused before it
+            is terminated.
+        interval : int
+            The amount of time to wait between checks of the session state.
+        """
+        start = datetime.now()
+        checked_time = 0
+        # Continue checking 2 intervals past the allowed limit in order to
+        # account for system variances.
+        check_limit = limit + (interval * 2)
+
+        while checked_time < check_limit:
+            self.get_all_stream_info()
+
+            if self.session_exists is False:
+                sys.stdout.write(
+                    "Session '{}'  from user '{}' is no longer active "
+                    .format(self.session_id, self.username) +
+                    "on the server, stopping monitoring.\n")
+                return False
+
+            now = datetime.now()
+            checked_time = (now - start).total_seconds()
+
+            if self.state == 'paused':
+                if checked_time >= limit:
+                    self.terminate(message)
+                    sys.stdout.write(
+                        "Session '{}' from user '{}' has been killed.\n"
+                        .format(self.session_id, self.username))
+                    return True
+                else:
+                    time.sleep(interval)
+
+            elif self.state == 'playing' or self.state == 'buffering':
+                sys.stdout.write(
+                    "Session '{}' from user '{}' has been resumed, "
+                    .format(self.session_id, self.username) +
+                    "stopping monitoring.\n")
+                return False
+
+
+class Notification(object):
+    def __init__(self, notifier_id, subject, body, tautulli, stream):
+        self.notifier_id = notifier_id
+        self.subject = subject
+        self.body = body
+
+        self.tautulli = tautulli
+        self.stream = stream
+
+    def send(self, subject='', body=''):
+        """Send to Tautulli notifier.
+
+        Parameters
+        ----------
+        subject : str
+            Subject of the message.
+        body : str
+            Body of the message.
+        """
+        subject = subject or self.subject
+        body = body or self.body
+        self.tautulli.notify(notifier_id=self.notifier_id, subject=subject, body=body)
+
+    def send_discord(self, title, color, poster_url, plex_url, message, footer):
+        """Build the Discord message.
+
+        Parameters
+        ----------
+        title : str
+            The title of the message.
+        color : int
+            The color of the message
+        poster_url : str
+            The media poster URL.
+        plex_url : str
+            Plex media URL.
+        message : str
+            Message sent to the player.
+        footer : str
+            Footer of the message.
+        """
+        discord_message = {
+            "embeds": [
+                {
+                    "author": {
+                        "icon_url": TAUTULLI_ICON,
+                        "name": "Tautulli",
+                        "url": TAUTULLI_LINK.rstrip('/')
+                    },
+                    "color": color,
+                    "fields": [
+                        {
+                            "inline": True,
+                            "name": "User",
+                            "value": self.stream.friendly_name
+                        },
+                        {
+                            "inline": True,
+                            "name": "Session Key",
+                            "value": self.stream.session_key
+                        },
+                        {
+                            "inline": True,
+                            "name": "Watching",
+                            "value": self.stream.full_title
+                        },
+                        {
+                            "inline": False,
+                            "name": "Message Sent",
+                            "value": message
+                        }
+                    ],
+                    "thumbnail": {
+                        "url": poster_url
+                    },
+                    "title": title,
+                    "timestamp": utc_now_iso(),
+                    "url": plex_url,
+                    "footer": {
+                        "text": footer
+                    }
+
+                }
+
+            ],
+        }
+
+        discord_message = json.dumps(discord_message, sort_keys=True,
+                                     separators=(',', ': '))
+        self.send(body=discord_message)
+
+    def send_slack(self, title, color, poster_url, plex_url, message, footer):
+        """Build the Slack message.
+
+        Parameters
+        ----------
+        title : str
+            The title of the message.
+        color : int
+            The color of the message
+        poster_url : str
+            The media poster URL.
+        plex_url : str
+            Plex media URL.
+        message : str
+            Message sent to the player.
+        footer : str
+            Footer of the message.
+        """
+        slack_message = {
+            "attachments": [
+                {
+                    "title": title,
+                    "title_link": plex_url,
+                    "author_icon": TAUTULLI_ICON,
+                    "author_name": "Tautulli",
+                    "author_link": TAUTULLI_LINK.rstrip('/'),
+                    "color": color,
+                    "fields": [
+                        {
+                            "title": "User",
+                            "value": self.stream.friendly_name,
+                            "short": True
+                        },
+                        {
+                            "title": "Session Key",
+                            "value": self.stream.session_key,
+                            "short": True
+                        },
+                        {
+                            "title": "Watching",
+                            "value": self.stream.full_title,
+                            "short": True
+                        },
+                        {
+                            "title": "Message Sent",
+                            "value": message,
+                            "short": False
+                        }
+                    ],
+                    "thumb_url": poster_url,
+                    "footer": footer,
+                    "ts": time.time()
+                }
+
+            ],
+        }
+
+        slack_message = json.dumps(slack_message, sort_keys=True,
+                                   separators=(',', ': '))
+        self.send(body=slack_message)
+
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser(
+        description="Killing Plex streams from Tautulli.")
+    parser.add_argument('--jbop', required=True, choices=SELECTOR,
+                        help='Kill selector.\nChoices: (%(choices)s)')
+    parser.add_argument('--userId', type=int,
+                        help='The unique identifier for the user.')
+    parser.add_argument('--username', type=arg_decoding,
+                        help='The username of the person streaming.')
+    parser.add_argument('--sessionId',
+                        help='The unique identifier for the stream.')
+    parser.add_argument('--notify', type=int,
+                        help='Notification Agent ID number to Agent to ' +
+                        'send notification.')
+    parser.add_argument('--limit', type=int, default=(20 * 60),  # 20 minutes
+                        help='The time session is allowed to remain paused.')
+    parser.add_argument('--interval', type=int, default=30,
+                        help='The seconds between paused session checks.')
+    parser.add_argument('--killMessage', nargs='+', type=arg_decoding,
+                        help='Message to send to user whose stream is killed.')
+    parser.add_argument('--richMessage', type=arg_decoding, choices=RICH_TYPE,
+                        help='Rich message type selector.\nChoices: (%(choices)s)')
+    parser.add_argument('--serverName', type=arg_decoding,
+                        help='Plex Server Name')
+    parser.add_argument('--plexUrl', type=arg_decoding,
+                        help='URL to plex media')
+    parser.add_argument('--posterUrl', type=arg_decoding,
+                        help='Poster URL of the media')
+    parser.add_argument('--richColor', type=arg_decoding,
+                        help='Color of the rich message')
+    parser.add_argument("--debug", action='store_true',
+                        help='Enable debug messages.')
+
+    opts = parser.parse_args()
+
+    if not opts.sessionId and opts.jbop != 'allStreams':
+        sys.stderr.write("No sessionId provided! Is this synced content?\n")
+        sys.exit(1)
+
+    if opts.debug:
+        # Import traceback to get more detailed information
+        import traceback
+        # Dump the ENVs passed from tautulli
+        debug_dump_vars()
+
+    # Create a Tautulli instance
+    tautulli_server = Tautulli(TAUTULLI_URL.rstrip('/'), TAUTULLI_APIKEY, VERIFY_SSL, opts.debug)
+
+    # Create initial Stream object with basic info
+    tautulli_stream = Stream(opts.sessionId, opts.userId, opts.username, tautulli_server)
+
+    # Only pull all stream info if using richMessage
+    if opts.notify and opts.richMessage:
+        tautulli_stream.get_all_stream_info()
+
+    # Set a default message if none is provided
+    if opts.killMessage:
+        kill_message = ' '.join(opts.killMessage)
+    else:
+        kill_message = 'The server owner has ended the stream.'
+
+    if opts.jbop == 'stream':
+        tautulli_stream.terminate(kill_message)
+        notify(opts, kill_message, 'Stream', tautulli_stream, tautulli_server)
+
+    elif opts.jbop == 'allStreams':
+        all_streams = get_all_streams(tautulli_server, opts.userId)
+        for a_stream in all_streams:
+            tautulli_server.terminate_session(session_id=a_stream.session_id, message=kill_message)
+            notify(opts, kill_message, 'All Streams', a_stream, tautulli_server)
+
+    elif opts.jbop == 'paused':
+        killed_stream = tautulli_stream.terminate_long_pause(kill_message, opts.limit, opts.interval)
+        if killed_stream:
+            notify(opts, kill_message, 'Paused', tautulli_stream, tautulli_server)

ansible/roles/tautulli/tasks/main.yml

@@ -1,3 +1,10 @@
+- name: Create service user
+  user:
+    name: "{{ role_name }}"
+    system: true
+  register: service_user
+  become: true
+
 - name: Create install directory
   file:
     path: "{{ install_directory }}/{{ role_name }}"
@@ -15,6 +22,16 @@
     validate: docker compose -f %s config
   become: true
 
+- name: Install script files
+  ansible.builtin.copy:
+    src: "{{ item }}"
+    dest: "{{ data_dir }}/tautulli/scripts"
+    mode: "{{ docker_compose_file_mask }}"
+    owner: "{{ primary_user }}"
+  with_fileglob:
+    - "files/*"
+  become: true
+
 - name: Start docker container
   community.docker.docker_compose_v2:
     project_src: "{{ install_directory }}/{{ role_name }}"

ansible/roles/tautulli/templates/docker-compose.yml

@@ -0,0 +1,22 @@
+
+networks:
+  traefik:
+    external: true
+
+services:
+  tautulli:
+    container_name: "tautulli"
+    image: lscr.io/linuxserver/tautulli:latest
+    restart: unless-stopped
+    networks:
+      - traefik
+    environment:
+      - "PUID={{ service_user.uid }}"
+      - "PGID={{ service_user.uid }}"
+      - "TZ={{ timezone }}"
+    volumes:
+      - "{{ data_dir }}/{{ role_name }}:/config"
+    labels:
+      traefik.enable: true
+      traefik.http.routers.tautulli.rule: "Host(`tautulli.local.{{ personal_domain }}`)"
+      traefik.http.routers.tautulli.middlewares: lan-whitelist@file

ansible/roles/tracearr/templates/docker-compose.yml

@@ -1,19 +0,0 @@
-networks:
-  traefik:
-    external: true
-
-services:
-  tracearr:
-    container_name: "tracearr"
-    image: ghcr.io/connorgallopo/tracearr:supervised
-    restart: unless-stopped
-    networks:
-      - traefik
-    environment:
-      - "TZ={{ timezone }}"
-    volumes:
-      - "{{ data_dir }}/{{ role_name }}:/data"
-    labels:
-      traefik.enable: true
-      traefik.http.routers.tracearr.rule: "Host(`{{ role_name }}.local.{{ personal_domain }}`)"
-      traefik.http.routers.tracearr.middlewares: lan-whitelist@file

ansible/roles/traefik/templates/conf/file-provider-lubelogger.yml

@@ -1,11 +0,0 @@
-http:
-  routers:
-    router-lubelogger:
-      rule: "Host(`lubelogger.local.{{ personal_domain }}`)"
-      service: service-lubelogger
-
-  services:
-    service-lubelogger:
-      loadBalancer:
-        servers:
-          - url: http://arch-web:5000

ansible/roles/traefik/templates/conf/file-provider-redlib.yml

@@ -1,11 +0,0 @@
-http:
-  routers:
-    router-redlib:
-      rule: "Host(`redlib.local.{{ personal_domain }}`)"
-      service: service-redlib
-
-  services:
-    service-redlib:
-      loadBalancer:
-        servers:
-          - url: http://arch-web:13225

ansible/roles/traefik/templates/docker-compose.yml

@@ -7,7 +7,7 @@ networks:
 services:
   traefik:
     container_name: traefik
-    image: traefik:latest
+    image: traefik:v3.1
     depends_on:
       docker_socket_proxy:
         condition: service_healthy