Format settings example

Co-authored-by: aider (gemini/gemini-2.5-pro) <aider@aider.chat>

main.py

@@ -4,6 +4,7 @@ logging.basicConfig(
         format='[%(asctime)s] %(levelname)s %(module)s/%(funcName)s - %(message)s',
         level=logging.DEBUG if DEBUG else logging.INFO)
 
+import argparse
 import hashlib
 import random
 import string
@@ -37,9 +38,14 @@ def run_pls_command(playlist_id):
         return ""
 
 
+def sanitize_for_filename(name):
+    """Sanitizes a string to be safe as a filename component."""
+    return name.replace('/', '_').replace('\\', '_')
+
+
 def save_playlist_file(playlist_dir, playlist_name, content):
     """Saves the transformed playlist content to a file."""
-    filename = f"{playlist_name}.m3u8"
+    filename = f"{sanitize_for_filename(playlist_name)}.m3u8"
     filepath = os.path.join(playlist_dir, filename)
     try:
         with open(filepath, 'w', encoding='utf-8') as f:
@@ -51,7 +57,7 @@ def save_playlist_file(playlist_dir, playlist_name, content):
 
 def delete_playlist_file(playlist_dir, playlist_name):
     """Deletes a playlist file."""
-    filename = f"{playlist_name}.m3u8"
+    filename = f"{sanitize_for_filename(playlist_name)}.m3u8"
     filepath = os.path.join(playlist_dir, filename)
     if os.path.exists(filepath):
         try:
@@ -61,8 +67,32 @@ def delete_playlist_file(playlist_dir, playlist_name):
             logging.error(f"Error deleting file {filepath}: {e}")
 
 
+def call_mopidy_rpc(method, params=None):
+    """Calls a Mopidy RPC method."""
+    if not settings.MOPIDY_RPC_URL:
+        return
+
+    data = {
+        'jsonrpc': '2.0',
+        'id': 1,
+        'method': method,
+    }
+    if params:
+        data['params'] = params
+
+    try:
+        response = requests.post(settings.MOPIDY_RPC_URL, json=data, timeout=5)
+        response.raise_for_status()
+        logging.info(f"Successfully called Mopidy RPC method: {method}")
+    except requests.exceptions.RequestException as e:
+        logging.error(f"Error calling Mopidy RPC: {e}")
+
+
 def main():
     """Get playlists from a Navidrome server using the Subsonic API."""
+    parser = argparse.ArgumentParser(description="Sync Navidrome playlists to Mopidy.")
+    parser.add_argument('--force-sync', action='store_true', help='Perform a one-time sync of all playlists and exit.')
+    args = parser.parse_args()
     mopidy_playlist_dir = settings.MOPIDY_PLAYLIST_DIR
     if not mopidy_playlist_dir:
         logging.error("MOPIDY_PLAYLIST_DIR must be set in settings.py.")
@@ -100,13 +130,55 @@ def main():
         'f': 'json'
     }
 
+    if args.force_sync:
+        logging.info("Starting one-time force sync of all playlists...")
+        api_url = f"{navidrome_url.rstrip('/')}/rest/getPlaylists.view"
+        try:
+            response = requests.get(api_url, params=params, timeout=5)
+            response.raise_for_status()
+        except requests.exceptions.RequestException as e:
+            logging.error(f"Error connecting to Navidrome: {e}")
+            return
+
+        data = response.json()
+        subsonic_response = data.get('subsonic-response')
+        if not subsonic_response or subsonic_response.get('status') == 'failed':
+            error = subsonic_response.get('error', {}) if subsonic_response else {}
+            logging.error(f"API Error during sync: {error.get('message')} (code: {error.get('code')})")
+            return
+        
+        playlists = subsonic_response.get('playlists', {}).get('playlist', [])
+        if not playlists:
+            logging.info("No playlists found to sync.")
+            return
+
+        logging.info(f"Found {len(playlists)} playlists to sync.")
+        synced_a_playlist = False
+        for playlist in playlists:
+            playlist_id = playlist.get('id')
+            playlist_name = playlist.get('name')
+            logging.info(f"Syncing playlist: '{playlist_name}' ({playlist_id})")
+            raw_output = run_pls_command(playlist_id)
+            if raw_output:
+                transformed_output = transform_m3u_to_m3u8(raw_output)
+                if transformed_output:
+                    save_playlist_file(mopidy_playlist_dir, playlist_name, transformed_output)
+                    synced_a_playlist = True
+        
+        if synced_a_playlist:
+            call_mopidy_rpc('core.playlists.refresh')
+
+        logging.info("Force sync complete.")
+        return
+
     known_playlists = {}
 
     while True:
+        playlists_changed = False
         api_url = f"{navidrome_url.rstrip('/')}/rest/getPlaylists.view"
 
         try:
-            response = requests.get(api_url, params=params)
+            response = requests.get(api_url, params=params, timeout=5)
             response.raise_for_status()  # Raise an exception for bad status codes
         except requests.exceptions.RequestException as e:
             logging.error(f"Error connecting to Navidrome: {e}")
@@ -161,6 +233,7 @@ def main():
             playlist_name = playlist_data.get('name')
             logging.info(f"Playlist deleted: '{playlist_name}' ({playlist_id}). Removing file.")
             delete_playlist_file(mopidy_playlist_dir, playlist_name)
+            playlists_changed = True
 
         # Check for song count or name changes in existing playlists
         for playlist_id, playlist_data in current_playlists.items():
@@ -175,6 +248,7 @@ def main():
                 name_changed = previous_name != current_name
 
                 if song_count_changed or name_changed:
+                    playlists_changed = True
                     log_msg = f"Playlist '{previous_name}' ({playlist_id}) changed."
                     if name_changed:
                         log_msg += f" Name: '{previous_name}' -> '{current_name}'."
@@ -193,6 +267,9 @@ def main():
         # Update the state for the next iteration.
         known_playlists = current_playlists
 
+        if playlists_changed:
+            call_mopidy_rpc('core.playlists.refresh')
+
         time.sleep(5)
 
 

settings.py.example

@@ -1,6 +1,7 @@
 MOPIDY_PLAYLIST_DIR = '/var/lib/mopidy/m3u'
 
-NAVIDROME_URL = ''
+MOPIDY_RPC_URL = 'http://127.0.0.1:6680/mopidy/rpc'
+NAVIDROME_URL = 'https://navidrome.example.com'
 
 NAVIDROME_USER = ''
 
@@ -9,3 +10,4 @@ NAVIDROME_PASSWORD = ''
 # or these two:
 SUBSONIC_SALT = ''
 SUBSONIC_TOKEN = ''
+