Compare commits

..

No commits in common. "main" and "1.0.3" have entirely different histories.
main ... 1.0.3

48 changed files with 186 additions and 812 deletions

View File

@ -1,7 +1,9 @@
FROM node:20-slim AS frontend FROM node:20-slim AS frontend
WORKDIR /app WORKDIR /app
RUN npm install -g corepack@latest && corepack use pnpm@latest ENV PNPM_HOME="/pnpm"
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
@ -9,7 +11,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.23 AS backend FROM golang:1.22.5 AS backend
WORKDIR /app WORKDIR /app
COPY backend/go.mod backend/go.sum ./ COPY backend/go.mod backend/go.sum ./

View File

@ -31,18 +31,14 @@ 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:v1.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
ports: network_mode: host
- 3900:3900
- 3901:3901
- 3902:3902
- 3903:3903
webui: webui:
image: khairul169/garage-webui:latest image: khairul169/garage-webui:latest
@ -52,9 +48,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"
``` ```
### Without Docker ### Without Docker
@ -62,7 +55,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.9/garage-webui-v1.0.9-linux-amd64 $ wget -O garage-webui https://github.com/khairul169/garage-webui/releases/download/1.0.2/garage-webui-v1.0.2-linux-amd64
$ chmod +x garage-webui $ chmod +x garage-webui
$ sudo cp garage-webui /usr/local/bin $ sudo cp garage-webui /usr/local/bin
``` ```
@ -136,39 +129,11 @@ 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 `API_BASE_URL` & `API_ADMIN_KEY` environment variables instead. However, if it fails to load, you can set these 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_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

View File

@ -1,6 +0,0 @@
#
BASE_PATH=""
AUTH_USER_PASS='username:$2y$10$DSTi9o0uQPEHSNlf66xMEOgm9KgVNBP3vHxA3SK0Xha2EVMb3mTXm'
API_BASE_URL="http://garage:3903"
S3_ENDPOINT_URL="http://garage:3900"
API_ADMIN_KEY=""

View File

@ -1,8 +1,6 @@
module khairul169/garage-webui module khairul169/garage-webui
go 1.23.0 go 1.22.5
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
@ -10,12 +8,10 @@ require (
github.com/aws/aws-sdk-go-v2/service/s3 v1.59.0 github.com/aws/aws-sdk-go-v2/service/s3 v1.59.0
github.com/aws/smithy-go v1.20.4 github.com/aws/smithy-go v1.20.4
github.com/joho/godotenv v1.5.1 github.com/joho/godotenv v1.5.1
github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646
github.com/pelletier/go-toml/v2 v2.2.2 github.com/pelletier/go-toml/v2 v2.2.2
) )
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
@ -24,5 +20,4 @@ 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
) )

View File

@ -1,5 +1,3 @@
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=
@ -29,8 +27,6 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0= github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4= github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 h1:zYyBkD/k9seD2A7fsi6Oo2LfFZAehjjQMERAvZLEDnQ=
github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646/go.mod h1:jpp1/29i3P1S/RLdc7JQKbRpFeM1dOBd8T9ki5s+AY8=
github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM= github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs= github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
@ -44,8 +40,6 @@ 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=

View File

@ -7,35 +7,20 @@ 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.Fatal("Failed to load config! ", err)
} }
basePath := os.Getenv("BASE_PATH") http.Handle("/api/", http.StripPrefix("/api", router.HandleApiRouter()))
mux := http.NewServeMux() ui.ServeUI()
// 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")
@ -43,7 +28,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, sessionMgr.LoadAndSave(mux)); err != nil { if err := http.ListenAndServe(addr, nil); err != nil {
log.Fatal(err) log.Fatal(err)
} }
} }

View File

@ -1,27 +0,0 @@
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)
})
}

View File

@ -1,64 +0,0 @@
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,
})
}

View File

