From c2a4570ea2e02b674b2cbd3cb2d0f5e2f6c57a33 Mon Sep 17 00:00:00 2001 From: Raymond Jacobson Date: Wed, 3 Jun 2026 14:38:17 -0700 Subject: [PATCH] perf(api): drive usdc purchase tracks from trending scores --- api/v1_tracks_usdc_purchase.go | 21 ++++++++++----------- 1 file changed, 10 insertions(+), 11 deletions(-) diff --git a/api/v1_tracks_usdc_purchase.go b/api/v1_tracks_usdc_purchase.go index faf29ef8..dbd2828a 100644 --- a/api/v1_tracks_usdc_purchase.go +++ b/api/v1_tracks_usdc_purchase.go @@ -21,21 +21,20 @@ func (app *ApiServer) v1TracksUsdcPurchase(c *fiber.Ctx) error { } sql := ` - WITH usdc_track_ids AS MATERIALIZED ( - SELECT track_id - FROM tracks - WHERE - is_unlisted = false AND - is_available = true AND - is_delete = false AND - stream_conditions ? 'usdc_purchase' - ) - SELECT track_trending_scores.track_id + SELECT track_trending_scores.track_id FROM track_trending_scores - JOIN usdc_track_ids ON track_trending_scores.track_id = usdc_track_ids.track_id WHERE type = 'TRACKS' AND version = 'pnagD' AND time_range = @time + AND EXISTS ( + SELECT 1 + FROM tracks + WHERE tracks.track_id = track_trending_scores.track_id + AND tracks.is_unlisted = false + AND tracks.is_available = true + AND tracks.is_delete = false + AND tracks.stream_conditions ? 'usdc_purchase' + ) ORDER BY track_trending_scores.score DESC, track_trending_scores.track_id DESC