http_server.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package http_server
  2. import (
  3. "fmt"
  4. "io/fs"
  5. "net/http"
  6. "pmail/config"
  7. "pmail/controllers"
  8. "pmail/controllers/email"
  9. "pmail/session"
  10. "time"
  11. )
  12. const HttpPort = 80
  13. // 这个服务是为了拦截http请求转发到https
  14. var httpServer *http.Server
  15. func HttpStop() {
  16. if httpServer != nil {
  17. httpServer.Close()
  18. }
  19. }
  20. func HttpStart() {
  21. mux := http.NewServeMux()
  22. if config.Instance.HttpsEnabled != 2 {
  23. mux.HandleFunc("/", controllers.Interceptor)
  24. httpServer = &http.Server{
  25. Addr: fmt.Sprintf(":%d", HttpPort),
  26. Handler: mux,
  27. ReadTimeout: time.Second * 60,
  28. WriteTimeout: time.Second * 60,
  29. }
  30. } else {
  31. fe, err := fs.Sub(local, "dist")
  32. if err != nil {
  33. panic(err)
  34. }
  35. mux.Handle("/", http.FileServer(http.FS(fe)))
  36. mux.HandleFunc("/api/ping", contextIterceptor(controllers.Ping))
  37. mux.HandleFunc("/api/login", contextIterceptor(controllers.Login))
  38. mux.HandleFunc("/api/group", contextIterceptor(controllers.GetUserGroup))
  39. mux.HandleFunc("/api/group/list", contextIterceptor(controllers.GetUserGroupList))
  40. mux.HandleFunc("/api/group/add", contextIterceptor(controllers.AddGroup))
  41. mux.HandleFunc("/api/group/del", contextIterceptor(controllers.DelGroup))
  42. mux.HandleFunc("/api/email/list", contextIterceptor(email.EmailList))
  43. mux.HandleFunc("/api/email/del", contextIterceptor(email.EmailDelete))
  44. mux.HandleFunc("/api/email/read", contextIterceptor(email.MarkRead))
  45. mux.HandleFunc("/api/email/detail", contextIterceptor(email.EmailDetail))
  46. mux.HandleFunc("/api/email/move", contextIterceptor(email.Move))
  47. mux.HandleFunc("/api/email/send", contextIterceptor(email.Send))
  48. mux.HandleFunc("/api/settings/modify_password", contextIterceptor(controllers.ModifyPassword))
  49. mux.HandleFunc("/attachments/", contextIterceptor(controllers.GetAttachments))
  50. mux.HandleFunc("/attachments/download/", contextIterceptor(controllers.Download))
  51. httpServer = &http.Server{
  52. Addr: fmt.Sprintf(":%d", HttpPort),
  53. Handler: session.Instance.LoadAndSave(mux),
  54. ReadTimeout: time.Second * 60,
  55. WriteTimeout: time.Second * 60,
  56. }
  57. }
  58. err := httpServer.ListenAndServe()
  59. if err != nil {
  60. panic(err)
  61. }
  62. }