@ -73,7 +73,8 @@ func (b *Browse) GetObjects(w http.ResponseWriter, r *http.Request) {
ObjectKey: &key, ObjectKey: &key,
LastModified: object.LastModified, LastModified: object.LastModified,
Size: object.Size, Size: object.Size,
Url: fmt.Sprintf("/browse/%s/%s", bucket, *object.Key), ViewUrl: fmt.Sprintf("/browse/%s/%s?view=1", bucket, *object.Key),
DownloadUrl: fmt.Sprintf("/browse/%s/%s?dl=1", bucket, *object.Key),
}) })
} }
@ -83,10 +84,8 @@ func (b *Browse) GetObjects(w http.ResponseWriter, r *http.Request) {
func (b *Browse) GetOneObject(w http.ResponseWriter, r *http.Request) { func (b *Browse) GetOneObject(w http.ResponseWriter, r *http.Request) {
bucket := r.PathValue("bucket") bucket := r.PathValue("bucket")
key := r.PathValue("key") key := r.PathValue("key")
queryParams := r.URL.Query() view := r.URL.Query().Get("view") == "1"
view := queryParams.Get("view") == "1" download := r.URL.Query().Get("dl") == "1"
thumbnail := queryParams.Get("thumb") == "1"
download := queryParams.Get("dl") == "1"
client, err := getS3Client(bucket) client, err := getS3Client(bucket)
if err != nil { if err != nil {
@ -94,18 +93,6 @@ func (b *Browse) GetOneObject(w http.ResponseWriter, r *http.Request) {
return return
} }
if !view && !download && !thumbnail {
object, err := client.HeadObject(context.Background(), &s3.HeadObjectInput{
Bucket: aws.String(bucket),
Key: aws.String(key),
})
if err != nil {
utils.ResponseError(w, err)
}
utils.ResponseSuccess(w, object)
return
}
object, err := client.GetObject(context.Background(), &s3.GetObjectInput{ object, err := client.GetObject(context.Background(), &s3.GetObjectInput{
Bucket: aws.String(bucket), Bucket: aws.String(bucket),
Key: aws.String(key), Key: aws.String(key),
@ -122,51 +109,31 @@ func (b *Browse) GetOneObject(w http.ResponseWriter, r *http.Request) {
return return
} }
defer object.Body.Close() if view || download {
keys := strings.Split(key, "/") defer object.Body.Close()
keys := strings.Split(key, "/")
if download {
w.Header().Set("Content-Disposition", fmt.Sprintf("attachment; filename=%s", keys[len(keys)-1]))
} else if thumbnail {
body, err := io.ReadAll(object.Body)
if err != nil {
utils.ResponseError(w, err)
return
}
thumb, err := utils.CreateThumbnailImage(body, 64, 64)
if err != nil {
utils.ResponseError(w, err)
return
}
w.Header().Set("Content-Type", "image/png")
w.Write(thumb)
return
}
w.Header().Set("Cache-Control", "max-age=86400")
w.Header().Set("Last-Modified", object.LastModified.Format(time.RFC1123))
if object.ContentType != nil {
w.Header().Set("Content-Type", *object.ContentType) 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)) w.Header().Set("Content-Length", strconv.FormatInt(*object.ContentLength, 10))
} w.Header().Set("Cache-Control", "max-age=86400")
if object.ETag != nil { w.Header().Set("Last-Modified", object.LastModified.Format(time.RFC1123))
w.Header().Set("Etag", *object.ETag) w.Header().Set("Etag", *object.ETag)
}
_, err = io.Copy(w, object.Body) if download {
w.Header().Set("Content-Disposition", fmt.Sprintf("attachment; filename=%s", keys[len(keys)-1]))
}
if err != nil { w.WriteHeader(http.StatusOK)
utils.ResponseError(w, err) _, err = io.Copy(w, object.Body)
if err != nil {
utils.ResponseError(w, err)
return
}
return return
} }
utils.ResponseSuccess(w, object)
} }
func (b *Browse) PutObject(w http.ResponseWriter, r *http.Request) { func (b *Browse) PutObject(w http.ResponseWriter, r *http.Request) {
@ -333,7 +300,7 @@ func getS3Client(bucket string) (*s3.Client, error) {
awsConfig := aws.Config{ awsConfig := aws.Config{
Credentials: creds, Credentials: creds,
Region: utils.Garage.GetS3Region(), Region: "garage",
BaseEndpoint: aws.String(utils.Garage.GetS3Endpoint()), BaseEndpoint: aws.String(utils.Garage.GetS3Endpoint()),
} }

View File

@ -34,14 +34,13 @@ func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) {
return return
} }
var data schema.Bucket var bucket schema.Bucket
if err := json.Unmarshal(body, &data); err != nil { if err := json.Unmarshal(body, &bucket); err != nil {
ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases} ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases}
return return
} }
data.LocalAliases = bucket.LocalAliases ch <- bucket
ch <- data
}() }()
} }

View File

@ -1,19 +1,9 @@
package router package router
import ( import "net/http"
"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)
@ -27,9 +17,7 @@ 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)
mux.Handle("/", middleware.AuthMiddleware(router)) return router
return mux
} }

View File

