[API-95] Add resolve endpoint, improve permalink matching

Author: raymondjacobson

api/dbv1/get_playlist_ids_by_permalink.sql.go

@@ -0,0 +1,10 @@
+-- name: GetPlaylistIdsByPermalink :many
+SELECT playlist_id
+FROM playlist_routes
+JOIN users ON users.user_id = playlist_routes.owner_id
+WHERE handle_lc = ANY(@handles::text[])
+    AND slug = ANY(@slugs::text[])
+    AND (
+        CONCAT(handle_lc, '/playlist/', slug) = ANY(@permalinks::text[]) -- in case of conflicts across users
+        OR CONCAT(handle_lc, '/album/', slug) = ANY(@permalinks::text[]) -- in case of conflicts across users
+    );

api/dbv1/get_user_for_handle.sql.go

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

api/dbv1/queries/get_playlist_ids_by_permalink.sql

@@ -161,6 +161,30 @@ var (
 		"updated_at":      time.Now(),
 		"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",
+	}
 )
 
 func insertFixtures(table string, baseRow map[string]any, csvFile string) {

api/dbv1/queries/get_user_for_handle.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/fixture_test.go

@@ -244,6 +244,9 @@ func NewApiServer(config config.Config) *ApiServer {
 
 		// Rewards
 		g.Get("/rewards/claim", app.v1ClaimRewards)
+
+		// Resolve
+		g.Get("/resolve", app.v1Resolve)
 	}
 
 	app.Static("/", "./static")
@@ -308,11 +311,9 @@ 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)
+	app.resolveHandleCache.Set(handle, int32(user_id))
+	return int32(user_id), err
 }
 
 func (as *ApiServer) Serve() {

api/resolve_middleware.go

@@ -77,7 +77,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")
 
 	// index to es / os

api/server.go

@@ -3,3 +3,5 @@ playlist_id,playlist_name,playlist_owner_id,is_album,playlist_contents,stream_co
 2,Follow Gated Stream,3,t,"{}","{""follow_user_id"": 3}"
 3,SecondAlbum,1,t,"{""track_ids"": [{""time"": 1722451644, ""track"": 200, ""metadata_time"": 1722451644},{""time"": 1722451644, ""track"": -1, ""metadata_time"": 1722451644},{""time"": 1722451644, ""track"": 300, ""metadata_time"": 1722451644}]}",
 4,Purchase Gated Stream,3,t,"{}","{""usdc_purchase"": {""price"": 135, ""splits"": [{""user_id"": 3, ""percentage"": 100.0}]}}"
+500,playlist by permalink,7,f,,
+501,album by permalink,7,t,,

api/server_test.go

@@ -0,0 +1,3 @@
+slug,title_slug,collision_id,owner_id,playlist_id
+playlist-by-permalink,playlist-by-permalink,0,7,500
+album-by-permalink,album-by-permalink,0,8,501