mirror of
https://github.com/0xJacky/nginx-ui.git
synced 2025-05-11 18:35:51 +02:00
150 lines
2.6 KiB
Go
150 lines
2.6 KiB
Go
package api
|
|
|
|
import (
|
|
"encoding/json"
|
|
"github.com/0xJacky/Nginx-UI/server/tool"
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/gorilla/websocket"
|
|
"log"
|
|
"net/http"
|
|
"os"
|
|
)
|
|
|
|
func CertInfo(c *gin.Context) {
|
|
domain := c.Param("domain")
|
|
|
|
key := tool.GetCertInfo(domain)
|
|
|
|
c.JSON(http.StatusOK, gin.H{
|
|
"subject_name": key.Subject.CommonName,
|
|
"issuer_name": key.Issuer.CommonName,
|
|
"not_after": key.NotAfter,
|
|
"not_before": key.NotBefore,
|
|
})
|
|
}
|
|
|
|
func IssueCert(c *gin.Context) {
|
|
domain := c.Param("domain")
|
|
var upGrader = websocket.Upgrader{
|
|
CheckOrigin: func(r *http.Request) bool {
|
|
return true
|
|
},
|
|
}
|
|
|
|
// upgrade http to websocket
|
|
ws, err := upGrader.Upgrade(c.Writer, c.Request, nil)
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
defer func(ws *websocket.Conn) {
|
|
err := ws.Close()
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
}(ws)
|
|
|
|
for {
|
|
// read
|
|
mt, message, err := ws.ReadMessage()
|
|
if err != nil {
|
|
break
|
|
}
|
|
if string(message) == "go" {
|
|
var m []byte
|
|
|
|
err = tool.IssueCert(domain)
|
|
if err != nil {
|
|
m, err = json.Marshal(gin.H{
|
|
"status": "error",
|
|
"message": err.Error(),
|
|
})
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
err = ws.WriteMessage(mt, m)
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
sslCertificatePath := tool.GetNginxConfPath("ssl/" + domain + "/fullchain.cer")
|
|
_, err = os.Stat(sslCertificatePath)
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
log.Println("[found]", "fullchain.cer")
|
|
m, err = json.Marshal(gin.H{
|
|
"status": "success",
|
|
"message": "[found] fullchain.cer",
|
|
})
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
err = ws.WriteMessage(mt, m)
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
sslCertificateKeyPath := tool.GetNginxConfPath("ssl/" + domain + "/" + domain + ".key")
|
|
_, err = os.Stat(sslCertificateKeyPath)
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
return
|
|
}
|
|
|
|
log.Println("[found]", "cert key")
|
|
m, err = json.Marshal(gin.H{
|
|
"status": "success",
|
|
"message": "[found] cert key",
|
|
})
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
}
|
|
|
|
err = ws.WriteMessage(mt, m)
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
}
|
|
|
|
log.Println("申请成功")
|
|
m, err = json.Marshal(gin.H{
|
|
"status": "success",
|
|
"message": "申请成功",
|
|
"ssl_certificate": sslCertificatePath,
|
|
"ssl_certificate_key": sslCertificateKeyPath,
|
|
})
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
}
|
|
|
|
err = ws.WriteMessage(mt, m)
|
|
|
|
if err != nil {
|
|
log.Println(err)
|
|
}
|
|
}
|
|
}
|
|
}
|