@ -13,5 +13,6 @@ type BrowserObject struct {
ObjectKey *string `json:"objectKey"` ObjectKey *string `json:"objectKey"`
LastModified *time.Time `json:"lastModified"` LastModified *time.Time `json:"lastModified"`
Size *int64 `json:"size"` Size *int64 `json:"size"`
Url string `json:"url"` ViewUrl string `json:"viewUrl"`
DownloadUrl string `json:"downloadUrl"`
} }

View File

@ -1,15 +1,14 @@
package schema package schema
type GetBucketsRes struct { type GetBucketsRes struct {
ID string `json:"id"` ID string `json:"id"`
GlobalAliases []string `json:"globalAliases"` GlobalAliases []string `json:"globalAliases"`
LocalAliases []LocalAlias `json:"localAliases"` LocalAliases []string `json:"localAliases"`
} }
type Bucket struct { type Bucket struct {
ID string `json:"id"` ID string `json:"id"`
GlobalAliases []string `json:"globalAliases"` GlobalAliases []string `json:"globalAliases"`
LocalAliases []LocalAlias `json:"localAliases"`
WebsiteAccess bool `json:"websiteAccess"` WebsiteAccess bool `json:"websiteAccess"`
WebsiteConfig WebsiteConfig `json:"websiteConfig"` WebsiteConfig WebsiteConfig `json:"websiteConfig"`
Keys []KeyElement `json:"keys"` Keys []KeyElement `json:"keys"`
@ -22,17 +21,12 @@ type Bucket struct {
Quotas Quotas `json:"quotas"` Quotas Quotas `json:"quotas"`
} }
type LocalAlias struct {
AccessKeyID string `json:"accessKeyId"`
Alias string `json:"alias"`
}
type KeyElement struct { type KeyElement struct {
AccessKeyID string `json:"accessKeyId"` AccessKeyID string `json:"accessKeyId"`
Name string `json:"name"` Name string `json:"name"`
Permissions Permissions `json:"permissions"` Permissions Permissions `json:"permissions"`
BucketLocalAliases []string `json:"bucketLocalAliases"` BucketLocalAliases []interface{} `json:"bucketLocalAliases"`
SecretAccessKey string `json:"secretAccessKey"` SecretAccessKey string `json:"secretAccessKey"`
} }
type Permissions struct { type Permissions struct {

View File

@ -1,12 +1,18 @@
package schema package schema
type Config struct { type Config struct {
RPCBindAddr string `json:"rpc_bind_addr" toml:"rpc_bind_addr"` CompressionLevel int64 `json:"compression_level" toml:"compression_level"`
RPCPublicAddr string `json:"rpc_public_addr" toml:"rpc_public_addr"` DataDir string `json:"data_dir" toml:"data_dir"`
RPCSecret string `json:"rpc_secret" toml:"rpc_secret"` DBEngine string `json:"db_engine" toml:"db_engine"`
Admin Admin `json:"admin" toml:"admin"` MetadataAutoSnapshotInterval string `json:"metadata_auto_snapshot_interval" toml:"metadata_auto_snapshot_interval"`
S3API S3API `json:"s3_api" toml:"s3_api"` MetadataDir string `json:"metadata_dir" toml:"metadata_dir"`
S3Web S3Web `json:"s3_web" toml:"s3_web"` ReplicationFactor int64 `json:"replication_factor" toml:"replication_factor"`
RPCBindAddr string `json:"rpc_bind_addr" toml:"rpc_bind_addr"`
RPCPublicAddr string `json:"rpc_public_addr" toml:"rpc_public_addr"`
RPCSecret string `json:"rpc_secret" toml:"rpc_secret"`
Admin Admin `json:"admin" toml:"admin"`
S3API S3API `json:"s3_api" toml:"s3_api"`
S3Web S3Web `json:"s3_web" toml:"s3_web"`
} }
type Admin struct { type Admin struct {

View File

@ -3,6 +3,4 @@
package ui package ui
import "net/http" func ServeUI() {}
func ServeUI(mux *http.ServeMux) {}

View File

@ -7,57 +7,28 @@ 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(mux *http.ServeMux) { func ServeUI() {
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")
mux.Handle(basePath+"/", http.StripPrefix(basePath, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { http.Handle("/", 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([]byte(html)) w.Write(index)
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"`)
})
} }

View File

@ -3,7 +3,6 @@ package utils
import ( import (
"bytes" "bytes"
"encoding/json" "encoding/json"
"errors"
"fmt" "fmt"
"io" "io"
"khairul169/garage-webui/schema" "khairul169/garage-webui/schema"
@ -74,17 +73,6 @@ func (g *garage) GetS3Endpoint() string {
return endpoint return endpoint
} }
func (g *garage) GetS3Region() string {
endpoint := os.Getenv("S3_REGION")
if len(endpoint) > 0 {
return endpoint
}
if len(g.Config.S3API.S3Region) == 0 {
return "garage"
}
return g.Config.S3API.S3Region
}
func (g *garage) GetAdminKey() string { func (g *garage) GetAdminKey() string {
key := os.Getenv("API_ADMIN_KEY") key := os.Getenv("API_ADMIN_KEY")
if len(key) > 0 { if len(key) > 0 {
@ -165,7 +153,7 @@ func (g *garage) Fetch(url string, options *FetchOptions) ([]byte, error) {
message = fmt.Sprintf("%v", data["message"]) message = fmt.Sprintf("%v", data["message"])
} }
return nil, errors.New(message) return nil, fmt.Errorf(message)
} }
body, err := io.ReadAll(res.Body) body, err := io.ReadAll(res.Body)

View File

@ -1,26 +0,0 @@
package utils
import (
"bytes"
"image"
_ "image/gif"
"image/jpeg"
_ "image/png"
"github.com/nfnt/resize"
)
func CreateThumbnailImage(buffer []byte, width uint, height uint) ([]byte, error) {
img, _, err := image.Decode(bytes.NewReader(buffer))
if err != nil {
return nil, err
}
thumb := resize.Thumbnail(width, height, img, resize.NearestNeighbor)
buf := new(bytes.Buffer)
if err := jpeg.Encode(buf, thumb, nil); err != nil {
return nil, err
}
return buf.Bytes(), nil
}

View File

@ -1,33 +0,0 @@
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())
}

View File

@ -1,17 +1,13 @@
services: services:
garage: garage:
image: dxflrs/garage:v1.0.1 image: dxflrs/garage:v1.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
ports: network_mode: host
- 3900:3900
- 3901:3901
- 3902:3903
- 3903:3903
webui: webui:
image: khairul169/garage-webui:latest image: khairul169/garage-webui:latest
@ -21,7 +17,3 @@ 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"

View File

@ -10,9 +10,6 @@
<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>

View File

@ -1,7 +1,7 @@
{ {
"name": "garage-webui", "name": "garage-webui",
"private": true, "private": true,
"version": "1.0.9", "version": "1.0.2",
"type": "module", "type": "module",
"scripts": { "scripts": {
"dev:client": "vite", "dev:client": "vite",
@ -47,11 +47,5 @@
"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"
]
} }
} }

View File

@ -1,65 +1,48 @@
import { createBrowserRouter, RouterProvider } from "react-router-dom"; import { createBrowserRouter, RouterProvider } from "react-router-dom";
import { lazy, Suspense } from "react"; import { lazy } 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,
},
],
},
],
{ {
basename: BASE_PATH, path: "/auth",
} 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 ( return <RouterProvider router={router} />;
<Suspense>
<RouterProvider router={router} />
</Suspense>
);
}; };
export default Router; export default Router;

View File

@ -4,7 +4,6 @@ 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";
@ -13,11 +12,6 @@ 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 },
@ -28,7 +22,6 @@ 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">
@ -64,48 +57,23 @@ const Sidebar = () => {
})} })}
</Menu> </Menu>
<div className="py-2 px-4 flex items-center gap-2"> <Dropdown className="my-2 mx-4" vertical="top">
<Dropdown vertical="top"> <Dropdown.Toggle button={false}>
<Dropdown.Toggle button={false}> <Button icon={Palette} color="ghost">
<Button icon={Palette} color="ghost"> Theme
{!auth.isEnabled ? "Theme" : null} </Button>
</Button> </Dropdown.Toggle>
</Dropdown.Toggle>
<Dropdown.Menu className="max-h-[500px] overflow-y-auto"> <Dropdown.Menu className="max-h-[200px] overflow-y-auto">
{themes.map((theme) => ( {themes.map((theme) => (
<Dropdown.Item <Dropdown.Item key={theme} onClick={() => appStore.setTheme(theme)}>
key={theme} {ucfirst(theme)}
onClick={() => appStore.setTheme(theme)} </Dropdown.Item>
> ))}
{ucfirst(theme)} </Dropdown.Menu>
</Dropdown.Item> </Dropdown>
))}
</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;

