Merge pull request #425 from mayuka-c/feedback-db

Feedback DB Implementation

Author: ppc64le-cloud-bot

internal/pkg/pac-go-server/db/interface.go

@@ -39,4 +39,7 @@ type DB interface {
 	AcceptTermsAndConditions(*models.TermsAndConditions) error
 	GetTermsAndConditionsByUserID(string) (*models.TermsAndConditions, error)
 	DeleteTermsAndConditionsByUserID(string) error
+
+	InsertFeedback(*models.Feedback) error
+	GetFeedbacks(models.FeedbacksFilter) ([]models.Feedback, error)
 }

internal/pkg/pac-go-server/db/mock_db_client.go

@@ -0,0 +1,53 @@
+package mongodb
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/PDeXchange/pac/internal/pkg/pac-go-server/models"
+	"go.mongodb.org/mongo-driver/bson"
+)
+
+// InsertFeedback - insert feedback record into the DB
+func (db *MongoDB) InsertFeedback(feedback *models.Feedback) error {
+	collection := db.Database.Collection("feedbacks")
+	ctx, cancel := context.WithTimeout(context.Background(), dbContextTimeout)
+	defer cancel()
+
+	if _, err := collection.InsertOne(ctx, feedback); err != nil {
+		return fmt.Errorf("error inserting feedback: %w", err)
+	}
+
+	return nil
+}
+
+// GetFeedbacks - returns list of feedbacks based on the provided filter
+func (db *MongoDB) GetFeedbacks(filter models.FeedbacksFilter) ([]models.Feedback, error) {
+	collection := db.Database.Collection("feedbacks")
+	ctx, cancel := context.WithTimeout(context.Background(), dbContextTimeout)
+	defer cancel()
+
+	cursor, err := collection.Find(ctx, buildFilter(filter))
+	if err != nil {
+		return nil, fmt.Errorf("error fetching feedbacks from DB: %w", err)
+	}
+	defer cursor.Close(ctx)
+
+	feedbacks := []models.Feedback{}
+	if err := cursor.All(context.TODO(), &feedbacks); err != nil {
+		return nil, fmt.Errorf("error getting feedbacks: %w", err)
+	}
+
+	return feedbacks, nil
+}
+
+func buildFilter(filter models.FeedbacksFilter) bson.M {
+	bsonFilter := bson.M{}
+
+	// Conditionally add filters based on whether fields are set
+	if filter.UserID != "" {
+		bsonFilter["user_id"] = filter.UserID
+	}
+
+	return bsonFilter
+}

internal/pkg/pac-go-server/db/mongodb/feedback.go

@@ -0,0 +1,31 @@
+package models
+
+import "go.mongodb.org/mongo-driver/bson/primitive"
+
+type Rating string
+
+const (
+	Positive Rating = "Positive"
+	Negative Rating = "Negative"
+	Neutral  Rating = "Neutral"
+)
+
+func (r Rating) IsValid() bool {
+	switch r {
+	case Positive, Negative, Neutral:
+		return true
+	default:
+		return false
+	}
+}
+
+type Feedback struct {
+	ID      primitive.ObjectID `json:"id" bson:"_id,omitempty"`
+	UserID  string             `json:"user_id" bson:"user_id,omitempty"`
+	Rating  Rating             `json:"rating" bson:"rating,omitempty"`
+	Comment string             `json:"comment" bson:"comment,omitempty"`
+}
+
+type FeedbacksFilter struct {
+	UserID string
+}