mirror of
https://github.com/khairul169/garage-webui.git
synced 2025-09-18 11:09:31 +07:00
Compare commits
20 Commits
Author | SHA1 | Date | |
---|---|---|---|
a6640157c1 | |||
72411c7f97 | |||
90a1018235 | |||
aeedaaa72e | |||
![]() |
c7d3d224ba | ||
![]() |
5f0f200c03 | ||
![]() |
ff39a6cd82 | ||
![]() |
6c6b9b076b | ||
b2bc905e3c | |||
59e68455b6 | |||
f30d4289f1 | |||
e6e21d3c01 | |||
2aaaf87dfd | |||
04a10eadfd | |||
8c3458c27f | |||
f8e65ccc0e | |||
b53859ae23 | |||
8728108d18 | |||
0d844c7ac6 | |||
ccfa2cde25 |
14
Dockerfile
14
Dockerfile
@ -1,9 +1,7 @@
|
|||||||
FROM node:20-slim AS frontend
|
FROM node:20-slim AS frontend
|
||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
|
|
||||||
ENV PNPM_HOME="/pnpm"
|
RUN npm install -g corepack@latest && corepack use pnpm@latest
|
||||||
ENV PATH="$PNPM_HOME:$PATH"
|
|
||||||
RUN corepack enable
|
|
||||||
|
|
||||||
COPY package.json pnpm-lock.yaml ./
|
COPY package.json pnpm-lock.yaml ./
|
||||||
RUN --mount=type=cache,id=pnpm,target=/pnpm/store pnpm install --frozen-lockfile
|
RUN --mount=type=cache,id=pnpm,target=/pnpm/store pnpm install --frozen-lockfile
|
||||||
@ -11,7 +9,7 @@ RUN --mount=type=cache,id=pnpm,target=/pnpm/store pnpm install --frozen-lockfile
|
|||||||
COPY . .
|
COPY . .
|
||||||
RUN pnpm run build
|
RUN pnpm run build
|
||||||
|
|
||||||
FROM golang:1.22.5 AS backend
|
FROM golang:1.23 AS backend
|
||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
|
|
||||||
COPY backend/go.mod backend/go.sum ./
|
COPY backend/go.mod backend/go.sum ./
|
||||||
@ -23,6 +21,12 @@ RUN make
|
|||||||
|
|
||||||
FROM scratch
|
FROM scratch
|
||||||
|
|
||||||
|
COPY --from=alpine /etc/ssl/certs/ca-certificates.crt /etc/ssl/certs/
|
||||||
|
COPY --from=ghcr.io/tarampampam/curl:8.6.0 /bin/curl /bin/curl
|
||||||
COPY --from=backend /app/main /bin/main
|
COPY --from=backend /app/main /bin/main
|
||||||
|
|
||||||
CMD [ "/bin/main" ]
|
HEALTHCHECK --interval=5m --timeout=2s --retries=3 --start-period=15s CMD [ \
|
||||||
|
"curl", "--fail", "http://127.0.0.1:3909" \
|
||||||
|
]
|
||||||
|
|
||||||
|
ENTRYPOINT [ "main" ]
|
41
README.md
41
README.md
@ -31,14 +31,18 @@ If you install Garage using Docker, you can install this web UI alongside Garage
|
|||||||
```yml
|
```yml
|
||||||
services:
|
services:
|
||||||
garage:
|
garage:
|
||||||
image: dxflrs/garage:v1.0.1
|
image: dxflrs/garage:v2.0.0
|
||||||
container_name: garage
|
container_name: garage
|
||||||
volumes:
|
volumes:
|
||||||
- ./garage.toml:/etc/garage.toml
|
- ./garage.toml:/etc/garage.toml
|
||||||
- ./meta:/var/lib/garage/meta
|
- ./meta:/var/lib/garage/meta
|
||||||
- ./data:/var/lib/garage/data
|
- ./data:/var/lib/garage/data
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
network_mode: host
|
ports:
|
||||||
|
- 3900:3900
|
||||||
|
- 3901:3901
|
||||||
|
- 3902:3902
|
||||||
|
- 3903:3903
|
||||||
|
|
||||||
webui:
|
webui:
|
||||||
image: khairul169/garage-webui:latest
|
image: khairul169/garage-webui:latest
|
||||||
@ -48,6 +52,9 @@ services:
|
|||||||
- ./garage.toml:/etc/garage.toml:ro
|
- ./garage.toml:/etc/garage.toml:ro
|
||||||
ports:
|
ports:
|
||||||
- 3909:3909
|
- 3909:3909
|
||||||
|
environment:
|
||||||
|
API_BASE_URL: "http://garage:3903"
|
||||||
|
S3_ENDPOINT_URL: "http://garage:3900"
|
||||||
```
|
```
|
||||||
|
|
||||||
### Without Docker
|
### Without Docker
|
||||||
@ -55,7 +62,7 @@ services:
|
|||||||
Get the latest binary from the [release page](https://github.com/khairul169/garage-webui/releases/latest) according to your OS architecture. For example:
|
Get the latest binary from the [release page](https://github.com/khairul169/garage-webui/releases/latest) according to your OS architecture. For example:
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
$ wget -O garage-webui https://github.com/khairul169/garage-webui/releases/download/1.0.5/garage-webui-v1.0.5-linux-amd64
|
$ wget -O garage-webui https://github.com/khairul169/garage-webui/releases/download/1.1.0/garage-webui-v1.1.0-linux-amd64
|
||||||
$ chmod +x garage-webui
|
$ chmod +x garage-webui
|
||||||
$ sudo cp garage-webui /usr/local/bin
|
$ sudo cp garage-webui /usr/local/bin
|
||||||
```
|
```
|
||||||
@ -129,14 +136,40 @@ admin_token = "YOUR_ADMIN_TOKEN_HERE"
|
|||||||
metrics_token = "YOUR_METRICS_TOKEN_HERE"
|
metrics_token = "YOUR_METRICS_TOKEN_HERE"
|
||||||
```
|
```
|
||||||
|
|
||||||
However, if it fails to load, you can set these environment variables instead:
|
However, if it fails to load, you can set `API_BASE_URL` & `API_ADMIN_KEY` environment variables instead.
|
||||||
|
|
||||||
|
### Environment Variables
|
||||||
|
|
||||||
|
Configurable envs:
|
||||||
|
|
||||||
- `CONFIG_PATH`: Path to the Garage `config.toml` file. Defaults to `/etc/garage.toml`.
|
- `CONFIG_PATH`: Path to the Garage `config.toml` file. Defaults to `/etc/garage.toml`.
|
||||||
|
- `BASE_PATH`: Base path or prefix for Web UI.
|
||||||
- `API_BASE_URL`: Garage admin API endpoint URL.
|
- `API_BASE_URL`: Garage admin API endpoint URL.
|
||||||
- `API_ADMIN_KEY`: Admin API key.
|
- `API_ADMIN_KEY`: Admin API key.
|
||||||
- `S3_REGION`: S3 Region.
|
- `S3_REGION`: S3 Region.
|
||||||
- `S3_ENDPOINT_URL`: S3 Endpoint url.
|
- `S3_ENDPOINT_URL`: S3 Endpoint url.
|
||||||
|
|
||||||
|
### Authentication
|
||||||
|
|
||||||
|
Enable authentication by setting the `AUTH_USER_PASS` environment variable in the format `username:password_hash`, where `password_hash` is a bcrypt hash of the password.
|
||||||
|
|
||||||
|
Generate the username and password hash using the following command:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
htpasswd -nbBC 10 "YOUR_USERNAME" "YOUR_PASSWORD"
|
||||||
|
```
|
||||||
|
|
||||||
|
> If command 'htpasswd' is not found, install `apache2-utils` using your package manager.
|
||||||
|
|
||||||
|
Then update your `docker-compose.yml`:
|
||||||
|
|
||||||
|
```yml
|
||||||
|
webui:
|
||||||
|
....
|
||||||
|
environment:
|
||||||
|
AUTH_USER_PASS: "username:$2y$10$DSTi9o..."
|
||||||
|
```
|
||||||
|
|
||||||
### Running
|
### Running
|
||||||
|
|
||||||
Once your instance of Garage Web UI is started, you can open the web UI at http://your-ip:3909. You can place it behind a reverse proxy to secure it with SSL.
|
Once your instance of Garage Web UI is started, you can open the web UI at http://your-ip:3909. You can place it behind a reverse proxy to secure it with SSL.
|
||||||
|
6
backend/.env.example
Normal file
6
backend/.env.example
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
#
|
||||||
|
BASE_PATH=""
|
||||||
|
AUTH_USER_PASS='username:$2y$10$DSTi9o0uQPEHSNlf66xMEOgm9KgVNBP3vHxA3SK0Xha2EVMb3mTXm'
|
||||||
|
API_BASE_URL="http://garage:3903"
|
||||||
|
S3_ENDPOINT_URL="http://garage:3900"
|
||||||
|
API_ADMIN_KEY=""
|
@ -1,6 +1,8 @@
|
|||||||
module khairul169/garage-webui
|
module khairul169/garage-webui
|
||||||
|
|
||||||
go 1.22.5
|
go 1.23.0
|
||||||
|
|
||||||
|
toolchain go1.24.0
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/aws/aws-sdk-go-v2 v1.30.4
|
github.com/aws/aws-sdk-go-v2 v1.30.4
|
||||||
@ -13,6 +15,7 @@ require (
|
|||||||
)
|
)
|
||||||
|
|
||||||
require (
|
require (
|
||||||
|
github.com/alexedwards/scs/v2 v2.8.0 // indirect
|
||||||
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.4 // indirect
|
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.4 // indirect
|
||||||
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.16 // indirect
|
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.16 // indirect
|
||||||
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.16 // indirect
|
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.16 // indirect
|
||||||
@ -21,4 +24,5 @@ require (
|
|||||||
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.18 // indirect
|
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.18 // indirect
|
||||||
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.18 // indirect
|
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.18 // indirect
|
||||||
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.16 // indirect
|
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.16 // indirect
|
||||||
|
golang.org/x/crypto v0.35.0
|
||||||
)
|
)
|
||||||
|
@ -1,3 +1,5 @@
|
|||||||
|
github.com/alexedwards/scs/v2 v2.8.0 h1:h31yUYoycPuL0zt14c0gd+oqxfRwIj6SOjHdKRZxhEw=
|
||||||
|
github.com/alexedwards/scs/v2 v2.8.0/go.mod h1:ToaROZxyKukJKT/xLcVQAChi5k6+Pn1Gvmdl7h3RRj8=
|
||||||
github.com/aws/aws-sdk-go-v2 v1.30.4 h1:frhcagrVNrzmT95RJImMHgabt99vkXGslubDaDagTk8=
|
github.com/aws/aws-sdk-go-v2 v1.30.4 h1:frhcagrVNrzmT95RJImMHgabt99vkXGslubDaDagTk8=
|
||||||
github.com/aws/aws-sdk-go-v2 v1.30.4/go.mod h1:CT+ZPWXbYrci8chcARI3OmI/qgd+f6WtuLOoaIA8PR0=
|
github.com/aws/aws-sdk-go-v2 v1.30.4/go.mod h1:CT+ZPWXbYrci8chcARI3OmI/qgd+f6WtuLOoaIA8PR0=
|
||||||
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.4 h1:70PVAiL15/aBMh5LThwgXdSQorVr91L127ttckI9QQU=
|
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.4 h1:70PVAiL15/aBMh5LThwgXdSQorVr91L127ttckI9QQU=
|
||||||
@ -42,6 +44,8 @@ github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO
|
|||||||
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
|
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
|
||||||
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
|
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
|
||||||
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
|
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
|
||||||
|
golang.org/x/crypto v0.35.0 h1:b15kiHdrGCHrP6LvwaQ3c03kgNhhiMgvlhxHQhmg2Xs=
|
||||||
|
golang.org/x/crypto v0.35.0/go.mod h1:dy7dXNW32cAb/6/PRuTNsix8T+vJAqvuIy5Bli/x0YQ=
|
||||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||||
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||||
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
||||||
|
@ -7,20 +7,35 @@ import (
|
|||||||
"khairul169/garage-webui/utils"
|
"khairul169/garage-webui/utils"
|
||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"os"
|
||||||
|
|
||||||
"github.com/joho/godotenv"
|
"github.com/joho/godotenv"
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
// Initialize app
|
||||||
godotenv.Load()
|
godotenv.Load()
|
||||||
utils.InitCacheManager()
|
utils.InitCacheManager()
|
||||||
|
sessionMgr := utils.InitSessionManager()
|
||||||
|
|
||||||
if err := utils.Garage.LoadConfig(); err != nil {
|
if err := utils.Garage.LoadConfig(); err != nil {
|
||||||
log.Println("Cannot load garage config!", err)
|
log.Println("Cannot load garage config!", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
http.Handle("/api/", http.StripPrefix("/api", router.HandleApiRouter()))
|
basePath := os.Getenv("BASE_PATH")
|
||||||
ui.ServeUI()
|
mux := http.NewServeMux()
|
||||||
|
|
||||||
|
// Serve API
|
||||||
|
apiPrefix := basePath + "/api"
|
||||||
|
mux.Handle(apiPrefix+"/", http.StripPrefix(apiPrefix, router.HandleApiRouter()))
|
||||||
|
|
||||||
|
// Static files
|
||||||
|
ui.ServeUI(mux)
|
||||||
|
|
||||||
|
// Redirect to UI if BASE_PATH is set
|
||||||
|
if basePath != "" {
|
||||||
|
mux.Handle("/", http.RedirectHandler(basePath, http.StatusMovedPermanently))
|
||||||
|
}
|
||||||
|
|
||||||
host := utils.GetEnv("HOST", "0.0.0.0")
|
host := utils.GetEnv("HOST", "0.0.0.0")
|
||||||
port := utils.GetEnv("PORT", "3909")
|
port := utils.GetEnv("PORT", "3909")
|
||||||
@ -28,7 +43,7 @@ func main() {
|
|||||||
addr := fmt.Sprintf("%s:%s", host, port)
|
addr := fmt.Sprintf("%s:%s", host, port)
|
||||||
log.Printf("Starting server on http://%s", addr)
|
log.Printf("Starting server on http://%s", addr)
|
||||||
|
|
||||||
if err := http.ListenAndServe(addr, nil); err != nil {
|
if err := http.ListenAndServe(addr, sessionMgr.LoadAndSave(mux)); err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
27
backend/middleware/auth.go
Normal file
27
backend/middleware/auth.go
Normal file
@ -0,0 +1,27 @@
|
|||||||
|
package middleware
|
||||||
|
|
||||||
|
import (
|
||||||
|
"errors"
|
||||||
|
"khairul169/garage-webui/utils"
|
||||||
|
"net/http"
|
||||||
|
)
|
||||||
|
|
||||||
|
func AuthMiddleware(next http.Handler) http.Handler {
|
||||||
|
authData := utils.GetEnv("AUTH_USER_PASS", "")
|
||||||
|
|
||||||
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
auth := utils.Session.Get(r, "authenticated")
|
||||||
|
|
||||||
|
if authData == "" {
|
||||||
|
next.ServeHTTP(w, r)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if auth == nil || !auth.(bool) {
|
||||||
|
utils.ResponseErrorStatus(w, errors.New("unauthorized"), http.StatusUnauthorized)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
next.ServeHTTP(w, r)
|
||||||
|
})
|
||||||
|
}
|
64
backend/router/auth.go
Normal file
64
backend/router/auth.go
Normal file
@ -0,0 +1,64 @@
|
|||||||
|
package router
|
||||||
|
|
||||||
|
import (
|
||||||
|
"encoding/json"
|
||||||
|
"errors"
|
||||||
|
"khairul169/garage-webui/utils"
|
||||||
|
"net/http"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"golang.org/x/crypto/bcrypt"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Auth struct{}
|
||||||
|
|
||||||
|
func (c *Auth) Login(w http.ResponseWriter, r *http.Request) {
|
||||||
|
var body struct {
|
||||||
|
Username string `json:"username"`
|
||||||
|
Password string `json:"password"`
|
||||||
|
}
|
||||||
|
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
|
||||||
|
utils.ResponseError(w, err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
userPass := strings.Split(utils.GetEnv("AUTH_USER_PASS", ""), ":")
|
||||||
|
if len(userPass) < 2 {
|
||||||
|
utils.ResponseErrorStatus(w, errors.New("AUTH_USER_PASS not set"), 500)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if strings.TrimSpace(body.Username) != userPass[0] || bcrypt.CompareHashAndPassword([]byte(userPass[1]), []byte(body.Password)) != nil {
|
||||||
|
utils.ResponseErrorStatus(w, errors.New("invalid username or password"), 401)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
utils.Session.Set(r, "authenticated", true)
|
||||||
|
utils.ResponseSuccess(w, map[string]bool{
|
||||||
|
"authenticated": true,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Auth) Logout(w http.ResponseWriter, r *http.Request) {
|
||||||
|
utils.Session.Clear(r)
|
||||||
|
utils.ResponseSuccess(w, true)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Auth) GetStatus(w http.ResponseWriter, r *http.Request) {
|
||||||
|
isAuthenticated := true
|
||||||
|
authSession := utils.Session.Get(r, "authenticated")
|
||||||
|
enabled := false
|
||||||
|
|
||||||
|
if utils.GetEnv("AUTH_USER_PASS", "") != "" {
|
||||||
|
enabled = true
|
||||||
|
}
|
||||||
|
|
||||||
|
if authSession != nil && authSession.(bool) {
|
||||||
|
isAuthenticated = true
|
||||||
|
}
|
||||||
|
|
||||||
|
utils.ResponseSuccess(w, map[string]bool{
|
||||||
|
"enabled": enabled,
|
||||||
|
"authenticated": isAuthenticated,
|
||||||
|
})
|
||||||
|
}
|
@ -146,11 +146,20 @@ func (b *Browse) GetOneObject(w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
w.Header().Set("Content-Type", *object.ContentType)
|
|
||||||
w.Header().Set("Content-Length", strconv.FormatInt(*object.ContentLength, 10))
|
|
||||||
w.Header().Set("Cache-Control", "max-age=86400")
|
w.Header().Set("Cache-Control", "max-age=86400")
|
||||||
w.Header().Set("Last-Modified", object.LastModified.Format(time.RFC1123))
|
w.Header().Set("Last-Modified", object.LastModified.Format(time.RFC1123))
|
||||||
w.Header().Set("Etag", *object.ETag)
|
|
||||||
|
if object.ContentType != nil {
|
||||||
|
w.Header().Set("Content-Type", *object.ContentType)
|
||||||
|
} else {
|
||||||
|
w.Header().Set("Content-Type", "application/octet-stream")
|
||||||
|
}
|
||||||
|
if object.ContentLength != nil {
|
||||||
|
w.Header().Set("Content-Length", strconv.FormatInt(*object.ContentLength, 10))
|
||||||
|
}
|
||||||
|
if object.ETag != nil {
|
||||||
|
w.Header().Set("Etag", *object.ETag)
|
||||||
|
}
|
||||||
|
|
||||||
_, err = io.Copy(w, object.Body)
|
_, err = io.Copy(w, object.Body)
|
||||||
|
|
||||||
@ -283,7 +292,7 @@ func getBucketCredentials(bucket string) (aws.CredentialsProvider, error) {
|
|||||||
return cacheData.(aws.CredentialsProvider), nil
|
return cacheData.(aws.CredentialsProvider), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
body, err := utils.Garage.Fetch("/v1/bucket?globalAlias="+bucket, &utils.FetchOptions{})
|
body, err := utils.Garage.Fetch("/v2/GetBucketInfo?globalAlias="+bucket, &utils.FetchOptions{})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@ -300,7 +309,7 @@ func getBucketCredentials(bucket string) (aws.CredentialsProvider, error) {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
body, err := utils.Garage.Fetch(fmt.Sprintf("/v1/key?id=%s&showSecretKey=true", k.AccessKeyID), &utils.FetchOptions{})
|
body, err := utils.Garage.Fetch(fmt.Sprintf("/v2/GetKeyInfo?id=%s&showSecretKey=true", k.AccessKeyID), &utils.FetchOptions{})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@ -322,15 +331,26 @@ func getS3Client(bucket string) (*s3.Client, error) {
|
|||||||
return nil, fmt.Errorf("cannot get credentials for bucket %s: %w", bucket, err)
|
return nil, fmt.Errorf("cannot get credentials for bucket %s: %w", bucket, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Determine endpoint and whether to disable HTTPS
|
||||||
|
endpoint := utils.Garage.GetS3Endpoint()
|
||||||
|
disableHTTPS := !strings.HasPrefix(endpoint, "https://")
|
||||||
|
|
||||||
|
// AWS config without BaseEndpoint
|
||||||
awsConfig := aws.Config{
|
awsConfig := aws.Config{
|
||||||
Credentials: creds,
|
Credentials: creds,
|
||||||
Region: utils.Garage.GetS3Region(),
|
Region: utils.Garage.GetS3Region(),
|
||||||
BaseEndpoint: aws.String(utils.Garage.GetS3Endpoint()),
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Build S3 client with custom endpoint resolver for proper signing
|
||||||
client := s3.NewFromConfig(awsConfig, func(o *s3.Options) {
|
client := s3.NewFromConfig(awsConfig, func(o *s3.Options) {
|
||||||
o.UsePathStyle = true
|
o.UsePathStyle = true
|
||||||
o.EndpointOptions.DisableHTTPS = true
|
o.EndpointOptions.DisableHTTPS = disableHTTPS
|
||||||
|
o.EndpointResolver = s3.EndpointResolverFunc(func(region string, opts s3.EndpointResolverOptions) (aws.Endpoint, error) {
|
||||||
|
return aws.Endpoint{
|
||||||
|
URL: endpoint,
|
||||||
|
SigningRegion: utils.Garage.GetS3Region(),
|
||||||
|
}, nil
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
return client, nil
|
return client, nil
|
||||||
|
@ -11,7 +11,7 @@ import (
|
|||||||
type Buckets struct{}
|
type Buckets struct{}
|
||||||
|
|
||||||
func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) {
|
func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) {
|
||||||
body, err := utils.Garage.Fetch("/v1/bucket?list", &utils.FetchOptions{})
|
body, err := utils.Garage.Fetch("/v2/ListBuckets", &utils.FetchOptions{})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.ResponseError(w, err)
|
utils.ResponseError(w, err)
|
||||||
return
|
return
|
||||||
@ -27,7 +27,7 @@ func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
for _, bucket := range buckets {
|
for _, bucket := range buckets {
|
||||||
go func() {
|
go func() {
|
||||||
body, err := utils.Garage.Fetch(fmt.Sprintf("/v1/bucket?id=%s", bucket.ID), &utils.FetchOptions{})
|
body, err := utils.Garage.Fetch(fmt.Sprintf("/v2/GetBucketInfo?id=%s", bucket.ID), &utils.FetchOptions{})
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases}
|
ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases}
|
||||||
|
@ -1,9 +1,19 @@
|
|||||||
package router
|
package router
|
||||||
|
|
||||||
import "net/http"
|
import (
|
||||||
|
"khairul169/garage-webui/middleware"
|
||||||
|
"net/http"
|
||||||
|
)
|
||||||
|
|
||||||
func HandleApiRouter() *http.ServeMux {
|
func HandleApiRouter() *http.ServeMux {
|
||||||
|
mux := http.NewServeMux()
|
||||||
|
|
||||||
|
auth := &Auth{}
|
||||||
|
mux.HandleFunc("POST /auth/login", auth.Login)
|
||||||
|
|
||||||
router := http.NewServeMux()
|
router := http.NewServeMux()
|
||||||
|
router.HandleFunc("POST /auth/logout", auth.Logout)
|
||||||
|
router.HandleFunc("GET /auth/status", auth.GetStatus)
|
||||||
|
|
||||||
config := &Config{}
|
config := &Config{}
|
||||||
router.HandleFunc("GET /config", config.GetAll)
|
router.HandleFunc("GET /config", config.GetAll)
|
||||||
@ -17,7 +27,9 @@ func HandleApiRouter() *http.ServeMux {
|
|||||||
router.HandleFunc("PUT /browse/{bucket}/{key...}", browse.PutObject)
|
router.HandleFunc("PUT /browse/{bucket}/{key...}", browse.PutObject)
|
||||||
router.HandleFunc("DELETE /browse/{bucket}/{key...}", browse.DeleteObject)
|
router.HandleFunc("DELETE /browse/{bucket}/{key...}", browse.DeleteObject)
|
||||||
|
|
||||||
|
// Proxy request to garage api endpoint
|
||||||
router.HandleFunc("/", ProxyHandler)
|
router.HandleFunc("/", ProxyHandler)
|
||||||
|
|
||||||
return router
|
mux.Handle("/", middleware.AuthMiddleware(router))
|
||||||
|
return mux
|
||||||
}
|
}
|
||||||
|
@ -4,6 +4,7 @@ type GetBucketsRes struct {
|
|||||||
ID string `json:"id"`
|
ID string `json:"id"`
|
||||||
GlobalAliases []string `json:"globalAliases"`
|
GlobalAliases []string `json:"globalAliases"`
|
||||||
LocalAliases []LocalAlias `json:"localAliases"`
|
LocalAliases []LocalAlias `json:"localAliases"`
|
||||||
|
Created string `json:"created"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type Bucket struct {
|
type Bucket struct {
|
||||||
@ -20,6 +21,7 @@ type Bucket struct {
|
|||||||
UnfinishedMultipartUploadParts int64 `json:"unfinishedMultipartUploadParts"`
|
UnfinishedMultipartUploadParts int64 `json:"unfinishedMultipartUploadParts"`
|
||||||
UnfinishedMultipartUploadBytes int64 `json:"unfinishedMultipartUploadBytes"`
|
UnfinishedMultipartUploadBytes int64 `json:"unfinishedMultipartUploadBytes"`
|
||||||
Quotas Quotas `json:"quotas"`
|
Quotas Quotas `json:"quotas"`
|
||||||
|
Created string `json:"created"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type LocalAlias struct {
|
type LocalAlias struct {
|
||||||
|
@ -3,4 +3,6 @@
|
|||||||
|
|
||||||
package ui
|
package ui
|
||||||
|
|
||||||
func ServeUI() {}
|
import "net/http"
|
||||||
|
|
||||||
|
func ServeUI(mux *http.ServeMux) {}
|
||||||
|
@ -7,28 +7,57 @@ import (
|
|||||||
"embed"
|
"embed"
|
||||||
"io/fs"
|
"io/fs"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"os"
|
||||||
"path"
|
"path"
|
||||||
|
"regexp"
|
||||||
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
//go:embed dist
|
//go:embed dist
|
||||||
var embeddedFs embed.FS
|
var embeddedFs embed.FS
|
||||||
|
|
||||||
func ServeUI() {
|
func ServeUI(mux *http.ServeMux) {
|
||||||
distFs, _ := fs.Sub(embeddedFs, "dist")
|
distFs, _ := fs.Sub(embeddedFs, "dist")
|
||||||
fileServer := http.FileServer(http.FS(distFs))
|
fileServer := http.FileServer(http.FS(distFs))
|
||||||
|
basePath := os.Getenv("BASE_PATH")
|
||||||
|
|
||||||
http.Handle("/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
mux.Handle(basePath+"/", http.StripPrefix(basePath, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
_path := path.Clean(r.URL.Path)[1:]
|
_path := path.Clean(r.URL.Path)[1:]
|
||||||
|
|
||||||
// Rewrite non-existing paths to index.html
|
// Rewrite non-existing paths to index.html
|
||||||
if _, err := fs.Stat(distFs, _path); err != nil {
|
if _, err := fs.Stat(distFs, _path); err != nil {
|
||||||
index, _ := fs.ReadFile(distFs, "index.html")
|
index, _ := fs.ReadFile(distFs, "index.html")
|
||||||
|
html := string(index)
|
||||||
|
|
||||||
|
// Set base path for the UI
|
||||||
|
html = strings.ReplaceAll(html, "%BASE_PATH%", basePath)
|
||||||
|
html = addBasePath(html, basePath)
|
||||||
|
|
||||||
w.Header().Add("Content-Type", "text/html")
|
w.Header().Add("Content-Type", "text/html")
|
||||||
w.WriteHeader(http.StatusOK)
|
w.WriteHeader(http.StatusOK)
|
||||||
w.Write(index)
|
w.Write([]byte(html))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add prefix to each /assets strings in js
|
||||||
|
if len(basePath) > 0 && strings.HasSuffix(_path, ".js") {
|
||||||
|
data, _ := fs.ReadFile(distFs, _path)
|
||||||
|
html := string(data)
|
||||||
|
html = strings.ReplaceAll(html, "assets/", basePath[1:]+"/assets/")
|
||||||
|
|
||||||
|
w.Header().Add("Content-Type", "text/javascript")
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
w.Write([]byte(html))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
fileServer.ServeHTTP(w, r)
|
fileServer.ServeHTTP(w, r)
|
||||||
}))
|
})))
|
||||||
|
}
|
||||||
|
|
||||||
|
func addBasePath(html string, basePath string) string {
|
||||||
|
re := regexp.MustCompile(`(href|src)=["'](/[^"'>]+)["']`)
|
||||||
|
return re.ReplaceAllStringFunc(html, func(match string) string {
|
||||||
|
return re.ReplaceAllString(match, `$1="`+basePath+`$2"`)
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
33
backend/utils/session.go
Normal file
33
backend/utils/session.go
Normal file
@ -0,0 +1,33 @@
|
|||||||
|
package utils
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/http"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"github.com/alexedwards/scs/v2"
|
||||||
|
)
|
||||||
|
|
||||||
|
type SessionManager struct {
|
||||||
|
mgr *scs.SessionManager
|
||||||
|
}
|
||||||
|
|
||||||
|
var Session *SessionManager
|
||||||
|
|
||||||
|
func InitSessionManager() *scs.SessionManager {
|
||||||
|
sessMgr := scs.New()
|
||||||
|
sessMgr.Lifetime = 24 * time.Hour
|
||||||
|
Session = &SessionManager{mgr: sessMgr}
|
||||||
|
return sessMgr
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionManager) Get(r *http.Request, key string) interface{} {
|
||||||
|
return s.mgr.Get(r.Context(), key)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionManager) Set(r *http.Request, key string, value interface{}) {
|
||||||
|
s.mgr.Put(r.Context(), key, value)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionManager) Clear(r *http.Request) error {
|
||||||
|
return s.mgr.Clear(r.Context())
|
||||||
|
}
|
@ -1,13 +1,17 @@
|
|||||||
services:
|
services:
|
||||||
garage:
|
garage:
|
||||||
image: dxflrs/garage:v1.0.0
|
image: dxflrs/garage:v2.0.0
|
||||||
container_name: garage
|
container_name: garage
|
||||||
volumes:
|
volumes:
|
||||||
- ./garage.toml:/etc/garage.toml
|
- ./garage.toml:/etc/garage.toml
|
||||||
- ./meta:/var/lib/garage/meta
|
- ./meta:/var/lib/garage/meta
|
||||||
- ./data:/var/lib/garage/data
|
- ./data:/var/lib/garage/data
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
network_mode: host
|
ports:
|
||||||
|
- 3900:3900
|
||||||
|
- 3901:3901
|
||||||
|
- 3902:3903
|
||||||
|
- 3903:3903
|
||||||
|
|
||||||
webui:
|
webui:
|
||||||
image: khairul169/garage-webui:latest
|
image: khairul169/garage-webui:latest
|
||||||
@ -17,3 +21,6 @@ services:
|
|||||||
- ./garage.toml:/etc/garage.toml:ro
|
- ./garage.toml:/etc/garage.toml:ro
|
||||||
ports:
|
ports:
|
||||||
- 3909:3909
|
- 3909:3909
|
||||||
|
environment:
|
||||||
|
API_BASE_URL: "http://garage:3903"
|
||||||
|
S3_ENDPOINT_URL: "http://garage:3900"
|
||||||
|
@ -10,6 +10,9 @@
|
|||||||
<link rel="manifest" href="/site.webmanifest" />
|
<link rel="manifest" href="/site.webmanifest" />
|
||||||
|
|
||||||
<title>Garage Web UI</title>
|
<title>Garage Web UI</title>
|
||||||
|
<script>
|
||||||
|
window.__BASE_PATH = "%BASE_PATH%";
|
||||||
|
</script>
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<div id="root"></div>
|
<div id="root"></div>
|
||||||
|
10
package.json
10
package.json
@ -1,7 +1,7 @@
|
|||||||
{
|
{
|
||||||
"name": "garage-webui",
|
"name": "garage-webui",
|
||||||
"private": true,
|
"private": true,
|
||||||
"version": "1.0.5",
|
"version": "1.1.0",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"dev:client": "vite",
|
"dev:client": "vite",
|
||||||
@ -47,5 +47,11 @@
|
|||||||
"typescript": "^5.5.3",
|
"typescript": "^5.5.3",
|
||||||
"typescript-eslint": "^8.0.0",
|
"typescript-eslint": "^8.0.0",
|
||||||
"vite": "^5.4.0"
|
"vite": "^5.4.0"
|
||||||
|
},
|
||||||
|
"pnpm": {
|
||||||
|
"onlyBuiltDependencies": [
|
||||||
|
"@swc/core",
|
||||||
|
"esbuild"
|
||||||
|
]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,48 +1,65 @@
|
|||||||
import { createBrowserRouter, RouterProvider } from "react-router-dom";
|
import { createBrowserRouter, RouterProvider } from "react-router-dom";
|
||||||
import { lazy } from "react";
|
import { lazy, Suspense } from "react";
|
||||||
import AuthLayout from "@/components/layouts/auth-layout";
|
import AuthLayout from "@/components/layouts/auth-layout";
|
||||||
import MainLayout from "@/components/layouts/main-layout";
|
import MainLayout from "@/components/layouts/main-layout";
|
||||||
|
import { BASE_PATH } from "@/lib/consts";
|
||||||
|
|
||||||
|
const LoginPage = lazy(() => import("@/pages/auth/login"));
|
||||||
const ClusterPage = lazy(() => import("@/pages/cluster/page"));
|
const ClusterPage = lazy(() => import("@/pages/cluster/page"));
|
||||||
const HomePage = lazy(() => import("@/pages/home/page"));
|
const HomePage = lazy(() => import("@/pages/home/page"));
|
||||||
const BucketsPage = lazy(() => import("@/pages/buckets/page"));
|
const BucketsPage = lazy(() => import("@/pages/buckets/page"));
|
||||||
const ManageBucketPage = lazy(() => import("@/pages/buckets/manage/page"));
|
const ManageBucketPage = lazy(() => import("@/pages/buckets/manage/page"));
|
||||||
const KeysPage = lazy(() => import("@/pages/keys/page"));
|
const KeysPage = lazy(() => import("@/pages/keys/page"));
|
||||||
|
|
||||||
const router = createBrowserRouter([
|
const router = createBrowserRouter(
|
||||||
|
[
|
||||||
|
{
|
||||||
|
path: "/auth",
|
||||||
|
Component: AuthLayout,
|
||||||
|
children: [
|
||||||
|
{
|
||||||
|
path: "login",
|
||||||
|
Component: LoginPage,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: "/",
|
||||||
|
Component: MainLayout,
|
||||||
|
children: [
|
||||||
|
{
|
||||||
|
index: true,
|
||||||
|
Component: HomePage,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: "cluster",
|
||||||
|
Component: ClusterPage,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: "buckets",
|
||||||
|
children: [
|
||||||
|
{ index: true, Component: BucketsPage },
|
||||||
|
{ path: ":id", Component: ManageBucketPage },
|
||||||
|
],
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: "keys",
|
||||||
|
Component: KeysPage,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
},
|
||||||
|
],
|
||||||
{
|
{
|
||||||
path: "/auth",
|
basename: BASE_PATH,
|
||||||
Component: AuthLayout,
|
}
|
||||||
},
|
);
|
||||||
{
|
|
||||||
path: "/",
|
|
||||||
Component: MainLayout,
|
|
||||||
children: [
|
|
||||||
{
|
|
||||||
index: true,
|
|
||||||
Component: HomePage,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
path: "cluster",
|
|
||||||
Component: ClusterPage,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
path: "buckets",
|
|
||||||
children: [
|
|
||||||
{ index: true, Component: BucketsPage },
|
|
||||||
{ path: ":id", Component: ManageBucketPage },
|
|
||||||
],
|
|
||||||
},
|
|
||||||
{
|
|
||||||
path: "keys",
|
|
||||||
Component: KeysPage,
|
|
||||||
},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
]);
|
|
||||||
|
|
||||||
const Router = () => {
|
const Router = () => {
|
||||||
return <RouterProvider router={router} />;
|
return (
|
||||||
|
<Suspense>
|
||||||
|
<RouterProvider router={router} />
|
||||||
|
</Suspense>
|
||||||
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
export default Router;
|
export default Router;
|
||||||
|
@ -4,6 +4,7 @@ import {
|
|||||||
HardDrive,
|
HardDrive,
|
||||||
KeySquare,
|
KeySquare,
|
||||||
LayoutDashboard,
|
LayoutDashboard,
|
||||||
|
LogOut,
|
||||||
Palette,
|
Palette,
|
||||||
} from "lucide-react";
|
} from "lucide-react";
|
||||||
import { Dropdown, Menu } from "react-daisyui";
|
import { Dropdown, Menu } from "react-daisyui";
|
||||||
@ -12,6 +13,11 @@ import Button from "../ui/button";
|
|||||||
import { themes } from "@/app/themes";
|
import { themes } from "@/app/themes";
|
||||||
import appStore from "@/stores/app-store";
|
import appStore from "@/stores/app-store";
|
||||||
import garageLogo from "@/assets/garage-logo.svg";
|
import garageLogo from "@/assets/garage-logo.svg";
|
||||||
|
import { useMutation } from "@tanstack/react-query";
|
||||||
|
import api from "@/lib/api";
|
||||||
|
import * as utils from "@/lib/utils";
|
||||||
|
import { toast } from "sonner";
|
||||||
|
import { useAuth } from "@/hooks/useAuth";
|
||||||
|
|
||||||
const pages = [
|
const pages = [
|
||||||
{ icon: LayoutDashboard, title: "Dashboard", path: "/", exact: true },
|
{ icon: LayoutDashboard, title: "Dashboard", path: "/", exact: true },
|
||||||
@ -22,6 +28,7 @@ const pages = [
|
|||||||
|
|
||||||
const Sidebar = () => {
|
const Sidebar = () => {
|
||||||
const { pathname } = useLocation();
|
const { pathname } = useLocation();
|
||||||
|
const auth = useAuth();
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<aside className="bg-base-100 border-r border-base-300/30 w-[80%] md:w-[250px] flex flex-col items-stretch overflow-hidden h-full">
|
<aside className="bg-base-100 border-r border-base-300/30 w-[80%] md:w-[250px] flex flex-col items-stretch overflow-hidden h-full">
|
||||||
@ -57,23 +64,48 @@ const Sidebar = () => {
|
|||||||
})}
|
})}
|
||||||
</Menu>
|
</Menu>
|
||||||
|
|
||||||
<Dropdown className="my-2 mx-4" vertical="top">
|
<div className="py-2 px-4 flex items-center gap-2">
|
||||||
<Dropdown.Toggle button={false}>
|
<Dropdown vertical="top">
|
||||||
<Button icon={Palette} color="ghost">
|
<Dropdown.Toggle button={false}>
|
||||||
Theme
|
<Button icon={Palette} color="ghost">
|
||||||
</Button>
|
{!auth.isEnabled ? "Theme" : null}
|
||||||
</Dropdown.Toggle>
|
</Button>
|
||||||
|
</Dropdown.Toggle>
|
||||||
|
|
||||||
<Dropdown.Menu className="max-h-[200px] overflow-y-auto">
|
<Dropdown.Menu className="max-h-[500px] overflow-y-auto">
|
||||||
{themes.map((theme) => (
|
{themes.map((theme) => (
|
||||||
<Dropdown.Item key={theme} onClick={() => appStore.setTheme(theme)}>
|
<Dropdown.Item
|
||||||
{ucfirst(theme)}
|
key={theme}
|
||||||
</Dropdown.Item>
|
onClick={() => appStore.setTheme(theme)}
|
||||||
))}
|
>
|
||||||
</Dropdown.Menu>
|
{ucfirst(theme)}
|
||||||
</Dropdown>
|
</Dropdown.Item>
|
||||||
|
))}
|
||||||
|
</Dropdown.Menu>
|
||||||
|
</Dropdown>
|
||||||
|
|
||||||
|
{auth.isEnabled ? <LogoutButton /> : null}
|
||||||
|
</div>
|
||||||
</aside>
|
</aside>
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const LogoutButton = () => {
|
||||||
|
const logout = useMutation({
|
||||||
|
mutationFn: () => api.post("/auth/logout"),
|
||||||
|
onSuccess: () => {
|
||||||
|
window.location.href = utils.url("/auth/login");
|
||||||
|
},
|
||||||
|
onError: (err) => {
|
||||||
|
toast.error(err?.message || "Unknown error");
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Button className="flex-1" icon={LogOut} onClick={() => logout.mutate()}>
|
||||||
|
Logout
|
||||||
|
</Button>
|
||||||
|
);
|
||||||
|
};
|
||||||
|
|
||||||
export default Sidebar;
|
export default Sidebar;
|
||||||
|
@ -1,5 +1,22 @@
|
|||||||
|
import { useAuth } from "@/hooks/useAuth";
|
||||||
|
import { Navigate, Outlet } from "react-router-dom";
|
||||||
|
|
||||||
const AuthLayout = () => {
|
const AuthLayout = () => {
|
||||||
return <div>AuthLayout</div>;
|
const auth = useAuth();
|
||||||
|
|
||||||
|
if (auth.isLoading) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (auth.isAuthenticated) {
|
||||||
|
return <Navigate to="/" replace />;
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className="min-h-svh flex items-center justify-center">
|
||||||
|
<Outlet />
|
||||||
|
</div>
|
||||||
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
export default AuthLayout;
|
export default AuthLayout;
|
||||||
|
@ -1,15 +1,17 @@
|
|||||||
import { PageContext } from "@/context/page-context";
|
import { PageContext } from "@/context/page-context";
|
||||||
import { Suspense, useContext, useEffect } from "react";
|
import { Suspense, useContext, useEffect } from "react";
|
||||||
import { Outlet, useLocation, useNavigate } from "react-router-dom";
|
import { Navigate, Outlet, useLocation, useNavigate } from "react-router-dom";
|
||||||
import Sidebar from "../containers/sidebar";
|
import Sidebar from "../containers/sidebar";
|
||||||
import { ArrowLeft, MenuIcon } from "lucide-react";
|
import { ArrowLeft, MenuIcon } from "lucide-react";
|
||||||
import Button from "../ui/button";
|
import Button from "../ui/button";
|
||||||
import { useDisclosure } from "@/hooks/useDisclosure";
|
import { useDisclosure } from "@/hooks/useDisclosure";
|
||||||
import { Drawer } from "react-daisyui";
|
import { Drawer } from "react-daisyui";
|
||||||
|
import { useAuth } from "@/hooks/useAuth";
|
||||||
|
|
||||||
const MainLayout = () => {
|
const MainLayout = () => {
|
||||||
const sidebar = useDisclosure();
|
const sidebar = useDisclosure();
|
||||||
const { pathname } = useLocation();
|
const { pathname } = useLocation();
|
||||||
|
const auth = useAuth();
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (sidebar.isOpen) {
|
if (sidebar.isOpen) {
|
||||||
@ -17,6 +19,14 @@ const MainLayout = () => {
|
|||||||
}
|
}
|
||||||
}, [pathname]);
|
}, [pathname]);
|
||||||
|
|
||||||
|
if (auth.isLoading) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!auth.isAuthenticated) {
|
||||||
|
return <Navigate to="/auth/login" />;
|
||||||
|
}
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<Drawer
|
<Drawer
|
||||||
open={sidebar.isOpen}
|
open={sidebar.isOpen}
|
||||||
|
@ -4,6 +4,7 @@ import { Button as BaseButton } from "react-daisyui";
|
|||||||
import { Link } from "react-router-dom";
|
import { Link } from "react-router-dom";
|
||||||
|
|
||||||
type ButtonProps = ComponentPropsWithoutRef<typeof BaseButton> & {
|
type ButtonProps = ComponentPropsWithoutRef<typeof BaseButton> & {
|
||||||
|
type?: HTMLButtonElement["type"];
|
||||||
href?: string;
|
href?: string;
|
||||||
target?: "_blank" | "_self" | "_parent" | "_top";
|
target?: "_blank" | "_self" | "_parent" | "_top";
|
||||||
icon?: LucideIcon;
|
icon?: LucideIcon;
|
||||||
|
7
src/global.d.ts
vendored
Normal file
7
src/global.d.ts
vendored
Normal file
@ -0,0 +1,7 @@
|
|||||||
|
export {};
|
||||||
|
|
||||||
|
declare global {
|
||||||
|
interface Window {
|
||||||
|
__BASE_PATH?: string;
|
||||||
|
}
|
||||||
|
}
|
20
src/hooks/useAuth.ts
Normal file
20
src/hooks/useAuth.ts
Normal file
@ -0,0 +1,20 @@
|
|||||||
|
import api from "@/lib/api";
|
||||||
|
import { useQuery } from "@tanstack/react-query";
|
||||||
|
|
||||||
|
type AuthResponse = {
|
||||||
|
enabled: boolean;
|
||||||
|
authenticated: boolean;
|
||||||
|
};
|
||||||
|
|
||||||
|
export const useAuth = () => {
|
||||||
|
const { data, isLoading } = useQuery({
|
||||||
|
queryKey: ["auth"],
|
||||||
|
queryFn: () => api.get<AuthResponse>("/auth/status"),
|
||||||
|
retry: false,
|
||||||
|
});
|
||||||
|
return {
|
||||||
|
isLoading,
|
||||||
|
isEnabled: data?.enabled,
|
||||||
|
isAuthenticated: data?.authenticated,
|
||||||
|
};
|
||||||
|
};
|
@ -1,10 +1,23 @@
|
|||||||
|
import * as utils from "@/lib/utils";
|
||||||
|
import { BASE_PATH } from "./consts";
|
||||||
|
|
||||||
type FetchOptions = Omit<RequestInit, "headers" | "body"> & {
|
type FetchOptions = Omit<RequestInit, "headers" | "body"> & {
|
||||||
params?: Record<string, any>;
|
params?: Record<string, any>;
|
||||||
headers?: Record<string, string>;
|
headers?: Record<string, string>;
|
||||||
body?: any;
|
body?: any;
|
||||||
};
|
};
|
||||||
|
|
||||||
export const API_URL = "/api";
|
export const API_URL = BASE_PATH + "/api";
|
||||||
|
|
||||||
|
export class APIError extends Error {
|
||||||
|
status!: number;
|
||||||
|
|
||||||
|
constructor(message: string, status: number = 400) {
|
||||||
|
super(message);
|
||||||
|
this.name = "APIError";
|
||||||
|
this.status = status;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
const api = {
|
const api = {
|
||||||
async fetch<T = any>(url: string, options?: Partial<FetchOptions>) {
|
async fetch<T = any>(url: string, options?: Partial<FetchOptions>) {
|
||||||
@ -27,6 +40,7 @@ const api = {
|
|||||||
|
|
||||||
const res = await fetch(_url, {
|
const res = await fetch(_url, {
|
||||||
...options,
|
...options,
|
||||||
|
credentials: "include",
|
||||||
headers: { ...headers, ...(options?.headers || {}) },
|
headers: { ...headers, ...(options?.headers || {}) },
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -35,13 +49,18 @@ const api = {
|
|||||||
?.includes("application/json");
|
?.includes("application/json");
|
||||||
const data = isJson ? await res.json() : await res.text();
|
const data = isJson ? await res.json() : await res.text();
|
||||||
|
|
||||||
|
if (res.status === 401 && !url.startsWith("/auth")) {
|
||||||
|
window.location.href = utils.url("/auth/login");
|
||||||
|
throw new APIError("unauthorized", res.status);
|
||||||
|
}
|
||||||
|
|
||||||
if (!res.ok) {
|
if (!res.ok) {
|
||||||
const message = isJson
|
const message = isJson
|
||||||
? data?.message
|
? data?.message
|
||||||
: typeof data === "string"
|
: typeof data === "string"
|
||||||
? data
|
? data
|
||||||
: res.statusText;
|
: res.statusText;
|
||||||
throw new Error(message);
|
throw new APIError(message, res.status);
|
||||||
}
|
}
|
||||||
|
|
||||||
return data as unknown as T;
|
return data as unknown as T;
|
||||||
|
6
src/lib/consts.ts
Normal file
6
src/lib/consts.ts
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
// consts.ts
|
||||||
|
|
||||||
|
export const BASE_PATH =
|
||||||
|
(import.meta.env.PROD ? window.__BASE_PATH : null) ||
|
||||||
|
import.meta.env.VITE_BASE_PATH ||
|
||||||
|
"";
|
@ -3,6 +3,7 @@ import { toast } from "sonner";
|
|||||||
import { twMerge } from "tailwind-merge";
|
import { twMerge } from "tailwind-merge";
|
||||||
import dayjsRelativeTime from "dayjs/plugin/relativeTime";
|
import dayjsRelativeTime from "dayjs/plugin/relativeTime";
|
||||||
import dayjs from "dayjs";
|
import dayjs from "dayjs";
|
||||||
|
import { BASE_PATH } from "./consts";
|
||||||
|
|
||||||
dayjs.extend(dayjsRelativeTime);
|
dayjs.extend(dayjsRelativeTime);
|
||||||
export { dayjs };
|
export { dayjs };
|
||||||
@ -53,3 +54,7 @@ export const copyToClipboard = async (text: string) => {
|
|||||||
textArea?.remove();
|
textArea?.remove();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const url = (...paths: unknown[]) => {
|
||||||
|
return BASE_PATH + paths.join("/");
|
||||||
|
};
|
||||||
|
21
src/pages/auth/hooks.ts
Normal file
21
src/pages/auth/hooks.ts
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
import { useMutation, useQueryClient } from "@tanstack/react-query";
|
||||||
|
import { z } from "zod";
|
||||||
|
import { loginSchema } from "./schema";
|
||||||
|
import api from "@/lib/api";
|
||||||
|
import { toast } from "sonner";
|
||||||
|
|
||||||
|
export const useLogin = () => {
|
||||||
|
const queryClient = useQueryClient();
|
||||||
|
|
||||||
|
return useMutation({
|
||||||
|
mutationFn: async (body: z.infer<typeof loginSchema>) => {
|
||||||
|
return api.post("/auth/login", { body });
|
||||||
|
},
|
||||||
|
onSuccess: () => {
|
||||||
|
queryClient.invalidateQueries({ queryKey: ["auth"] });
|
||||||
|
},
|
||||||
|
onError: (err) => {
|
||||||
|
toast.error(err?.message || "Unknown error");
|
||||||
|
},
|
||||||
|
});
|
||||||
|
};
|
54
src/pages/auth/login.tsx
Normal file
54
src/pages/auth/login.tsx
Normal file
@ -0,0 +1,54 @@
|
|||||||
|
import Button from "@/components/ui/button";
|
||||||
|
import { zodResolver } from "@hookform/resolvers/zod";
|
||||||
|
import { Card } from "react-daisyui";
|
||||||
|
import { useForm } from "react-hook-form";
|
||||||
|
import { loginSchema } from "./schema";
|
||||||
|
import { InputField } from "@/components/ui/input";
|
||||||
|
import { useLogin } from "./hooks";
|
||||||
|
|
||||||
|
export default function LoginPage() {
|
||||||
|
const form = useForm({
|
||||||
|
resolver: zodResolver(loginSchema),
|
||||||
|
defaultValues: { username: "", password: "" },
|
||||||
|
});
|
||||||
|
const login = useLogin();
|
||||||
|
|
||||||
|
return (
|
||||||
|
<form onSubmit={form.handleSubmit((v) => login.mutate(v))}>
|
||||||
|
<Card className="w-full max-w-md" bordered>
|
||||||
|
<Card.Body>
|
||||||
|
<Card.Title tag="h2">Login</Card.Title>
|
||||||
|
<p className="text-base-content/60">
|
||||||
|
Enter username and password below to log in to your account
|
||||||
|
</p>
|
||||||
|
|
||||||
|
<InputField
|
||||||
|
form={form}
|
||||||
|
name="username"
|
||||||
|
title="Username"
|
||||||
|
placeholder="Enter your username"
|
||||||
|
/>
|
||||||
|
|
||||||
|
<InputField
|
||||||
|
form={form}
|
||||||
|
name="password"
|
||||||
|
title="Password"
|
||||||
|
type="password"
|
||||||
|
placeholder="Enter your password"
|
||||||
|
/>
|
||||||
|
|
||||||
|
<Card.Actions className="mt-4">
|
||||||
|
<Button
|
||||||
|
type="submit"
|
||||||
|
color="primary"
|
||||||
|
className="w-full md:w-auto min-w-[100px]"
|
||||||
|
loading={login.isPending}
|
||||||
|
>
|
||||||
|
Login
|
||||||
|
</Button>
|
||||||
|
</Card.Actions>
|
||||||
|
</Card.Body>
|
||||||
|
</Card>
|
||||||
|
</form>
|
||||||
|
);
|
||||||
|
}
|
6
src/pages/auth/schema.ts
Normal file
6
src/pages/auth/schema.ts
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
import { z } from "zod";
|
||||||
|
|
||||||
|
export const loginSchema = z.object({
|
||||||
|
username: z.string().min(1, "Username is required"),
|
||||||
|
password: z.string().min(1, "Password is required"),
|
||||||
|
});
|
@ -18,7 +18,7 @@ export const useCreateBucket = (
|
|||||||
options?: UseMutationOptions<any, Error, CreateBucketSchema>
|
options?: UseMutationOptions<any, Error, CreateBucketSchema>
|
||||||
) => {
|
) => {
|
||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: (body) => api.post("/v1/bucket", { body }),
|
mutationFn: (body) => api.post("/v2/CreateBucket", { body }),
|
||||||
...options,
|
...options,
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
@ -10,7 +10,7 @@ import { Bucket, Permissions } from "../types";
|
|||||||
export const useBucket = (id?: string | null) => {
|
export const useBucket = (id?: string | null) => {
|
||||||
return useQuery({
|
return useQuery({
|
||||||
queryKey: ["bucket", id],
|
queryKey: ["bucket", id],
|
||||||
queryFn: () => api.get<Bucket>("/v1/bucket", { params: { id } }),
|
queryFn: () => api.get<Bucket>("/v2/GetBucketInfo", { params: { id } }),
|
||||||
enabled: !!id,
|
enabled: !!id,
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
@ -18,7 +18,10 @@ export const useBucket = (id?: string | null) => {
|
|||||||
export const useUpdateBucket = (id?: string | null) => {
|
export const useUpdateBucket = (id?: string | null) => {
|
||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: (values: any) => {
|
mutationFn: (values: any) => {
|
||||||
return api.put<any>("/v1/bucket", { params: { id }, body: values });
|
return api.post<any>("/v2/UpdateBucket", {
|
||||||
|
params: { id },
|
||||||
|
body: values,
|
||||||
|
});
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
@ -29,8 +32,8 @@ export const useAddAlias = (
|
|||||||
) => {
|
) => {
|
||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: (alias: string) => {
|
mutationFn: (alias: string) => {
|
||||||
return api.put("/v1/bucket/alias/global", {
|
return api.post("/v2/AddBucketAlias", {
|
||||||
params: { id: bucketId, alias },
|
body: { bucketId, globalAlias: alias },
|
||||||
});
|
});
|
||||||
},
|
},
|
||||||
...options,
|
...options,
|
||||||
@ -43,8 +46,8 @@ export const useRemoveAlias = (
|
|||||||
) => {
|
) => {
|
||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: (alias: string) => {
|
mutationFn: (alias: string) => {
|
||||||
return api.delete("/v1/bucket/alias/global", {
|
return api.post("/v2/RemoveBucketAlias", {
|
||||||
params: { id: bucketId, alias },
|
body: { bucketId, globalAlias: alias },
|
||||||
});
|
});
|
||||||
},
|
},
|
||||||
...options,
|
...options,
|
||||||
@ -62,8 +65,7 @@ export const useAllowKey = (
|
|||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: async (payload) => {
|
mutationFn: async (payload) => {
|
||||||
const promises = payload.map(async (key) => {
|
const promises = payload.map(async (key) => {
|
||||||
console.log("test", key);
|
return api.post("/v2/AllowBucketKey", {
|
||||||
return api.post("/v1/bucket/allow", {
|
|
||||||
body: {
|
body: {
|
||||||
bucketId,
|
bucketId,
|
||||||
accessKeyId: key.keyId,
|
accessKeyId: key.keyId,
|
||||||
@ -88,7 +90,7 @@ export const useDenyKey = (
|
|||||||
) => {
|
) => {
|
||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: (payload) => {
|
mutationFn: (payload) => {
|
||||||
return api.post("/v1/bucket/deny", {
|
return api.post("/v2/DenyBucketKey", {
|
||||||
body: {
|
body: {
|
||||||
bucketId,
|
bucketId,
|
||||||
accessKeyId: payload.keyId,
|
accessKeyId: payload.keyId,
|
||||||
@ -104,7 +106,7 @@ export const useRemoveBucket = (
|
|||||||
options?: MutationOptions<any, Error, string>
|
options?: MutationOptions<any, Error, string>
|
||||||
) => {
|
) => {
|
||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: (id) => api.delete("/v1/bucket", { params: { id } }),
|
mutationFn: (id) => api.post("/v2/DeleteBucket", { params: { id } }),
|
||||||
...options,
|
...options,
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
@ -66,7 +66,8 @@ const AssignNodeDialog = () => {
|
|||||||
}, [data]);
|
}, [data]);
|
||||||
|
|
||||||
const zoneList = useMemo(() => {
|
const zoneList = useMemo(() => {
|
||||||
const list = cluster?.nodes
|
const nodes = cluster?.nodes || cluster?.knownNodes || [];
|
||||||
|
const list = nodes
|
||||||
.flatMap((i) => {
|
.flatMap((i) => {
|
||||||
const role = layout?.roles.find((role) => role.id === i.id);
|
const role = layout?.roles.find((role) => role.id === i.id);
|
||||||
const staged = layout?.stagedRoleChanges.find(
|
const staged = layout?.stagedRoleChanges.find(
|
||||||
@ -83,7 +84,8 @@ const AssignNodeDialog = () => {
|
|||||||
}, [cluster, layout]);
|
}, [cluster, layout]);
|
||||||
|
|
||||||
const tagsList = useMemo(() => {
|
const tagsList = useMemo(() => {
|
||||||
const list = cluster?.nodes
|
const nodes = cluster?.nodes || cluster?.knownNodes || [];
|
||||||
|
const list = nodes
|
||||||
.flatMap((i) => {
|
.flatMap((i) => {
|
||||||
const role = layout?.roles.find((role) => role.id === i.id);
|
const role = layout?.roles.find((role) => role.id === i.id);
|
||||||
const staged = layout?.stagedRoleChanges.find(
|
const staged = layout?.stagedRoleChanges.find(
|
||||||
|
@ -268,7 +268,9 @@ const NodesList = ({ nodes }: NodeListProps) => {
|
|||||||
|
|
||||||
<Dropdown
|
<Dropdown
|
||||||
end
|
end
|
||||||
vertical={idx >= items.length - 2 ? "top" : "bottom"}
|
vertical={
|
||||||
|
idx > 2 && idx >= items.length - 2 ? "top" : "bottom"
|
||||||
|
}
|
||||||
>
|
>
|
||||||
<Dropdown.Toggle button={false}>
|
<Dropdown.Toggle button={false}>
|
||||||
<Button shape="circle" color="ghost">
|
<Button shape="circle" color="ghost">
|
||||||
|
@ -3,6 +3,7 @@ import {
|
|||||||
ApplyLayoutResult,
|
ApplyLayoutResult,
|
||||||
AssignNodeBody,
|
AssignNodeBody,
|
||||||
GetClusterLayoutResult,
|
GetClusterLayoutResult,
|
||||||
|
GetNodeInfoResult,
|
||||||
GetStatusResult,
|
GetStatusResult,
|
||||||
} from "./types";
|
} from "./types";
|
||||||
import {
|
import {
|
||||||
@ -11,24 +12,37 @@ import {
|
|||||||
useQuery,
|
useQuery,
|
||||||
} from "@tanstack/react-query";
|
} from "@tanstack/react-query";
|
||||||
|
|
||||||
|
export const useNodeInfo = () => {
|
||||||
|
return useQuery({
|
||||||
|
queryKey: ["node-info"],
|
||||||
|
queryFn: () =>
|
||||||
|
api.get<GetNodeInfoResult>("/v2/GetNodeInfo", {
|
||||||
|
params: { node: "self" },
|
||||||
|
}),
|
||||||
|
select: (data) => Object.values(data?.success || {})?.[0],
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
export const useClusterStatus = () => {
|
export const useClusterStatus = () => {
|
||||||
return useQuery({
|
return useQuery({
|
||||||
queryKey: ["status"],
|
queryKey: ["status"],
|
||||||
queryFn: () => api.get<GetStatusResult>("/v1/status"),
|
queryFn: () => api.get<GetStatusResult>("/v2/GetClusterStatus"),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
export const useClusterLayout = () => {
|
export const useClusterLayout = () => {
|
||||||
return useQuery({
|
return useQuery({
|
||||||
queryKey: ["layout"],
|
queryKey: ["layout"],
|
||||||
queryFn: () => api.get<GetClusterLayoutResult>("/v1/layout"),
|
queryFn: () => api.get<GetClusterLayoutResult>("/v2/GetClusterLayout"),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
export const useConnectNode = (options?: Partial<UseMutationOptions>) => {
|
export const useConnectNode = (options?: Partial<UseMutationOptions>) => {
|
||||||
return useMutation<any, Error, string>({
|
return useMutation<any, Error, string>({
|
||||||
mutationFn: async (nodeId) => {
|
mutationFn: async (nodeId) => {
|
||||||
const [res] = await api.post("/v1/connect", { body: [nodeId] });
|
const [res] = await api.post("/v2/ConnectClusterNodes", {
|
||||||
|
body: [nodeId],
|
||||||
|
});
|
||||||
if (!res.success) {
|
if (!res.success) {
|
||||||
throw new Error(res.error || "Unknown error");
|
throw new Error(res.error || "Unknown error");
|
||||||
}
|
}
|
||||||
@ -40,7 +54,10 @@ export const useConnectNode = (options?: Partial<UseMutationOptions>) => {
|
|||||||
|
|
||||||
export const useAssignNode = (options?: Partial<UseMutationOptions>) => {
|
export const useAssignNode = (options?: Partial<UseMutationOptions>) => {
|
||||||
return useMutation<any, Error, AssignNodeBody>({
|
return useMutation<any, Error, AssignNodeBody>({
|
||||||
mutationFn: (data) => api.post("/v1/layout", { body: [data] }),
|
mutationFn: (data) =>
|
||||||
|
api.post("/v2/UpdateClusterLayout", {
|
||||||
|
body: { parameters: null, roles: [data] },
|
||||||
|
}),
|
||||||
...(options as any),
|
...(options as any),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
@ -48,15 +65,16 @@ export const useAssignNode = (options?: Partial<UseMutationOptions>) => {
|
|||||||
export const useUnassignNode = (options?: Partial<UseMutationOptions>) => {
|
export const useUnassignNode = (options?: Partial<UseMutationOptions>) => {
|
||||||
return useMutation<any, Error, string>({
|
return useMutation<any, Error, string>({
|
||||||
mutationFn: (nodeId) =>
|
mutationFn: (nodeId) =>
|
||||||
api.post("/v1/layout", { body: [{ id: nodeId, remove: true }] }),
|
api.post("/v2/UpdateClusterLayout", {
|
||||||
|
body: { parameters: null, roles: [{ id: nodeId, remove: true }] },
|
||||||
|
}),
|
||||||
...(options as any),
|
...(options as any),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
export const useRevertChanges = (options?: Partial<UseMutationOptions>) => {
|
export const useRevertChanges = (options?: Partial<UseMutationOptions>) => {
|
||||||
return useMutation<any, Error, number>({
|
return useMutation<any, Error, number>({
|
||||||
mutationFn: (version) =>
|
mutationFn: () => api.post("/v2/RevertClusterLayout"),
|
||||||
api.post("/v1/layout/revert", { body: { version } }),
|
|
||||||
...(options as any),
|
...(options as any),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
@ -64,7 +82,7 @@ export const useRevertChanges = (options?: Partial<UseMutationOptions>) => {
|
|||||||
export const useApplyChanges = (options?: Partial<UseMutationOptions>) => {
|
export const useApplyChanges = (options?: Partial<UseMutationOptions>) => {
|
||||||
return useMutation<ApplyLayoutResult, Error, number>({
|
return useMutation<ApplyLayoutResult, Error, number>({
|
||||||
mutationFn: (version) =>
|
mutationFn: (version) =>
|
||||||
api.post("/v1/layout/apply", { body: { version } }),
|
api.post("/v2/ApplyClusterLayout", { body: { version } }),
|
||||||
...(options as any),
|
...(options as any),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
@ -1,10 +1,25 @@
|
|||||||
import Page from "@/context/page-context";
|
import Page from "@/context/page-context";
|
||||||
import { useClusterStatus } from "./hooks";
|
import { useClusterStatus, useNodeInfo } from "./hooks";
|
||||||
import { Card } from "react-daisyui";
|
import { Card } from "react-daisyui";
|
||||||
import NodesList from "./components/nodes-list";
|
import NodesList from "./components/nodes-list";
|
||||||
|
import { useMemo } from "react";
|
||||||
|
|
||||||
const ClusterPage = () => {
|
const ClusterPage = () => {
|
||||||
const { data } = useClusterStatus();
|
const { data } = useClusterStatus();
|
||||||
|
const { data: node } = useNodeInfo();
|
||||||
|
|
||||||
|
const nodes = useMemo(() => {
|
||||||
|
if (!data) return [];
|
||||||
|
|
||||||
|
if (Array.isArray(data.knownNodes)) {
|
||||||
|
return data.knownNodes.map((node) => ({
|
||||||
|
...node,
|
||||||
|
role: data.layout?.roles.find((role) => role.id === node.id),
|
||||||
|
}));
|
||||||
|
}
|
||||||
|
|
||||||
|
return data.nodes || [];
|
||||||
|
}, [data]);
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="container">
|
<div className="container">
|
||||||
@ -14,11 +29,14 @@ const ClusterPage = () => {
|
|||||||
<Card.Body className="gap-1">
|
<Card.Body className="gap-1">
|
||||||
<Card.Title className="mb-2">Details</Card.Title>
|
<Card.Title className="mb-2">Details</Card.Title>
|
||||||
|
|
||||||
<DetailItem title="Node ID" value={data?.node} />
|
{/* <DetailItem title="Node ID" value={node?.nodeId} /> */}
|
||||||
<DetailItem title="Version" value={data?.garageVersion} />
|
<DetailItem title="Garage Version" value={node?.garageVersion} />
|
||||||
{/* <DetailItem title="Rust version" value={data?.rustVersion} /> */}
|
{/* <DetailItem title="Rust version" value={data?.rustVersion} /> */}
|
||||||
<DetailItem title="DB engine" value={data?.dbEngine} />
|
<DetailItem title="DB engine" value={node?.dbEngine} />
|
||||||
<DetailItem title="Layout version" value={data?.layoutVersion} />
|
<DetailItem
|
||||||
|
title="Layout version"
|
||||||
|
value={data?.layoutVersion || data?.layout?.version || "-"}
|
||||||
|
/>
|
||||||
</Card.Body>
|
</Card.Body>
|
||||||
</Card>
|
</Card>
|
||||||
|
|
||||||
@ -26,7 +44,7 @@ const ClusterPage = () => {
|
|||||||
<Card.Body>
|
<Card.Body>
|
||||||
<Card.Title>Nodes</Card.Title>
|
<Card.Title>Nodes</Card.Title>
|
||||||
|
|
||||||
<NodesList nodes={data?.nodes || []} />
|
<NodesList nodes={nodes} />
|
||||||
</Card.Body>
|
</Card.Body>
|
||||||
</Card>
|
</Card>
|
||||||
</div>
|
</div>
|
||||||
|
@ -1,5 +1,19 @@
|
|||||||
//
|
//
|
||||||
|
|
||||||
|
export type GetNodeInfoResult = {
|
||||||
|
success: {
|
||||||
|
[key: string]: {
|
||||||
|
nodeId: string;
|
||||||
|
garageVersion: string;
|
||||||
|
garageFeatures: string[];
|
||||||
|
rustVersion: string;
|
||||||
|
dbEngine: string;
|
||||||
|
};
|
||||||
|
};
|
||||||
|
error: Error;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
export type GetStatusResult = {
|
export type GetStatusResult = {
|
||||||
node: string;
|
node: string;
|
||||||
garageVersion: string;
|
garageVersion: string;
|
||||||
@ -7,7 +21,9 @@ export type GetStatusResult = {
|
|||||||
rustVersion: string;
|
rustVersion: string;
|
||||||
dbEngine: string;
|
dbEngine: string;
|
||||||
layoutVersion: number;
|
layoutVersion: number;
|
||||||
nodes: Node[];
|
nodes?: Node[];
|
||||||
|
knownNodes?: Node[];
|
||||||
|
layout?: GetClusterLayoutResult;
|
||||||
};
|
};
|
||||||
|
|
||||||
export type Node = {
|
export type Node = {
|
||||||
@ -17,9 +33,9 @@ export type Node = {
|
|||||||
hostname: string;
|
hostname: string;
|
||||||
isUp: boolean;
|
isUp: boolean;
|
||||||
lastSeenSecsAgo: number | null;
|
lastSeenSecsAgo: number | null;
|
||||||
draining: boolean;
|
draining?: boolean;
|
||||||
dataPartition: DataPartition;
|
dataPartition?: DataPartition;
|
||||||
metadataPartition: DataPartition;
|
metadataPartition?: DataPartition;
|
||||||
};
|
};
|
||||||
|
|
||||||
export type DataPartition = {
|
export type DataPartition = {
|
||||||
|
@ -5,6 +5,6 @@ import { useQuery } from "@tanstack/react-query";
|
|||||||
export const useNodesHealth = () => {
|
export const useNodesHealth = () => {
|
||||||
return useQuery({
|
return useQuery({
|
||||||
queryKey: ["health"],
|
queryKey: ["health"],
|
||||||
queryFn: () => api.get<GetHealthResult>("/v1/health"),
|
queryFn: () => api.get<GetHealthResult>("/v2/GetClusterHealth"),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
@ -10,7 +10,7 @@ import { CreateKeySchema } from "./schema";
|
|||||||
export const useKeys = () => {
|
export const useKeys = () => {
|
||||||
return useQuery({
|
return useQuery({
|
||||||
queryKey: ["keys"],
|
queryKey: ["keys"],
|
||||||
queryFn: () => api.get<Key[]>("/v1/key?list"),
|
queryFn: () => api.get<Key[]>("/v2/ListKeys"),
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
@ -20,9 +20,9 @@ export const useCreateKey = (
|
|||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: async (body) => {
|
mutationFn: async (body) => {
|
||||||
if (body.isImport) {
|
if (body.isImport) {
|
||||||
return api.post("/v1/key/import", { body });
|
return api.post("/v2/ImportKey", { body });
|
||||||
}
|
}
|
||||||
return api.post("/v1/key", { body });
|
return api.post("/v2/CreateKey", { body });
|
||||||
},
|
},
|
||||||
...options,
|
...options,
|
||||||
});
|
});
|
||||||
@ -32,7 +32,7 @@ export const useRemoveKey = (
|
|||||||
options?: UseMutationOptions<any, Error, string>
|
options?: UseMutationOptions<any, Error, string>
|
||||||
) => {
|
) => {
|
||||||
return useMutation({
|
return useMutation({
|
||||||
mutationFn: (id) => api.delete("/v1/key", { params: { id } }),
|
mutationFn: (id) => api.post("/v2/DeleteKey", { params: { id } }),
|
||||||
...options,
|
...options,
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
@ -24,7 +24,7 @@ const KeysPage = () => {
|
|||||||
|
|
||||||
const fetchSecretKey = useCallback(async (id: string) => {
|
const fetchSecretKey = useCallback(async (id: string) => {
|
||||||
try {
|
try {
|
||||||
const result = await api.get("/v1/key", {
|
const result = await api.get("/v2/GetKeyInfo", {
|
||||||
params: { id, showSecretKey: "true" },
|
params: { id, showSecretKey: "true" },
|
||||||
});
|
});
|
||||||
if (!result?.secretAccessKey) {
|
if (!result?.secretAccessKey) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user