implements user managers endpoint

Author: schottra

api/dbv1/full_managers.go

@@ -0,0 +1,47 @@
+package dbv1
+
+import (
+	"context"
+)
+
+type FullGrant struct {
+	GetGrantsForUserIdRow
+	GranteeUserID *struct{} `json:"grantee_user_id,omitempty"`
+}
+
+type FullManager struct {
+	Manager FullUser  `json:"manager"`
+	Grant   FullGrant `json:"grant"`
+}
+
+func (q *Queries) FullManagers(ctx context.Context, params GetGrantsForUserIdParams) ([]FullManager, error) {
+
+	grants, err := q.GetGrantsForUserId(ctx, params)
+	if err != nil {
+		return nil, err
+	}
+
+	user_ids := make([]int32, len(grants))
+	for i, grant := range grants {
+		user_ids[i] = int32(grant.GranteeUserID)
+	}
+
+	users, err := q.FullUsersKeyed(ctx, GetUsersParams{
+		Ids:  user_ids,
+		MyID: params.UserID,
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	managers := make([]FullManager, len(grants))
+	for i, grant := range grants {
+		managers[i] = FullManager{
+			Manager: users[int32(grant.GranteeUserID)],
+			Grant:   FullGrant{GetGrantsForUserIdRow: grant},
+		}
+	}
+
+	return managers, nil
+}

api/dbv1/get_grants.sql.go

@@ -0,0 +1,33 @@
+-- name: GetGrantsForUserId :many
+SELECT
+  g.user_id,
+  g.grantee_address,
+  g.is_revoked,
+  g.is_approved,
+  g.created_at,
+  g.updated_at,
+  u.user_id as grantee_user_id
+FROM grants g
+JOIN users u ON u.wallet = g.grantee_address
+WHERE g.user_id = @user_id::int
+  AND g.is_revoked = @is_revoked
+  AND g.is_current = true
+  AND sqlc.narg('is_approved')::boolean IS NULL OR g.is_approved = sqlc.narg('is_approved')
+ORDER BY g.created_at DESC;
+
+-- name: GetGrantsForGranteeAddress :many
+SELECT
+  g.user_id,
+  g.grantee_address,
+  g.is_revoked,
+  g.is_approved,
+  g.created_at,
+  g.updated_at,
+  u.user_id as grantee_user_id
+FROM grants g
+JOIN users u ON u.wallet = g.grantee_address
+WHERE g.grantee_address = @grantee_address
+  AND g.is_current = true
+  AND g.is_revoked = @is_revoked
+  AND sqlc.narg('is_approved')::boolean IS NULL OR g.is_approved = sqlc.narg('is_approved')
+ORDER BY g.created_at DESC;

api/dbv1/models.go

@@ -233,6 +233,7 @@ func NewApiServer(config config.Config) *ApiServer {
 		g.Get("/users/:userId/following", app.v1UsersFollowing)
 		g.Get("/users/:userId/library/tracks", app.v1UsersLibraryTracks)
 		g.Get("/users/:userId/library/:playlistType", app.v1UsersLibraryPlaylists)
+		g.Get("/users/:userId/managers", app.v1UsersManagers)
 		g.Get("/users/:userId/mutuals", app.v1UsersMutuals)
 		g.Get("/users/:userId/reposts", app.v1UsersReposts)
 		g.Get("/users/:userId/related", app.v1UsersRelated)

api/dbv1/queries/get_grants.sql

@@ -0,0 +1,40 @@
+package api
+
+import (
+	"log"
+	"strconv"
+
+	"bridgerton.audius.co/api/dbv1"
+	"github.com/gofiber/fiber/v2"
+	"github.com/jackc/pgx/v5/pgtype"
+)
+
+func (app *ApiServer) v1UsersManagers(c *fiber.Ctx) error {
+	// Behavior of this field is a little odd. We only want to filter by it
+	// if it is passed, but otherwise not use a default value for either.
+	var isApproved *bool
+	if approvedStr := c.Query("is_approved"); approvedStr != "" {
+		parsed, err := strconv.ParseBool(approvedStr)
+		if err != nil {
+			return fiber.NewError(fiber.StatusBadRequest, "Invalid value for is_approved")
+		}
+		isApproved = &parsed
+	}
+
+	isRevoked := c.QueryBool("is_revoked", false)
+	log.Printf("isApproved: %v, isRevoked: %v", isApproved, isRevoked)
+	params := dbv1.GetGrantsForUserIdParams{
+		UserID:     int32(c.Locals("userId").(int)),
+		IsApproved: pgtype.Bool{Bool: isApproved != nil && *isApproved, Valid: isApproved != nil},
+		IsRevoked:  isRevoked,
+	}
+
+	managers, err := app.queries.FullManagers(c.Context(), params)
+	if err != nil {
+		return err
+	}
+
+	return c.JSON(fiber.Map{
+		"data": managers,
+	})
+}

api/server.go

@@ -46,6 +46,10 @@ sql:
             go_type:
               import: "bridgerton.audius.co/trashid"
               type: "HashId"
+          - column: "grants.user_id"
+            go_type:
+              import: "bridgerton.audius.co/trashid"
+              type: "HashId"
 
           - column: "tracks.copyright_line"
             go_type: