First commit !

notify.py

@@ -0,0 +1,156 @@
+import os
+
+from time import sleep
+from datetime import datetime
+import base64
+import requests
+
+#Spotipy import
+import spotipy
+
+#Instagrapi Imports
+from instagrapi import Client
+from instagrapi.mixins.challenge import ChallengeChoice
+from instagrapi.types import NoteResponse
+from dotenv import load_dotenv
+
+def debug(message):
+    timestamp = datetime.now().strftime('%H:%M:%S')
+    print(f"[{timestamp}] : {message}")
+
+def setup_env_file():
+    if not os.path.isfile(".env"):
+        client_id = input("Please enter your Spotify client ID: ")
+        client_secret = input("Please enter your Spotify client secret: ")
+        refresh_token = input("Please enter your Spotify refresh token: ")
+        bot_refresh_rate = input("Please enter the bot refresh rate (in seconds): ")
+
+        ig_username = input("Please enter your Instagram username: ")
+        ig_password = input("Please enter your Instagram password: ")
+
+
+        if not bot_refresh_rate:
+            bot_refresh_rate = "180"
+
+        with open(".env", "w") as env_file:
+            env_file.write(f"SPOTIPY_CLIENT_ID={client_id}\n")
+            env_file.write(f"SPOTIPY_CLIENT_SECRET={client_secret}\n")
+            env_file.write(f"SPOTIPY_REFRESH_TOKEN={refresh_token}\n")
+            env_file.write(f"BOT_REFRESH_RATE={bot_refresh_rate}\n")
+            env_file.write(f"IG_USERNAME={ig_username}\n")
+            env_file.write(f"IG_PASSWORD={ig_password}\n")
+
+
+setup_env_file()
+load_dotenv()
+
+
+debug("Loading credentials from .env file ...")
+load_dotenv();
+debug("Credentials are loaded !")
+
+# Instagram credentials and config file
+IG_USERNAME = os.getenv("IG_USERNAME")
+IG_PASSWORD = os.getenv("IG_PASSWORD")
+IG_CREDENTIAL_PATH = './ig_settings.json'
+
+SLEEP_TIME = os.getenv("BOT_REFRESH_RATE") # in seconds
+
+
+# Spotify credentials
+client_id = os.getenv("SPOTIPY_CLIENT_ID")
+client_secret = os.getenv("SPOTIPY_CLIENT_SECRET")
+refresh_token = os.getenv("SPOTIPY_REFRESH_TOKEN")
+
+def get_access_token(client_id, client_secret, refresh_token):
+    debug("Getting an access token from Spotify API ...")
+    data = {
+        "grant_type": "refresh_token",
+        "refresh_token": refresh_token,
+    }
+    auth = f"{client_id}:{client_secret}"
+    auth = auth.encode("utf-8")
+    auth = base64.b64encode(auth).decode("utf-8")
+    response = requests.post("https://accounts.spotify.com/api/token",data=data,
+                             headers={
+                                 "Authorization": f"Basic {auth}",
+                             })
+
+    if response.status_code != 200:
+        raise Exception(f"Request failed with status code {response.status_code}: {response.text}")
+    response_data = response.json()
+    access_token = response_data["access_token"]
+    debug("Access token has been retrived from Spotify API !")
+    return access_token
+
+
+access_token = get_access_token(client_id,client_secret,refresh_token)
+sp = spotipy.Spotify(auth=access_token)
+
+
+
+
+class Bot:
+    _cl = None
+
+    def __init__(self):
+        self._cl = Client()
+        if os.path.exists(IG_CREDENTIAL_PATH):
+            self._cl.load_settings(IG_CREDENTIAL_PATH)
+            debug(f'Connecting to Instagram as {IG_USERNAME}')
+            self._cl.login(IG_USERNAME, IG_PASSWORD)
+        else:
+            debug(f'Connecting to Instagram as {IG_USERNAME} for the first time, with 2FA code : {TOTA}')
+            self._cl.login(IG_USERNAME, IG_PASSWORD,verification_code = TOTA)
+            debug('Instagram Credentials has been saved !')
+            self._cl.dump_settings(IG_CREDENTIAL_PATH)
+
+
+
+    def sendMusicNote(self,song_name,artist):
+        previous_note = None
+        note_content = f"🎧 {song_name} - {artist}"
+        if note_content == previous_note and previous_note is not None:
+            debug("The content of the note is the same as before, no need to send a new one")
+        if len(note_content) < 60:
+                self._cl.send_note(f"🎧: {song_name} - {artist}",0)
+        else:
+            raise Exception(f'The content of the note is too long. (note_content_len : {len(note_content)}')
+        previous_note = note_content
+
+
+
+    def update(self,spotify):
+
+        current_track = spotify.current_playback()
+        if current_track:
+            song_name = current_track["item"]["name"]
+            artist = current_track["item"]["artists"][0]["name"]
+            note_content = f"{song_name} - {artist}"
+            debug(note_content)
+            debug("Sending note to Instagram API.")
+            bot.sendMusicNote(song_name,artist)
+            debug(f'Note should be set on {IG_USERNAME} account.')
+        else:
+            debug("Currently nothing is playing.")
+        pass
+
+if __name__ == '__main__':
+    bot = Bot()
+    trigged_fail = False
+    while True:
+        try:
+           # bot.update(sp)
+            sleep(SLEEP_TIME)
+        except spotipy.exceptions.SpotifyException as e:
+            if e.http_status == 401:
+                debug("Token has expired, refreshing it...")
+                access_token= get_access_token(client_id,client_secret,refresh_token)
+                sp = spotipy.Spotify(auth=access_token)
+                debug("Token has been refresh, a new note has been created")
+            else:
+                raise e
+
+
+
+

requirements.txt

@@ -0,0 +1,4 @@
+instagrapi==1.16.33
+requests==2.28.1
+spotipy==2.22.1
+python-dotenv==0.14.0