WIP
Some checks failed
ci/woodpecker/push/build Pipeline was successful
ci/woodpecker/push/release Pipeline was successful
ci/woodpecker/push/lint Pipeline was successful
ci/woodpecker/pr/build Pipeline was successful
ci/woodpecker/pr/release Pipeline was successful
ci/woodpecker/pr/lint Pipeline failed
Some checks failed
ci/woodpecker/push/build Pipeline was successful
ci/woodpecker/push/release Pipeline was successful
ci/woodpecker/push/lint Pipeline was successful
ci/woodpecker/pr/build Pipeline was successful
ci/woodpecker/pr/release Pipeline was successful
ci/woodpecker/pr/lint Pipeline failed
This commit is contained in:
parent
a1a1d13b86
commit
aea76b10f3
4 changed files with 99 additions and 38 deletions
|
@ -4,10 +4,11 @@ import (
|
||||||
"embed"
|
"embed"
|
||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"time"
|
||||||
|
|
||||||
"git.gnous.eu/gnouseu/plakken/internal/constant"
|
"git.gnous.eu/gnouseu/plakken/internal/constant"
|
||||||
"git.gnous.eu/gnouseu/plakken/internal/web/health"
|
|
||||||
"git.gnous.eu/gnouseu/plakken/internal/web/plak"
|
"git.gnous.eu/gnouseu/plakken/internal/web/plak"
|
||||||
|
"git.gnous.eu/gnouseu/plakken/internal/web/status"
|
||||||
"github.com/redis/go-redis/v9"
|
"github.com/redis/go-redis/v9"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -17,6 +18,7 @@ type ServerConfig struct {
|
||||||
DB *redis.Client
|
DB *redis.Client
|
||||||
Static embed.FS
|
Static embed.FS
|
||||||
Templates embed.FS
|
Templates embed.FS
|
||||||
|
StartTime time.Time
|
||||||
}
|
}
|
||||||
|
|
||||||
func (config ServerConfig) home(w http.ResponseWriter, _ *http.Request) {
|
func (config ServerConfig) home(w http.ResponseWriter, _ *http.Request) {
|
||||||
|
@ -41,7 +43,9 @@ func (config ServerConfig) router() {
|
||||||
|
|
||||||
http.HandleFunc("GET /{$}", config.home)
|
http.HandleFunc("GET /{$}", config.home)
|
||||||
http.Handle("GET /static/{file}", http.FileServer(staticFiles))
|
http.Handle("GET /static/{file}", http.FileServer(staticFiles))
|
||||||
http.HandleFunc("GET /health/", health.Config{DB: config.DB}.Health)
|
http.HandleFunc("GET /readyz", status.Config{DB: config.DB}.Ready)
|
||||||
|
http.HandleFunc("GET /infoz", status.Config{DB: config.DB, StartTime: config.StartTime}.Info)
|
||||||
|
http.HandleFunc("GET /healthz", status.Config{DB: config.DB}.Health)
|
||||||
http.HandleFunc("GET /{key}/{settings...}", WebConfig.View)
|
http.HandleFunc("GET /{key}/{settings...}", WebConfig.View)
|
||||||
http.HandleFunc("POST /{$}", WebConfig.CurlCreate)
|
http.HandleFunc("POST /{$}", WebConfig.CurlCreate)
|
||||||
http.HandleFunc("POST /create/{$}", WebConfig.PostCreate)
|
http.HandleFunc("POST /create/{$}", WebConfig.PostCreate)
|
||||||
|
|
|
@ -1,34 +0,0 @@
|
||||||
package health
|
|
||||||
|
|
||||||
import (
|
|
||||||
"io"
|
|
||||||
"log"
|
|
||||||
"net/http"
|
|
||||||
|
|
||||||
"git.gnous.eu/gnouseu/plakken/internal/database"
|
|
||||||
"github.com/redis/go-redis/v9"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Config struct {
|
|
||||||
DB *redis.Client
|
|
||||||
}
|
|
||||||
|
|
||||||
func (config Config) Health(w http.ResponseWriter, _ *http.Request) {
|
|
||||||
err := database.Ping(config.DB)
|
|
||||||
w.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
|
||||||
_, err := io.WriteString(w, "Redis connection has failed")
|
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
_, err = io.WriteString(w, "ok")
|
|
||||||
if err != nil {
|
|
||||||
log.Println(err)
|
|
||||||
}
|
|
||||||
}
|
|
90
internal/web/status/status.go
Normal file
90
internal/web/status/status.go
Normal file
|
@ -0,0 +1,90 @@
|
||||||
|
package status
|
||||||
|
|
||||||
|
import (
|
||||||
|
"encoding/json"
|
||||||
|
"io"
|
||||||
|
"log"
|
||||||
|
"net/http"
|
||||||
|
"runtime"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"git.gnous.eu/gnouseu/plakken/internal/database"
|
||||||
|
"github.com/redis/go-redis/v9"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Config struct {
|
||||||
|
DB *redis.Client
|
||||||
|
StartTime time.Time
|
||||||
|
}
|
||||||
|
|
||||||
|
type info struct {
|
||||||
|
Uptime time.Duration `json:"uptime"`
|
||||||
|
Version string `json:"version"`
|
||||||
|
GoVersion string `json:"goVersion"`
|
||||||
|
Source string `json:"Source"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type health struct {
|
||||||
|
Status string `json:"status"`
|
||||||
|
DB string `json:"db"` // TODO: struct with ping duration ?
|
||||||
|
}
|
||||||
|
|
||||||
|
func (config Config) Ready(w http.ResponseWriter, _ *http.Request) {
|
||||||
|
err := database.Ping(config.DB)
|
||||||
|
w.Header().Set("Content-Type", "text/plain; charset=utf-8")
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
w.WriteHeader(http.StatusServiceUnavailable)
|
||||||
|
_, err := io.WriteString(w, "ko")
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
_, err = io.WriteString(w, "ok")
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (config Config) Info(w http.ResponseWriter, _ *http.Request) {
|
||||||
|
w.Header().Set("Content-Type", "application/json; charset=utf-8")
|
||||||
|
response := info{
|
||||||
|
Uptime: uptime(config.StartTime),
|
||||||
|
Version: "nightly", // TODO
|
||||||
|
GoVersion: runtime.Version(),
|
||||||
|
Source: "https://git.gnous.eu/gnouseu/plakken",
|
||||||
|
}
|
||||||
|
|
||||||
|
err := json.NewEncoder(w).Encode(response)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (config Config) Health(w http.ResponseWriter, _ *http.Request) {
|
||||||
|
w.Header().Set("Content-Type", "application/json; charset=utf-8")
|
||||||
|
var response health
|
||||||
|
if database.Ping(config.DB) != nil {
|
||||||
|
response.DB = "ko"
|
||||||
|
} else {
|
||||||
|
response.DB = "ok"
|
||||||
|
}
|
||||||
|
|
||||||
|
if response.DB == "ok" {
|
||||||
|
response.Status = "ok"
|
||||||
|
} else {
|
||||||
|
response.Status = "ko"
|
||||||
|
}
|
||||||
|
|
||||||
|
err := json.NewEncoder(w).Encode(response)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func uptime(startTime time.Time) time.Duration {
|
||||||
|
return time.Since(startTime)
|
||||||
|
}
|
5
main.go
5
main.go
|
@ -2,11 +2,11 @@ package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"embed"
|
"embed"
|
||||||
"log"
|
|
||||||
|
|
||||||
"git.gnous.eu/gnouseu/plakken/internal/config"
|
"git.gnous.eu/gnouseu/plakken/internal/config"
|
||||||
"git.gnous.eu/gnouseu/plakken/internal/database"
|
"git.gnous.eu/gnouseu/plakken/internal/database"
|
||||||
"git.gnous.eu/gnouseu/plakken/internal/httpserver"
|
"git.gnous.eu/gnouseu/plakken/internal/httpserver"
|
||||||
|
"log"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -31,6 +31,7 @@ func main() {
|
||||||
DB: db,
|
DB: db,
|
||||||
Static: static,
|
Static: static,
|
||||||
Templates: templates,
|
Templates: templates,
|
||||||
|
StartTime: time.Now(),
|
||||||
}
|
}
|
||||||
|
|
||||||
serverConfig.Server()
|
serverConfig.Server()
|
||||||
|
|
Loading…
Reference in a new issue