chore: Add logic for put and get by id handler
Some checks failed
Backend ci / build (push) Has been cancelled
Some checks failed
Backend ci / build (push) Has been cancelled
This commit is contained in:
@@ -5,6 +5,7 @@ import (
|
||||
"gitea.d3m0k1d.ru/d3m0k1d/d3m0k1d.ru/backend/internal/repositories"
|
||||
"gitea.d3m0k1d.ru/d3m0k1d/d3m0k1d.ru/backend/internal/storage"
|
||||
"github.com/gin-gonic/gin"
|
||||
"strconv"
|
||||
)
|
||||
|
||||
type PostHandlers struct {
|
||||
@@ -41,11 +42,28 @@ func (h *PostHandlers) GetPosts(c *gin.Context) {
|
||||
// @Description Get post by id
|
||||
// @Tags posts
|
||||
// @Accept json
|
||||
// @Param id path int true "Post ID"
|
||||
// @Produce json
|
||||
// @Success 200 {object} storage.PostReq
|
||||
// @Failure 400 {object} map[string]string "Invalid ID format"
|
||||
// @Failure 500 {object} map[string]string "Internal server error"
|
||||
// @Router /posts/{id} [get]
|
||||
func GetPost(c *gin.Context) {
|
||||
log.Info("GetPost")
|
||||
func (h *PostHandlers) GetPost(c *gin.Context) {
|
||||
var result storage.PostReq
|
||||
id_p := c.Param("id")
|
||||
id, err := strconv.Atoi(id_p)
|
||||
if err != nil {
|
||||
log.Error("error request: " + err.Error())
|
||||
c.Status(500)
|
||||
}
|
||||
result, err = h.repo.GetByID(c.Request.Context(), id)
|
||||
if err != nil {
|
||||
log.Error("error request: " + err.Error())
|
||||
c.Status(500)
|
||||
}
|
||||
log.Info("200 OK GET /posts/" + id_p)
|
||||
c.JSON(200, result)
|
||||
// TODO: added validaton for 400 response
|
||||
}
|
||||
|
||||
// CreatePost godoc
|
||||
@@ -84,11 +102,31 @@ func (h *PostHandlers) CreatePost(c *gin.Context) {
|
||||
// @Description Update post
|
||||
// @Tags posts
|
||||
// @Accept json
|
||||
// @Param id path int true "Post ID"
|
||||
// @Param post body storage.PostCreate true "Post data"
|
||||
// @Produce json
|
||||
// @Success 200 {object} storage.Post
|
||||
// @Success 200 {object} storage.PostCreate
|
||||
// @Router /posts/{id} [put]
|
||||
func UpdatePost(c *gin.Context) {
|
||||
log.Info("UpdatePost")
|
||||
func (h *PostHandlers) UpdatePost(c *gin.Context) {
|
||||
id_p := c.Param("id")
|
||||
id, err := strconv.Atoi(id_p)
|
||||
if err != nil {
|
||||
log.Error("error request: " + err.Error())
|
||||
c.Status(500)
|
||||
}
|
||||
var req storage.Post
|
||||
if err := c.ShouldBindJSON(&req); err != nil {
|
||||
c.JSON(400, gin.H{"error": err.Error()})
|
||||
return
|
||||
}
|
||||
err = h.repo.Update(c.Request.Context(), id, req)
|
||||
if err != nil {
|
||||
c.JSON(500, gin.H{"error": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
c.JSON(200, req)
|
||||
log.Info("200 OK PUT /posts/" + id_p)
|
||||
}
|
||||
|
||||
// DeletePost godoc
|
||||
|
||||
@@ -13,9 +13,9 @@ func Register(router *gin.Engine, db *sql.DB) {
|
||||
posts := v1.Group("posts")
|
||||
{
|
||||
posts.GET("/", handler_posts.GetPosts)
|
||||
posts.GET("/:id", GetPost)
|
||||
posts.GET("/:id", handler_posts.GetPost)
|
||||
posts.POST("/", handler_posts.CreatePost)
|
||||
posts.PUT("/:id", UpdatePost)
|
||||
posts.PUT("/:id", handler_posts.UpdatePost)
|
||||
posts.DELETE("/:id", DeletePost)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -21,7 +21,7 @@ func NewPostRepository(db *sql.DB) PostRepository {
|
||||
}
|
||||
func (p *postRepository) GetAll(ctx context.Context) ([]storage.PostReq, error) {
|
||||
var result []storage.PostReq
|
||||
rows, err := p.db.Query("SELECT title content FROM posts")
|
||||
rows, err := p.db.Query("SELECT id, title, content FROM posts")
|
||||
if err != nil {
|
||||
p.logger.Error(err.Error())
|
||||
return nil, err
|
||||
@@ -29,11 +29,13 @@ func (p *postRepository) GetAll(ctx context.Context) ([]storage.PostReq, error)
|
||||
for rows.Next() {
|
||||
var title string
|
||||
var content string
|
||||
err := rows.Scan(&title, &content)
|
||||
var id int
|
||||
err := rows.Scan(&id, &title, &content)
|
||||
if err != nil {
|
||||
p.logger.Error("error scan: " + err.Error())
|
||||
}
|
||||
result = append(result, storage.PostReq{
|
||||
ID: id,
|
||||
Title: title,
|
||||
Content: content,
|
||||
})
|
||||
@@ -43,7 +45,7 @@ func (p *postRepository) GetAll(ctx context.Context) ([]storage.PostReq, error)
|
||||
|
||||
func (p *postRepository) GetByID(ctx context.Context, id int) (storage.PostReq, error) {
|
||||
var result storage.PostReq
|
||||
row := p.db.QueryRow("SELECT title content FROM posts WHERE id = ?", id)
|
||||
row := p.db.QueryRow("SELECT title, content FROM posts WHERE id = ?", id)
|
||||
var title string
|
||||
var content string
|
||||
err := row.Scan(&title, &content)
|
||||
@@ -51,6 +53,7 @@ func (p *postRepository) GetByID(ctx context.Context, id int) (storage.PostReq,
|
||||
p.logger.Error("error scan: " + err.Error())
|
||||
}
|
||||
result = storage.PostReq{
|
||||
ID: id,
|
||||
Title: title,
|
||||
Content: content,
|
||||
}
|
||||
@@ -75,7 +78,16 @@ func (p *postRepository) Create(ctx context.Context, post storage.Post) error {
|
||||
}
|
||||
|
||||
func (p *postRepository) Update(ctx context.Context, id int, post storage.Post) error {
|
||||
|
||||
_, err := p.db.Exec(
|
||||
"UPDATE posts SET title = ?, content = ? WHERE id = ?",
|
||||
post.Title,
|
||||
post.Content,
|
||||
id,
|
||||
)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
p.logger.Info("Post updated:", "id", id)
|
||||
return nil
|
||||
}
|
||||
|
||||
|
||||
@@ -8,6 +8,7 @@ type Post struct {
|
||||
}
|
||||
|
||||
type PostReq struct {
|
||||
ID int `json:"id"`
|
||||
Title string `json:"title"`
|
||||
Content string `json:"content"`
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user