Skip to content

post/put requests for track/user/playlist #635

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
rickyrombo merged 1 commit into from
Feb 11, 2026
+883 −6
Merged

post/put requests for track/user/playlist #635

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions api/server.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -339,6 +339,7 @@ func NewApiServer(config config.Config) *ApiServer {
for _, g := range []fiber.Router{v1, v1Full} {
// Users
g.Get("/users", app.v1Users)
g.Post("/users", app.requireAuthMiddleware, app.postV1Users)
g.Get("/users/address", app.v1UserIdsByAddresses)
g.Get("/users/search", app.v1UsersSearch)
g.Get("/users/unclaimed_id", app.v1UsersUnclaimedId)
Expand Down Expand Up @@ -424,9 +425,11 @@ func NewApiServer(config config.Config) *ApiServer {
g.Delete("/users/:userId/subscribe", app.requireAuthMiddleware, app.deleteV1UserSubscribe)
g.Post("/users/:userId/mute", app.requireAuthMiddleware, app.postV1UserMute)
g.Delete("/users/:userId/mute", app.requireAuthMiddleware, app.deleteV1UserMute)
g.Put("/users/:userId", app.requireAuthMiddleware, app.putV1User)

// Tracks
g.Get("/tracks", app.v1Tracks)
g.Post("/tracks", app.requireAuthMiddleware, app.postV1Tracks)
g.Get("/tracks/search", app.v1TracksSearch)
g.Get("/tracks/unclaimed_id", app.v1TracksUnclaimedId)

Expand Down Expand Up @@ -457,6 +460,7 @@ func NewApiServer(config config.Config) *ApiServer {
g.Delete("/tracks/:trackId/favorites", app.requireAuthMiddleware, app.deleteV1TrackFavorite)
g.Post("/tracks/:trackId/shares", app.requireAuthMiddleware, app.postV1TrackShare)
g.Post("/tracks/:trackId/downloads", app.requireAuthMiddleware, app.postV1TrackDownload)
g.Put("/tracks/:trackId", app.requireAuthMiddleware, app.putV1Track)
g.Delete("/tracks/:trackId", app.requireAuthMiddleware, app.deleteV1Track)
g.Get("/tracks/:trackId/comments", app.v1TrackComments)
g.Get("/tracks/:trackId/comment_count", app.v1TrackCommentCount)
Expand All @@ -470,6 +474,7 @@ func NewApiServer(config config.Config) *ApiServer {

// Playlists
g.Get("/playlists", app.v1Playlists)
g.Post("/playlists", app.requireAuthMiddleware, app.postV1Playlists)
g.Get("/playlists/search", app.v1PlaylistsSearch)
g.Get("/playlists/unclaimed_id", app.v1PlaylistsUnclaimedId)
g.Get("/playlists/unclaimed-id", app.v1PlaylistsUnclaimedId)
Expand All @@ -488,6 +493,8 @@ func NewApiServer(config config.Config) *ApiServer {
g.Post("/playlists/:playlistId/favorites", app.requireAuthMiddleware, app.postV1PlaylistFavorite)
g.Delete("/playlists/:playlistId/favorites", app.requireAuthMiddleware, app.deleteV1PlaylistFavorite)
g.Post("/playlists/:playlistId/shares", app.requireAuthMiddleware, app.postV1PlaylistShare)
g.Put("/playlists/:playlistId", app.requireAuthMiddleware, app.putV1Playlist)
g.Delete("/playlists/:playlistId", app.requireAuthMiddleware, app.deleteV1Playlist)
g.Get("/playlists/:playlistId/tracks", app.v1PlaylistTracks)

// Explore
Expand Down
278 changes: 278 additions & 0 deletions api/v1_playlist.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,70 @@
package api

import (
"encoding/json"
"strconv"
"time"

"api.audius.co/api/dbv1"
"api.audius.co/indexer"
"api.audius.co/trashid"
corev1 "github.com/OpenAudio/go-openaudio/pkg/api/core/v1"
"github.com/ethereum/go-ethereum/common"
"github.com/gofiber/fiber/v2"
"go.uber.org/zap"
)

type PlaylistTrackInfo struct {
TrackId string `json:"track_id" validate:"required"`
Timestamp int64 `json:"timestamp" validate:"required,min=0"`
MetadataTimestamp *int64 `json:"metadata_timestamp,omitempty" validate:"omitempty,min=0"`
}

type CreatePlaylistRequest struct {
PlaylistId *string `json:"playlist_id,omitempty"`
PlaylistName string `json:"playlist_name" validate:"required,min=1"`
Description *string `json:"description,omitempty" validate:"omitempty,max=1000"`
IsPrivate *bool `json:"is_private,omitempty"`
IsAlbum *bool `json:"is_album,omitempty"`
Genre *string `json:"genre,omitempty" validate:"omitempty,min=1"`
Mood *string `json:"mood,omitempty"`
Tags *string `json:"tags,omitempty"`
License *string `json:"license,omitempty"`
Upc *string `json:"upc,omitempty"`
ReleaseDate *string `json:"release_date,omitempty"`
CoverArtCid *string `json:"cover_art_cid,omitempty"`
PlaylistContents *[]PlaylistTrackInfo `json:"playlist_contents,omitempty" validate:"omitempty,dive"`
DdexApp *string `json:"ddex_app,omitempty"`
DdexReleaseIds *map[string]string `json:"ddex_release_ids,omitempty"`
Artists *[]DDEXResourceContributor `json:"artists,omitempty" validate:"omitempty,dive"`
CopyrightLine *DDEXCopyright `json:"copyright_line,omitempty" validate:"omitempty"`
ProducerCopyrightLine *DDEXCopyright `json:"producer_copyright_line,omitempty" validate:"omitempty"`
ParentalWarningType *string `json:"parental_warning_type,omitempty"`
IsImageAutogenerated *bool `json:"is_image_autogenerated,omitempty"`
}

type UpdatePlaylistRequest struct {
PlaylistName *string `json:"playlist_name,omitempty" validate:"omitempty,min=1"`
Description *string `json:"description,omitempty" validate:"omitempty,max=1000"`
IsPrivate *bool `json:"is_private,omitempty"`
IsAlbum *bool `json:"is_album,omitempty"`
Genre *string `json:"genre,omitempty" validate:"omitempty,min=1"`
Mood *string `json:"mood,omitempty"`
Tags *string `json:"tags,omitempty"`
License *string `json:"license,omitempty"`
Upc *string `json:"upc,omitempty"`
ReleaseDate *string `json:"release_date,omitempty"`
CoverArtCid *string `json:"cover_art_cid,omitempty"`
PlaylistContents *[]PlaylistTrackInfo `json:"playlist_contents,omitempty" validate:"omitempty,dive"`
DdexApp *string `json:"ddex_app,omitempty"`
DdexReleaseIds *map[string]string `json:"ddex_release_ids,omitempty"`
Artists *[]DDEXResourceContributor `json:"artists,omitempty" validate:"omitempty,dive"`
CopyrightLine *DDEXCopyright `json:"copyright_line,omitempty" validate:"omitempty"`
Copy link
Member

@raymondjacobson raymondjacobson Feb 11, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

is this ddex type right?

Copy link
Contributor Author

@rickyrombo rickyrombo Feb 11, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It's based on our Zod types, so hopefully!

https://github.com/AudiusProject/apps/blob/db3f11a9a7e9615a0ba36f3ddd5f4f73bfe27d5b/packages/sdk/src/sdk/types/DDEX.ts#L3-L24

ProducerCopyrightLine *DDEXCopyright `json:"producer_copyright_line,omitempty" validate:"omitempty"`
ParentalWarningType *string `json:"parental_warning_type,omitempty"`
IsImageAutogenerated *bool `json:"is_image_autogenerated,omitempty"`
}

func (app *ApiServer) v1Playlist(c *fiber.Ctx) error {
myId := app.getMyId(c)
playlistId := c.Locals("playlistId").(int)
Expand All @@ -27,3 +87,221 @@ func (app *ApiServer) v1Playlist(c *fiber.Ctx) error {

return v1PlaylistResponse(c, playlist)
}

func (app *ApiServer) postV1Playlists(c *fiber.Ctx) error {
userID := app.getUserId(c)

// Parse and validate request body
var req CreatePlaylistRequest
if err := c.BodyParser(&req); err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "Invalid request body: " + err.Error(),
})
}

// Validate struct tags
if err := app.requestValidator.Validate(&req); err != nil {
return err
}

// Determine playlist ID
var playlistID int
if req.PlaylistId != nil {
decodedID, err := trashid.DecodeHashId(*req.PlaylistId)
if err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "Invalid playlist_id: " + err.Error(),
})
}
playlistID = decodedID
} else {
// Generate playlist ID from timestamp if not provided
playlistID = int(time.Now().UnixNano() % 1000000000)
}

// Convert struct to map for metadata
metadataBytes, err := json.Marshal(req)
if err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "Failed to serialize metadata",
})
}

