mirror of
https://github.com/1Panel-dev/1Panel.git
synced 2025-12-18 21:38:57 +08:00
997b820a42
* perf: use gzipped data for improved load speed in big files * perf: switch to gzipped response for GetFileTree to enhance performance * perf: switch to gzipped response for SearchApp to improve performance * perf: update file size conditions for gzipped response to enhance performance
335 lines
9.7 KiB
Go
335 lines
9.7 KiB
Go
package v2
|
|
|
|
import (
|
|
"io"
|
|
"mime/multipart"
|
|
"net/http"
|
|
"net/url"
|
|
"reflect"
|
|
"strconv"
|
|
|
|
"github.com/1Panel-dev/1Panel/agent/app/model"
|
|
|
|
"github.com/1Panel-dev/1Panel/agent/app/api/v2/helper"
|
|
"github.com/1Panel-dev/1Panel/agent/app/dto"
|
|
"github.com/1Panel-dev/1Panel/agent/app/dto/request"
|
|
"github.com/gin-gonic/gin"
|
|
)
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Page website ssl
|
|
// @Accept json
|
|
// @Param request body request.WebsiteSSLSearch true "request"
|
|
// @Success 200 {array} response.WebsiteSSLDTO
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/search [post]
|
|
func (b *BaseApi) PageWebsiteSSL(c *gin.Context) {
|
|
var req request.WebsiteSSLSearch
|
|
if err := helper.CheckBind(&req, c); err != nil {
|
|
return
|
|
}
|
|
if !reflect.DeepEqual(req.PageInfo, dto.PageInfo{}) {
|
|
total, accounts, err := websiteSSLService.Page(req)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.SuccessWithDataGzipped(c, dto.PageResult{
|
|
Total: total,
|
|
Items: accounts,
|
|
})
|
|
} else {
|
|
list, err := websiteSSLService.Search(req)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.SuccessWithDataGzipped(c, list)
|
|
}
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Create website ssl
|
|
// @Accept json
|
|
// @Param request body request.WebsiteSSLCreate true "request"
|
|
// @Success 200 {object} request.WebsiteSSLCreate
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl [post]
|
|
// @x-panel-log {"bodyKeys":["primaryDomain"],"paramKeys":[],"BeforeFunctions":[],"formatZH":"创建网站 ssl [primaryDomain]","formatEN":"Create website ssl [primaryDomain]"}
|
|
func (b *BaseApi) CreateWebsiteSSL(c *gin.Context) {
|
|
var req request.WebsiteSSLCreate
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
res, err := websiteSSLService.Create(req)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.SuccessWithData(c, res)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Apply ssl
|
|
// @Accept json
|
|
// @Param request body request.WebsiteSSLApply true "request"
|
|
// @Success 200
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/obtain [post]
|
|
// @x-panel-log {"bodyKeys":["ID"],"paramKeys":[],"BeforeFunctions":[{"input_column":"id","input_value":"ID","isList":false,"db":"website_ssls","output_column":"primary_domain","output_value":"domain"}],"formatZH":"申请证书 [domain]","formatEN":"apply ssl [domain]"}
|
|
func (b *BaseApi) ApplyWebsiteSSL(c *gin.Context) {
|
|
var req request.WebsiteSSLApply
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
if err := websiteSSLService.ObtainSSL(req); err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.Success(c)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Resolve website ssl
|
|
// @Accept json
|
|
// @Param request body request.WebsiteDNSReq true "request"
|
|
// @Success 200 {array} response.WebsiteDNSRes
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/resolve [post]
|
|
func (b *BaseApi) GetDNSResolve(c *gin.Context) {
|
|
var req request.WebsiteDNSReq
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
res, err := websiteSSLService.GetDNSResolve(req)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.SuccessWithData(c, res)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Delete website ssl
|
|
// @Accept json
|
|
// @Param request body request.WebsiteBatchDelReq true "request"
|
|
// @Success 200
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/del [post]
|
|
// @x-panel-log {"bodyKeys":["ids"],"paramKeys":[],"BeforeFunctions":[{"input_column":"id","input_value":"ids","isList":true,"db":"website_ssls","output_column":"primary_domain","output_value":"domain"}],"formatZH":"删除 ssl [domain]","formatEN":"Delete ssl [domain]"}
|
|
func (b *BaseApi) DeleteWebsiteSSL(c *gin.Context) {
|
|
var req request.WebsiteBatchDelReq
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
if err := websiteSSLService.Delete(req.IDs); err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.Success(c)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Search website ssl by website id
|
|
// @Accept json
|
|
// @Param websiteId path integer true "request"
|
|
// @Success 200 {object} response.WebsiteSSLDTO
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/website/:websiteId [get]
|
|
func (b *BaseApi) GetWebsiteSSLByWebsiteId(c *gin.Context) {
|
|
websiteId, err := helper.GetIntParamByKey(c, "websiteId")
|
|
if err != nil {
|
|
helper.BadRequest(c, err)
|
|
return
|
|
}
|
|
websiteSSL, err := websiteSSLService.GetWebsiteSSL(websiteId)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.SuccessWithData(c, websiteSSL)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Search website ssl by id
|
|
// @Accept json
|
|
// @Param id path integer true "request"
|
|
// @Success 200 {object} response.WebsiteSSLDTO
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/:id [get]
|
|
func (b *BaseApi) GetWebsiteSSLById(c *gin.Context) {
|
|
id, err := helper.GetParamID(c)
|
|
if err != nil {
|
|
helper.BadRequest(c, err)
|
|
return
|
|
}
|
|
websiteSSL, err := websiteSSLService.GetSSL(id)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.SuccessWithData(c, websiteSSL)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Update ssl
|
|
// @Accept json
|
|
// @Param request body request.WebsiteSSLUpdate true "request"
|
|
// @Success 200
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/update [post]
|
|
// @x-panel-log {"bodyKeys":["id"],"paramKeys":[],"BeforeFunctions":[{"input_column":"id","input_value":"id","isList":false,"db":"website_ssls","output_column":"primary_domain","output_value":"domain"}],"formatZH":"更新证书设置 [domain]","formatEN":"Update ssl config [domain]"}
|
|
func (b *BaseApi) UpdateWebsiteSSL(c *gin.Context) {
|
|
var req request.WebsiteSSLUpdate
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
if err := websiteSSLService.Update(req); err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.Success(c)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Upload ssl
|
|
// @Accept json
|
|
// @Param request body request.WebsiteSSLUpload true "request"
|
|
// @Success 200
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/upload [post]
|
|
// @x-panel-log {"bodyKeys":["type"],"paramKeys":[],"BeforeFunctions":[],"formatZH":"上传 ssl [type]","formatEN":"Upload ssl [type]"}
|
|
func (b *BaseApi) UploadWebsiteSSL(c *gin.Context) {
|
|
var req request.WebsiteSSLUpload
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
if err := websiteSSLService.Upload(req); err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.Success(c)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Upload SSL file
|
|
// @Accept multipart/form-data
|
|
// @Param type formData string true "type"
|
|
// @Param description formData string false "description"
|
|
// @Param sslID formData string false "sslID"
|
|
// @Param privateKeyFile formData file true "privateKeyFile"
|
|
// @Param certificateFile formData file true "certificateFile"
|
|
// @Success 200
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/upload/file [post]
|
|
// @x-panel-log {"bodyKeys":["type"],"paramKeys":[],"BeforeFunctions":[],"formatZH":"上传 ssl 文件 [type]","formatEN":"Upload ssl file [type]"}
|
|
func (b *BaseApi) UploadSSLFile(c *gin.Context) {
|
|
var req request.WebsiteSSLFileUpload
|
|
|
|
req.Description = c.PostForm("description")
|
|
sslID := c.PostForm("sslID")
|
|
if sslID != "" {
|
|
req.SSLID, _ = strconv.ParseUint(sslID, 10, 64)
|
|
}
|
|
|
|
privateKeyFile, err := c.FormFile("privateKeyFile")
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
|
|
certificateFile, err := c.FormFile("certificateFile")
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
|
|
privateKeyContent, err := readUploadedFile(privateKeyFile)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
|
|
certificateContent, err := readUploadedFile(certificateFile)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
|
|
uploadReq := request.WebsiteSSLUpload{
|
|
Type: "paste",
|
|
PrivateKey: string(privateKeyContent),
|
|
Certificate: string(certificateContent),
|
|
Description: req.Description,
|
|
SSLID: uint(req.SSLID),
|
|
}
|
|
|
|
if err := websiteSSLService.Upload(uploadReq); err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
|
|
helper.Success(c)
|
|
}
|
|
|
|
func readUploadedFile(fileHeader *multipart.FileHeader) ([]byte, error) {
|
|
file, err := fileHeader.Open()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer file.Close()
|
|
|
|
return io.ReadAll(file)
|
|
}
|
|
|
|
// @Tags Website SSL
|
|
// @Summary Download SSL file
|
|
// @Accept json
|
|
// @Param request body request.WebsiteResourceReq true "request"
|
|
// @Success 200
|
|
// @Security ApiKeyAuth
|
|
// @Security Timestamp
|
|
// @Router /websites/ssl/download [post]
|
|
// @x-panel-log {"bodyKeys":["id"],"paramKeys":[],"BeforeFunctions":[{"input_column":"id","input_value":"id","isList":false,"db":"website_ssls","output_column":"primary_domain","output_value":"domain"}],"formatZH":"下载证书文件 [domain]","formatEN":"download ssl file [domain]"}
|
|
func (b *BaseApi) DownloadWebsiteSSL(c *gin.Context) {
|
|
var req request.WebsiteResourceReq
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
file, err := websiteSSLService.DownloadFile(req.ID)
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
defer file.Close()
|
|
info, err := file.Stat()
|
|
if err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
c.Header("Content-Length", strconv.FormatInt(info.Size(), 10))
|
|
c.Header("Content-Disposition", "attachment; filename*=utf-8''"+url.PathEscape(info.Name()))
|
|
http.ServeContent(c.Writer, c.Request, info.Name(), info.ModTime(), file)
|
|
}
|
|
|
|
func (b *BaseApi) ImportMasterSSL(c *gin.Context) {
|
|
var req model.WebsiteSSL
|
|
if err := helper.CheckBindAndValidate(&req, c); err != nil {
|
|
return
|
|
}
|
|
if err := websiteSSLService.ImportMasterSSL(req); err != nil {
|
|
helper.InternalServer(c, err)
|
|
return
|
|
}
|
|
helper.Success(c)
|
|
}
|