feat: call Apple Music API for latest song

This cost me £80 to set up!!

.gitignore

···
 node_modules
+.env
 /frontend/fonts
 /frontend/build
 /frontend/src/css/tailwind-out.css

justfile

···
+set dotenv-load := true
+
 [parallel]
 serve: serve-js serve-rs
 

server/Cargo.lock

···
 ]
 
 [[package]]
+name = "deranged"
+version = "0.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c9e6a11ca8224451684bc0d7d5a7adbf8f2fd6887261a1cfc3c0432f9d4068e"
+dependencies = [
+ "powerfmt",
+]
+
+[[package]]
 name = "derive_more"
 version = "2.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 checksum = "335ff9f135e4384c8150d6f27c6daed433577f86b4750418338c01a1a2528592"
 dependencies = [
  "cfg-if",
+ "js-sys",
  "libc",
  "wasi 0.11.1+wasi-snapshot-preview1",
+ "wasm-bindgen",
 ]
 
 [[package]]
···
 ]
 
 [[package]]
+name = "jsonwebtoken"
+version = "9.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5a87cc7a48537badeae96744432de36f4be2b4a34a05a5ef32e9dd8a1c169dde"
+dependencies = [
+ "base64",
+ "js-sys",
+ "pem",
+ "ring",
+ "serde",
+ "serde_json",
+ "simple_asn1",
+]
+
+[[package]]
 name = "lazy_static"
 version = "1.5.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
  "askama",
  "axum",
  "cached",
+ "jsonwebtoken",
  "reqwest",
  "scraper",
  "serde",
···
 ]
 
 [[package]]
+name = "num-bigint"
+version = "0.4.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a5e44f723f1133c9deac646763579fdb3ac745e418f2a7af9cd0c431da1f20b9"
+dependencies = [
+ "num-integer",
+ "num-traits",
+]
+
+[[package]]
+name = "num-conv"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "51d515d32fb182ee37cda2ccdcb92950d6a3c2893aa280e540671c2cd0f3b1d9"
+
+[[package]]
+name = "num-integer"
+version = "0.1.46"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7969661fd2958a5cb096e56c8e1ad0444ac2bbcd0061bd28660485a44879858f"
+dependencies = [
+ "num-traits",
+]
+
+[[package]]
+name = "num-traits"
+version = "0.2.19"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "071dfc062690e90b734c0b2273ce72ad0ffa95f0c74596bc250dcfd960262841"
+dependencies = [
+ "autocfg",
+]
+
+[[package]]
 name = "object"
 version = "0.36.7"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "pem"
+version = "3.0.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "38af38e8470ac9dee3ce1bae1af9c1671fffc44ddfd8bd1d0a3445bf349a8ef3"
+dependencies = [
+ "base64",
+ "serde",
+]
+
+[[package]]
 name = "percent-encoding"
 version = "2.3.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "powerfmt"
+version = "0.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "439ee305def115ba05938db6eb1644ff94165c5ab5e9420d1c1bcedbba909391"
+
+[[package]]
 name = "precomputed-hash"
 version = "0.1.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 ]
 
 [[package]]
+name = "simple_asn1"
+version = "0.6.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "297f631f50729c8c99b84667867963997ec0b50f32b2a7dbcab828ef0541e8bb"
+dependencies = [
+ "num-bigint",
+ "num-traits",
+ "thiserror",
+ "time",
+]
+
+[[package]]
 name = "siphasher"
 version = "1.0.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
···
 checksum = "f60246a4944f24f6e018aa17cdeffb7818b76356965d03b07d6a9886e8962185"
 dependencies = [
  "cfg-if",
+]
+
+[[package]]
+name = "time"
+version = "0.3.41"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8a7619e19bc266e0f9c5e6686659d394bc57973859340060a69221e57dbc0c40"
+dependencies = [
+ "deranged",
+ "itoa",
+ "num-conv",
+ "powerfmt",
+ "serde",
+ "time-core",
+ "time-macros",
+]
+
+[[package]]
+name = "time-core"
+version = "0.1.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c9e9a38711f559d9e3ce1cdb06dd7c5b8ea546bc90052da6d06bb76da74bb07c"
+
+[[package]]
+name = "time-macros"
+version = "0.2.22"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3526739392ec93fd8b359c8e98514cb3e8e021beb4e5f597b00a0221f8ed8a49"
+dependencies = [
+ "num-conv",
+ "time-core",
 ]
 
 [[package]]

server/Cargo.toml

···
 askama = "0.14.0"
 axum = "0.8.1"
 cached = { version = "0.56.0", features = ["async"] }
+jsonwebtoken = "9.3.1"
 reqwest = { version = "0.12.23", features = ["json"] }
 scraper = "0.24.0"
 serde = { version = "1.0.219", features = ["derive"] }

server/src/index.rs