var metadata map[string]interface{}
if err := json.Unmarshal(metadataBytes, &metadata); err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "Failed to process metadata",
})
}

// Remove nil values from metadata
for key, value := range metadata {
if value == nil {
delete(metadata, key)
}
}

signer, err := app.getApiSigner(c)
if err != nil {
return err
}

nonce := time.Now().UnixNano()

// Build metadata JSON with cid and data fields
metadataJSON := map[string]interface{}{
"cid": "",
"data": metadata,
}
finalMetadataBytes, _ := json.Marshal(metadataJSON)

manageEntityTx := &corev1.ManageEntityLegacy{
Signer: common.HexToAddress(signer.Address).String(),
UserId: int64(userID),
EntityId: int64(playlistID),
Action: indexer.Action_Create,
EntityType: indexer.Entity_Playlist,
Nonce: strconv.FormatInt(nonce, 10),
Metadata: string(finalMetadataBytes),
}

response, err := app.sendTransactionWithSigner(manageEntityTx, signer.PrivateKey)
if err != nil {
app.logger.Error("Failed to send playlist create transaction", zap.Error(err))
return c.Status(fiber.StatusInternalServerError).JSON(fiber.Map{
"error": "Failed to create playlist",
})
}

encodedPlaylistID, _ := trashid.EncodeHashId(playlistID)
return c.JSON(fiber.Map{
"success": true,
"transaction_hash": response.Msg.GetTransaction().GetHash(),
"playlist_id": encodedPlaylistID,
})
}

