Initial code creation. working on creating review schema and model setup and handler functions

backend/internal/models/review.go

@@ -0,0 +1,13 @@
+package models
+
+import "time"
+
+type Review struct {
+	UserID    string    `json:"user_id"`
+	MediaType string    `json:"media_type"`
+	MediaID   string    `json:"media_id"`
+	Rating    string    `json:"rating"`
+	Desc      *string   `json:"desc,omitempty"`
+	CreatedAt time.Time `json:"created_at"`
+	UpdatedAt time.Time `json:"updated_at"`
+}

backend/internal/service/handler/review.go

@@ -0,0 +1,104 @@
+package handler
+
+import (
+	"fmt"
+	"platnm/internal/storage"
+	"strconv"
+
+	"github.com/gofiber/fiber/v2"
+)
+
+type ReviewHandler struct {
+	reviewRepository storage.ReviewRepository
+}
+
+func NewReviewHandler(reviewRepository storage.ReviewRepository) *ReviewHandler {
+	return &ReviewHandler{
+		reviewRepository,
+	}
+}
+
+func (h *ReviewHandler) GetReviews(c *fiber.Ctx) error {
+	review, err := h.reviewRepository.GetReviews(c.Context())
+	if err != nil {
+		return err
+	}
+
+	return c.Status(fiber.StatusOK).JSON(review)
+}
+
+func (h *ReviewHandler) GetReviewById(c *fiber.Ctx, mediaType string) error {
+	id := c.Params("id")
+	offsetstr := c.Query("offset", "0")
+	limitstr := c.Query("limit", "10")
+	//limitParam := r.URL.Query().Get("limit")
+	//offsetParam := r.URL.Query().Get("offset")
+	//review, err := h.reviewRepository.GetReviewsByID(id, mediaType, c.Context())
+
+	var offset int
+	if offsetstr == "" {
+		offset = 0 // Default to 0 if no offset is provided
+	} else {
+		var err error
+		offset, err = strconv.Atoi(offsetstr)
+		if err != nil || offset < 0 {
+			offset = 0 // Ensure offset is non-negative
+		}
+	}
+
+	// Check if limitstr is empty, then default to 10
+	var limit int
+	if limitstr == "" {
+		limit = 10 // Default to 10 if no limit is provided
+	} else {
+		var err error
+		limit, err = strconv.Atoi(limitstr)
+		if err != nil || limit <= 0 {
+			limit = 10 // Ensure limit is positive
+		}
+	}
+
+	print("running?")
+
+	// Fetch the review based on ID and media type
+	review, err := h.reviewRepository.GetReviewsByID(c.Context(), id, mediaType)
+	if err != nil {
+		// If error, log it and return 500
+		fmt.Println(err.Error(), "from transactions err ")
+		return c.Status(fiber.StatusInternalServerError).JSON(fiber.Map{
+			"error": "Unable to retrieve reviews",
+		})
+	}
+
+	// If no review is found, return a 404 status
+	if len(review) == 0 {
+		return c.Status(fiber.StatusNotFound).JSON(fiber.Map{
+			"message": "No reviews found",
+		})
+	}
+
+	// Calculate average rating
+	var avgRating float64
+	for _, r := range review {
+		rating, err := strconv.ParseFloat(r.Rating, 64)
+		if err != nil {
+			avgRating += rating
+		}
+
+	}
+	if len(review) > 0 {
+		avgRating /= float64(len(review))
+	}
+
+	var end = offset*limit - 1
+	var start = end - limit
+	var paginatedReview = review[start:end]
+
+	// Return the reviews and average rating
+	response := fiber.Map{
+		"avgRating": avgRating,
+		"reviews":   paginatedReview,
+	}
+
+	return c.Status(fiber.StatusOK).JSON(response)
+}

backend/internal/service/server.go

@@ -36,6 +36,18 @@ func setupRoutes(app *fiber.App, conn *pgxpool.Pool) {
 		r.Get("/", userHandler.GetUsers)
 		r.Get("/:id", userHandler.GetUserById)
 	})
