summaryrefslogtreecommitdiff
path: root/http_server.go
diff options
context:
space:
mode:
Diffstat (limited to 'http_server.go')
-rw-r--r--http_server.go372
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)
+}
generated by cgit v1.3 (git 2.53.0) at 2026-04-15 04:17:21 +0000