[API-95] Add resolve endpoint, improve permalink matching (#55)

New working URLs


http://localhost:1323/v1/resolve?url=https://audius.co/jacknifemusic/jacknife-bladeboi-on-my-mind-remix-contest

http://localhost:1323/v1/resolve?url=https://audius.co/sturmfrau/playlist/this-is-sturmfrau
http://localhost:1323/v1/resolve?url=https://audius.co/oshimakesmusic

Tested=
```
make test
```

Author: raymondjacobson

api/dbv1/get_playlist_ids_by_permalink.sql.go

@@ -0,0 +1,24 @@
+-- name: GetPlaylistIdsByPermalink :many
+WITH lower_handles AS (
+  SELECT LOWER(h) AS handle
+  FROM unnest(@handles::text[]) AS h
+),
+lower_permalinks AS (
+  SELECT LOWER(p) AS permalink
+  FROM unnest(@permalinks::text[]) AS p
+)
+SELECT pr.playlist_id
+FROM playlist_routes pr
+JOIN users u ON u.user_id = pr.owner_id
+JOIN lower_handles lh
+  ON u.handle_lc = lh.handle
+WHERE pr.slug = ANY(@slugs::text[])
+  -- in case of conflicts across users
+  AND (
+    CONCAT('/', u.handle_lc, '/playlist/', LOWER(pr.slug)) = ANY(
+      SELECT permalink FROM lower_permalinks
+    )
+    OR CONCAT('/', u.handle_lc, '/album/', LOWER(pr.slug)) = ANY(
+      SELECT permalink FROM lower_permalinks
+    )
+  );

api/dbv1/get_track_ids_by_permalink.sql.go

@@ -1,8 +1,19 @@
 -- name: GetTrackIdsByPermalink :many
-SELECT track_id
-FROM track_routes
-JOIN users ON users.user_id = track_routes.owner_id
-WHERE handle_lc = ANY(@handles::text[])
-    AND slug = ANY(@slugs::text[])
-    AND CONCAT(handle_lc, '/', slug) = ANY(@permalinks::text[]) -- in case of conflicts across users
-;
+WITH lower_handles AS (
+  SELECT LOWER(h) AS handle
+  FROM unnest(@handles::text[]) AS h
+),
+lower_permalinks AS (
+  SELECT LOWER(p) AS permalink
+  FROM unnest(@permalinks::text[]) AS p
+)
+SELECT tr.track_id
+FROM track_routes tr
+JOIN users u ON u.user_id = tr.owner_id
+JOIN lower_handles lh
+  ON u.handle_lc = lh.handle
+WHERE tr.slug = ANY(@slugs::text[])
+  -- in case of conflicts across usAers
+  AND CONCAT('/', u.handle_lc, '/', LOWER(tr.slug)) = ANY(
+    SELECT permalink FROM lower_permalinks
+  );

api/dbv1/get_user_for_handle.sql.go

@@ -0,0 +1,6 @@
+-- name: GetUserForHandle :one
+SELECT user_id FROM users
+WHERE
+    handle_lc = lower(@handle)
+ORDER BY created_at ASC
+LIMIT 1;

api/dbv1/queries/get_playlist_ids_by_permalink.sql

@@ -162,6 +162,30 @@ var (
 		"txhash":          "tx123",
 	}
 
+	trackRouteBaseRow = map[string]any{
+		"slug":         nil,
+		"title_slug":   nil,
+		"collision_id": nil,
+		"owner_id":     nil,
+		"track_id":     nil,
+		"is_current":   true,
+		"blockhash":    "block_abc123",
+		"blocknumber":  101,
+		"txhash":       "tx123",
+	}
+
+	playlistRouteBaseRow = map[string]any{
+		"slug":         nil,
+		"title_slug":   nil,
+		"collision_id": nil,
+		"owner_id":     nil,
+		"playlist_id":  nil,
+		"is_current":   true,
+		"blockhash":    "block_abc123",
+		"blocknumber":  101,
+		"txhash":       "tx123",
+	}
+
 	commentBaseRow = map[string]any{
 		"entity_type": "Track",
 		"created_at":  time.Now(),

api/dbv1/queries/get_track_ids_by_permalink.sql

@@ -14,6 +14,10 @@ func (app *ApiServer) isFullMiddleware(c *fiber.Ctx) error {
 	return c.Next()
 }
 
+func (app *ApiServer) getIsFull(c *fiber.Ctx) bool {
+	return c.Locals("isFull").(bool)
+}
+
 // will set myId if valid, defaults to 0
 func (app *ApiServer) resolveMyIdMiddleware(c *fiber.Ctx) error {
 	myId, _ := trashid.DecodeHashId(c.Query("user_id"))

api/dbv1/queries/get_user_for_handle.sql

@@ -250,6 +250,9 @@ func NewApiServer(config config.Config) *ApiServer {
 		// Rewards
 		g.Get("/rewards/claim", app.v1ClaimRewards)
 
+		// Resolve
+		g.Get("/resolve", app.v1Resolve)
+
 		// Comments
 		g.Get("/comments/unclaimed_id", app.v1CommentsUnclaimedId)
 	}
@@ -316,11 +319,12 @@ func (app *ApiServer) resolveUserHandleToId(handle string) (int32, error) {
 	if hit, ok := app.resolveHandleCache.Get(handle); ok {
 		return hit, nil
 	}
-	var userId int32
-	sql := `select user_id from users where handle_lc = lower($1)`
-	err := app.pool.QueryRow(context.Background(), sql, handle).Scan(&userId)
-	app.resolveHandleCache.Set(handle, userId)
-	return userId, err
+	user_id, err := app.queries.GetUserForHandle(context.Background(), handle)
+	if err != nil {
+		return 0, err
+	}
+	app.resolveHandleCache.Set(handle, int32(user_id))
+	return int32(user_id), nil
 }
 
 func (as *ApiServer) Serve() {

api/fixture_test.go

@@ -78,7 +78,8 @@ func TestMain(m *testing.M) {
 	insertFixtures("associated_wallets", connectedWalletsBaseRow, "testdata/connected_wallets_fixtures.csv")
 	insertFixtures("aggregate_user_tips", aggregateUserTipsBaseRow, "testdata/aggregate_user_tips_fixtures.csv")
 	insertFixtures("usdc_purchases", usdcPurchaseBaseRow, "testdata/usdc_purchases_fixtures.csv")
-	insertFixtures("track_routes", map[string]any{}, "testdata/track_routes_fixtures.csv")
+	insertFixtures("track_routes", trackRouteBaseRow, "testdata/track_routes_fixtures.csv")
+	insertFixtures("playlist_routes", playlistRouteBaseRow, "testdata/playlist_routes_fixtures.csv")
 	insertFixtures("grants", grantBaseRow, "testdata/grants_fixtures.csv")
 	insertFixtures("comments", commentBaseRow, "testdata/comment_fixtures.csv")
 	insertFixtures("comment_threads", map[string]any{}, "testdata/comment_thread_fixtures.csv")