+
+	reviewHandler := handler.NewReviewHandler(repository.Review)
+	app.Route("/reviews", func(r fiber.Router) {
+		r.Get("/album", reviewHandler.GetReviews)
+		r.Get("/album/:albumID", func(c *fiber.Ctx) error {
+			return reviewHandler.GetReviewById(c, "album")
+		})
+		r.Get("/track", reviewHandler.GetReviews)
+		r.Get("/track/:trackID", func(c *fiber.Ctx) error {
+			return reviewHandler.GetReviewById(c, "track")
+		})
+	})
 }
 
 func setupApp() *fiber.App {

backend/internal/storage/postgres/schema/review.go

@@ -0,0 +1,103 @@
+package user
+
+import (
+	"context"
+	"platnm/internal/models"
+
+	"time"
+
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type ReviewRepository struct {
+	db *pgxpool.Pool
+}
+
+func (r *ReviewRepository) GetReviews(ctx context.Context) ([]*models.Review, error) {
+	rows, err := r.db.Query(context.Background(), "SELECT user_id, media_id, media_type, desc, rating, CreatedAt, UpdatedAt FROM review")
+	if err != nil {
+		print(err.Error(), "from transactions err ")
+		return []*models.Review{}, err
+	}
+	defer rows.Close()
+
+	var reviews []*models.Review
+	for rows.Next() {
+		var review models.Review
+		var userID, mediaID, mediaType, desc, rating *string
+		var CreatedAt, UpdatedAt *time.Time
+
+		if err := rows.Scan(&userID, &mediaID, &mediaType, &desc, &rating, &UpdatedAt, &CreatedAt); err != nil {
+			print(err.Error(), "from transactions err ")
+			return reviews, err
+		}
+
+		review.UserID = *userID
+		review.MediaID = *mediaID
+		review.MediaType = *mediaType
+		review.Desc = desc
+		review.Rating = *rating
+		review.UpdatedAt = *UpdatedAt
+		review.CreatedAt = *CreatedAt
+
+		reviews = append(reviews, &review)
+	}
+
+	if err := rows.Err(); err != nil {
+		print(err.Error(), "from transactions err ")
+		return []*models.Review{}, err
+	}
+
+	return reviews, nil
+}
+
+func (r *ReviewRepository) GetReviewsByID(ctx context.Context, id string, mediaType string) ([]*models.Review, error) {
+
+	rows, err := r.db.Query(ctx, "SELECT * FROM review WHERE media_id = $1 and Media_type = $2", id, mediaType)
+	print(rows)
+	if err != nil {
+		print(err.Error(), "from transactions err ")
+		return []*models.Review{}, err
+	}
+	defer rows.Close()
+
+	var reviews []*models.Review
+
+	for rows.Next() {
+		print("1")
+		var review models.Review
+		print("2")
+		var mediaType, desc, userID, mediaID, rating *string
+		var createdAt, updatedAt *time.Time
+		print("3")
+		if err := rows.Scan(&userID, &mediaID, &mediaType, &rating, &desc, &createdAt, &updatedAt); err != nil {
+			print(err.Error(), "from transactions err ")
+			return reviews, err
+		}
+		print("4")
+		review.UserID = *userID
+		review.MediaID = *mediaID
+		review.MediaType = *mediaType
+		review.Desc = desc
+		review.Rating = *rating
+		review.CreatedAt = *createdAt
+		review.UpdatedAt = *updatedAt
+		print("5")
+		reviews = append(reviews, &review)
+	}
+
+	print("second")
+	if err := rows.Err(); err != nil {
+		print(err.Error(), "this from transactions err ")
+		return []*models.Review{}, err
+	}
+
+	return reviews, nil
+
+}
+
+func NewReviewRepository(db *pgxpool.Pool) *ReviewRepository {
+	return &ReviewRepository{
+		db: db,
+	}
+}

backend/internal/storage/postgres/storage.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"log"
 	"platnm/internal/storage"
+	review "platnm/internal/storage/postgres/schema"
 	user "platnm/internal/storage/postgres/schema"
 
 	"github.com/jackc/pgx/v5"
@@ -40,6 +41,7 @@ func ConnectDatabase(host, user, password, dbname, port string) *pgxpool.Pool {
 
 func NewRepository(db *pgxpool.Pool) *storage.Repository {
 	return &storage.Repository{
-		User: user.NewUserRepository(db),
+		User:   user.NewUserRepository(db),
+		Review: review.NewReviewRepository(db),
 	}
 }

backend/internal/storage/storage.go

@@ -10,7 +10,13 @@ type UserRepository interface {
 	GetUserByID(id string, ctx context.Context) (*models.User, error)
 }
 
+type ReviewRepository interface {
+	GetReviews(ctx context.Context) ([]*models.Review, error)
+	GetReviewsByID(ctx context.Context, id string, mediaType string) ([]*models.Review, error)
+}
+
 // Repository storage of all repositories.
 type Repository struct {
-	User UserRepository
+	User   UserRepository
+	Review ReviewRepository
 }

backend/internal/supabase/migrations/20240916024934_remote_schema.sql

@@ -42,6 +42,17 @@ CREATE TABLE IF NOT EXISTS "public"."users" (
     "push_notification_enabled" boolean DEFAULT false
 );
 
+CREATE TABLE review (
+    user_id VARCHAR(255) NOT NULL,
+    media_type VARCHAR(50) NOT NULL,
+    media_id VARCHAR(255) NOT NULL,
+    rating VARCHAR(10) NOT NULL,
+    description TEXT,
+    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    PRIMARY KEY (user_id, media_id, media_type) -- Assuming a composite key
+);
+
 ALTER TABLE "public"."users" OWNER TO "postgres";
 
 ALTER TABLE ONLY "public"."users"

backend/internal/supabase/seed.sql

@@ -4,4 +4,11 @@ VALUES
   ('user2', 'Jane', 'Doe', '[email protected]', '987-654-3210', NULL),
   ('user3', 'Bob', 'Johnson', '[email protected]', NULL, NULL, NULL),
   ('user4', 'Emily', 'Garcia', '[email protected]', '555-1212', NULL)
-;
+;
+
+INSERT INTO review (user_id, media_type, media_id, rating, description, created_at, updated_at)
+VALUES 
+('user123', 'album', 'album123', '1', 'Great album, enjoyed every track!', '2023-09-19 14:45:00', '2023-09-19 14:45:00'),
+('user456', 'track', 'track789', '1', 'Not my taste, but decent production.', '2023-09-19 15:00:00', '2023-09-19 15:00:00'),
+('user789', 'album', 'album456', '2', 'Absolutely fantastic! Best album of the year.', '2023-09-20 08:30:00', '2023-09-20 08:30:00'),
+('user101', 'track', 'track654', '2', NULL, '2023-09-20 09:45:00', '2023-09-20 09:45:00');