spotify playlist created

.env.template

@@ -1,6 +1,8 @@
 SPOTIPY_CLIENT_ID="xxxx"
 SPOTIPY_CLIENT_SECRET="xxxx"
 SPOTIFY_REDIRECT_URI="xxxx"
+SPOTIFY_USERNAME="xxxx"
+SPOTIFY_PLAYLIST_ID="xxxx"
 GOOGLE_APPLICATION_CREDENTIALS="xxxx"
 WHOAMI="xxxx"
 POSTGRES_URI="xxxx"

spotify_playlist/fetch_songs.py

@@ -0,0 +1,18 @@
+from c3po.db.base import session_scope
+from c3po.db.models.user import UserPosts
+from c3po.db.models.link import Link
+from spotify_uri import get_spotify_id
+
+# get first 50 songs from the db
+def get_song_url():
+    with session_scope() as session:
+        songs = []
+        for u,l in session.query(UserPosts,Link).filter(UserPosts.link_id==Link.id).limit(50).all():
+            if len(songs)<=50:
+                if get_spotify_id(l.url) is not None:
+                    songs.append(get_spotify_id(l.url))
+                else:
+                    continue
+            else:
+                break
+        return songs

spotify_playlist/spotify_playlist.py

@@ -0,0 +1,19 @@
+import os
+import spotipy
+from spotipy.oauth2 import SpotifyOAuth
+from fetch_songs import get_song_url
+from music_metadata_extractor import SongData
+
+scope="playlist-modify-public"
+username=os.getenv("SPOTIFY_USERNAME")
+token = SpotifyOAuth(scope=scope,username=username)
+spotifyObject = spotipy.Spotify(auth_manager=token)
+
+ # fetch spotify uri
+list_of_songs = get_song_url()
+
+# fetch latest created playlist id
+playlist_id = os.getenv("SPOTIFY_PLAYLIST_ID")
+
+# add songs to playlist
+spotifyObject.user_playlist_replace_tracks(user=username,playlist_id=playlist_id,tracks=list_of_songs)

spotify_playlist/spotify_uri.py

@@ -0,0 +1,26 @@
+import re
+from music_metadata_extractor import SongData
+
+def get_spotify_id(url):
+    spotify_pattern = re.compile(
+        r"""
+        https?:\/\/open\.spotify\.com\/track\/(?P<id>[a-zA-Z0-9]+)
+        """,
+        re.VERBOSE
+    )
+    spotify_match = spotify_pattern.match(url)
+    if spotify_match:
+        return spotify_match.group("id")
+    else:
+        yt_pattern = re.compile(
+            r"""
+            (https?://)?(www\.)?(youtube|youtu|youtube-nocookie)\.
+            (com|be)/(watch\?v=|embed/|v/|.+\?v=)?
+            (?P<id>[A-Za-z0-9\-=_]{11})""",
+            re.VERBOSE,
+        )
+        yt_match = yt_pattern.match(url)
+        if(yt_match):
+            data = SongData(url)
+            if data.track:
+                return data.track.provider_id