rocksky/crates/ at main · rocksky.app/rocksky · Tangled

rocksky.app / rocksky

0

A decentralized music tracking and discovery platform built on AT Protocol 🎵 rocksky.app

spotify atproto lastfm musicbrainz scrobbling listenbrainz

0

rocksky / crates

19 folders

at main

Tsiry Sandratraina fix(connect): don't clobber own device id from device_registered events 17min ago

fix(connect): don't clobber own device id from device_registered events Same bug as the CLI: the connect daemon read `deviceId` from every server message, including the `device_registered` broadcast carrying ANOTHER device's id when a new device (e.g. a miniplayer) joins. That overwrote its own id, so its now-playing pushes were tagged with the wrong device and miniplayers mislabeled the source. Only adopt the id from the registration reply (status: "registered"); ignore device_registered announcements.

17 minutes ago

feat: remove unused crate main files for analytics, dropbox, googledrive, jetstream, playlists, scrobbler, and webscrobbler

10 months ago

feat: remove unused crate main files for analytics, dropbox, googledrive, jetstream, playlists, scrobbler, and webscrobbler

10 months ago

fix(scrobbles): prevent duplicate scrobbles across sources Same track+timestamp from different at-uris was slipping past the uri-only unique constraint. Three layers: - DB UNIQUE (user_id, track_id, timestamp) + dedupe migration that re-points shouts before deleting losing rows. - ON CONFLICT DO NOTHING in jetstream + navidrome inserts; jetstream skips the NATS publish + Discord webhook on conflict. - Redis SETNX guard around putScrobbleRecord so concurrent sources (Spotify/Last.fm/Navidrome) can't each write their own at-record for the same listen.

1 month ago

feat(deezer): add Deezer fallback to all remaining enrichment pipelines Audited every metadata enrichment flow that resolves tracks via Spotify / MusicBrainz and wired the Deezer fallback into the ones that were still missing it, so no pipeline ends up with incomplete metadata when the other providers fail. Rust: - crates/webscrobbler: new deezer module (client + EnrichedTrack->Track) and a Deezer step in resolve_track between Spotify and MusicBrainz. - crates/mirror: enrich_via_deezer fills album_art / isrc / track & disc number / duration on NormalizedTrack after a Spotify miss (durationMs already ms). TypeScript (apps/api): - New shared lib/deezer.ts helper (enrichWithDeezer, never throws). - nowplaying.service.ts (live scrobble path): fill album art, ISRC, duration, track/disc number, label, release date/year, genres, artist picture, deezer link after MusicBrainz/Spotify. - subscribers/status.ts: Deezer fallback for album art, and resolve a correct track number (payload -> DB -> Deezer) that is only published when > 0. Adds trackNumber (minimum 1) to the actor.defs#trackView lexicon. - scripts/backfill-isrc-mbid.ts: Deezer ISRC fallback when Spotify has none.

1 day ago

feat(api): add app.rocksky.library.* XRPC group for uploaded music Expose the full navidrome/Subsonic-compat surface (crates/navidrome) as a JWT-authenticated XRPC group. Handlers are thin proxies: authenticate the caller via the Rocksky JWT (-> DID), resolve the DID to the user's handle, then forward to the internal navidrome service and unwrap the subsonic-response envelope. navidrome remains the single source of truth for SQL / S3 / Typesense / NATS logic. - crates/navidrome: add an internal server-to-server auth path. A request carrying X-Rocksky-Internal: <secret> + u=<handle> resolves the user by handle (new repo::user::get_user_by_handle) and skips Subsonic credential auth. Gated behind NAVIDROME_INTERNAL_SECRET (disabled when unset); applied to GET/POST/HEAD /rest/{method}. - apps/api: src/lib/navidrome.ts proxy helper (callNavidrome / callNavidromeForUrl + Subsonic->HTTP error mapping); 39 methods authored in pkl -> lexicons json -> generated types -> one-line handlers under src/xrpc/app/rocksky/library. - Numbered Subsonic aliases (search3, getAlbumList2, getStarred2, ...) collapse into letters-only NSIDs (AT Proto forbids digits in the method segment) pointing at navidrome's richer variant. Binary media (stream/download/getCoverArt) are exposed as getStreamUrl/getDownloadUrl/ getCoverArtUrl returning { url } — navidrome already redirects, so the proxy reads Location. - New env: NAVIDROME_INTERNAL_URL, NAVIDROME_INTERNAL_SECRET (both sides).

3 days ago

feat(scrobble): add optional ISRC to song + scrobble lexicons Adds an optional `isrc` field to the `app.rocksky.song` and `app.rocksky.scrobble` lexicons, plumbs it through every scrobble producer (scrobbler / webscrobbler / spotify / mirror crates) and the Rocksky API (`/now-playing`, `createScrobble`, `createSong`). Track lookup now ORs `isrc` alongside `sha256` and `mb_id` so the same recording isn't duplicated across cosmetic title variations. XRPC getSong / getSongs / matchSong gain `mbid`, `isrc`, and `spotifyId` query params (Spotify ID resolved internally to the canonical track URL). Adds a `bun backfill:isrc-mbid` script that fills missing `mb_id` / `isrc` via MusicBrainz hydrate + Spotify Search, with random active-token rotation, dead-token retirement, 429 / 5xx / network backoff, and progress logging.

1 month ago

refactor: remove unused std::env import from spotify.rs

9 months ago

fix empty googledrive parent dir value

1 year ago

feat(sdk): add notifications + shout GIF across all SDKs; type all TS responses Wire the new app.rocksky.notification.* XRPC group (getUnreadCount, listNotifications, updateSeen) and shout GIF/sticker/clip attachments into every SDK, and type all previously-untyped TypeScript client responses. Core (crates/rocksky-sdk): - Regenerate shout + notification lexicon bindings (adopt only those to avoid codegen churn); shout record gains gif/facets, message now optional - Typed AppView notification methods (unread_count/notifications/update_seen) with NotificationView/Actor/List/UnreadCount/UpdateSeenResult wire types + a POST mutate helper - ShoutGif input + agent shout_with_gif / reply_shout_with_gif FFI cores: uniffi (typed Records + methods + ShoutGifInput), capi C ABI (rocksky_update_seen, gif shout fns), rustler NIF (update_seen, gif shout nifs). Language SDKs: - python/kotlin: regenerate uniffi bindings - ruby/clojure/erlang/elixir/gleam: hand-written wrappers over capi/nif - typescript: notifications + gif; type every Promise<unknown> read against the regenerated lexicon views (only the generic get() escape hatch stays unknown) - go: regenerate types; typed notification methods + gif shout variants Bump versions: rust sdk 0.6.0, uniffi/nif 0.3.0, ts 0.8.0, python/ruby/elixir 0.8.0, gleam 1.8.0, erlang 0.5.0, kotlin 0.9.0, clojure 0.8.0-SNAPSHOT.

1 day ago

feat(sdk): propagate matchSong track/disc number to all typed SDKs Add trackNumber/discNumber to the songMatchView lexicon (pkl source + generated JSON) so matchSong's `matches` list carries the fields Deezer now backfills. Regenerate server lexicon types, the TypeScript and Go SDKs, and the crates/rocksky-sdk Rust bindings; forward the fields through the hand-written DeezerMatch type via the existing `...m` spread. Bump every native/FFI SDK to a patch release (TS/Python/Ruby/Elixir 0.8.1, Clojure 0.8.1-SNAPSHOT, Kotlin 0.9.1, Erlang 0.5.1, Gleam 1.8.1); rocksky-sdk already at 0.6.1, sdk/rust deprecated, Go versioned by tag.

20 hours ago

