add http server api for tenant

pkg/admin/router/tenants.go

@@ -19,6 +19,7 @@ package router
 
 import (
 	"context"
+	"net/http"
 )
 
 import (
@@ -27,11 +28,16 @@ import (
 
 import (
 	"github.com/arana-db/arana/pkg/admin"
+	"github.com/arana-db/arana/pkg/boot"
 )
 
 func init() {
 	admin.Register(func(router gin.IRoutes) {
 		router.GET("/tenants", ListTenants)
+		router.POST("/tenants", CreateTenant)
+		router.GET("/tenants/:tenant", GetTenant)
+		router.PUT("/tenants/:tenant", UpdateTenant)
+		router.DELETE("/tenants/:tenant", RemoveTenant)
 	})
 }
 
@@ -42,5 +48,58 @@ func ListTenants(c *gin.Context) {
 		_ = c.Error(err)
 		return
 	}
-	c.JSON(200, tenants)
+	c.JSON(http.StatusOK, tenants)
+}
+
+func CreateTenant(c *gin.Context) {
+	service := admin.GetService(c)
+	var tenantBody *boot.TenantBody
+	if err := c.ShouldBindJSON(&tenantBody); err == nil {
+		err := service.UpsertTenant(context.Background(), "", tenantBody)
+		if err != nil {
+			_ = c.Error(err)
+			return
+		}
+		c.JSON(http.StatusCreated, nil)
+	} else {
+		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+	}
+}
+
+func GetTenant(c *gin.Context) {
+	service := admin.GetService(c)
+	tenant := c.Param("tenant")
+	data, err := service.GetTenant(context.Background(), tenant)
+	if err != nil {
+		_ = c.Error(err)
+		return
+	}
+	c.JSON(http.StatusOK, data)
+}
+
+func UpdateTenant(c *gin.Context) {
+	service := admin.GetService(c)
+	tenant := c.Param("tenant")
+	var tenantBody *boot.TenantBody
+	if err := c.ShouldBindJSON(&tenantBody); err == nil {
+		err := service.UpsertTenant(context.Background(), tenant, tenantBody)
+		if err != nil {
+			_ = c.Error(err)
+			return
+		}
+		c.JSON(http.StatusOK, nil)
+	} else {
+		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+	}
+}
+
+func RemoveTenant(c *gin.Context) {
+	service := admin.GetService(c)
+	tenant := c.Param("tenant")
+	err := service.RemoveTenant(context.Background(), tenant)
+	if err != nil {
+		_ = c.Error(err)
+		return
+	}
+	c.JSON(http.StatusNoContent, nil)
 }