123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134 |
- package api
- import (
- "github.com/0xJacky/Nginx-UI/server/pkg/cert"
- "github.com/0xJacky/Nginx-UI/server/pkg/nginx"
- "github.com/gin-gonic/gin"
- "github.com/gorilla/websocket"
- "log"
- "net/http"
- "os"
- )
- func CertInfo(c *gin.Context) {
- domain := c.Param("domain")
- key, err := cert.GetCertInfo(domain)
- if err != nil {
- c.JSON(http.StatusOK, gin.H{
- "error": err,
- })
- return
- }
- 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("defer websocket close err", err)
- }
- }(ws)
- // read
- mt, message, err := ws.ReadMessage()
- if err != nil {
- log.Println(err)
- return
- }
- if mt == websocket.TextMessage && string(message) == "go" {
- err = cert.IssueCert(domain)
- if err != nil {
- log.Println(err)
- err = ws.WriteJSON(gin.H{
- "status": "error",
- "message": err.Error(),
- })
- if err != nil {
- log.Println(err)
- return
- }
- return
- }
- sslCertificatePath := nginx.GetNginxConfPath("ssl/" + domain + "/fullchain.cer")
- _, err = os.Stat(sslCertificatePath)
- if err != nil {
- log.Println(err)
- return
- }
- log.Println("[found]", "fullchain.cer")
- err = ws.WriteJSON(gin.H{
- "status": "success",
- "message": "[found] fullchain.cer",
- })
- if err != nil {
- log.Println(err)
- return
- }
- sslCertificateKeyPath := nginx.GetNginxConfPath("ssl/" + domain + "/" + domain + ".key")
- _, err = os.Stat(sslCertificateKeyPath)
- if err != nil {
- log.Println(err)
- return
- }
- log.Println("[found]", "cert key")
- err = ws.WriteJSON(gin.H{
- "status": "success",
- "message": "[found] Certificate Key",
- })
- if err != nil {
- log.Println(err)
- return
- }
- err = ws.WriteJSON(gin.H{
- "status": "success",
- "message": "Issued certificate successfully",
- "ssl_certificate": sslCertificatePath,
- "ssl_certificate_key": sslCertificateKeyPath,
- })
- if err != nil {
- log.Println(err)
- return
- }
- }
- }
|