10 Commits
26 changed files with 329 additions and 124 deletions
+4 -2
View File
@@ -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.1/garage-webui-v1.0.1-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
View File
@@ -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
) )
+2
View File
@@ -27,6 +27,8 @@ 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=
+1 -1
View File
@@ -16,7 +16,7 @@ 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()))
+89 -17
View File
@@ -16,6 +16,7 @@ import (
"github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/credentials" "github.com/aws/aws-sdk-go-v2/credentials"
"github.com/aws/aws-sdk-go-v2/service/s3" "github.com/aws/aws-sdk-go-v2/service/s3"
"github.com/aws/aws-sdk-go-v2/service/s3/types"
"github.com/aws/smithy-go" "github.com/aws/smithy-go"
) )
@@ -72,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),
}) })
} }
@@ -83,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 {
@@ -92,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),
@@ -108,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) {
@@ -183,6 +208,8 @@ func (b *Browse) PutObject(w http.ResponseWriter, r *http.Request) {
func (b *Browse) DeleteObject(w http.ResponseWriter, r *http.Request) { func (b *Browse) DeleteObject(w http.ResponseWriter, r *http.Request) {
bucket := r.PathValue("bucket") bucket := r.PathValue("bucket")
key := r.PathValue("key") key := r.PathValue("key")
recursive := r.URL.Query().Get("recursive") == "true"
isDirectory := strings.HasSuffix(key, "/")
client, err := getS3Client(bucket) client, err := getS3Client(bucket)
if err != nil { if err != nil {
@@ -190,7 +217,52 @@ func (b *Browse) DeleteObject(w http.ResponseWriter, r *http.Request) {
return return
} }
_, err = client.DeleteObject(context.Background(), &s3.DeleteObjectInput{ // Delete directory and its content
if isDirectory && recursive {
objects, err := client.ListObjectsV2(context.Background(), &s3.ListObjectsV2Input{
Bucket: aws.String(bucket),
Prefix: aws.String(key),
})
if err != nil {
utils.ResponseError(w, err)
return
}
if len(objects.Contents) == 0 {
utils.ResponseSuccess(w, true)
return
}
keys := make([]types.ObjectIdentifier, 0, len(objects.Contents))
for _, object := range objects.Contents {
keys = append(keys, types.ObjectIdentifier{
Key: object.Key,
})
}
res, err := client.DeleteObjects(context.Background(), &s3.DeleteObjectsInput{
Bucket: aws.String(bucket),
Delete: &types.Delete{Objects: keys},
})
if err != nil {
utils.ResponseError(w, fmt.Errorf("cannot delete object: %w", err))
return
}
if len(res.Errors) > 0 {
utils.ResponseError(w, fmt.Errorf("cannot delete object: %v", res.Errors[0]))
return
}
utils.ResponseSuccess(w, res)
return
}
// Delete single object
res, err := client.DeleteObject(context.Background(), &s3.DeleteObjectInput{
Bucket: aws.String(bucket), Bucket: aws.String(bucket),
Key: aws.String(key), Key: aws.String(key),
}) })
@@ -200,7 +272,7 @@ func (b *Browse) DeleteObject(w http.ResponseWriter, r *http.Request) {
return return
} }
utils.ResponseSuccess(w, nil) utils.ResponseSuccess(w, res)
} }
func getBucketCredentials(bucket string) (aws.CredentialsProvider, error) { func getBucketCredentials(bucket string) (aws.CredentialsProvider, error) {
@@ -252,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()),
} }
+4 -3
View File
@@ -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 -2
View File
@@ -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"`
} }
+8 -2
View File
@@ -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"`
} }
-6
View File
@@ -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
View File
@@ -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)
+26
View File
@@ -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 -1
View File
@@ -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",
+1 -1
View File
@@ -21,7 +21,7 @@ const MainLayout = () => {
<Drawer <Drawer
open={sidebar.isOpen} open={sidebar.isOpen}
onClickOverlay={sidebar.onClose} onClickOverlay={sidebar.onClose}
className="md:drawer-open h-screen" className="md:drawer-open h-screen max-h-dvh"
side={<Sidebar />} side={<Sidebar />}
contentClassName="flex flex-col overflow-hidden" contentClassName="flex flex-col overflow-hidden"
> >
+9 -11
View File
@@ -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>) {
+2 -2
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; 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>
+5 -2
View File
@@ -40,10 +40,13 @@ export const usePutObject = (
export const useDeleteObject = ( export const useDeleteObject = (
bucket: string, bucket: string,
options?: UseMutationOptions<any, Error, string> options?: UseMutationOptions<any, Error, { key: string; recursive?: boolean }>
) => { ) => {
return useMutation({ return useMutation({
mutationFn: (key) => api.delete(`/browse/${bucket}/${key}`), mutationFn: (data) =>
api.delete(`/browse/${bucket}/${data.key}`, {
params: { recursive: data.recursive },
}),
...options, ...options,
}); });
}; };
@@ -12,10 +12,11 @@ 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;
}; };
const ObjectActions = ({ prefix = "", object }: Props) => { const ObjectActions = ({ prefix = "", object, end }: Props) => {
const { bucketName } = useBucketContext(); const { bucketName } = useBucketContext();
const queryClient = useQueryClient(); const queryClient = useQueryClient();
const isDirectory = object.objectKey.endsWith("/"); const isDirectory = object.objectKey.endsWith("/");
@@ -29,12 +30,21 @@ const ObjectActions = ({ prefix = "", object }: 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 = () => {
if (window.confirm("Are you sure you want to delete this object?")) { if (
deleteObject.mutate(prefix + object.objectKey); window.confirm(
`Are you sure you want to delete this ${
isDirectory ? "directory and its content" : "object"
}?`
)
) {
deleteObject.mutate({
key: prefix + object.objectKey,
recursive: isDirectory,
});
} }
}; };
@@ -45,12 +55,12 @@ const ObjectActions = ({ prefix = "", object }: Props) => {
<Button icon={DownloadIcon} color="ghost" onClick={onDownload} /> <Button icon={DownloadIcon} color="ghost" onClick={onDownload} />
)} )}
<Dropdown end> <Dropdown end vertical={end ? "top" : "bottom"}>
<Dropdown.Toggle button={false}> <Dropdown.Toggle button={false}>
<Button icon={EllipsisVertical} color="ghost" /> <Button icon={EllipsisVertical} color="ghost" />
</Dropdown.Toggle> </Dropdown.Toggle>
<Dropdown.Menu className="bg-base-300 gap-y-1"> <Dropdown.Menu className="gap-y-1">
<Dropdown.Item <Dropdown.Item
onClick={() => onClick={() =>
shareDialog.open({ key: object.objectKey, prefix }) shareDialog.open({ key: object.objectKey, prefix })
+44 -12
View File
@@ -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 pb-32"> <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,11 +84,11 @@ 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>
))} ))}
{data?.objects.map((object) => { {data?.objects.map((object, idx) => {
const extIdx = object.objectKey.lastIndexOf("."); const extIdx = object.objectKey.lastIndexOf(".");
const filename = const filename =
extIdx >= 0 extIdx >= 0
@@ -93,7 +118,13 @@ const ObjectList = ({ prefix, onPrefixChange }: Props) => {
<td className="whitespace-nowrap"> <td className="whitespace-nowrap">
{dayjs(object.lastModified).fromNow()} {dayjs(object.lastModified).fromNow()}
</td> </td>
<ObjectActions prefix={data.prefix} object={object} /> <ObjectActions
prefix={data.prefix}
object={object}
end={
idx >= data.objects.length - 2 && data.objects.length > 5
}
/>
</tr> </tr>
); );
})} })}
@@ -121,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"
/> />
+1 -2
View File
@@ -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 = {
+24 -4
View File
@@ -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}
+12 -5
View File
@@ -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]);
+7 -1
View File
@@ -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 = {
+5 -2
View File
@@ -184,7 +184,7 @@ const NodesList = ({ nodes }: NodeListProps) => {
</Alert> </Alert>
) : null} ) : null}
<div className="w-full overflow-x-auto min-h-[400px] pb-16"> <div className="w-full overflow-x-auto overflow-y-hidden min-h-[400px]">
<Table size="sm" className="min-w-[800px]"> <Table size="sm" className="min-w-[800px]">
<Table.Head> <Table.Head>
<span>#</span> <span>#</span>
@@ -266,7 +266,10 @@ const NodesList = ({ nodes }: NodeListProps) => {
: "Inactive"} : "Inactive"}
</Badge> </Badge>
<Dropdown end> <Dropdown
end
vertical={idx >= items.length - 2 ? "top" : "bottom"}
>
<Dropdown.Toggle button={false}> <Dropdown.Toggle button={false}>
<Button shape="circle" color="ghost"> <Button shape="circle" color="ghost">
<EllipsisVertical /> <EllipsisVertical />
+1
View File
@@ -96,6 +96,7 @@ const KeysPage = () => {
icon={Eye} icon={Eye}
size="sm" size="sm"
onClick={() => fetchSecretKey(key.id)} onClick={() => fetchSecretKey(key.id)}
className="shrink-0 min-w-[80px]"
> >
View View
</Button> </Button>