From 1af656d757fe534c2ed34a3a0c55b1c0a6bf4b91 Mon Sep 17 00:00:00 2001 From: Ciprian Dorin Craciun Date: Fri, 2 Sep 2022 14:59:24 +0300 Subject: [PATCH] [server] Add support for exporting version and sources via HTTP. --- sources/cmd/server/server.go | 47 ++++++++++++++++++++++++++++++++++ sources/cmd/version/version.go | 3 ++- 2 files changed, 49 insertions(+), 1 deletion(-) diff --git a/sources/cmd/server/server.go b/sources/cmd/server/server.go index 9495e1a..759c900 100644 --- a/sources/cmd/server/server.go +++ b/sources/cmd/server/server.go @@ -37,6 +37,7 @@ import . "github.com/volution/kawipiko/lib/common" import . "github.com/volution/kawipiko/lib/server" import "github.com/volution/kawipiko/cmd/version" +import "github.com/volution/kawipiko/embedded" import _ "embed" @@ -135,6 +136,15 @@ func (_server *server) ServeUnwrapped (_context *fasthttp.RequestCtx) () { } else if bytes.Equal (_path, StringToBytes ("/__/about")) || bytes.Equal (_path, StringToBytes ("/__/about/")) { _server.ServeStatic (_context, http.StatusOK, AboutBannerData, AboutBannerContentType, AboutBannerContentEncoding, true) return + } else if bytes.Equal (_path, StringToBytes ("/__/version")) || bytes.Equal (_path, StringToBytes ("/__/version/")) { + _server.ServeSpecial (_context, "version", true) + return + } else if bytes.Equal (_path, StringToBytes ("/__/sources.md5")) { + _server.ServeSpecial (_context, "sources.md5", true) + return + } else if bytes.Equal (_path, StringToBytes ("/__/sources.cpio")) { + _server.ServeSpecial (_context, "sources.cpio", true) + return } else if bytes.HasPrefix (_path, StringToBytes ("/__/banners/errors/")) { _code := _path[len ("/__/banners/errors/") :] if _code, _error := strconv.Atoi (BytesToString (*NoEscapeBytes (&_code))); _error == nil { @@ -415,6 +425,7 @@ var _namespaces_b_static = []string { + func (_server *server) ServeStatic (_context *fasthttp.RequestCtx, _status uint, _data []byte, _contentType string, _contentEncoding string, _cache bool) () { _response := (*fasthttp.Response) (NoEscape (unsafe.Pointer (&_context.Response))) @@ -488,6 +499,42 @@ func (_server *server) ServeError (_context *fasthttp.RequestCtx, _status uint, } +func (_server *server) ServeSpecial (_context *fasthttp.RequestCtx, _special string, _cache bool) () { + + var _data []byte + var _contentType string + var _contentEncoding string + + switch _special { + + case "version" : + _buffer := bytes.NewBuffer (nil) + if _error := version.Version ("kawipiko-server", "", _buffer); _error != nil { + _server.ServeError (_context, http.StatusInternalServerError, _error, false) + return + } + _data = _buffer.Bytes () + _contentType = MimeTypeText + _contentEncoding = "identity" + + case "sources.md5" : + _data = StringToBytes (embedded.BuildSourcesMd5) + _contentType = MimeTypeText + _contentEncoding = "identity" + + case "sources.cpio" : + _data = embedded.BuildSourcesCpioGz + _contentType = MimeTypeText + _contentEncoding = "application/x-cpio" + + default : + panic ("[8546f2bd]") + } + + _server.ServeStatic (_context, http.StatusOK, _data, _contentType, _contentEncoding, _cache) +} + + func (_server *server) ServeDummy (_context *fasthttp.RequestCtx) () { _server.ServeStatic (_context, http.StatusOK, DummyData, DummyContentType, DummyContentEncoding, false) } diff --git a/sources/cmd/version/version.go b/sources/cmd/version/version.go index 7708a5f..ff28cc0 100644 --- a/sources/cmd/version/version.go +++ b/sources/cmd/version/version.go @@ -5,6 +5,7 @@ package version import "bytes" import "fmt" +import "io" import "os" @@ -14,7 +15,7 @@ import . "github.com/volution/kawipiko/embedded" -func Version (_executableName string, _executable string, _stream *os.File) (error) { +func Version (_executableName string, _executable string, _stream io.Writer) (error) { if _executable == "" { if _executable_0, _error := os.Executable (); _error == nil {