Migrate httpd.go

This commit is contained in:
Timur Ismagilov 2024-09-07 21:50:07 +03:00
parent 4c5f385afd
commit cab7c60bad
2 changed files with 45 additions and 23 deletions

View File

@ -1,16 +1,18 @@
package main package main
import ( import (
"github.com/bouncepaw/mycorrhiza/internal/cfg" "errors"
"log" "log/slog"
"net" "net"
"net/http" "net/http"
"os" "os"
"strings" "strings"
"time" "time"
"github.com/bouncepaw/mycorrhiza/internal/cfg"
) )
func serveHTTP(handler http.Handler) { func serveHTTP(handler http.Handler) (err error) {
server := &http.Server{ server := &http.Server{
ReadTimeout: 300 * time.Second, ReadTimeout: 300 * time.Second,
WriteTimeout: 300 * time.Second, WriteTimeout: 300 * time.Second,
@ -19,35 +21,51 @@ func serveHTTP(handler http.Handler) {
} }
if strings.HasPrefix(cfg.ListenAddr, "/") { if strings.HasPrefix(cfg.ListenAddr, "/") {
startUnixSocketServer(server, cfg.ListenAddr) err = startUnixSocketServer(server, cfg.ListenAddr)
} else { } else {
server.Addr = cfg.ListenAddr server.Addr = cfg.ListenAddr
startHTTPServer(server) err = startHTTPServer(server)
} }
return err
} }
func startUnixSocketServer(server *http.Server, socketFile string) { func startUnixSocketServer(server *http.Server, socketPath string) error {
os.Remove(socketFile) err := os.Remove(socketPath)
listener, err := net.Listen("unix", socketFile)
if err != nil { if err != nil {
log.Fatalf("Failed to start a server: %v", err) return err
}
defer listener.Close()
if err := os.Chmod(socketFile, 0666); err != nil {
log.Fatalf("Failed to set socket permissions: %v", err)
} }
log.Printf("Listening on Unix socket %s", cfg.ListenAddr) listener, err := net.Listen("unix", socketPath)
if err := server.Serve(listener); err != http.ErrServerClosed { if err != nil {
log.Fatalf("Failed to start a server: %v", err) slog.Error("Failed to start the server", "err", err)
return err
} }
defer func(listener net.Listener) {
_ = listener.Close()
}(listener)
if err := os.Chmod(socketPath, 0666); err != nil {
slog.Error("Failed to set socket permissions", "err", err)
return err
}
slog.Info("Listening Unix socket", "addr", socketPath)
if err := server.Serve(listener); !errors.Is(err, http.ErrServerClosed) {
slog.Error("Failed to start the server", "err", err)
return err
}
return nil
} }
func startHTTPServer(server *http.Server) { func startHTTPServer(server *http.Server) error {
log.Printf("Listening on %s", server.Addr) slog.Info("Listening over HTTP", "addr", server.Addr)
if err := server.ListenAndServe(); err != http.ErrServerClosed {
log.Fatalf("Failed to start a server: %v", err) if err := server.ListenAndServe(); !errors.Is(err, http.ErrServerClosed) {
slog.Error("Failed to start the server", "err", err)
return err
} }
return nil
} }

View File

@ -8,6 +8,7 @@ import (
"github.com/bouncepaw/mycorrhiza/internal/categories" "github.com/bouncepaw/mycorrhiza/internal/categories"
"log" "log"
"os" "os"
"syscall"
"github.com/bouncepaw/mycorrhiza/history" "github.com/bouncepaw/mycorrhiza/history"
"github.com/bouncepaw/mycorrhiza/internal/backlinks" "github.com/bouncepaw/mycorrhiza/internal/backlinks"
@ -62,5 +63,8 @@ func main() {
log.Println("Your wiki has no admin yet. Run Mycorrhiza with -create-admin <username> option to create an admin.") log.Println("Your wiki has no admin yet. Run Mycorrhiza with -create-admin <username> option to create an admin.")
} }
serveHTTP(web.Handler()) err := serveHTTP(web.Handler())
if err != nil {
syscall.Exit(1)
}
} }