func (app *ApiServer) putV1Playlist(c *fiber.Ctx) error {
userID := app.getUserId(c)
playlistID, err := trashid.DecodeHashId(c.Params("playlistId"))
if err != nil {
return err
}

// Parse and validate request body
var req UpdatePlaylistRequest
if err := c.BodyParser(&req); err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "Invalid request body: " + err.Error(),
})
}

// Validate struct tags
if err := app.requestValidator.Validate(&req); err != nil {
return err
}

// Convert struct to map for metadata
metadataBytes, err := json.Marshal(req)
if err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "Failed to serialize metadata",
})
}

var metadata map[string]interface{}
if err := json.Unmarshal(metadataBytes, &metadata); err != nil {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "Failed to process metadata",
})
}

// Remove nil values from metadata
for key, value := range metadata {
if value == nil {
delete(metadata, key)
}
}

// Ensure at least one field is being updated
if len(metadata) == 0 {
return c.Status(fiber.StatusBadRequest).JSON(fiber.Map{
"error": "At least one field must be provided for update",
})
}

signer, err := app.getApiSigner(c)
if err != nil {
return err
}

nonce := time.Now().UnixNano()

// Build metadata JSON with cid and data fields
metadataJSON := map[string]interface{}{
"cid": "",
"data": metadata,
}
finalMetadataBytes, _ := json.Marshal(metadataJSON)

manageEntityTx := &corev1.ManageEntityLegacy{
Signer: common.HexToAddress(signer.Address).String(),
UserId: int64(userID),
EntityId: int64(playlistID),
Action: indexer.Action_Update,
EntityType: indexer.Entity_Playlist,
Nonce: strconv.FormatInt(nonce, 10),
Metadata: string(finalMetadataBytes),
}

response, err := app.sendTransactionWithSigner(manageEntityTx, signer.PrivateKey)
if err != nil {
app.logger.Error("Failed to send playlist update transaction", zap.Error(err))
return c.Status(fiber.StatusInternalServerError).JSON(fiber.Map{
"error": "Failed to update playlist",
})
}

return c.JSON(fiber.Map{
"success": true,
"transaction_hash": response.Msg.GetTransaction().GetHash(),
})
}

func (app *ApiServer) deleteV1Playlist(c *fiber.Ctx) error {
userID := app.getUserId(c)
playlistID, err := trashid.DecodeHashId(c.Params("playlistId"))
if err != nil {
return err
}

signer, err := app.getApiSigner(c)
if err != nil {
return err
}

nonce := time.Now().UnixNano()

manageEntityTx := &corev1.ManageEntityLegacy{
Signer: common.HexToAddress(signer.Address).String(),
UserId: int64(userID),
EntityId: int64(playlistID),
Action: indexer.Action_Delete,
EntityType: indexer.Entity_Playlist,
Nonce: strconv.FormatInt(nonce, 10),
Metadata: "",
}

response, err := app.sendTransactionWithSigner(manageEntityTx, signer.PrivateKey)
if err != nil {
app.logger.Error("Failed to send playlist delete transaction", zap.Error(err))
return c.Status(fiber.StatusInternalServerError).JSON(fiber.Map{
"error": "Failed to delete playlist",
})
}

return c.JSON(fiber.Map{
"success": true,
"transaction_hash": response.Msg.GetTransaction().GetHash(),
})
}
Loading