from flask import Flask, request, redirect
import spotipy
from spotipy.oauth2 import SpotifyOAuth
import threading
import os
import sys
import time
import requests
from datetime import datetime
import subprocess
import logging

app = Flask(__name__)
stop_flask = threading.Event()

logger = logging.getLogger('flask')
logger.setLevel(logging.ERROR)  # Set to ERROR to ignore lower levels

client_id = "c0020cc0e05245efb2ddb61b7045e4f2"
client_secret = "2e2e7c98f849403fbacc219c1f01c17d"
redirect_uri = "https://elease-uncapsuled-yosef.ngrok-free.dev/callback"  # Hardcoded ngrok URL

sp_oauth = SpotifyOAuth(client_id=client_id, client_secret=client_secret, redirect_uri=redirect_uri, scope="playlist-modify-private user-library-read")

# This will store whether the access token was acquired
access_token_obtained = threading.Event()

@app.route('/')
def index():
    return "Welcome! <a href='/login'>Login to Spotify</a>"

@app.route('/login')
def login():
    return redirect(sp_oauth.get_authorize_url())

@app.route('/callback')
def callback():
    code = request.args.get('code')
    token_info = sp_oauth.get_access_token(code)
    access_token = token_info['access_token']
    
    with open("access_token.txt", "w") as f:
        f.write(access_token)

    #print("Authorization complete. You can close this window.", file=sys.stderr)
    
    # Signal that the access token has been obtained
    access_token_obtained.set()
    
    return "Authorization complete. You can close this window."

def create_playlist():
    if not os.path.exists("access_token.txt"):
        print("No access token found.", file=sys.stderr)
        return

    with open("access_token.txt", "r") as f:
        access_token = f.read().strip()

    sp = spotipy.Spotify(auth=access_token)

    print("Fetching liked songs...", file=sys.stderr)
    liked_songs = []
    results = sp.current_user_saved_tracks()

    while results:
        for item in results['items']:
            liked_songs.append(item['track']['id'])
        if results['next']:
            results = sp.next(results)
        else:
            break

    playlist_name = datetime.now().strftime("Liked Songs Collection - %Y-%m-%d %H-%M-%S")
    user_id = sp.me()['id']
    new_playlist = sp.user_playlist_create(user_id, playlist_name, public=False)

    print(f"Created playlist: {playlist_name}", file=sys.stderr)

    for i in range(0, len(liked_songs), 100):
        batch = liked_songs[i:i + 100]
        sp.playlist_add_items(new_playlist['id'], batch)
        print(f"Added {len(batch)} songs...", file=sys.stderr)

    playlist_url = new_playlist['external_urls']['spotify']
    print(f"Playlist URL: {playlist_url}", file=sys.stderr)

    return playlist_url

def run_flask():
    with open(os.devnull, 'w') as fnull:
        # Redirect both stdout and stderr to devnull
        #sys.stdout = fnull
        sys.stderr = fnull # COMMENT FOR DEBUG
        subprocess.run(["xdg-open", "http://192.168.0.100:8888"])
        app.run(host="0.0.0.0", port=8888, use_reloader=False)
    # sys.stdout = sys.__stdout__  # Restore original stdout
    # sys.stderr = sys.__stderr__  # Restore original stderr

def kill_ngrok():
    try:
        # Find ngrok process and kill it
        subprocess.call(["pkill", "ngrok"])
    except Exception as e:
        print(f"Error stopping ngrok: {str(e)}", file=sys.stderr)


def main():
    kill_ngrok()

    # Start Flask in a background thread
    flask_thread = threading.Thread(target=run_flask, daemon=True)
    flask_thread.start()

    # Allow some time for Flask to start
    time.sleep(2)

    # Start ngrok dynamically
    os.system("ngrok http 8888 &")
    
    # Allow time for ngrok to initialize
    time.sleep(5)

    # Print out the hardcoded ngrok URL
    print(f"Ngrok URL: {redirect_uri}", file=sys.stderr )
    print("Please authorize access via the following URL:", sp_oauth.get_authorize_url(), file=sys.stderr)

    # Wait for the access token to be acquired
    access_token_obtained.wait()  # Wait until the access token is provided

    # Now that we have the token, proceed with creating the playlist
    playlist_url = create_playlist()
    print(playlist_url)
    stop_flask.set()  # Signal Flask to stop
    flask_thread.join()  # Wait for the Flask thread to complete
    sys.exit(0)

if __name__ == "__main__":
    main()