Add API endpoint for re-following the queue playlist

Author: Nikos410

listeningSession/listeningSession.go

@@ -384,3 +384,26 @@ func NewQueuePlaylist(session model.FullListeningSession) *SpotifeteError {
 
 	return nil
 }
+
+func RefollowQueuePlaylist(session model.FullListeningSession) *SpotifeteError {
+
+	owner := session.Owner
+	client := users.Client(owner)
+
+	ownerId := spotify.ID(owner.SpotifyId)
+	queuePlaylistId := spotify.ID(session.QueuePlaylistId)
+
+	err := client.UnfollowPlaylist(ownerId, queuePlaylistId)
+	if err != nil {
+		return NewError("Could not unfollow playlist.", err, http.StatusInternalServerError)
+	}
+
+	time.Sleep(1 * time.Second)
+
+	err = client.FollowPlaylist(ownerId, queuePlaylistId, false)
+	if err == nil {
+		return nil
+	} else {
+		return NewError("Could not unfollow playlist.", err, http.StatusInternalServerError)
+	}
+}

webapp/apiv2/listeningSession/listeningSession.go

@@ -319,6 +319,44 @@ func newQueuePlaylist(c *gin.Context) {
 	}
 }
 
+func refollowQueuePlaylist(c *gin.Context) {
+
+	joinId := c.Param("joinId")
+	session := listeningSession.FindFullListeningSession(model.SimpleListeningSession{
+		JoinId: joinId,
+		Active: true,
+	})
+	if session == nil {
+		c.JSON(http.StatusNotFound, ErrorResponse{Message: "Listening session not found."})
+		return
+	}
+
+	request := AuthenticatedRequest{}
+	err := c.ShouldBindJSON(&request)
+	if err != nil {
+		c.JSON(http.StatusBadRequest, ErrorResponse{Message: "invalid requestBody: " + err.Error()})
+		return
+	}
+
+	authenticatedUser, spotifeteError := request.GetSimpleUser()
+	if spotifeteError != nil {
+		SetJsonError(*spotifeteError, c)
+		return
+	}
+
+	if session.OwnerId != authenticatedUser.ID {
+		c.JSON(http.StatusUnauthorized, ErrorResponse{Message: "Only the session owner can delete requests from the queue!"})
+		return
+	}
+
+	spotifeteError = listeningSession.RefollowQueuePlaylist(*session)
+	if spotifeteError == nil {
+		c.Status(http.StatusNoContent)
+	} else {
+		SetJsonError(*spotifeteError, c)
+	}
+}
+
 func changeFallbackPlaylist(c *gin.Context) {
 	request := ChangeFallbackPlaylistRequest{}
 	err := c.ShouldBindJSON(&request)

webapp/apiv2/listeningSession/routes.go

@@ -18,6 +18,7 @@ func SetupRoutes(baseRouterGroup *gin.RouterGroup) {
 	router.GET("/id/:joinId/search/playlist", searchPlaylist)
 	router.POST("/id/:joinId/request-track", requestTrack)
 	router.POST("/id/:joinId/new-queue-playlist", newQueuePlaylist)
+	router.POST("/id/:joinId/refollow-queue-playlist", refollowQueuePlaylist)
 	router.PUT("/id/:joinId/fallback-playlist", changeFallbackPlaylist)
 	router.DELETE("/id/:joinId/fallback-playlist", removeFallbackPlaylist)
 	router.PATCH("/id/:joinId/fallback-playlist/shuffle", setFallbackPlaylistShuffle)