···
-use crate::scrapers::backloggd::{self, Backloggd};
-use crate::scrapers::letterboxd::{self, Letterboxd};
+use crate::scrapers::{
+    apple_music::{self, AppleMusic},
+    backloggd::{self, Backloggd},
+    letterboxd::{self, Letterboxd},
+};
 
 use askama::Template;
 
···
 pub struct RootTemplate {
     game: Option<Backloggd>,
     movie: Option<Letterboxd>,
+    song: Option<AppleMusic>,
 }
 
 impl RootTemplate {
     pub async fn new() -> RootTemplate {
-        let (game, movie) = tokio::join!(backloggd::cached_fetch(), letterboxd::cached_fetch(),);
-        RootTemplate { game, movie }
+        let (game, movie, song) = tokio::join!(
+            backloggd::cached_fetch(),
+            letterboxd::cached_fetch(),
+            apple_music::cached_fetch()
+        );
+        RootTemplate { game, movie, song }
     }
 }

server/src/scrapers.rs

···
+pub mod apple_music;
 pub mod backloggd;
 pub mod letterboxd;

server/src/scrapers/apple_music.rs

···
+use std::{env, time::Duration};
+
+use anyhow::Context;
+use cached::proc_macro::once;
+use jsonwebtoken::{Algorithm, EncodingKey, Header};
+use reqwest::Client;
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Clone)]
+pub struct AppleMusic {
+    pub name: String,
+    pub art: String,
+}
+
+#[derive(Serialize, Debug, Clone)]
+struct Claims {
+    iss: String,
+    iat: u64,
+    exp: u64,
+}
+
+impl Claims {
+    fn new(issuer_id: String) -> Self {
+        let iat = jsonwebtoken::get_current_timestamp();
+        Claims {
+            iss: issuer_id,
+            iat,
+            exp: iat + 3600,
+        }
+    }
+}
+
+#[derive(Deserialize, Debug, Clone)]
+struct AppleMusicResponse {
+    data: [AppleMusicTrack; 1],
+}
+
+#[derive(Deserialize, Debug, Clone)]
+struct AppleMusicTrack {
+    attributes: AppleMusicTrackAttributes,
+}
+
+#[derive(Deserialize, Debug, Clone)]
+struct AppleMusicTrackAttributes {
+    name: String,
+    artwork: AppleMusicTrackArtwork,
+}
+
+#[derive(Deserialize, Debug, Clone)]
+struct AppleMusicTrackArtwork {
+    url: String,
+}
+
+impl AppleMusic {
+    pub async fn fetch() -> anyhow::Result<Self> {
+        let mut header = Header::new(Algorithm::ES256);
+        header.kid = Some(
+            env::var("APPLE_DEVELOPER_TOKEN_KEY_ID").context("missing apple developer key ID")?,
+        );
+        let team_id =
+            env::var("APPLE_DEVELOPER_TOKEN_TEAM_ID").context("missing apple developer team ID")?;
+        let claims = Claims::new(team_id);
+        let auth_key = env::var("APPLE_DEVELOPER_TOKEN_AUTH_KEY")
+            .context("missing apple developer auth key")?;
+        let key = EncodingKey::from_ec_pem(auth_key.as_bytes())
+            .context("failed to parse appple developer auth key")?;
+        let jwt = jsonwebtoken::encode(&header, &claims, &key)
+            .context("failed to encode apple developer JWT")?;
+        let user_token = env::var("APPLE_USER_TOKEN").context("missing apple user token")?;
+
+        let client = Client::new();
+        let response: AppleMusicResponse = client
+            .get("https://api.music.apple.com/v1/me/recent/played/tracks")
+            .bearer_auth(jwt)
+            .header("Music-User-Token", user_token)
+            .query(&[("types", "songs"), ("limit", "1")])
+            .send()
+            .await
+            .context("failed to call Apple Music API")?
+            .json()
+            .await
+            .context("failed to parse Apple Music response")?;
+        let track = &response.data[0];
+
+        let artwork_url = &track.attributes.artwork.url;
+        let dimensions = "240";
+        let artwork_url = artwork_url
+            .replace("{w}", dimensions)
+            .replace("{h}", dimensions);
+
+        Ok(Self {
+            name: track.attributes.name.clone(),
+            art: artwork_url,
+        })
+    }
+}
+
+#[once(time = 30, option = false)]
+pub async fn cached_fetch() -> Option<AppleMusic> {
+    AppleMusic::fetch()
+        .await
+        .map_err(|error| tracing::warn!(?error, "failed to call Apple Music"))
+        .ok()
+}

server/templates/index.html

···
           src="{{ movie.poster }}"
           alt="Poster for {{ movie.name }}"
         />
+        {%- endif %} {% if let Some(song) = song -%}
+        <img
+          class="p-3"
+          src="{{ song.art }}"
+          alt="Album art for {{ song.name }}"
+        />
         {%- endif %}
+
       </div>
     </div>
   </body>