131 lines
3.9 KiB
Go
131 lines
3.9 KiB
Go
package api
|
|
|
|
import (
|
|
"fmt"
|
|
dbclient "github.com/TicketsBot/GoPanel/database"
|
|
"github.com/TicketsBot/GoPanel/utils"
|
|
"github.com/TicketsBot/database"
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/go-playground/validator/v10"
|
|
"strings"
|
|
)
|
|
|
|
type integrationCreateBody struct {
|
|
Name string `json:"name" validate:"required,min=1,max=32"`
|
|
Description string `json:"description" validate:"required,min=1,max=255"`
|
|
ImageUrl *string `json:"image_url" validate:"omitempty,url,max=255,startswith=https://"`
|
|
PrivacyPolicyUrl *string `json:"privacy_policy_url" validate:"omitempty,url,max=255,startswith=https://"`
|
|
|
|
Method string `json:"http_method" validate:"required,oneof=GET POST"`
|
|
WebhookUrl string `json:"webhook_url" validate:"required,webhook,max=255"`
|
|
|
|
Secrets []struct {
|
|
Name string `json:"name" validate:"required,min=1,max=32,excludesall=% "`
|
|
} `json:"secrets" validate:"dive,omitempty,min=0,max=5"`
|
|
|
|
Headers []struct {
|
|
Name string `json:"name" validate:"required,min=1,max=32,excludes= "`
|
|
Value string `json:"value" validate:"required,min=1,max=255"`
|
|
} `json:"headers" validate:"dive,omitempty,min=0,max=5"`
|
|
|
|
Placeholders []struct {
|
|
Placeholder string `json:"name" validate:"required,min=1,max=32,excludesall=% "`
|
|
JsonPath string `json:"json_path" validate:"required,min=1,max=255"`
|
|
} `json:"placeholders" validate:"dive,omitempty,min=0,max=15"`
|
|
}
|
|
|
|
var validate = newIntegrationValidator()
|
|
|
|
func CreateIntegrationHandler(ctx *gin.Context) {
|
|
userId := ctx.Keys["userid"].(uint64)
|
|
|
|
ownedCount, err := dbclient.Client.CustomIntegrations.GetOwnedCount(userId)
|
|
if err != nil {
|
|
ctx.JSON(500, utils.ErrorJson(err))
|
|
return
|
|
}
|
|
|
|
if ownedCount >= 5 {
|
|
ctx.JSON(403, utils.ErrorStr("You have reached the integration limit (5/5)"))
|
|
return
|
|
}
|
|
|
|
var data integrationCreateBody
|
|
if err := ctx.BindJSON(&data); err != nil {
|
|
ctx.JSON(400, utils.ErrorJson(err))
|
|
return
|
|
}
|
|
|
|
if err := validate.Struct(data); err != nil {
|
|
validationErrors, ok := err.(validator.ValidationErrors)
|
|
if !ok {
|
|
ctx.JSON(500, utils.ErrorStr("An error occurred while validating the integration"))
|
|
return
|
|
}
|
|
|
|
formatted := "Your input contained the following errors:"
|
|
for _, validationError := range validationErrors {
|
|
formatted += fmt.Sprintf("\n%s", validationError.Error())
|
|
}
|
|
|
|
formatted = strings.TrimSuffix(formatted, "\n")
|
|
ctx.JSON(400, utils.ErrorStr(formatted))
|
|
return
|
|
}
|
|
|
|
integration, err := dbclient.Client.CustomIntegrations.Create(userId, data.WebhookUrl, data.Method, data.Name, data.Description, data.ImageUrl, data.PrivacyPolicyUrl)
|
|
if err != nil {
|
|
ctx.JSON(500, utils.ErrorJson(err))
|
|
return
|
|
}
|
|
|
|
// Store secrets
|
|
if len(data.Secrets) > 0 {
|
|
secrets := make([]database.CustomIntegrationSecret, len(data.Secrets))
|
|
for i, secret := range data.Secrets {
|
|
secrets[i] = database.CustomIntegrationSecret{
|
|
Name: secret.Name,
|
|
}
|
|
}
|
|
|
|
if _, err := dbclient.Client.CustomIntegrationSecrets.CreateOrUpdate(integration.Id, secrets); err != nil {
|
|
ctx.JSON(500, utils.ErrorJson(err))
|
|
return
|
|
}
|
|
}
|
|
|
|
// Store headers
|
|
if len(data.Headers) > 0 {
|
|
headers := make([]database.CustomIntegrationHeader, len(data.Headers))
|
|
for i, header := range data.Headers {
|
|
headers[i] = database.CustomIntegrationHeader{
|
|
Name: header.Name,
|
|
Value: header.Value,
|
|
}
|
|
}
|
|
|
|
if _, err := dbclient.Client.CustomIntegrationHeaders.CreateOrUpdate(integration.Id, headers); err != nil {
|
|
ctx.JSON(500, utils.ErrorJson(err))
|
|
return
|
|
}
|
|
}
|
|
|
|
// Store placeholders
|
|
if len(data.Placeholders) > 0 {
|
|
placeholders := make([]database.CustomIntegrationPlaceholder, len(data.Placeholders))
|
|
for i, placeholder := range data.Placeholders {
|
|
placeholders[i] = database.CustomIntegrationPlaceholder{
|
|
Name: placeholder.Placeholder,
|
|
JsonPath: placeholder.JsonPath,
|
|
}
|
|
}
|
|
|
|
if _, err := dbclient.Client.CustomIntegrationPlaceholders.Set(integration.Id, placeholders); err != nil {
|
|
ctx.JSON(500, utils.ErrorJson(err))
|
|
return
|
|
}
|
|
}
|
|
|
|
ctx.JSON(200, integration)
|
|
}
|