updateSpotify.py

import threading
import time
import os
import subprocess

import playlistChecker

def createFolderIfNotExist(name):
    if not os.path.exists(name):
        os.makedirs(name)
        print(f"Folder '{name}' created.")
        return(True)
    return(False)

def _runCommand( command, callback=print):
    process = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
    for line in process.stdout:
        callback(line.strip())
    for line in process.stderr:
        callback(line.strip())

class SpotifyDownloader:
    def __init__(self, playlists):
        self._urlPrefix = "https://open.spotify.com/playlist/"
        self.playlists = self._preparePlaylists(playlists)

    def _preparePlaylists(self, playlists):
        playlistFolders = []
        for playlist in playlists:
            playlistID = playlist.removeprefix(self._urlPrefix).split("?si=")[0]
            if createFolderIfNotExist(playlistID):
                time.sleep(1)
                print("Folder created")
                self._createPlaylistConfig(playlistID)      #< create config file for the playlist if it doesn't exist
            playlistFolders.append(playlistID)
        return(playlistFolders)

    def _getListeners(self, listener=playlistChecker.PlaylistChangeListener):
        listeners = {}
        for id in self.playlists:
            listeners[id] = listener(f"{self._urlPrefix}{id}")
        return(listeners)

    def listenForChange(self, interval=2):
        listeners = self._getListeners()

        while self.run:
            try:
                for id, listener in listeners.items():
                    if listener.isChange():
                        self.syncPlaylist(id)
                time.sleep(interval)
            except Exception as e:
                print(f"Got error {e}, restarting in a few seconds")
                time.sleep(5)

        print("App stopped...")

    def _createPlaylistConfig(self, id, callback=print):
        originalDir = os.getcwd()
        os.chdir(id)
        _runCommand(f"python -m spotdl sync {self._urlPrefix}{id} --save-file conf.spotdl", callback=callback)
        os.chdir(originalDir)

    def syncPlaylist(self, id, callback=print):
        originalDir = os.getcwd()
        callback(f"updating playlist {id}")
        os.chdir(id)
        _runCommand("python -m spotdl sync conf.spotdl", callback=callback)
        os.chdir(originalDir)

    def syncPlaylists(self, callback=print):
        for playlist in self.playlists:
            self.syncPlaylist(playlist, callback=callback)

    def start(self):
        self.run = True
        self.listenForChange()
        self.startChangeListener()
    
    def startChangeListener(self):
        threading.Thread(target=self.listenForChange).start()

    def stop(self):
        self.run = False