mirror of
https://github.com/khairul169/garage-webui.git
synced 2026-09-18 18:27:39 +07:00
Compare commits
7
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b8b87d8289 | ||
|
|
1b1b815443 | ||
|
|
37027396ca | ||
|
|
c1619276c0 | ||
|
|
611258d0db | ||
|
|
91c396dd68 | ||
|
|
5a90dd8377 |
@@ -31,7 +31,7 @@ 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.0
|
image: dxflrs/garage:v1.0.1
|
||||||
container_name: garage
|
container_name: garage
|
||||||
volumes:
|
volumes:
|
||||||
- ./garage.toml:/etc/garage.toml
|
- ./garage.toml:/etc/garage.toml
|
||||||
@@ -55,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.2/garage-webui-v1.0.2-linux-amd64
|
$ wget -O garage-webui https://github.com/khairul169/garage-webui/releases/download/1.0.5/garage-webui-v1.0.5-linux-amd64
|
||||||
$ chmod +x garage-webui
|
$ chmod +x garage-webui
|
||||||
$ sudo cp garage-webui /usr/local/bin
|
$ sudo cp garage-webui /usr/local/bin
|
||||||
```
|
```
|
||||||
@@ -134,6 +134,8 @@ However, if it fails to load, you can set these environment variables instead:
|
|||||||
- `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`.
|
||||||
- `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.
|
||||||
|
|
||||||
### Running
|
### Running
|
||||||
|
|
||||||
|
|||||||
+1
-2
@@ -8,6 +8,7 @@ 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
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -20,6 +21,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
|
||||||
github.com/coder/websocket v1.8.12 // indirect
|
|
||||||
golang.org/x/net v0.28.0 // indirect
|
|
||||||
)
|
)
|
||||||
|
|||||||
+2
-4
@@ -22,13 +22,13 @@ github.com/aws/aws-sdk-go-v2/service/s3 v1.59.0 h1:Cso4Ev/XauMVsbwdhYEoxg8rxZWw4
|
|||||||
github.com/aws/aws-sdk-go-v2/service/s3 v1.59.0/go.mod h1:BSPI0EfnYUuNHPS0uqIo5VrRwzie+Fp+YhQOUs16sKI=
|
github.com/aws/aws-sdk-go-v2/service/s3 v1.59.0/go.mod h1:BSPI0EfnYUuNHPS0uqIo5VrRwzie+Fp+YhQOUs16sKI=
|
||||||
github.com/aws/smithy-go v1.20.4 h1:2HK1zBdPgRbjFOHlfeQZfpC4r72MOb9bZkiFwggKO+4=
|
github.com/aws/smithy-go v1.20.4 h1:2HK1zBdPgRbjFOHlfeQZfpC4r72MOb9bZkiFwggKO+4=
|
||||||
github.com/aws/smithy-go v1.20.4/go.mod h1:irrKGvNn1InZwb2d7fkIRNucdfwR8R+Ts3wxYa/cJHg=
|
github.com/aws/smithy-go v1.20.4/go.mod h1:irrKGvNn1InZwb2d7fkIRNucdfwR8R+Ts3wxYa/cJHg=
|
||||||
github.com/coder/websocket v1.8.12 h1:5bUXkEPPIbewrnkU8LTCLVaxi4N4J8ahufH2vlo4NAo=
|
|
||||||
github.com/coder/websocket v1.8.12/go.mod h1:LNVeNrXQZfe5qhS9ALED3uA+l5pPqvwXg3CKoDBB2gs=
|
|
||||||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
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=
|
||||||
@@ -42,8 +42,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/net v0.28.0 h1:a9JDOJc5GMUJ0+UDqmLT86WiEy7iWyIhz8gz8E4e5hE=
|
|
||||||
golang.org/x/net v0.28.0/go.mod h1:yqtgsTWOOnlGLG9GFRrK3++bGOUEkNBoHZc8MEDWPNg=
|
|
||||||
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=
|
||||||
|
|||||||
+1
-3
@@ -16,12 +16,10 @@ func main() {
|
|||||||
utils.InitCacheManager()
|
utils.InitCacheManager()
|
||||||
|
|
||||||
if err := utils.Garage.LoadConfig(); err != nil {
|
if err := utils.Garage.LoadConfig(); err != nil {
|
||||||
log.Fatal("Failed to load config! ", err)
|
log.Println("Cannot load garage config!", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
http.Handle("/api/", http.StripPrefix("/api", router.HandleApiRouter()))
|
http.Handle("/api/", http.StripPrefix("/api", router.HandleApiRouter()))
|
||||||
http.Handle("/ws/", http.StripPrefix("/ws", router.HandleWebsocket()))
|
|
||||||
|
|
||||||
ui.ServeUI()
|
ui.ServeUI()
|
||||||
|
|
||||||
host := utils.GetEnv("HOST", "0.0.0.0")
|
host := utils.GetEnv("HOST", "0.0.0.0")
|
||||||
|
|||||||
+39
-15
@@ -73,8 +73,7 @@ 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,
|
||||||
ViewUrl: fmt.Sprintf("/browse/%s/%s?view=1", bucket, *object.Key),
|
Url: fmt.Sprintf("/browse/%s/%s", bucket, *object.Key),
|
||||||
DownloadUrl: fmt.Sprintf("/browse/%s/%s?dl=1", bucket, *object.Key),
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -84,8 +83,10 @@ 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")
|
||||||
view := r.URL.Query().Get("view") == "1"
|
queryParams := r.URL.Query()
|
||||||
download := r.URL.Query().Get("dl") == "1"
|
view := queryParams.Get("view") == "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 {
|
||||||
@@ -93,6 +94,18 @@ 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),
|
||||||
@@ -109,31 +122,42 @@ func (b *Browse) GetOneObject(w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if view || download {
|
|
||||||
defer object.Body.Close()
|
defer object.Body.Close()
|
||||||
keys := strings.Split(key, "/")
|
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("Content-Type", *object.ContentType)
|
w.Header().Set("Content-Type", *object.ContentType)
|
||||||
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")
|
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)
|
w.Header().Set("Etag", *object.ETag)
|
||||||
|
|
||||||
if download {
|
|
||||||
w.Header().Set("Content-Disposition", fmt.Sprintf("attachment; filename=%s", keys[len(keys)-1]))
|
|
||||||
}
|
|
||||||
|
|
||||||
w.WriteHeader(http.StatusOK)
|
|
||||||
_, err = io.Copy(w, object.Body)
|
_, err = io.Copy(w, object.Body)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.ResponseError(w, err)
|
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) {
|
||||||
@@ -300,7 +324,7 @@ func getS3Client(bucket string) (*s3.Client, error) {
|
|||||||
|
|
||||||
awsConfig := aws.Config{
|
awsConfig := aws.Config{
|
||||||
Credentials: creds,
|
Credentials: creds,
|
||||||
Region: "garage",
|
Region: utils.Garage.GetS3Region(),
|
||||||
BaseEndpoint: aws.String(utils.Garage.GetS3Endpoint()),
|
BaseEndpoint: aws.String(utils.Garage.GetS3Endpoint()),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -34,13 +34,14 @@ func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
var bucket schema.Bucket
|
var data schema.Bucket
|
||||||
if err := json.Unmarshal(body, &bucket); err != nil {
|
if err := json.Unmarshal(body, &data); err != nil {
|
||||||
ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases}
|
ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
ch <- bucket
|
data.LocalAliases = bucket.LocalAliases
|
||||||
|
ch <- data
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,8 +1,6 @@
|
|||||||
package router
|
package router
|
||||||
|
|
||||||
import (
|
import "net/http"
|
||||||
"net/http"
|
|
||||||
)
|
|
||||||
|
|
||||||
func HandleApiRouter() *http.ServeMux {
|
func HandleApiRouter() *http.ServeMux {
|
||||||
router := http.NewServeMux()
|
router := http.NewServeMux()
|
||||||
@@ -23,11 +21,3 @@ func HandleApiRouter() *http.ServeMux {
|
|||||||
|
|
||||||
return router
|
return router
|
||||||
}
|
}
|
||||||
|
|
||||||
func HandleWebsocket() *http.ServeMux {
|
|
||||||
router := http.NewServeMux()
|
|
||||||
|
|
||||||
router.HandleFunc("/terminal", TerminalHandler)
|
|
||||||
|
|
||||||
return router
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1,114 +0,0 @@
|
|||||||
package router
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"fmt"
|
|
||||||
"net/http"
|
|
||||||
"os"
|
|
||||||
"os/exec"
|
|
||||||
|
|
||||||
"github.com/coder/websocket"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Terminal struct {
|
|
||||||
ws *websocket.Conn
|
|
||||||
remoteAddr string
|
|
||||||
cmd *exec.Cmd
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Terminal) NewSession(w http.ResponseWriter, r *http.Request) {
|
|
||||||
cwd, err := os.Getwd()
|
|
||||||
if err != nil {
|
|
||||||
fmt.Printf("Failed to get current working directory: %v\n", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
cmd := &exec.Cmd{
|
|
||||||
// Path: "/bin/bash",
|
|
||||||
Path: "/usr/bin/fish",
|
|
||||||
Dir: cwd,
|
|
||||||
}
|
|
||||||
c.cmd = cmd
|
|
||||||
|
|
||||||
stdin, err := cmd.StdinPipe()
|
|
||||||
if err != nil {
|
|
||||||
fmt.Printf("Failed to create stdin pipe: %v\n", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
stdout, err := cmd.StdoutPipe()
|
|
||||||
if err != nil {
|
|
||||||
fmt.Printf("Failed to create stdout pipe: %v\n", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
cmd.Stderr = cmd.Stdout
|
|
||||||
cmd.Stdout = os.Stdout
|
|
||||||
|
|
||||||
if err := cmd.Start(); err != nil {
|
|
||||||
fmt.Printf("Failed to start command: %v\n", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
go func() {
|
|
||||||
// if err := cmd.Wait(); err != nil {
|
|
||||||
// fmt.Printf("Shell exited with error: %v\n", err)
|
|
||||||
// }
|
|
||||||
// c.ws.CloseNow()
|
|
||||||
}()
|
|
||||||
|
|
||||||
go func() {
|
|
||||||
buf := make([]byte, 1024)
|
|
||||||
for {
|
|
||||||
n, err := stdout.Read(buf)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Printf("Data from stdout: %s\n", string(buf[:n]))
|
|
||||||
|
|
||||||
err = c.ws.Write(context.Background(), websocket.MessageText, buf[:n])
|
|
||||||
if err != nil {
|
|
||||||
fmt.Printf("Failed to write data to websocket: %v\n", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
|
|
||||||
for {
|
|
||||||
_, data, err := c.ws.Read(context.Background())
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Printf("Data from websocket: %s\n", string(data))
|
|
||||||
|
|
||||||
if _, err := stdin.Write(data); err != nil {
|
|
||||||
fmt.Printf("Failed to write data to stdin: %v\n", err)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Terminal) Close() {
|
|
||||||
if c.cmd != nil {
|
|
||||||
c.cmd.Process.Kill()
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Println("Terminal session closed:", c.remoteAddr)
|
|
||||||
c.ws.Close(websocket.StatusInternalError, "the connection is closed")
|
|
||||||
}
|
|
||||||
|
|
||||||
func TerminalHandler(w http.ResponseWriter, r *http.Request) {
|
|
||||||
fmt.Printf("New terminal session: %s\n", r.RemoteAddr)
|
|
||||||
|
|
||||||
c, err := websocket.Accept(w, r, nil)
|
|
||||||
if err != nil {
|
|
||||||
fmt.Printf("Failed to accept websocket: %v\n", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
term := &Terminal{ws: c, remoteAddr: r.RemoteAddr}
|
|
||||||
defer term.Close()
|
|
||||||
|
|
||||||
term.NewSession(w, r)
|
|
||||||
}
|
|
||||||
@@ -13,6 +13,5 @@ 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"`
|
||||||
ViewUrl string `json:"viewUrl"`
|
Url string `json:"url"`
|
||||||
DownloadUrl string `json:"downloadUrl"`
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,12 +3,13 @@ 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 []string `json:"localAliases"`
|
LocalAliases []LocalAlias `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"`
|
||||||
@@ -21,11 +22,16 @@ 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 []interface{} `json:"bucketLocalAliases"`
|
BucketLocalAliases []string `json:"bucketLocalAliases"`
|
||||||
SecretAccessKey string `json:"secretAccessKey"`
|
SecretAccessKey string `json:"secretAccessKey"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,12 +1,6 @@
|
|||||||
package schema
|
package schema
|
||||||
|
|
||||||
type Config struct {
|
type Config struct {
|
||||||
CompressionLevel int64 `json:"compression_level" toml:"compression_level"`
|
|
||||||
DataDir string `json:"data_dir" toml:"data_dir"`
|
|
||||||
DBEngine string `json:"db_engine" toml:"db_engine"`
|
|
||||||
MetadataAutoSnapshotInterval string `json:"metadata_auto_snapshot_interval" toml:"metadata_auto_snapshot_interval"`
|
|
||||||
MetadataDir string `json:"metadata_dir" toml:"metadata_dir"`
|
|
||||||
ReplicationFactor int64 `json:"replication_factor" toml:"replication_factor"`
|
|
||||||
RPCBindAddr string `json:"rpc_bind_addr" toml:"rpc_bind_addr"`
|
RPCBindAddr string `json:"rpc_bind_addr" toml:"rpc_bind_addr"`
|
||||||
RPCPublicAddr string `json:"rpc_public_addr" toml:"rpc_public_addr"`
|
RPCPublicAddr string `json:"rpc_public_addr" toml:"rpc_public_addr"`
|
||||||
RPCSecret string `json:"rpc_secret" toml:"rpc_secret"`
|
RPCSecret string `json:"rpc_secret" toml:"rpc_secret"`
|
||||||
|
|||||||
+13
-1
@@ -3,6 +3,7 @@ package utils
|
|||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"khairul169/garage-webui/schema"
|
"khairul169/garage-webui/schema"
|
||||||
@@ -73,6 +74,17 @@ 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 {
|
||||||
@@ -153,7 +165,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, fmt.Errorf(message)
|
return nil, errors.New(message)
|
||||||
}
|
}
|
||||||
|
|
||||||
body, err := io.ReadAll(res.Body)
|
body, err := io.ReadAll(res.Body)
|
||||||
|
|||||||
@@ -0,0 +1,26 @@
|
|||||||
|
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
|
||||||
|
}
|
||||||
+1
-3
@@ -1,7 +1,7 @@
|
|||||||
{
|
{
|
||||||
"name": "garage-webui",
|
"name": "garage-webui",
|
||||||
"private": true,
|
"private": true,
|
||||||
"version": "1.0.2",
|
"version": "1.0.5",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"dev:client": "vite",
|
"dev:client": "vite",
|
||||||
@@ -14,8 +14,6 @@
|
|||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@hookform/resolvers": "^3.9.0",
|
"@hookform/resolvers": "^3.9.0",
|
||||||
"@tanstack/react-query": "^5.51.23",
|
"@tanstack/react-query": "^5.51.23",
|
||||||
"@xterm/addon-attach": "^0.11.0",
|
|
||||||
"@xterm/xterm": "^5.5.0",
|
|
||||||
"clsx": "^2.1.1",
|
"clsx": "^2.1.1",
|
||||||
"dayjs": "^1.11.12",
|
"dayjs": "^1.11.12",
|
||||||
"lucide-react": "^0.427.0",
|
"lucide-react": "^0.427.0",
|
||||||
|
|||||||
Generated
-20
@@ -14,12 +14,6 @@ importers:
|
|||||||
'@tanstack/react-query':
|
'@tanstack/react-query':
|
||||||
specifier: ^5.51.23
|
specifier: ^5.51.23
|
||||||
version: 5.51.23([email protected])
|
version: 5.51.23([email protected])
|
||||||
'@xterm/addon-attach':
|
|
||||||
specifier: ^0.11.0
|
|
||||||
version: 0.11.0(@xterm/[email protected])
|
|
||||||
'@xterm/xterm':
|
|
||||||
specifier: ^5.5.0
|
|
||||||
version: 5.5.0
|
|
||||||
clsx:
|
clsx:
|
||||||
specifier: ^2.1.1
|
specifier: ^2.1.1
|
||||||
version: 2.1.1
|
version: 2.1.1
|
||||||
@@ -681,14 +675,6 @@ packages:
|
|||||||
peerDependencies:
|
peerDependencies:
|
||||||
vite: ^4 || ^5
|
vite: ^4 || ^5
|
||||||
|
|
||||||
'@xterm/[email protected]':
|
|
||||||
resolution: {integrity: sha512-JboCN0QAY6ZLY/SSB/Zl2cQ5zW1Eh4X3fH7BnuR1NB7xGRhzbqU2Npmpiw/3zFlxDaU88vtKzok44JKi2L2V2Q==}
|
|
||||||
peerDependencies:
|
|
||||||
'@xterm/xterm': ^5.0.0
|
|
||||||
|
|
||||||
'@xterm/[email protected]':
|
|
||||||
resolution: {integrity: sha512-hqJHYaQb5OptNunnyAnkHyM8aCjZ1MEIDTQu1iIbbTD/xops91NB5yq1ZK/dC2JDbVWtF23zUtl9JE2NqwT87A==}
|
|
||||||
|
|
||||||
[email protected]:
|
[email protected]:
|
||||||
resolution: {integrity: sha512-rq9s+JNhf0IChjtDXxllJ7g41oZk5SlXtp0LHwyA5cejwn7vKmKp4pPri6YEePv2PU65sAsegbXtIinmDFDXgQ==}
|
resolution: {integrity: sha512-rq9s+JNhf0IChjtDXxllJ7g41oZk5SlXtp0LHwyA5cejwn7vKmKp4pPri6YEePv2PU65sAsegbXtIinmDFDXgQ==}
|
||||||
peerDependencies:
|
peerDependencies:
|
||||||
@@ -2238,12 +2224,6 @@ snapshots:
|
|||||||
transitivePeerDependencies:
|
transitivePeerDependencies:
|
||||||
- '@swc/helpers'
|
- '@swc/helpers'
|
||||||
|
|
||||||
'@xterm/[email protected](@xterm/[email protected])':
|
|
||||||
dependencies:
|
|
||||||
'@xterm/xterm': 5.5.0
|
|
||||||
|
|
||||||
'@xterm/[email protected]': {}
|
|
||||||
|
|
||||||
[email protected]([email protected]):
|
[email protected]([email protected]):
|
||||||
dependencies:
|
dependencies:
|
||||||
acorn: 8.12.1
|
acorn: 8.12.1
|
||||||
|
|||||||
@@ -8,7 +8,6 @@ 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 TerminalPage = lazy(() => import("@/pages/terminal/page"));
|
|
||||||
|
|
||||||
const router = createBrowserRouter([
|
const router = createBrowserRouter([
|
||||||
{
|
{
|
||||||
@@ -38,10 +37,6 @@ const router = createBrowserRouter([
|
|||||||
path: "keys",
|
path: "keys",
|
||||||
Component: KeysPage,
|
Component: KeysPage,
|
||||||
},
|
},
|
||||||
{
|
|
||||||
path: "terminal",
|
|
||||||
Component: TerminalPage,
|
|
||||||
},
|
|
||||||
],
|
],
|
||||||
},
|
},
|
||||||
]);
|
]);
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ import {
|
|||||||
KeySquare,
|
KeySquare,
|
||||||
LayoutDashboard,
|
LayoutDashboard,
|
||||||
Palette,
|
Palette,
|
||||||
SquareTerminal,
|
|
||||||
} from "lucide-react";
|
} from "lucide-react";
|
||||||
import { Dropdown, Menu } from "react-daisyui";
|
import { Dropdown, Menu } from "react-daisyui";
|
||||||
import { Link, useLocation } from "react-router-dom";
|
import { Link, useLocation } from "react-router-dom";
|
||||||
@@ -19,7 +18,6 @@ const pages = [
|
|||||||
{ icon: HardDrive, title: "Cluster", path: "/cluster" },
|
{ icon: HardDrive, title: "Cluster", path: "/cluster" },
|
||||||
{ icon: ArchiveIcon, title: "Buckets", path: "/buckets" },
|
{ icon: ArchiveIcon, title: "Buckets", path: "/buckets" },
|
||||||
{ icon: KeySquare, title: "Keys", path: "/keys" },
|
{ icon: KeySquare, title: "Keys", path: "/keys" },
|
||||||
{ icon: SquareTerminal, title: "Terminal", path: "/terminal" },
|
|
||||||
];
|
];
|
||||||
|
|
||||||
const Sidebar = () => {
|
const Sidebar = () => {
|
||||||
|
|||||||
+9
-11
@@ -30,23 +30,21 @@ const api = {
|
|||||||
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 (isJson) {
|
if (!res.ok) {
|
||||||
const json = (await res.json()) as T;
|
const message = isJson
|
||||||
return json;
|
? data?.message
|
||||||
|
: typeof data === "string"
|
||||||
|
? data
|
||||||
|
: res.statusText;
|
||||||
|
throw new Error(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
const text = await res.text();
|
return data as unknown as T;
|
||||||
return text as unknown as T;
|
|
||||||
},
|
},
|
||||||
|
|
||||||
async get<T = any>(url: string, options?: Partial<FetchOptions>) {
|
async get<T = any>(url: string, options?: Partial<FetchOptions>) {
|
||||||
|
|||||||
@@ -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;
|
data: Bucket & { aliases: string[] };
|
||||||
};
|
};
|
||||||
|
|
||||||
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.globalAliases?.join(", ")}
|
{data.aliases?.join(", ")}
|
||||||
</p>
|
</p>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ import { shareDialog } from "./share-dialog";
|
|||||||
|
|
||||||
type Props = {
|
type Props = {
|
||||||
prefix?: string;
|
prefix?: string;
|
||||||
object: Pick<Object, "objectKey" | "downloadUrl">;
|
object: Pick<Object, "objectKey" | "url">;
|
||||||
end?: boolean;
|
end?: boolean;
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -30,7 +30,7 @@ const ObjectActions = ({ prefix = "", object, end }: Props) => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
const onDownload = () => {
|
const onDownload = () => {
|
||||||
window.open(API_URL + object.downloadUrl, "_blank");
|
window.open(API_URL + object.url + "?dl=1", "_blank");
|
||||||
};
|
};
|
||||||
|
|
||||||
const onDelete = () => {
|
const onDelete = () => {
|
||||||
|
|||||||
@@ -1,10 +1,16 @@
|
|||||||
import { Table } from "react-daisyui";
|
import { Alert, Loading, 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 { FileArchive, FileIcon, FileType, Folder } from "lucide-react";
|
import {
|
||||||
|
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";
|
||||||
@@ -16,14 +22,17 @@ type Props = {
|
|||||||
|
|
||||||
const ObjectList = ({ prefix, onPrefixChange }: Props) => {
|
const ObjectList = ({ prefix, onPrefixChange }: Props) => {
|
||||||
const { bucketName } = useBucketContext();
|
const { bucketName } = useBucketContext();
|
||||||
const { data } = useBrowseObjects(bucketName, { prefix, limit: 1000 });
|
const { data, error, isLoading } = useBrowseObjects(bucketName, {
|
||||||
|
prefix,
|
||||||
|
limit: 1000,
|
||||||
|
});
|
||||||
|
|
||||||
const onObjectClick = (object: Object) => {
|
const onObjectClick = (object: Object) => {
|
||||||
window.open(API_URL + object.viewUrl, "_blank");
|
window.open(API_URL + object.url + "?view=1", "_blank");
|
||||||
};
|
};
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="overflow-x-auto overflow-y-hidden">
|
<div className="overflow-x-auto min-h-[400px]">
|
||||||
<Table>
|
<Table>
|
||||||
<Table.Head>
|
<Table.Head>
|
||||||
<span>Name</span>
|
<span>Name</span>
|
||||||
@@ -32,13 +41,29 @@ const ObjectList = ({ prefix, onPrefixChange }: Props) => {
|
|||||||
</Table.Head>
|
</Table.Head>
|
||||||
|
|
||||||
<Table.Body>
|
<Table.Body>
|
||||||
{!data?.prefixes?.length && !data?.objects?.length && (
|
{isLoading ? (
|
||||||
<tr>
|
<tr>
|
||||||
<td className="text-center py-8" colSpan={3}>
|
<td 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
|
||||||
@@ -59,7 +84,7 @@ const ObjectList = ({ prefix, onPrefixChange }: Props) => {
|
|||||||
</span>
|
</span>
|
||||||
</td>
|
</td>
|
||||||
<td colSpan={2} />
|
<td colSpan={2} />
|
||||||
<ObjectActions object={{ objectKey: prefix, downloadUrl: "" }} />
|
<ObjectActions object={{ objectKey: prefix, url: "" }} />
|
||||||
</tr>
|
</tr>
|
||||||
))}
|
))}
|
||||||
|
|
||||||
@@ -96,7 +121,9 @@ const ObjectList = ({ prefix, onPrefixChange }: Props) => {
|
|||||||
<ObjectActions
|
<ObjectActions
|
||||||
prefix={data.prefix}
|
prefix={data.prefix}
|
||||||
object={object}
|
object={object}
|
||||||
end={idx >= data.objects.length - 2}
|
end={
|
||||||
|
idx >= data.objects.length - 2 && data.objects.length > 5
|
||||||
|
}
|
||||||
/>
|
/>
|
||||||
</tr>
|
</tr>
|
||||||
);
|
);
|
||||||
@@ -125,9 +152,10 @@ 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.viewUrl}
|
src={API_URL + object.url + (thumbnailSupport ? "?thumb=1" : "?view=1")}
|
||||||
alt={object.objectKey}
|
alt={object.objectKey}
|
||||||
className="size-5 object-cover overflow-hidden mr-2"
|
className="size-5 object-cover overflow-hidden mr-2"
|
||||||
/>
|
/>
|
||||||
|
|||||||
@@ -15,8 +15,7 @@ export type Object = {
|
|||||||
objectKey: string;
|
objectKey: string;
|
||||||
lastModified: Date;
|
lastModified: Date;
|
||||||
size: number;
|
size: number;
|
||||||
viewUrl: string;
|
url: string;
|
||||||
downloadUrl: string;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
export type PutObjectPayload = {
|
export type PutObjectPayload = {
|
||||||
|
|||||||
@@ -2,12 +2,18 @@ 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 { ChartLine, FolderSearch, LockKeyhole } from "lucide-react";
|
import {
|
||||||
|
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[] = [
|
||||||
{
|
{
|
||||||
@@ -32,26 +38,40 @@ const tabs: Tab[] = [
|
|||||||
|
|
||||||
const ManageBucketPage = () => {
|
const ManageBucketPage = () => {
|
||||||
const { id } = useParams();
|
const { id } = useParams();
|
||||||
const { data, refetch } = useBucket(id);
|
const { data, error, isLoading, 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>
|
||||||
|
)}
|
||||||
|
</>
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@@ -84,7 +84,7 @@ const AllowKeyDialog = ({ currentKeys }: Props) => {
|
|||||||
Allow Key
|
Allow Key
|
||||||
</Button>
|
</Button>
|
||||||
|
|
||||||
<Modal ref={dialogRef} backdrop open={isOpen}>
|
<Modal ref={dialogRef} backdrop open={isOpen} className="max-w-2xl">
|
||||||
<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,6 +100,7 @@ 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"
|
||||||
@@ -129,23 +130,31 @@ const AllowKeyDialog = ({ currentKeys }: Props) => {
|
|||||||
<Table.Body>
|
<Table.Body>
|
||||||
{!keyFields.length ? (
|
{!keyFields.length ? (
|
||||||
<tr>
|
<tr>
|
||||||
<td colSpan={4} className="text-center">
|
<td colSpan={5} 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(
|
||||||
|
(key) => key.accessKeyId === field.keyId
|
||||||
|
);
|
||||||
|
return (
|
||||||
<Table.Row key={field.id}>
|
<Table.Row key={field.id}>
|
||||||
<CheckboxField
|
<CheckboxField
|
||||||
form={form}
|
form={form}
|
||||||
name={`keys.${index}.checked`}
|
name={`keys.${index}.checked`}
|
||||||
label={field.name || field.keyId?.substring(0, 8)}
|
label={field.name || field.keyId?.substring(0, 8)}
|
||||||
/>
|
/>
|
||||||
|
<span>
|
||||||
|
{curKey?.bucketLocalAliases?.join(", ") || "-"}
|
||||||
|
</span>
|
||||||
<CheckboxField form={form} name={`keys.${index}.read`} />
|
<CheckboxField form={form} name={`keys.${index}.read`} />
|
||||||
<CheckboxField form={form} name={`keys.${index}.write`} />
|
<CheckboxField form={form} name={`keys.${index}.write`} />
|
||||||
<CheckboxField form={form} name={`keys.${index}.owner`} />
|
<CheckboxField form={form} name={`keys.${index}.owner`} />
|
||||||
</Table.Row>
|
</Table.Row>
|
||||||
))}
|
);
|
||||||
|
})}
|
||||||
</Table.Body>
|
</Table.Body>
|
||||||
</Table>
|
</Table>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -50,6 +50,7 @@ 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>
|
||||||
@@ -61,6 +62,7 @@ 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}
|
||||||
|
|||||||
@@ -10,20 +10,27 @@ const BucketsPage = () => {
|
|||||||
const [search, setSearch] = useState("");
|
const [search, setSearch] = useState("");
|
||||||
|
|
||||||
const items = useMemo(() => {
|
const items = useMemo(() => {
|
||||||
let buckets = data || [];
|
let buckets =
|
||||||
|
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.globalAliases.find((alias) => alias.includes(q))
|
bucket.aliases.find((alias) => alias.includes(q))
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
buckets = buckets.sort((a, b) =>
|
buckets = buckets.sort((a, b) => a.aliases[0].localeCompare(b.aliases[0]));
|
||||||
a.globalAliases[0].localeCompare(b.globalAliases[0])
|
|
||||||
);
|
|
||||||
|
|
||||||
return buckets;
|
return buckets;
|
||||||
}, [data, search]);
|
}, [data, search]);
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ 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[];
|
||||||
@@ -17,11 +18,16 @@ 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: any[];
|
bucketLocalAliases: string[];
|
||||||
};
|
};
|
||||||
|
|
||||||
export type Permissions = {
|
export type Permissions = {
|
||||||
|
|||||||
@@ -1,42 +0,0 @@
|
|||||||
import Page from "@/context/page-context";
|
|
||||||
import { useEffect, useRef } from "react";
|
|
||||||
import { Terminal } from "@xterm/xterm";
|
|
||||||
import { AttachAddon } from "@xterm/addon-attach";
|
|
||||||
import "@xterm/xterm/css/xterm.css";
|
|
||||||
|
|
||||||
const WS_URL = "ws://" + location.host + "/ws";
|
|
||||||
|
|
||||||
const TerminalPage = () => {
|
|
||||||
const terminalContainerRef = useRef<HTMLDivElement | null>(null);
|
|
||||||
const wsRef = useRef<WebSocket | null>(null);
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
const container = terminalContainerRef.current;
|
|
||||||
if (!container || wsRef.current) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const url = WS_URL + "/terminal";
|
|
||||||
const ws = new WebSocket(url);
|
|
||||||
wsRef.current = ws;
|
|
||||||
|
|
||||||
const term = new Terminal();
|
|
||||||
const attachAddon = new AttachAddon(ws);
|
|
||||||
term.loadAddon(attachAddon);
|
|
||||||
term.open(container);
|
|
||||||
|
|
||||||
// return () => {
|
|
||||||
// term.dispose();
|
|
||||||
// ws.close();
|
|
||||||
// };
|
|
||||||
}, []);
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className="container">
|
|
||||||
<Page title="Terminal" />
|
|
||||||
<div ref={terminalContainerRef}></div>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
};
|
|
||||||
|
|
||||||
export default TerminalPage;
|
|
||||||
@@ -19,10 +19,6 @@ export default defineConfig(({ mode }) => {
|
|||||||
target: process.env.VITE_API_URL,
|
target: process.env.VITE_API_URL,
|
||||||
changeOrigin: true,
|
changeOrigin: true,
|
||||||
},
|
},
|
||||||
"/ws": {
|
|
||||||
target: process.env.VITE_API_URL?.replace("http", "ws"),
|
|
||||||
ws: true,
|
|
||||||
},
|
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user