You can close this window.
`) +} + +func exchangeCodeForToken(clientId, clientSecret, code, redirectURI string) (*SpotifyTokenResponse, error) { + data := url.Values{} + data.Set("grant_type", "authorization_code") + data.Set("code", code) + data.Set("redirect_uri", redirectURI) + data.Set("client_id", clientId) + data.Set("client_secret", clientSecret) + + req, err := http.NewRequest("POST", SpotifyTokenURL, strings.NewReader(data.Encode())) + if err != nil { + return nil, err + } + req.Header.Set("Content-Type", "application/x-www-form-urlencoded") + + resp, err := spotifyClient.Do(req) + if err != nil { + return nil, err + } + defer resp.Body.Close() + + body, err := io.ReadAll(resp.Body) + if err != nil { + return nil, err + } + + if resp.StatusCode != 200 { + return nil, fmt.Errorf("Spotify token exchange failed: %s", string(body)) + } + + var token SpotifyTokenResponse + if err := json.Unmarshal(body, &token); err != nil { + return nil, err + } + + return &token, nil +} + +func refreshSpotifyToken(clientId, clientSecret, refreshToken string) (*SpotifyTokenResponse, error) { + data := url.Values{} + data.Set("grant_type", "refresh_token") + data.Set("refresh_token", refreshToken) + data.Set("client_id", clientId) + data.Set("client_secret", clientSecret) + + req, err := http.NewRequest("POST", SpotifyTokenURL, strings.NewReader(data.Encode())) + if err != nil { + return nil, err + } + req.Header.Set("Content-Type", "application/x-www-form-urlencoded") + + resp, err := spotifyClient.Do(req) + if err != nil { + return nil, err + } + defer resp.Body.Close() + + body, err := io.ReadAll(resp.Body) + if err != nil { + return nil, err + } + + if resp.StatusCode != 200 { + return nil, fmt.Errorf("Spotify token refresh failed: %s", string(body)) + } + + var token SpotifyTokenResponse + if err := json.Unmarshal(body, &token); err != nil { + return nil, err + } + + return &token, nil +} + +func StartSpotifyPoller() { + ticker := time.NewTicker(30 * time.Second) + go func() { + for range ticker.C { + spotifyMu.Lock() + users, err := GetUsersWithSpotify() + if err != nil { + fmt.Fprintf(os.Stderr, "Error getting users with Spotify: %v\n", err) + spotifyMu.Unlock() + continue + } + + for _, userId := range users { + err := pollSpotify(userId) + if err != nil { + fmt.Fprintf(os.Stderr, "Error polling Spotify for user %d: %v\n", userId, err) + } + } + spotifyMu.Unlock() + } + }() +} + +func pollSpotify(userId int) error { + clientId, clientSecret, accessToken, refreshToken, expiresAt, err := GetUserSpotifyCredentials(userId) + if err != nil { + return err + } + + if accessToken == "" { + return fmt.Errorf("no access token") + } + + if time.Now().After(expiresAt.Add(-60 * time.Second)) { + token, err := refreshSpotifyToken(clientId, clientSecret, refreshToken) + if err != nil { + return err + } + accessToken = token.AccessToken + if token.RefreshToken != "" { + refreshToken = token.RefreshToken + } + UpdateUserSpotifyTokens(userId, accessToken, refreshToken, token.ExpiresIn) + } + + err = checkCurrentlyPlaying(userId, accessToken) + if err != nil { + fmt.Fprintf(os.Stderr, "Error checking currently playing: %v\n", err) + } + + err = checkRecentPlays(userId, accessToken) + if err != nil { + fmt.Fprintf(os.Stderr, "Error checking recent plays: %v\n", err) + } + + UpdateUserSpotifyCheck(userId) + + return nil +} + +func checkCurrentlyPlaying(userId int, accessToken string) error { + req, err := http.NewRequest("GET", SpotifyAPIURL+"/me/player/currently-playing", nil) + if err != nil { + return err + } + req.Header.Set("Authorization", "Bearer "+accessToken) + + resp, err := spotifyClient.Do(req) + if err != nil { + return err + } + defer resp.Body.Close() + + if resp.StatusCode == 204 { + ClearNowPlaying(userId) + return nil + } + + if resp.StatusCode != 200 { + return fmt.Errorf("currently playing returned %d", resp.StatusCode) + } + + var playing SpotifyCurrentlyPlaying + if err := json.NewDecoder(resp.Body).Decode(&playing); err != nil { + return err + } + + if !playing.IsPlaying || playing.Item.Name == "" { + ClearNowPlaying(userId) + return nil + } + + artistName := "" + if len(playing.Item.Artists) > 0 { + artistName = playing.Item.Artists[0].Name + } + + UpdateNowPlaying(NowPlaying{ + UserId: userId, + SongName: playing.Item.Name, + Artist: artistName, + Album: playing.Item.Album.Name, + MsPlayed: playing.Item.DurationMs, + Platform: "spotify", + UpdatedAt: time.Now(), + }) + + return nil +} + +func checkRecentPlays(userId int, accessToken string) error { + req, err := http.NewRequest("GET", SpotifyAPIURL+"/me/player/recently-played?limit=50", nil) + if err != nil { + return err + } + req.Header.Set("Authorization", "Bearer "+accessToken) + + resp, err := spotifyClient.Do(req) + if err != nil { + return err + } + defer resp.Body.Close() + + if resp.StatusCode != 200 { + return fmt.Errorf("recently played returned %d", resp.StatusCode) + } + + var recent SpotifyRecentPlays + if err := json.NewDecoder(resp.Body).Decode(&recent); err != nil { + return err + } + + if len(recent.Items) == 0 { + return nil + } + + scrobbles := make([]Scrobble, 0, len(recent.Items)) + for _, item := range recent.Items { + artistName := "" + if len(item.Track.Artists) > 0 { + artistName = item.Track.Artists[0].Name + } + + scrobbles = append(scrobbles, Scrobble{ + UserId: userId, + Timestamp: time.Unix(item.PlayedAtMs/1000, 0).UTC(), + SongName: item.Track.Name, + Artist: artistName, + Album: item.Track.Album.Name, + MsPlayed: item.Track.DurationMs, + Platform: "spotify", + }) + } + + SaveScrobbles(scrobbles) + + return nil +} + +func userIdToInt(s string) int { + var id int + fmt.Sscanf(s, "%d", &id) + return id +} + +func getBaseURL(r *http.Request) string { + scheme := "http" + if r.TLS != nil { + scheme = "https" + } + return scheme + "://" + r.Host +} + +func GetSpotifyAuthURL(userId int, baseURL string) (string, error) { + clientId, _, _, _, _, err := GetUserSpotifyCredentials(userId) + if err != nil || clientId == "" { + return "", fmt.Errorf("Spotify credentials not configured") + } + + redirectURI := baseURL + "/scrobble/spotify/callback" + scope := "user-read-currently-playing user-read-recently-played" + + return fmt.Sprintf("%s?client_id=%s&response_type=code&redirect_uri=%s&scope=%s&state=%d", + SpotifyAuthURL, url.QueryEscape(clientId), url.QueryEscape(redirectURI), url.QueryEscape(scope), userId), nil +} diff --git a/static/style.css b/static/style.css index a077651..8413e78 100644 --- a/static/style.css +++ b/static/style.css @@ -397,3 +397,40 @@ font-size: 14px; margin-top: 10px; } + +/* Tab Panels */ +.tab-panel { + display: none; +} + +.tab-panel.active { + display: block; +} + +/* API Key Display */ +.api-key-display { + margin: 15px 0; + display: flex; + flex-direction: column; + align-items: flex-start; + gap: 5px; +} + +.api-key-display label { + color: #888; + font-size: 14px; +} + +.api-key-display code { + background: #111; + padding: 8px 12px; + border-radius: 4px; + color: #AFA; + font-family: monospace; + word-break: break-all; +} + +.success { + color: #8F8; + margin-top: 10px; +} diff --git a/templates/settings.gohtml b/templates/settings.gohtml index 9a316d2..6811582 100644 --- a/templates/settings.gohtml +++ b/templates/settings.gohtml @@ -5,6 +5,7 @@Generate an API key to receive scrobbles from external apps.
+ {{if .APIKey}} +{{.APIKey}}
+ {{.APISecret}}
+ Use these URLs in your scrobbling apps:
+/2.0/
+ /1/submit-listens
+ Connect your Spotify account to automatically import your listening history.
+Create a Spotify app at developer.spotify.com and enter your credentials below.
+ + + + {{if .SpotifyConnected}} +Spotify is connected and importing!
+ {{end}} +