1 files changed, 144 insertions, 0 deletions
diff --git a/rescached_httpd.go b/rescached_httpd.go
new file mode 100644
index 0000000..4ded760
--- /dev/null
+++ b/rescached_httpd.go
@@ -0,0 +1,144 @@
+// Copyright 2020, Shulhan <ms@kilabit.info>. All rights reserved.
+// Use of this source code is governed by a BSD-style
+// license that can be found in the LICENSE file.
+
+package rescached
+
+import (
+	"encoding/json"
+	"fmt"
+	"log"
+	stdhttp "net/http"
+
+	liberrors "github.com/shuLhan/share/lib/errors"
+	"github.com/shuLhan/share/lib/http"
+)
+
+const (
+	defHTTPDRootDir = "_www/public/"
+)
+
+func (srv *Server) httpdInit() (err error) {
+	opts := &http.ServerOptions{
+		Root:    defHTTPDRootDir,
+		Address: srv.opts.WuiListen,
+		Includes: []string{
+			`.*\.css`,
+			`.*\.html`,
+			`.*\.js`,
+		},
+		CORSAllowOrigins: []string{
+			"http://127.0.0.1:5000",
+		},
+		CORSAllowHeaders: []string{
+			http.HeaderContentType,
+		},
+	}
+
+	srv.httpd, err = http.NewServer(opts)
+	if err != nil {
+		return fmt.Errorf("newHTTPServer: %w", err)
+	}
+
+	err = srv.httpdRegisterEndpoints()
+	if err != nil {
+		return fmt.Errorf("newHTTPServer: %w", err)
+	}
+
+	return nil
+}
+
+func (srv *Server) httpdRegisterEndpoints() (err error) {
+	epAPIGetEnvironment := &http.Endpoint{
+		Method:       http.RequestMethodGet,
+		Path:         "/api/environment",
+		RequestType:  http.RequestTypeJSON,
+		ResponseType: http.ResponseTypeJSON,
+		Call:         srv.httpdAPIGetEnvironment,
+	}
+
+	err = srv.httpd.RegisterEndpoint(epAPIGetEnvironment)
+	if err != nil {
+		return err
+	}
+
+	epAPIPostEnvironment := &http.Endpoint{
+		Method:       http.RequestMethodPost,
+		Path:         "/api/environment",
+		RequestType:  http.RequestTypeJSON,
+		ResponseType: http.ResponseTypeJSON,
+		Call:         srv.httpdAPIPostEnvironment,
+	}
+
+	err = srv.httpd.RegisterEndpoint(epAPIPostEnvironment)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (srv *Server) httpdRun() {
+	defer func() {
+		err := recover()
+		if err != nil {
+			log.Printf("httpServer: %s", err)
+		}
+	}()
+
+	log.Printf("=== rescached: httpd listening at %s", srv.opts.WuiListen)
+
+	err := srv.httpd.Start()
+	if err != nil {
+		log.Printf("httpServer.run: %s", err)
+	}
+}
+
+func (srv *Server) httpdAPIGetEnvironment(
+	httpRes stdhttp.ResponseWriter, req *stdhttp.Request, reqBody []byte,
+) (
+	resBody []byte, err error,
+) {
+	return json.Marshal(srv.opts)
+}
+
+func (srv *Server) httpdAPIPostEnvironment(
+	httpRes stdhttp.ResponseWriter, req *stdhttp.Request, reqBody []byte,
+) (
+	resBody []byte, err error,
+) {
+	newOpts := new(Options)
+	err = json.Unmarshal(reqBody, newOpts)
+	if err != nil {
+		return nil, err
+	}
+
+	newOpts.init()
+
+	fmt.Printf("new options: %+v\n", newOpts)
+
+	res := &liberrors.E{
+		Code:    stdhttp.StatusOK,
+		Message: "Restarting DNS server",
+	}
+
+	err = newOpts.write(srv.fileConfig)
+	if err != nil {
+		log.Println("httpdAPIPostEnvironment:", err.Error())
+		res.Code = stdhttp.StatusInternalServerError
+		res.Message = err.Error()
+		return json.Marshal(res)
+	}
+
+	srv.opts = newOpts
+
+	srv.Stop()
+	err = srv.Start()
+	if err != nil {
+		log.Println("httpdAPIPostEnvironment:", err.Error())
+		res.Code = stdhttp.StatusInternalServerError
+		res.Message = err.Error()
+	}
+
+	return json.Marshal(res)
+}