cert.go 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. package api
  2. import (
  3. "encoding/json"
  4. "github.com/0xJacky/Nginx-UI/server/tool"
  5. "github.com/gin-gonic/gin"
  6. "github.com/gorilla/websocket"
  7. "log"
  8. "net/http"
  9. "os"
  10. )
  11. func CertInfo(c *gin.Context) {
  12. domain := c.Param("domain")
  13. key := tool.GetCertInfo(domain)
  14. c.JSON(http.StatusOK, gin.H{
  15. "subject_name": key.Subject.CommonName,
  16. "issuer_name": key.Issuer.CommonName,
  17. "not_after": key.NotAfter,
  18. "not_before": key.NotBefore,
  19. })
  20. }
  21. func IssueCert(c *gin.Context) {
  22. domain := c.Param("domain")
  23. var upGrader = websocket.Upgrader{
  24. CheckOrigin: func(r *http.Request) bool {
  25. return true
  26. },
  27. }
  28. // upgrade http to websocket
  29. ws, err := upGrader.Upgrade(c.Writer, c.Request, nil)
  30. if err != nil {
  31. log.Println(err)
  32. return
  33. }
  34. defer func(ws *websocket.Conn) {
  35. err := ws.Close()
  36. if err != nil {
  37. log.Println(err)
  38. return
  39. }
  40. }(ws)
  41. for {
  42. // read
  43. mt, message, err := ws.ReadMessage()
  44. if err != nil {
  45. break
  46. }
  47. if string(message) == "go" {
  48. var m []byte
  49. err = tool.IssueCert(domain)
  50. if err != nil {
  51. m, err = json.Marshal(gin.H{
  52. "status": "error",
  53. "message": err.Error(),
  54. })
  55. if err != nil {
  56. log.Println(err)
  57. return
  58. }
  59. err = ws.WriteMessage(mt, m)
  60. if err != nil {
  61. log.Println(err)
  62. return
  63. }
  64. log.Println(err)
  65. return
  66. }
  67. sslCertificatePath := tool.GetNginxConfPath("ssl/" + domain + "/fullchain.cer")
  68. _, err = os.Stat(sslCertificatePath)
  69. if err != nil {
  70. log.Println(err)
  71. return
  72. }
  73. log.Println("[found]", "fullchain.cer")
  74. m, err = json.Marshal(gin.H{
  75. "status": "success",
  76. "message": "[found] fullchain.cer",
  77. })
  78. if err != nil {
  79. log.Println(err)
  80. return
  81. }
  82. err = ws.WriteMessage(mt, m)
  83. if err != nil {
  84. log.Println(err)
  85. return
  86. }
  87. sslCertificateKeyPath := tool.GetNginxConfPath("ssl/" + domain + "/" + domain + ".key")
  88. _, err = os.Stat(sslCertificateKeyPath)
  89. if err != nil {
  90. log.Println(err)
  91. return
  92. }
  93. log.Println("[found]", "cert key")
  94. m, err = json.Marshal(gin.H{
  95. "status": "success",
  96. "message": "[found] cert key",
  97. })
  98. if err != nil {
  99. log.Println(err)
  100. }
  101. err = ws.WriteMessage(mt, m)
  102. if err != nil {
  103. log.Println(err)
  104. }
  105. log.Println("申请成功")
  106. m, err = json.Marshal(gin.H{
  107. "status": "success",
  108. "message": "申请成功",
  109. "ssl_certificate": sslCertificatePath,
  110. "ssl_certificate_key": sslCertificateKeyPath,
  111. })
  112. if err != nil {
  113. log.Println(err)
  114. }
  115. err = ws.WriteMessage(mt, m)
  116. if err != nil {
  117. log.Println(err)
  118. }
  119. }
  120. }
  121. }