[API-216] Migrate /v1/users/:userId/collectibles (#400)

Extremely basic endpoint. We're just fetching the raw data from the row
and returning it back. Fun quirks:
* I named the column `data` originally, so it's `data.data` in the
response.
* Similar to a few other endpoints, we don't 404 on not found, just
return `null`. Can't guarantee client won't error if we break from that
behavior.

Author: schottra

api/server.go

@@ -336,6 +336,7 @@ func NewApiServer(config config.Config) *ApiServer {
 		g.Use("/users/:userId", app.requireUserIdMiddleware)
 		g.Get("/users/:userId", app.v1User)
 		g.Get("/users/:userId/challenges", app.v1UsersChallenges)
+		g.Get("/users/:userId/collectibles", app.v1UsersCollectibles)
 		g.Get("/users/:userId/comments", app.v1UsersComments)
 		g.Get("/users/:userId/emails/:grantorUserId/key", app.v1UsersEmailsKey)
 		g.Get("/users/:userId/followers", app.v1UsersFollowers)

api/v1_users_collectibles.go

@@ -0,0 +1,39 @@
+package api
+
+import (
+	"encoding/json"
+
+	"github.com/gofiber/fiber/v2"
+	"github.com/jackc/pgx/v5"
+)
+
+type CollectiblesRow struct {
+	Data json.RawMessage `json:"data"`
+}
+
+func (app *ApiServer) v1UsersCollectibles(c *fiber.Ctx) error {
+	userId := app.getUserId(c)
+
+	sql := `
+		SELECT data FROM collectibles
+		WHERE user_id = @userId
+	`
+
+	var collectible CollectiblesRow
+
+	err := app.pool.QueryRow(c.Context(), sql, pgx.NamedArgs{
+		"userId": userId,
+	}).Scan(&collectible.Data)
+	if err != nil {
+		if err == pgx.ErrNoRows {
+			return c.JSON(fiber.Map{
+				"data": nil,
+			})
+		}
+		return err
+	}
+
+	return c.JSON(fiber.Map{
+		"data": collectible,
+	})
+}

api/v1_users_collectibles_test.go

@@ -0,0 +1,54 @@
+package api
+
+import (
+	"testing"
+
+	"api.audius.co/database"
+	"api.audius.co/trashid"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestUsersCollectibles(t *testing.T) {
+	app := emptyTestApp(t)
+
+	fixtures := database.FixtureMap{
+		"users": {
+			{
+				"user_id": 1,
+			},
+		},
+		"collectibles": {
+			{
+				"user_id": 1,
+				"data": map[string]any{
+					"1:::0x1234": map[string]any{},
+					"order": []string{
+						"1:::0x1234",
+					},
+				},
+			},
+		},
+	}
+
+	database.Seed(app.writePool, fixtures)
+
+	{
+		status, body := testGet(t, app, "/v1/users/"+trashid.MustEncodeHashID(1)+"/collectibles")
+		assert.Equal(t, 200, status)
+
+		jsonAssert(t, body, map[string]any{
+			"data.data.1:::0x1234": "{}",
+			"data.data.order.#":    1,
+			"data.data.order.0":    "1:::0x1234",
+		})
+	}
+
+	{
+		status, body := testGet(t, app, "/v1/users/"+trashid.MustEncodeHashID(2)+"/collectibles")
+		assert.Equal(t, 200, status)
+
+		jsonAssert(t, body, map[string]any{
+			"data": nil,
+		})
+	}
+}

database/seed.go

@@ -562,6 +562,14 @@ var (
 			"created_at":          time.Now(),
 			"updated_at":          time.Now(),
 		},
+		"collectibles": {
+			"user_id":     nil,
+			"data":        nil,
+			"blockhash":   "block_abc123",
+			"blocknumber": 101,
+			"created_at":  time.Now(),
+			"updated_at":  time.Now(),
+		},
 	}
 )