all: rename http_api.go to http_server.go

We will move all fields related to HTTP server into one struct later.

1 files changed, 372 insertions, 0 deletions

diff --git a/http_server.go b/http_server.go
new file mode 100644
index 0000000..c5d1c56
--- /dev/null
+++ b/http_server.go
@@ -0,0 +1,372 @@
+// SPDX-FileCopyrightText: 2021 M. Shulhan <ms@kilabit.info>
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+package awwan
+
+import (
+	"encoding/json"
+	"fmt"
+	"net/http"
+	"os"
+	"path"
+	"path/filepath"
+	"strings"
+
+	libbytes "github.com/shuLhan/share/lib/bytes"
+	libhttp "github.com/shuLhan/share/lib/http"
+	"github.com/shuLhan/share/lib/memfs"
+)
+
+const (
+	httpApiFs      = "/awwan/api/fs"
+	httpApiExecute = "/awwan/api/execute"
+
+	paramNamePath = "path"
+)
+
+type fsRequest struct {
+	Path    string `json:"path"`
+	Content []byte `json:"content"`
+	IsDir   bool   `json:"is_dir"`
+}
+
+func (aww *Awwan) registerHttpApis() (err error) {
+	var (
+		logp = "registerHttpApis"
+	)
+
+	err = aww.httpd.RegisterEndpoint(&libhttp.Endpoint{
+		Method:       libhttp.RequestMethodGet,
+		Path:         httpApiFs,
+		RequestType:  libhttp.RequestTypeQuery,
+		ResponseType: libhttp.ResponseTypeJSON,
+		Call:         aww.httpApiFs,
+	})
+	if err != nil {
+		return fmt.Errorf("%s: %w", logp, err)
+	}
+
+	err = aww.httpd.RegisterEndpoint(&libhttp.Endpoint{
+		Method:       libhttp.RequestMethodDelete,
+		Path:         httpApiFs,
+		RequestType:  libhttp.RequestTypeJSON,
+		ResponseType: libhttp.ResponseTypeJSON,
+		Call:         aww.httpApiFsDelete,
+	})
+	if err != nil {
+		return fmt.Errorf("%s: %w", logp, err)
+	}
+
+	err = aww.httpd.RegisterEndpoint(&libhttp.Endpoint{
+		Method:       libhttp.RequestMethodPost,
+		Path:         httpApiFs,
+		RequestType:  libhttp.RequestTypeJSON,
+		ResponseType: libhttp.ResponseTypeJSON,
+		Call:         aww.httpApiFsPost,
+	})
+	if err != nil {
+		return fmt.Errorf("%s: %w", logp, err)
+	}
+
+	err = aww.httpd.RegisterEndpoint(&libhttp.Endpoint{
+		Method:       libhttp.RequestMethodPut,
+		Path:         httpApiFs,
+		RequestType:  libhttp.RequestTypeJSON,
+		ResponseType: libhttp.ResponseTypeJSON,
+		Call:         aww.httpApiFsPut,
+	})
+	if err != nil {
+		return fmt.Errorf("%s: %w", logp, err)
+	}
+
+	err = aww.httpd.RegisterEndpoint(&libhttp.Endpoint{
+		Method:       libhttp.RequestMethodPost,
+		Path:         httpApiExecute,
+		RequestType:  libhttp.RequestTypeJSON,
+		ResponseType: libhttp.ResponseTypeJSON,
+		Call:         aww.httpApiExecute,
+	})
+	if err != nil {
+		return fmt.Errorf("%s: %w", logp, err)
+	}
+
+	return nil
+}
+
+// httpApiFs get the list of files or specific file using query parameter
+// "path".
+func (aww *Awwan) httpApiFs(epr *libhttp.EndpointRequest) (resb []byte, err error) {
+	var (
+		res = &libhttp.EndpointResponse{}
+
+		node *memfs.Node
+		path string
+	)
+
+	path = epr.HttpRequest.Form.Get(paramNamePath)
+	if len(path) == 0 {
+		res.Code = http.StatusOK
+		res.Data = aww.memfsBase
+		return json.Marshal(res)
+	}
+
+	node, err = aww.memfsBase.Get(path)
+	if err != nil {
+		return nil, err
+	}
+
+	res.Code = http.StatusOK
+	res.Data = node
+	return json.Marshal(res)
+}
+
+// httpApiFsDelete an HTTP API to delete a file.
+//
+// # Request
+//
+// Format,
+//
+//	DELETE /awwan/api/fs
+//	Content-Type: application/json
+//
+//	{
+//		"path": <string>, the path to file or directory to be removed.
+//		"is_dir": <boolean>, true if its directory.
+//	}
+//
+// # Response
+//
+// Format,
+//
+//	Content-Type: application/json
+//
+//	{
+//		"code": <number>
+//		"message": <string>
+//	}
+//
+// List of valid response code,
+//   - 200: OK.
+//   - 400: Bad request.
+//   - 401: Unauthorized.
+//   - 404: File not found.
+func (aww *Awwan) httpApiFsDelete(epr *libhttp.EndpointRequest) (resb []byte, err error) {
+	var (
+		logp = "httpApiFsDelete"
+		res  = &libhttp.EndpointResponse{}
+		req  = &fsRequest{}
+
+		parentPath string
+		sysPath    string
+		nodeParent *memfs.Node
+	)
+
+	res.Code = http.StatusBadRequest
+
+	err = json.Unmarshal(epr.RequestBody, req)
+	if err != nil {
+		res.Message = err.Error()
+		return nil, res
+	}
+
+	parentPath = path.Dir(req.Path)
+	nodeParent = aww.memfsBase.PathNodes.Get(parentPath)
+	if nodeParent == nil {
+		res.Message = fmt.Sprintf("%s: invalid path %s", logp, req.Path)
+		return nil, res
+	}
+
+	sysPath = filepath.Join(nodeParent.SysPath, path.Base(req.Path))
+	sysPath, err = filepath.Abs(sysPath)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+	if !strings.HasPrefix(sysPath, aww.memfsBase.Opts.Root) {
+		res.Message = fmt.Sprintf("%s: invalid path %q", logp, sysPath)
+		return nil, res
+	}
+
+	err = os.Remove(sysPath)
+	if err != nil {
+		res.Code = http.StatusInternalServerError
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	res.Code = http.StatusOK
+	res.Message = fmt.Sprintf("%s: %q has been removed", logp, sysPath)
+
+	return json.Marshal(res)
+}
+
+// httpApiFsPost create new directory or file.
+//
+// # Request
+//
+// Format,
+//
+//	POST /awwan/api/fs
+//	Content-Type: application/json
+//
+//	{
+//		"path": <string>, the path to new directory or file.
+//		"is_dir": <boolean>, true if its directory.
+//	}
+func (aww *Awwan) httpApiFsPost(epr *libhttp.EndpointRequest) (rawBody []byte, err error) {
+	var (
+		logp = "httpApiFsPost"
+		res  = &libhttp.EndpointResponse{}
+		req  = &fsRequest{}
+
+		nodeParent *memfs.Node
+		node       *memfs.Node
+		fi         os.FileInfo
+		parentPath string
+		sysPath    string
+	)
+
+	res.Code = http.StatusBadRequest
+
+	err = json.Unmarshal(epr.RequestBody, req)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	parentPath = path.Dir(req.Path)
+	nodeParent = aww.memfsBase.PathNodes.Get(parentPath)
+	if nodeParent == nil {
+		res.Message = fmt.Sprintf("%s: invalid path %s", logp, req.Path)
+		return nil, res
+	}
+	node = aww.memfsBase.PathNodes.Get(req.Path)
+	if node != nil {
+		res.Message = fmt.Sprintf("%s: file exist", logp)
+		return nil, res
+	}
+
+	res.Code = http.StatusInternalServerError
+
+	sysPath = filepath.Join(nodeParent.SysPath, path.Base(req.Path))
+	sysPath, err = filepath.Abs(sysPath)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+	if !strings.HasPrefix(sysPath, aww.memfsBase.Opts.Root) {
+		res.Message = fmt.Sprintf("%s: invalid path %q", logp, sysPath)
+		return nil, res
+	}
+	if req.IsDir {
+		err = os.Mkdir(sysPath, 0700)
+	} else {
+		err = os.WriteFile(sysPath, nil, 0600)
+	}
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	fi, err = os.Stat(sysPath)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	node, err = aww.memfsBase.AddChild(nodeParent, fi)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	res.Code = http.StatusOK
+	res.Data = node
+
+	return json.Marshal(res)
+}
+
+// httpApiFsPut save the content of file.
+func (aww *Awwan) httpApiFsPut(epr *libhttp.EndpointRequest) (rawBody []byte, err error) {
+	var (
+		logp = "httpApiFsPut"
+		res  = &libhttp.EndpointResponse{}
+		req  = &fsRequest{}
+
+		node *memfs.Node
+	)
+
+	res.Code = http.StatusInternalServerError
+
+	err = json.Unmarshal(epr.RequestBody, req)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	node = aww.memfsBase.PathNodes.Get(req.Path)
+	if node == nil {
+		res.Code = http.StatusNotFound
+		res.Message = fmt.Sprintf("%s: invalid or empty path %s", logp, req.Path)
+		return nil, res
+	}
+
+	err = node.Save(req.Content)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	res.Code = http.StatusOK
+	res.Data = node
+
+	return json.Marshal(res)
+}
+
+func (aww *Awwan) httpApiExecute(epr *libhttp.EndpointRequest) (resb []byte, err error) {
+	var (
+		logp = "httpApiExecute"
+		req  = &Request{}
+		res  = &libhttp.EndpointResponse{}
+
+		data *HttpResponse
+	)
+
+	res.Code = http.StatusInternalServerError
+
+	err = json.Unmarshal(epr.RequestBody, req)
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	req.Script = filepath.Join(aww.memfsBase.Opts.Root, req.Script)
+	req.lineRange = parseLineRange(req.LineRange)
+
+	aww.bufout.Reset()
+	aww.buferr.Reset()
+
+	req.stdout = &aww.bufout
+	req.stderr = &aww.buferr
+
+	if req.Mode == CommandModeLocal {
+		err = aww.Local(req)
+	} else {
+		err = aww.Play(req)
+	}
+	if err != nil {
+		res.Message = fmt.Sprintf("%s: %s", logp, err)
+		return nil, res
+	}
+
+	data = &HttpResponse{
+		Request: req,
+		Stdout:  libbytes.Copy(aww.bufout.Bytes()),
+		Stderr:  libbytes.Copy(aww.buferr.Bytes()),
+	}
+
+	res.Code = http.StatusOK
+	res.Data = data
+
+	return json.Marshal(res)
+}