View File

@ -1,22 +1,5 @@
import { useAuth } from "@/hooks/useAuth";
import { Navigate, Outlet } from "react-router-dom";
const AuthLayout = () => { const AuthLayout = () => {
const auth = useAuth(); return <div>AuthLayout</div>;
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;

View File

@ -1,17 +1,15 @@
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 { Navigate, Outlet, useLocation, useNavigate } from "react-router-dom"; import { 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) {
@ -19,14 +17,6 @@ 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}

View File

@ -4,7 +4,6 @@ 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
View File

@ -1,7 +0,0 @@
export {};
declare global {
interface Window {
__BASE_PATH?: string;
}
}

View File

@ -1,20 +0,0 @@
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,
};
};

View File

@ -1,23 +1,10 @@
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 = BASE_PATH + "/api"; export const API_URL = "/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>) {
@ -40,30 +27,26 @@ const api = {
const res = await fetch(_url, { const res = await fetch(_url, {
...options, ...options,
credentials: "include",
headers: { ...headers, ...(options?.headers || {}) }, headers: { ...headers, ...(options?.headers || {}) },
}); });
if (!res.ok) {
const json = await res.json().catch(() => {});
const message = json?.message || res.statusText;
throw new Error(message);
}
const isJson = res.headers const isJson = res.headers
.get("Content-Type") .get("Content-Type")
?.includes("application/json"); ?.includes("application/json");
const data = isJson ? await res.json() : await res.text();
if (res.status === 401 && !url.startsWith("/auth")) { if (isJson) {
window.location.href = utils.url("/auth/login"); const json = (await res.json()) as T;
throw new APIError("unauthorized", res.status); return json;
} }
if (!res.ok) { const text = await res.text();
const message = isJson return text as unknown as T;
? data?.message
: typeof data === "string"
? data
: res.statusText;
throw new APIError(message, res.status);
}
return data as unknown as T;
}, },
async get<T = any>(url: string, options?: Partial<FetchOptions>) { async get<T = any>(url: string, options?: Partial<FetchOptions>) {

View File

@ -1,6 +0,0 @@
// consts.ts
export const BASE_PATH =
(import.meta.env.PROD ? window.__BASE_PATH : null) ||
import.meta.env.VITE_BASE_PATH ||
"";

View File

@ -3,7 +3,6 @@ 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 };
@ -54,7 +53,3 @@ export const copyToClipboard = async (text: string) => {
textArea?.remove(); textArea?.remove();
} }
}; };
export const url = (...paths: unknown[]) => {
return BASE_PATH + paths.join("/");
};

