forked from GDSC-UIT/egreenbin-api
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
96168fb
commit 654e707
Showing
5 changed files
with
228 additions
and
30 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,188 @@ | ||
| package handlers | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "net/http" | ||
| "time" | ||
|
|
||
| "github.com/GDSC-UIT/egreenbin-api/common" | ||
| "github.com/GDSC-UIT/egreenbin-api/component" | ||
| "github.com/GDSC-UIT/egreenbin-api/models" | ||
| "github.com/gin-gonic/gin" | ||
| "go.mongodb.org/mongo-driver/bson" | ||
| "go.mongodb.org/mongo-driver/bson/primitive" | ||
| "go.mongodb.org/mongo-driver/mongo" | ||
| ) | ||
|
|
||
| // CommentHandler represent the httphandler for article | ||
| type CommentHandler struct { | ||
| DB *mongo.Database | ||
| } | ||
|
|
||
| // CommentHandler will initialize the articles/ resources endpoint | ||
| func NewCommentHandler(gin *gin.RouterGroup, appCtx component.AppContext, db *mongo.Database) { | ||
| handler := &CommentHandler{ | ||
| DB: db, | ||
| } | ||
| comments := gin.Group("/comments") | ||
| { | ||
| comments.GET("", handler.GetComments) | ||
| comments.POST("", handler.Create) | ||
| comments.GET(":id", handler.GetByID) | ||
| comments.PUT(":id", handler.Update) | ||
| comments.DELETE(":id", handler.Delete) | ||
| } | ||
| } | ||
|
|
||
| // FetchArticle will fetch the article based on given params | ||
| func (a *CommentHandler) GetComments(c *gin.Context) { | ||
| ctx := c.Request.Context() | ||
| var comments []models.Comment | ||
| cursor, err := a.DB.Collection("comments").Find(context.TODO(), bson.M{}) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| if err = cursor.All(ctx, &comments); err != nil { | ||
| c.JSON(http.StatusBadRequest, err) | ||
| return | ||
| } | ||
|
|
||
| c.JSON(http.StatusOK, common.SimpleSuccessResponse(comments)) | ||
| } | ||
|
|
||
| // GetByID will get comment by given id | ||
| func (a *CommentHandler) GetByID(c *gin.Context) { | ||
| ctx := c.Request.Context() | ||
|
|
||
| id := c.Param("id") | ||
|
|
||
| objectID, err := primitive.ObjectIDFromHex(id) | ||
| if err != nil { | ||
| c.JSON(http.StatusBadRequest, nil) | ||
| return | ||
| } | ||
| // Find the user with the matching ID in the "comments" collection | ||
| var comment models.Comment | ||
| err = a.DB.Collection("comments").FindOne(ctx, bson.M{"_id": objectID}).Decode(&comment) | ||
| if err != nil { | ||
| c.JSON(http.StatusBadRequest, nil) | ||
| return | ||
| } | ||
| c.JSON(http.StatusOK, common.SimpleSuccessResponse(comment)) | ||
| } | ||
|
|
||
| // Create comment will create a new comment based on given request body | ||
| // func (a *CommentHandler) Create(c *gin.Context) { | ||
| // ctx := c.Request.Context() | ||
|
|
||
| // var comment models.Comment | ||
| // if err := c.ShouldBindJSON(&comment); err != nil { | ||
| // c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request payload"}) | ||
| // return | ||
| // } | ||
|
|
||
| // comment.ID = primitive.NewObjectID() | ||
| // now := time.Now() | ||
| // comment.DateCreated = now | ||
| // comment.DateUpdated = now | ||
|
|
||
| // _, err := a.DB.Collection("comments").InsertOne(ctx, comment) | ||
| // if err != nil { | ||
| // c.JSON(http.StatusInternalServerError, gin.H{"error": "failed to create comment"}) | ||
| // return | ||
| // } | ||
|
|
||
| // c.JSON(http.StatusCreated, gin.H{"data": comment}) | ||
| // } | ||
|
|
||
| type Response struct { | ||
| Status string `json:"status"` | ||
| Data interface{} `json:"data"` | ||
| Message string `json:"message"` | ||
| } | ||
|
|
||
| func (a *CommentHandler) Create(c *gin.Context) { | ||
| ctx := c.Request.Context() | ||
|
|
||
| var comment models.Comment | ||
| if err := json.NewDecoder(c.Request.Body).Decode(&comment); err != nil { | ||
| c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()}) | ||
| return | ||
| } | ||
|
|
||
| comment.ID = primitive.NewObjectID() | ||
| now := primitive.NewDateTimeFromTime(time.Now()) | ||
| comment.DateCreated = now | ||
| comment.DateUpdated = now | ||
|
|
||
| if _, err := a.DB.Collection("comments").InsertOne(ctx, comment); err != nil { | ||
| c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) | ||
| return | ||
| } | ||
|
|
||
| res := Response{ | ||
| Status: "success", | ||
| Data: comment, | ||
| Message: "Comment has been created.", | ||
| } | ||
| c.JSON(http.StatusCreated, res) | ||
| } | ||
|
|
||
| // Update will update a comment by given id | ||
| func (a *CommentHandler) Update(c *gin.Context) { | ||
| ctx := c.Request.Context() | ||
|
|
||
| id := c.Param("id") | ||
| var requestBody models.Comment | ||
|
|
||
| if err := c.BindJSON(&requestBody); err != nil { | ||
| c.JSON(http.StatusBadRequest, err) | ||
| return | ||
| } | ||
| updates := map[string]interface{}{ | ||
| "student": requestBody.Student, | ||
| "content": requestBody.Content, | ||
| // "DateSort": requestBody.DateSort, | ||
| "type": requestBody.Type, | ||
| // "dateCreated": requestBody.DateCreated, | ||
| "dateUpdated": primitive.NewDateTimeFromTime(time.Now()), | ||
| } | ||
|
|
||
| objectID, err := primitive.ObjectIDFromHex(id) | ||
| if err != nil { | ||
| c.JSON(http.StatusBadRequest, err) | ||
| return | ||
| } | ||
|
|
||
| // Update the user with the matching ID in the "comments" collection | ||
| _, err = a.DB.Collection("comments").UpdateOne(ctx, bson.M{"_id": objectID}, bson.M{"$set": updates}) | ||
| if err != nil { | ||
| c.JSON(http.StatusBadRequest, err) | ||
| return | ||
| } | ||
|
|
||
| c.JSON(http.StatusNoContent, gin.H{"message": "success"}) | ||
| } | ||
|
|
||
| // Delete will delete a comment by given id | ||
| func (a *CommentHandler) Delete(c *gin.Context) { | ||
| ctx := c.Request.Context() | ||
|
|
||
| id := c.Param("id") | ||
|
|
||
| objectID, err := primitive.ObjectIDFromHex(id) | ||
| if err != nil { | ||
| c.JSON(http.StatusBadRequest, err) | ||
| return | ||
| } | ||
|
|
||
| // Delete the user with the matching ID in the "comments" collection | ||
| _, err = a.DB.Collection("comments").DeleteOne(ctx, bson.M{"_id": objectID}) | ||
| if err != nil { | ||
| c.JSON(http.StatusBadRequest, err) | ||
| return | ||
| } | ||
| c.JSON(http.StatusNoContent, gin.H{"message": "success"}) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| package models | ||
|
|
||
| import ( | ||
| "go.mongodb.org/mongo-driver/bson/primitive" | ||
| ) | ||
|
|
||
| type Comment struct { | ||
| ID primitive.ObjectID `bson:"_id" json:"id" ` | ||
| Student Student `bson:"student,inline" json:"Student"` | ||
| Content string `bson:"content" json:"Content"` | ||
| // DateSort primitive.DateTime `bson:"dateSort" json:"DateSort"` | ||
| Type string `bson:"type" json:"type"` | ||
| DateCreated primitive.DateTime `bson:"dateCreated" json:"DateCreated"` | ||
| DateUpdated primitive.DateTime `bson:"dateUpdated" json:"DateUpdated"` | ||
|
|
||
| // String idStudent; // id of student of comment | ||
| // String content; // content of comment | ||
| // String dateSort; // xem class dateSort, co the tra ve 3 kieu: date, week, month | ||
| // String type; // date, week, month | ||
| // DateTime? dateCreate; // date create of comment | ||
| } |