diff options
| author | Shulhan <ms@kilabit.info> | 2022-05-22 21:47:09 +0700 |
|---|---|---|
| committer | Shulhan <ms@kilabit.info> | 2022-05-22 21:51:48 +0700 |
| commit | 3a38245a6a418b2ddbe4dfcd916ab83708b6f500 (patch) | |
| tree | 5e7972a3ba569fb0269bbf573d8a7ad719540075 | |
| parent | 0b92dbb8463dee31c005c59f67c2bf754a9eae12 (diff) | |
| download | rescached-3a38245a6a418b2ddbe4dfcd916ab83708b6f500.tar.xz | |
all: implement HTTP API to fetch list of block.d
Given the following request,
GET /api/block.d
It will return list of hosts in block.d as JSON format:
{
"data": {
"<name>": <Blockd>
...
}
}
| -rw-r--r-- | client.go | 27 | ||||
| -rw-r--r-- | httpd.go | 39 |
2 files changed, 66 insertions, 0 deletions
@@ -33,6 +33,33 @@ func NewClient(serverUrl string, insecure bool) (cl *Client) { return cl } +// Blockd return list of all block.d files on the server. +func (cl *Client) Blockd() (hostBlockd map[string]*Blockd, err error) { + var ( + logp = "Blockd" + res = libhttp.EndpointResponse{} + + resb []byte + ) + + _, resb, err = cl.Get(apiBlockd, nil, nil) + if err != nil { + return nil, fmt.Errorf("%s: %w", logp, err) + } + + res.Data = &hostBlockd + + err = json.Unmarshal(resb, &res) + if err != nil { + return nil, fmt.Errorf("%s: %w", logp, err) + } + if res.Code != http.StatusOK { + return nil, fmt.Errorf("%s: %d %s", logp, res.Code, res.Message) + } + + return hostBlockd, nil +} + // BlockdDisable disable specific hosts on block.d. func (cl *Client) BlockdDisable(blockdName string) (an interface{}, err error) { var ( @@ -119,6 +119,17 @@ func (srv *Server) httpdRegisterEndpoints() (err error) { } err = srv.httpd.RegisterEndpoint(&libhttp.Endpoint{ + Method: libhttp.RequestMethodGet, + Path: apiBlockd, + RequestType: libhttp.RequestTypeNone, + ResponseType: libhttp.ResponseTypeJSON, + Call: srv.httpApiBlockdList, + }) + if err != nil { + return err + } + + err = srv.httpd.RegisterEndpoint(&libhttp.Endpoint{ Method: libhttp.RequestMethodPost, Path: apiBlockd, RequestType: libhttp.RequestTypeJSON, @@ -301,6 +312,34 @@ func (srv *Server) httpdRun() { } } +// httpApiBlockdList fetch the list of block.d files. +// +// # Request +// +// GET /api/block.d +// +// # Response +// +// On success it will return list of hosts in block.d, +// +// { +// "data": { +// "<name>": <Blockd> +// ... +// } +// } +func (srv *Server) httpApiBlockdList(epr *libhttp.EndpointRequest) (resBody []byte, err error) { + var ( + res = libhttp.EndpointResponse{} + ) + + res.Code = http.StatusOK + res.Data = srv.env.HostBlockd + + resBody, err = json.Marshal(&res) + return resBody, err +} + // httpApiBlockdDisable disable the hosts block.d. func (srv *Server) httpApiBlockdDisable(epr *libhttp.EndpointRequest) (resBody []byte, err error) { var ( |