View File

@ -1,21 +0,0 @@
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");
},
});
};

View File

@ -1,54 +0,0 @@
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>
);
}

View File

@ -1,6 +0,0 @@
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"),
});

View File

@ -4,7 +4,7 @@ import { readableBytes } from "@/lib/utils";
import Button from "@/components/ui/button"; import Button from "@/components/ui/button";
type Props = { type Props = {
data: Bucket & { aliases: string[] }; data: Bucket;
}; };
const BucketCard = ({ data }: Props) => { const BucketCard = ({ data }: Props) => {
@ -15,7 +15,7 @@ const BucketCard = ({ data }: Props) => {
<ArchiveIcon size={28} className="shrink-0" /> <ArchiveIcon size={28} className="shrink-0" />
<p className="text-xl font-medium truncate"> <p className="text-xl font-medium truncate">
{data.aliases?.join(", ")} {data.globalAliases?.join(", ")}
</p> </p>
</div> </div>

View File

@ -12,7 +12,7 @@ import { shareDialog } from "./share-dialog";
type Props = { type Props = {
prefix?: string; prefix?: string;
object: Pick<Object, "objectKey" | "url">; object: Pick<Object, "objectKey" | "downloadUrl">;
end?: boolean; end?: boolean;
}; };
@ -30,7 +30,7 @@ const ObjectActions = ({ prefix = "", object, end }: Props) => {
}); });
const onDownload = () => { const onDownload = () => {
window.open(API_URL + object.url + "?dl=1", "_blank"); window.open(API_URL + object.downloadUrl, "_blank");
}; };
const onDelete = () => { const onDelete = () => {

View File

@ -1,16 +1,10 @@
import { Alert, Loading, Table } from "react-daisyui"; import { Table } from "react-daisyui";
import { useBrowseObjects } from "./hooks"; import { useBrowseObjects } from "./hooks";
import { dayjs, readableBytes } from "@/lib/utils"; import { dayjs, readableBytes } from "@/lib/utils";
import mime from "mime/lite"; import mime from "mime/lite";
import { Object } from "./types"; import { Object } from "./types";
import { API_URL } from "@/lib/api"; import { API_URL } from "@/lib/api";
import { import { FileArchive, FileIcon, FileType, Folder } from "lucide-react";
CircleXIcon,
FileArchive,
FileIcon,
FileType,
Folder,
} from "lucide-react";
import { useBucketContext } from "../context"; import { useBucketContext } from "../context";
import ObjectActions from "./object-actions"; import ObjectActions from "./object-actions";
import GotoTopButton from "@/components/ui/goto-top-btn"; import GotoTopButton from "@/components/ui/goto-top-btn";
@ -22,17 +16,14 @@ type Props = {
const ObjectList = ({ prefix, onPrefixChange }: Props) => { const ObjectList = ({ prefix, onPrefixChange }: Props) => {
const { bucketName } = useBucketContext(); const { bucketName } = useBucketContext();
const { data, error, isLoading } = useBrowseObjects(bucketName, { const { data } = useBrowseObjects(bucketName, { prefix, limit: 1000 });
prefix,
limit: 1000,
});
const onObjectClick = (object: Object) => { const onObjectClick = (object: Object) => {
window.open(API_URL + object.url + "?view=1", "_blank"); window.open(API_URL + object.viewUrl, "_blank");
}; };
return ( return (
<div className="overflow-x-auto min-h-[400px]"> <div className="overflow-x-auto overflow-y-hidden">
<Table> <Table>
<Table.Head> <Table.Head>
<span>Name</span> <span>Name</span>
@ -41,29 +32,13 @@ const ObjectList = ({ prefix, onPrefixChange }: Props) => {
</Table.Head> </Table.Head>
<Table.Body> <Table.Body>
{isLoading ? ( {!data?.prefixes?.length && !data?.objects?.length && (
<tr> <tr>
<td colSpan={3}> <td className="text-center py-8" colSpan={3}>
<div className="h-[320px] flex items-center justify-center">
<Loading />
</div>
</td>
</tr>
) : error ? (
<tr>
<td colSpan={3}>
<Alert status="error" icon={<CircleXIcon />}>
<span>{error.message}</span>
</Alert>
</td>
</tr>
) : !data?.prefixes?.length && !data?.objects?.length ? (
<tr>
<td className="text-center py-16" colSpan={3}>
No objects No objects
</td> </td>
</tr> </tr>
) : null} )}
{data?.prefixes.map((prefix) => ( {data?.prefixes.map((prefix) => (
<tr <tr
@ -84,7 +59,7 @@ const ObjectList = ({ prefix, onPrefixChange }: Props) => {
</span> </span>
</td> </td>
<td colSpan={2} /> <td colSpan={2} />
<ObjectActions object={{ objectKey: prefix, url: "" }} /> <ObjectActions object={{ objectKey: prefix, downloadUrl: "" }} />
</tr> </tr>
))} ))}
@ -121,9 +96,7 @@ const ObjectList = ({ prefix, onPrefixChange }: Props) => {
<ObjectActions <ObjectActions
prefix={data.prefix} prefix={data.prefix}
object={object} object={object}
end={ end={idx >= data.objects.length - 2}
idx >= data.objects.length - 2 && data.objects.length > 5
}
/> />
</tr> </tr>
); );
@ -152,10 +125,9 @@ const FilePreview = ({ ext, object }: FilePreviewProps) => {
} }
if (type === "image") { if (type === "image") {
const thumbnailSupport = ["jpg", "jpeg", "png", "gif"].includes(ext || "");
return ( return (
<img <img
src={API_URL + object.url + (thumbnailSupport ? "?thumb=1" : "?view=1")} src={API_URL + object.viewUrl}
alt={object.objectKey} alt={object.objectKey}
className="size-5 object-cover overflow-hidden mr-2" className="size-5 object-cover overflow-hidden mr-2"
/> />

View File

@ -15,7 +15,8 @@ export type Object = {
objectKey: string; objectKey: string;
lastModified: Date; lastModified: Date;
size: number; size: number;
url: string; viewUrl: string;
downloadUrl: string;
}; };
export type PutObjectPayload = { export type PutObjectPayload = {

View File

@ -2,18 +2,12 @@ import { useParams } from "react-router-dom";
import { useBucket } from "./hooks"; import { useBucket } from "./hooks";
import Page from "@/context/page-context"; import Page from "@/context/page-context";
import TabView, { Tab } from "@/components/containers/tab-view"; import TabView, { Tab } from "@/components/containers/tab-view";
import { import { ChartLine, FolderSearch, LockKeyhole } from "lucide-react";
ChartLine,
CircleXIcon,
FolderSearch,
LockKeyhole,
} from "lucide-react";
import OverviewTab from "./overview/overview-tab"; import OverviewTab from "./overview/overview-tab";
import PermissionsTab from "./permissions/permissions-tab"; import PermissionsTab from "./permissions/permissions-tab";
import MenuButton from "./components/menu-button"; import MenuButton from "./components/menu-button";
import BrowseTab from "./browse/browse-tab"; import BrowseTab from "./browse/browse-tab";
import { BucketContext } from "./context"; import { BucketContext } from "./context";
import { Alert, Loading } from "react-daisyui";
const tabs: Tab[] = [ const tabs: Tab[] = [
{ {
@ -38,40 +32,26 @@ const tabs: Tab[] = [
const ManageBucketPage = () => { const ManageBucketPage = () => {
const { id } = useParams(); const { id } = useParams();
const { data, error, isLoading, refetch } = useBucket(id); const { data, refetch } = useBucket(id);
const name = data?.globalAliases[0]; const name = data?.globalAliases[0];
return ( return (
<> <div className="container">
<Page <Page
title={name || "Manage Bucket"} title={name || "Manage Bucket"}
prev="/buckets" prev="/buckets"
actions={data ? <MenuButton /> : undefined} actions={data ? <MenuButton /> : undefined}
/> />
{isLoading && (
<div className="h-full flex items-center justify-center">
<Loading size="lg" />
</div>
)}
{error != null && (
<Alert status="error" icon={<CircleXIcon />}>
<span>{error.message}</span>
</Alert>
)}
{data && ( {data && (
<div className="container"> <BucketContext.Provider
<BucketContext.Provider value={{ bucket: data, refetch, bucketName: name || "" }}
value={{ bucket: data, refetch, bucketName: name || "" }} >
> <TabView tabs={tabs} className="bg-base-100 h-14 px-1.5" />
<TabView tabs={tabs} className="bg-base-100 h-14 px-1.5" /> </BucketContext.Provider>
</BucketContext.Provider>
</div>
)} )}
</> </div>
); );
}; };

View File

@ -84,7 +84,7 @@ const AllowKeyDialog = ({ currentKeys }: Props) => {
Allow Key Allow Key
</Button> </Button>
<Modal ref={dialogRef} backdrop open={isOpen} className="max-w-2xl"> <Modal ref={dialogRef} backdrop open={isOpen}>
<Modal.Header className="mb-1">Allow Key</Modal.Header> <Modal.Header className="mb-1">Allow Key</Modal.Header>
<Modal.Body> <Modal.Body>
<p>Enter the key you want to allow access to.</p> <p>Enter the key you want to allow access to.</p>
@ -100,7 +100,6 @@ const AllowKeyDialog = ({ currentKeys }: Props) => {
/> />
Key Key
</label> </label>
<label>Local Aliases</label>
<label className="flex items-center gap-2 cursor-pointer"> <label className="flex items-center gap-2 cursor-pointer">
<Checkbox <Checkbox
color="primary" color="primary"
@ -130,31 +129,23 @@ const AllowKeyDialog = ({ currentKeys }: Props) => {
<Table.Body> <Table.Body>
{!keyFields.length ? ( {!keyFields.length ? (
<tr> <tr>
<td colSpan={5} className="text-center"> <td colSpan={4} className="text-center">
No keys found No keys found
</td> </td>
</tr> </tr>
) : null} ) : null}
{keyFields.map((field, index) => { {keyFields.map((field, index) => (
const curKey = bucket.keys.find( <Table.Row key={field.id}>
(key) => key.accessKeyId === field.keyId <CheckboxField
); form={form}
return ( name={`keys.${index}.checked`}
<Table.Row key={field.id}> label={field.name || field.keyId?.substring(0, 8)}
<CheckboxField />
form={form} <CheckboxField form={form} name={`keys.${index}.read`} />
name={`keys.${index}.checked`} <CheckboxField form={form} name={`keys.${index}.write`} />
label={field.name || field.keyId?.substring(0, 8)} <CheckboxField form={form} name={`keys.${index}.owner`} />
/> </Table.Row>
<span> ))}
{curKey?.bucketLocalAliases?.join(", ") || "-"}
</span>
<CheckboxField form={form} name={`keys.${index}.read`} />
<CheckboxField form={form} name={`keys.${index}.write`} />
<CheckboxField form={form} name={`keys.${index}.owner`} />
</Table.Row>
);
})}
</Table.Body> </Table.Body>
</Table> </Table>
</div> </div>

View File

@ -50,7 +50,6 @@ const PermissionsTab = () => {
<Table.Head> <Table.Head>
<span>#</span> <span>#</span>
<span>Key</span> <span>Key</span>
<span>Aliases</span>
<span>Read</span> <span>Read</span>
<span>Write</span> <span>Write</span>
<span>Owner</span> <span>Owner</span>
@ -62,7 +61,6 @@ const PermissionsTab = () => {
<Table.Row> <Table.Row>
<span>{idx + 1}</span> <span>{idx + 1}</span>
<span>{key.name || key.accessKeyId?.substring(0, 8)}</span> <span>{key.name || key.accessKeyId?.substring(0, 8)}</span>
<span>{key.bucketLocalAliases?.join(", ") || "-"}</span>
<span> <span>
<Checkbox <Checkbox
checked={key.permissions?.read} checked={key.permissions?.read}

View File

@ -10,27 +10,20 @@ const BucketsPage = () => {
const [search, setSearch] = useState(""); const [search, setSearch] = useState("");
const items = useMemo(() => { const items = useMemo(() => {
let buckets = let buckets = data || [];
data?.map((bucket) => {
return {
...bucket,
aliases: [
...(bucket.globalAliases || []),
...(bucket.localAliases?.map((l) => l.alias) || []),
],
};
}) || [];
if (search?.length > 0) { if (search?.length > 0) {
const q = search.toLowerCase(); const q = search.toLowerCase();
buckets = buckets.filter( buckets = buckets.filter(
(bucket) => (bucket) =>
bucket.id.includes(q) || bucket.id.includes(q) ||
bucket.aliases.find((alias) => alias.includes(q)) bucket.globalAliases.find((alias) => alias.includes(q))
); );
} }
buckets = buckets.sort((a, b) => a.aliases[0].localeCompare(b.aliases[0])); buckets = buckets.sort((a, b) =>
a.globalAliases[0].localeCompare(b.globalAliases[0])
);
return buckets; return buckets;
}, [data, search]); }, [data, search]);

View File

@ -5,7 +5,6 @@ export type GetBucketRes = Bucket[];
export type Bucket = { export type Bucket = {
id: string; id: string;
globalAliases: string[]; globalAliases: string[];
localAliases: LocalAlias[];
websiteAccess: boolean; websiteAccess: boolean;
websiteConfig?: WebsiteConfig | null; websiteConfig?: WebsiteConfig | null;
keys: Key[]; keys: Key[];
@ -18,16 +17,11 @@ export type Bucket = {
quotas: Quotas; quotas: Quotas;
}; };
export type LocalAlias = {
accessKeyId: string;
alias: string;
};
export type Key = { export type Key = {
accessKeyId: string; accessKeyId: string;
name: string; name: string;
permissions: Permissions; permissions: Permissions;
bucketLocalAliases: string[]; bucketLocalAliases: any[];
}; };
export type Permissions = { export type Permissions = {

View File

@ -66,8 +66,7 @@ const AssignNodeDialog = () => {
}, [data]); }, [data]);
const zoneList = useMemo(() => { const zoneList = useMemo(() => {
const nodes = cluster?.nodes || cluster?.knownNodes || []; const list = cluster?.nodes
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(
@ -84,8 +83,7 @@ const AssignNodeDialog = () => {
}, [cluster, layout]); }, [cluster, layout]);
const tagsList = useMemo(() => { const tagsList = useMemo(() => {
const nodes = cluster?.nodes || cluster?.knownNodes || []; const list = cluster?.nodes
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(

View File

@ -268,9 +268,7 @@ const NodesList = ({ nodes }: NodeListProps) => {
<Dropdown <Dropdown
end end
vertical={ vertical={idx >= items.length - 2 ? "top" : "bottom"}
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">

View File

@ -2,22 +2,9 @@ import Page from "@/context/page-context";
import { useClusterStatus } from "./hooks"; import { useClusterStatus } 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 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">
@ -31,10 +18,7 @@ const ClusterPage = () => {
<DetailItem title="Version" value={data?.garageVersion} /> <DetailItem title="Version" value={data?.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={data?.dbEngine} />
<DetailItem <DetailItem title="Layout version" value={data?.layoutVersion} />
title="Layout version"
value={data?.layoutVersion || data?.layout?.version}
/>
</Card.Body> </Card.Body>
</Card> </Card>
@ -42,7 +26,7 @@ const ClusterPage = () => {
<Card.Body> <Card.Body>
<Card.Title>Nodes</Card.Title> <Card.Title>Nodes</Card.Title>
<NodesList nodes={nodes} /> <NodesList nodes={data?.nodes || []} />
</Card.Body> </Card.Body>
</Card> </Card>
</div> </div>

View File

@ -7,9 +7,7 @@ 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 = {
@ -19,9 +17,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 = {