added cluster model

Author: Ubuntu

pkg/controllers/cluster.controller.go

@@ -0,0 +1,131 @@
+package controllers
+
+import (
+	"net/http"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/gin-gonic/gin"
+	"github.com/kriipke/console-api/pkg/models"
+	"gorm.io/gorm"
+)
+
+type PostController struct {
+	DB *gorm.DB
+}
+
+func NewPostController(DB *gorm.DB) PostController {
+	return PostController{DB}
+}
+
+// [...] Create Post Handler
+func (pc *PostController) CreatePost(ctx *gin.Context) {
+	currentUser := ctx.MustGet("currentUser").(models.User)
+	var payload *models.CreatePostRequest
+
+	if err := ctx.ShouldBindJSON(&payload); err != nil {
+		ctx.JSON(http.StatusBadRequest, err.Error())
+		return
+	}
+
+	now := time.Now()
+	newPost := models.Post{
+		Title:     payload.Title,
+		Content:   payload.Content,
+		Image:     payload.Image,
+		User:      currentUser.ID,
+		CreatedAt: now,
+		UpdatedAt: now,
+	}
+
+	result := pc.DB.Create(&newPost)
+	if result.Error != nil {
+		if strings.Contains(result.Error.Error(), "duplicate key") {
+			ctx.JSON(http.StatusConflict, gin.H{"status": "fail", "message": "Post with that title already exists"})
+			return
+		}
+		ctx.JSON(http.StatusBadGateway, gin.H{"status": "error", "message": result.Error.Error()})
+		return
+	}
+
+	ctx.JSON(http.StatusCreated, gin.H{"status": "success", "data": newPost})
+}
+
+// [...] Update Post Handler
+func (pc *PostController) UpdatePost(ctx *gin.Context) {
+	postId := ctx.Param("postId")
+	currentUser := ctx.MustGet("currentUser").(models.User)
+
+	var payload *models.UpdatePost
+	if err := ctx.ShouldBindJSON(&payload); err != nil {
+		ctx.JSON(http.StatusBadGateway, gin.H{"status": "fail", "message": err.Error()})
+		return
+	}
+	var updatedPost models.Post
+	result := pc.DB.First(&updatedPost, "id = ?", postId)
+	if result.Error != nil {
+		ctx.JSON(http.StatusNotFound, gin.H{"status": "fail", "message": "No post with that title exists"})
+		return
+	}
+	now := time.Now()
+	postToUpdate := models.Post{
+		Title:     payload.Title,
+		Content:   payload.Content,
+		Image:     payload.Image,
+		User:      currentUser.ID,
+		CreatedAt: updatedPost.CreatedAt,
+		UpdatedAt: now,
+	}
+
+	pc.DB.Model(&updatedPost).Updates(postToUpdate)
+
+	ctx.JSON(http.StatusOK, gin.H{"status": "success", "data": updatedPost})
+}
+
+// [...] Get Single Post Handler
+func (pc *PostController) FindPostById(ctx *gin.Context) {
+	postId := ctx.Param("postId")
+
+	var post models.Post
+	result := pc.DB.First(&post, "id = ?", postId)
+	if result.Error != nil {
+		ctx.JSON(http.StatusNotFound, gin.H{"status": "fail", "message": "No post with that title exists"})
+		return
+	}
+
+	ctx.JSON(http.StatusOK, gin.H{"status": "success", "data": post})
+}
+
+// [...] Get All Posts Handler
+func (pc *PostController) FindPosts(ctx *gin.Context) {
+	var page = ctx.DefaultQuery("page", "1")
+	var limit = ctx.DefaultQuery("limit", "10")
+
+	intPage, _ := strconv.Atoi(page)
+	intLimit, _ := strconv.Atoi(limit)
+	offset := (intPage - 1) * intLimit
+
+	var posts []models.Post
+	results := pc.DB.Limit(intLimit).Offset(offset).Find(&posts)
+	if results.Error != nil {
+		ctx.JSON(http.StatusBadGateway, gin.H{"status": "error", "message": results.Error})
+		return
+	}
+
+	ctx.JSON(http.StatusOK, gin.H{"status": "success", "results": len(posts), "data": posts})
+}
+
+// [...] Delete Post Handler
+func (pc *PostController) DeletePost(ctx *gin.Context) {
+	postId := ctx.Param("postId")
+
+	result := pc.DB.Delete(&models.Post{}, "id = ?", postId)
+
+	if result.Error != nil {
+		ctx.JSON(http.StatusNotFound, gin.H{"status": "fail", "message": "No post with that title exists"})
+		return
+	}
+
+	ctx.JSON(http.StatusNoContent, nil)
+}

pkg/migrate/migrate.go

@@ -19,6 +19,6 @@ func init() {
 }
 
 func main() {
-	initializers.DB.AutoMigrate(&models.User{}, &models.Post{})
+	initializers.DB.AutoMigrate(&models.User{}, &models.Post{}, &models.Cluster{})
 	fmt.Println("? Migration complete")
 }

pkg/models/cluster.model.go

@@ -0,0 +1,39 @@
+package models
+
+import (
+	"time"
+
+	"github.com/google/uuid"
+)
+
+type Cluster struct {
+	ID        				uuid.UUID `gorm:"type:uuid;default:uuid_generate_v4();primary_key" json:"id,omitempty"`
+	ApiServerHost     string    `gorm:"uniqueIndex;not null" json:"api_server_host,omitempty"`
+	ApiServerPort     string    `gorm:"uniqueIndex;not null" json:"api_server_port,omitempty"`
+	Name   						string    `gorm:"not null" json:"name,omitempty"`
+	Image     				string    `gorm:"not null" json:"image,omitempty"`
+	AddedBy      			uuid.UUID `gorm:"not null" json:"added_by,omitempty"`
+	CreatedAt 				time.Time `gorm:"not null" json:"created_at,omitempty"`
+	UpdatedAt 				time.Time `gorm:"not null" json:"updated_at,omitempty"`
+}
+
+type CreateClusterRequest struct {
+	ApiServerHost     string    `json:"api_server_host"  binding:"required"`
+	ApiServerPort     string    `json:"api_server_port"  binding:"required"`
+	Name   						string    `json:"name" binding:"required"`
+	Image     				string    `json:"image,omitempty"`
+	AddedBy      			string    `json:"added_by,omitempty"`
+	CreatedAt					time.Time `json:"created_at,omitempty"`
+	UpdatedAt 				time.Time `json:"updated_at,omitempty"`
+}
+
+type UpdateCluster struct {
+	ApiServerHost    	string    `json:"api_server_host,omitempty"`
+	ApiServerPort 		string    `json:"api_server_port,omitempty"`
+	Name   						string    `json:"name,omitempty"`
+	Image     				string    `json:"image,omitempty"`
+	AddedBy      			string    `json:"added_by,omitempty"`
+	CreateAt  				time.Time `json:"created_at,omitempty"`
+	UpdatedAt 				time.Time `json:"updated_at,omitempty"`
+}
+