feat(sdk): add notifications + shout GIF across all SDKs; type all TS responses Wire the new app.rocksky.notification.* XRPC group (getUnreadCount, listNotifications, updateSeen) and shout GIF/sticker/clip attachments into every SDK, and type all previously-untyped TypeScript client responses. Core (crates/rocksky-sdk): - Regenerate shout + notification lexicon bindings (adopt only those to avoid codegen churn); shout record gains gif/facets, message now optional - Typed AppView notification methods (unread_count/notifications/update_seen) with NotificationView/Actor/List/UnreadCount/UpdateSeenResult wire types + a POST mutate helper - ShoutGif input + agent shout_with_gif / reply_shout_with_gif FFI cores: uniffi (typed Records + methods + ShoutGifInput), capi C ABI (rocksky_update_seen, gif shout fns), rustler NIF (update_seen, gif shout nifs). Language SDKs: - python/kotlin: regenerate uniffi bindings - ruby/clojure/erlang/elixir/gleam: hand-written wrappers over capi/nif - typescript: notifications + gif; type every Promise<unknown> read against the regenerated lexicon views (only the generic get() escape hatch stays unknown) - go: regenerate types; typed notification methods + gif shout variants Bump versions: rust sdk 0.6.0, uniffi/nif 0.3.0, ts 0.8.0, python/ruby/elixir 0.8.0, gleam 1.8.0, erlang 0.5.0, kotlin 0.9.0, clojure 0.8.0-SNAPSHOT.

1 day ago

feat: mirror Last.fm, ListenBrainz, Teal.fm scrobbles into Rocksky Adds `rockskyd mirror` and an `app.rocksky.mirror.*` XRPC surface so users can opt in to mirroring plays from external scrobblers. Last.fm and ListenBrainz are polled per-user on 30s intervals; Teal.fm uses a single Jetstream subscription on `fm.teal.alpha.feed.play` filtered by a shared enabled-DID set. All paths share a ±120s dedup pre-check against the `scrobbles` table to avoid double-scrobbling plays the user already has from another source.

1 month ago

fix(scrobbler,webscrobbler): backfill 0 track/disc number from Deezer The Deezer fallback previously only triggered when Spotify failed entirely. A track resolved via Spotify or MusicBrainz kept its track_number/disc_number as-is — and the MusicBrainz conversion defaults both to 0 when a recording has no release media — so those zeros were never filled. Add backfill_track_disc_from_deezer to both crates: when a resolved track has track_number == 0 or disc_number == 0, query Deezer and fill just those (gated, so no extra call when both are already set). - webscrobbler resolve_track: applied at the DB, Spotify and MusicBrainz return sites (the Deezer-fallback branch already carries Deezer's numbers). - scrobbler: route all submit sites through a single submit_scrobble choke-point that backfills before rocksky::scrobble, so every resolution path (cache, DB, Spotify, MusicBrainz) is covered across scrobble / scrobble_v1 / scrobble_listenbrainz.

1 day ago

fix(spotify): tolerate missing href in currently-playing responses Spotify omits href on simplified item/album/artist objects (local files, certain context objects, non-track items), which crashed the watch task with `missing field href`. These fields are never read, so make them Option<String> to deserialize cleanly.

2 days ago

feat: update dependencies to include tracing and improve logging throughout the application

10 months ago

feat: update dependencies to include tracing and improve logging throughout the application

10 months ago

fix(scrobbler,webscrobbler): backfill 0 track/disc number from Deezer The Deezer fallback previously only triggered when Spotify failed entirely. A track resolved via Spotify or MusicBrainz kept its track_number/disc_number as-is — and the MusicBrainz conversion defaults both to 0 when a recording has no release media — so those zeros were never filled. Add backfill_track_disc_from_deezer to both crates: when a resolved track has track_number == 0 or disc_number == 0, query Deezer and fill just those (gated, so no extra call when both are already set). - webscrobbler resolve_track: applied at the DB, Spotify and MusicBrainz return sites (the Deezer-fallback branch already carries Deezer's numbers). - scrobbler: route all submit sites through a single submit_scrobble choke-point that backfills before rocksky::scrobble, so every resolution path (cache, DB, Spotify, MusicBrainz) is covered across scrobble / scrobble_v1 / scrobble_listenbrainz.

1 day ago

xataid-extension

crates: set rockskyd as the main CLI entrypoint

10 months ago