Merge pull request #65 from imrishuroy/ft/feature-posts

add feature post APIs

api/feature_posts.go

@@ -0,0 +1,96 @@
+package api
+
+import (
+	"firebase.google.com/go/v4/auth"
+	"github.com/gin-gonic/gin"
+	db "github.com/imrishuroy/legal-referral/db/sqlc"
+	"net/http"
+	"strconv"
+)
+
+type saveFeaturePostReq struct {
+	PostID int32  `json:"post_id"`
+	UserID string `json:"user_id"`
+}
+
+func (server *Server) saveFeaturePost(ctx *gin.Context) {
+	var req saveFeaturePostReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		ctx.JSON(400, errorResponse(err))
+		return
+	}
+
+	authPayload := ctx.MustGet(authorizationPayloadKey).(*auth.Token)
+	if authPayload.UID != req.UserID {
+		ctx.JSON(http.StatusUnauthorized, gin.H{"message": "Unauthorized"})
+		return
+	}
+
+	arg := db.SaveFeaturePostParams{
+		PostID: req.PostID,
+		UserID: req.UserID,
+	}
+
+	err := server.store.SaveFeaturePost(ctx, arg)
+	if err != nil {
+
+		errorCode := db.ErrorCode(err)
+		if errorCode == db.UniqueViolation {
+			ctx.JSON(400, gin.H{"message": "Post already saved"})
+			return
+		}
+		ctx.JSON(500, errorResponse(err))
+		return
+	}
+
+	ctx.JSON(200, gin.H{"message": "success"})
+}
+
+func (server *Server) unSaveFeaturePost(ctx *gin.Context) {
+	postIdStr := ctx.Param("post_id")
+
+	postID, err := strconv.Atoi(postIdStr)
+	if err != nil {
+		ctx.JSON(400, errorResponse(err))
+		return
+	}
+
+	authPayload := ctx.MustGet(authorizationPayloadKey).(*auth.Token)
+	if authPayload.UID == "" {
+		ctx.JSON(http.StatusUnauthorized, gin.H{"message": "Unauthorized"})
+		return
+	}
+
+	arg := db.UnSaveFeaturePostParams{
+		PostID: int32(postID),
+		UserID: authPayload.UID,
+	}
+
+	err = server.store.UnSaveFeaturePost(ctx, arg)
+
+	if err != nil {
+		ctx.JSON(500, errorResponse(err))
+		return
+	}
+
+	ctx.JSON(200, gin.H{"message": "success"})
+}
+
+func (server *Server) listFeaturePosts(ctx *gin.Context) {
+
+	userID := ctx.Param("user_id")
+
+	authPayload := ctx.MustGet(authorizationPayloadKey).(*auth.Token)
+	if authPayload.UID != userID {
+		ctx.JSON(http.StatusUnauthorized, gin.H{"message": "Unauthorized"})
+		return
+	}
+
+	posts, err := server.store.ListFeaturePosts(ctx)
+	if err != nil {
+		ctx.JSON(500, errorResponse(err))
+		return
+	}
+
+	ctx.JSON(200, posts)
+}

api/router.go

@@ -182,9 +182,14 @@ func (server *Server) setupRouter() {
 
 	// save post
 	auth.POST("/saved-posts", server.savePost)
-	auth.DELETE("/saved-posts/:saved_post_id", server.unsavePost)
+	auth.DELETE("/saved-posts/:saved_post_id", server.unSavePost)
 	auth.GET("/saved-posts/:user_id", server.listSavedPosts)
 
+	// feature posts
+	auth.POST("/feature-posts", server.saveFeaturePost)
+	auth.DELETE("/feature-posts/:post_id", server.unSaveFeaturePost)
+	auth.GET("/feature-posts/:user_id", server.listFeaturePosts)
+
 }
 
 func CORSMiddleware() gin.HandlerFunc {

api/saved_posts.go

@@ -47,7 +47,7 @@ func (server *Server) savePost(ctx *gin.Context) {
 
 }
 
-func (server *Server) unsavePost(ctx *gin.Context) {
+func (server *Server) unSavePost(ctx *gin.Context) {
 
 	savedPostParam := ctx.Param("saved_post_id")
 	// convert this to int32

db/migration/000030_feature_posts.down.sql

@@ -0,0 +1 @@
+DROP TABLE IF EXISTS feature_posts;

db/migration/000030_feature_posts.up.sql

@@ -0,0 +1,9 @@
+CREATE TABLE feature_posts (
+    feature_post_id SERIAL PRIMARY KEY,
+    post_id INT NOT NULL,
+    user_id VARCHAR NOT NULL,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT current_timestamp,
+    FOREIGN KEY (post_id) REFERENCES posts(post_id),
+    FOREIGN KEY (user_id) REFERENCES users(user_id),
+    UNIQUE (post_id, user_id)
+);

db/query/feature_posts.sql

@@ -0,0 +1,24 @@
+-- name: SaveFeaturePost :exec
+INSERT INTO feature_posts (
+    user_id,
+    post_id
+) VALUES (
+    $1, $2
+) RETURNING *;
+
+-- name: UnSaveFeaturePost :exec
+DELETE FROM feature_posts
+WHERE
+    user_id = $1 AND post_id = $2;
+
+-- name: ListFeaturePosts :many
+SELECT
+    feature_posts.feature_post_id,
+    sqlc.embed(posts),
+    feature_posts.created_at
+FROM
+    feature_posts
+JOIN
+    posts ON feature_posts.post_id = posts.post_id
+ORDER BY
+    feature_posts.created_at DESC;