Compare commits

..

14 Commits
1.0.7 ... main

Author SHA1 Message Date
a6640157c1 chore: bump version to 1.1.0 2025-09-01 09:42:26 +00:00
72411c7f97 feat: update to garage v2 api endpoint 2025-09-01 09:23:44 +00:00
90a1018235
Merge pull request #23 from LeeXN/19-garage-2.0-status
fix: update API endpoint for cluster status query
2025-09-01 15:58:33 +08:00
aeedaaa72e
Merge pull request #17 from jasonyang-ee/fix/https
fix: support https connection to garage api
2025-09-01 15:57:43 +08:00
LeeXN
c7d3d224ba fix: update API endpoint for cluster status query in garage v2.0.0(from /v1/status to /v2/GetClusterStatus 2025-08-06 10:46:24 +08:00
Jason Yang
5f0f200c03
fix: browser for bucket handle https connection using new resolver 2025-06-03 23:20:00 -07:00
Jason Yang
ff39a6cd82
feat: using scratch image w/ copy binary from other distro, and included healthcheck 2025-06-03 21:57:58 -07:00
Jason Yang
6c6b9b076b
fix: using full distro to include ca-certificate supporting https connection 2025-06-01 19:30:47 -07:00
b2bc905e3c chore: mark version 1.0.9 2025-04-15 14:04:50 +07:00
59e68455b6 fix: panic when download file 2025-04-15 03:20:04 +07:00
f30d4289f1 docs: update readme 2025-03-19 06:06:34 +07:00
e6e21d3c01 chore: mark version 1.0.8 2025-03-19 05:47:30 +07:00
2aaaf87dfd feat: add base path configuration 2025-03-19 05:36:01 +07:00
04a10eadfd fix: redirect to login after logout 2025-03-02 04:41:31 +07:00
25 changed files with 261 additions and 100 deletions

View File

@ -21,6 +21,12 @@ RUN make
FROM scratch FROM scratch
COPY --from=alpine /etc/ssl/certs/ca-certificates.crt /etc/ssl/certs/
COPY --from=ghcr.io/tarampampam/curl:8.6.0 /bin/curl /bin/curl
COPY --from=backend /app/main /bin/main COPY --from=backend /app/main /bin/main
CMD [ "/bin/main" ] HEALTHCHECK --interval=5m --timeout=2s --retries=3 --start-period=15s CMD [ \
"curl", "--fail", "http://127.0.0.1:3909" \
]
ENTRYPOINT [ "main" ]

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.1 image: dxflrs/garage:v2.0.0
container_name: garage container_name: garage
volumes: volumes:
- ./garage.toml:/etc/garage.toml - ./garage.toml:/etc/garage.toml
@ -41,7 +41,7 @@ services:
ports: ports:
- 3900:3900 - 3900:3900
- 3901:3901 - 3901:3901
- 3902:3903 - 3902:3902
- 3903:3903 - 3903:3903
webui: webui:
@ -62,7 +62,7 @@ services:
Get the latest binary from the [release page](https://github.com/khairul169/garage-webui/releases/latest) according to your OS architecture. For example: Get the latest binary from the [release page](https://github.com/khairul169/garage-webui/releases/latest) according to your OS architecture. For example:
```sh ```sh
$ wget -O garage-webui https://github.com/khairul169/garage-webui/releases/download/1.0.7/garage-webui-v1.0.7-linux-amd64 $ wget -O garage-webui https://github.com/khairul169/garage-webui/releases/download/1.1.0/garage-webui-v1.1.0-linux-amd64
$ chmod +x garage-webui $ chmod +x garage-webui
$ sudo cp garage-webui /usr/local/bin $ sudo cp garage-webui /usr/local/bin
``` ```
@ -136,9 +136,14 @@ admin_token = "YOUR_ADMIN_TOKEN_HERE"
metrics_token = "YOUR_METRICS_TOKEN_HERE" metrics_token = "YOUR_METRICS_TOKEN_HERE"
``` ```
However, if it fails to load, you can set these environment variables instead: However, if it fails to load, you can set `API_BASE_URL` & `API_ADMIN_KEY` environment variables instead.
### Environment Variables
Configurable envs:
- `CONFIG_PATH`: Path to the Garage `config.toml` file. Defaults to `/etc/garage.toml`. - `CONFIG_PATH`: Path to the Garage `config.toml` file. Defaults to `/etc/garage.toml`.
- `BASE_PATH`: Base path or prefix for Web UI.
- `API_BASE_URL`: Garage admin API endpoint URL. - `API_BASE_URL`: Garage admin API endpoint URL.
- `API_ADMIN_KEY`: Admin API key. - `API_ADMIN_KEY`: Admin API key.
- `S3_REGION`: S3 Region. - `S3_REGION`: S3 Region.
@ -146,7 +151,9 @@ However, if it fails to load, you can set these environment variables instead:
### Authentication ### Authentication
Enable authentication by setting `AUTH_USER_PASS` environment variable. Generate the username and password hash using the following command: 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 ```bash
htpasswd -nbBC 10 "YOUR_USERNAME" "YOUR_PASSWORD" htpasswd -nbBC 10 "YOUR_USERNAME" "YOUR_PASSWORD"

6
backend/.env.example Normal file
View File

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

View File

@ -7,6 +7,7 @@ import (
"khairul169/garage-webui/utils" "khairul169/garage-webui/utils"
"log" "log"
"net/http" "net/http"
"os"
"github.com/joho/godotenv" "github.com/joho/godotenv"
) )
@ -21,10 +22,21 @@ func main() {
log.Println("Cannot load garage config!", err) log.Println("Cannot load garage config!", err)
} }
basePath := os.Getenv("BASE_PATH")
mux := http.NewServeMux() mux := http.NewServeMux()
mux.Handle("/api/", http.StripPrefix("/api", router.HandleApiRouter()))
// Serve API
apiPrefix := basePath + "/api"
mux.Handle(apiPrefix+"/", http.StripPrefix(apiPrefix, router.HandleApiRouter()))
// Static files
ui.ServeUI(mux) 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")

View File

@ -146,11 +146,20 @@ func (b *Browse) GetOneObject(w http.ResponseWriter, r *http.Request) {
return return
} }
w.Header().Set("Content-Type", *object.ContentType)
w.Header().Set("Content-Length", strconv.FormatInt(*object.ContentLength, 10))
w.Header().Set("Cache-Control", "max-age=86400") w.Header().Set("Cache-Control", "max-age=86400")
w.Header().Set("Last-Modified", object.LastModified.Format(time.RFC1123)) w.Header().Set("Last-Modified", object.LastModified.Format(time.RFC1123))
if object.ContentType != nil {
w.Header().Set("Content-Type", *object.ContentType)
} else {
w.Header().Set("Content-Type", "application/octet-stream")
}
if object.ContentLength != nil {
w.Header().Set("Content-Length", strconv.FormatInt(*object.ContentLength, 10))
}
if object.ETag != nil {
w.Header().Set("Etag", *object.ETag) w.Header().Set("Etag", *object.ETag)
}
_, err = io.Copy(w, object.Body) _, err = io.Copy(w, object.Body)
@ -283,7 +292,7 @@ func getBucketCredentials(bucket string) (aws.CredentialsProvider, error) {
return cacheData.(aws.CredentialsProvider), nil return cacheData.(aws.CredentialsProvider), nil
} }
body, err := utils.Garage.Fetch("/v1/bucket?globalAlias="+bucket, &utils.FetchOptions{}) body, err := utils.Garage.Fetch("/v2/GetBucketInfo?globalAlias="+bucket, &utils.FetchOptions{})
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -300,7 +309,7 @@ func getBucketCredentials(bucket string) (aws.CredentialsProvider, error) {
continue continue
} }
body, err := utils.Garage.Fetch(fmt.Sprintf("/v1/key?id=%s&showSecretKey=true", k.AccessKeyID), &utils.FetchOptions{}) body, err := utils.Garage.Fetch(fmt.Sprintf("/v2/GetKeyInfo?id=%s&showSecretKey=true", k.AccessKeyID), &utils.FetchOptions{})
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -322,15 +331,26 @@ func getS3Client(bucket string) (*s3.Client, error) {
return nil, fmt.Errorf("cannot get credentials for bucket %s: %w", bucket, err) return nil, fmt.Errorf("cannot get credentials for bucket %s: %w", bucket, err)
} }
// Determine endpoint and whether to disable HTTPS
endpoint := utils.Garage.GetS3Endpoint()
disableHTTPS := !strings.HasPrefix(endpoint, "https://")
// AWS config without BaseEndpoint
awsConfig := aws.Config{ awsConfig := aws.Config{
Credentials: creds, Credentials: creds,
Region: utils.Garage.GetS3Region(), Region: utils.Garage.GetS3Region(),
BaseEndpoint: aws.String(utils.Garage.GetS3Endpoint()),
} }
// Build S3 client with custom endpoint resolver for proper signing
client := s3.NewFromConfig(awsConfig, func(o *s3.Options) { client := s3.NewFromConfig(awsConfig, func(o *s3.Options) {
o.UsePathStyle = true o.UsePathStyle = true
o.EndpointOptions.DisableHTTPS = true o.EndpointOptions.DisableHTTPS = disableHTTPS
o.EndpointResolver = s3.EndpointResolverFunc(func(region string, opts s3.EndpointResolverOptions) (aws.Endpoint, error) {
return aws.Endpoint{
URL: endpoint,
SigningRegion: utils.Garage.GetS3Region(),
}, nil
})
}) })
return client, nil return client, nil

View File

@ -11,7 +11,7 @@ import (
type Buckets struct{} type Buckets struct{}
func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) { func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) {
body, err := utils.Garage.Fetch("/v1/bucket?list", &utils.FetchOptions{}) body, err := utils.Garage.Fetch("/v2/ListBuckets", &utils.FetchOptions{})
if err != nil { if err != nil {
utils.ResponseError(w, err) utils.ResponseError(w, err)
return return
@ -27,7 +27,7 @@ func (b *Buckets) GetAll(w http.ResponseWriter, r *http.Request) {
for _, bucket := range buckets { for _, bucket := range buckets {
go func() { go func() {
body, err := utils.Garage.Fetch(fmt.Sprintf("/v1/bucket?id=%s", bucket.ID), &utils.FetchOptions{}) body, err := utils.Garage.Fetch(fmt.Sprintf("/v2/GetBucketInfo?id=%s", bucket.ID), &utils.FetchOptions{})
if err != nil { if err != nil {
ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases} ch <- schema.Bucket{ID: bucket.ID, GlobalAliases: bucket.GlobalAliases}

View File

@ -4,6 +4,7 @@ type GetBucketsRes struct {
ID string `json:"id"` ID string `json:"id"`
GlobalAliases []string `json:"globalAliases"` GlobalAliases []string `json:"globalAliases"`
LocalAliases []LocalAlias `json:"localAliases"` LocalAliases []LocalAlias `json:"localAliases"`
Created string `json:"created"`
} }
type Bucket struct { type Bucket struct {
@ -20,6 +21,7 @@ type Bucket struct {
UnfinishedMultipartUploadParts int64 `json:"unfinishedMultipartUploadParts"` UnfinishedMultipartUploadParts int64 `json:"unfinishedMultipartUploadParts"`
UnfinishedMultipartUploadBytes int64 `json:"unfinishedMultipartUploadBytes"` UnfinishedMultipartUploadBytes int64 `json:"unfinishedMultipartUploadBytes"`
Quotas Quotas `json:"quotas"` Quotas Quotas `json:"quotas"`
Created string `json:"created"`
} }
type LocalAlias struct { type LocalAlias struct {

View File

@ -7,7 +7,10 @@ import (
"embed" "embed"
"io/fs" "io/fs"
"net/http" "net/http"
"os"
"path" "path"
"regexp"
"strings"
) )
//go:embed dist //go:embed dist
@ -16,19 +19,45 @@ var embeddedFs embed.FS
func ServeUI(mux *http.ServeMux) { func ServeUI(mux *http.ServeMux) {
distFs, _ := fs.Sub(embeddedFs, "dist") distFs, _ := fs.Sub(embeddedFs, "dist")
fileServer := http.FileServer(http.FS(distFs)) fileServer := http.FileServer(http.FS(distFs))
basePath := os.Getenv("BASE_PATH")
mux.Handle("/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { mux.Handle(basePath+"/", http.StripPrefix(basePath, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
_path := path.Clean(r.URL.Path)[1:] _path := path.Clean(r.URL.Path)[1:]
// Rewrite non-existing paths to index.html // Rewrite non-existing paths to index.html
if _, err := fs.Stat(distFs, _path); err != nil { if _, err := fs.Stat(distFs, _path); err != nil {
index, _ := fs.ReadFile(distFs, "index.html") index, _ := fs.ReadFile(distFs, "index.html")
html := string(index)
// Set base path for the UI
html = strings.ReplaceAll(html, "%BASE_PATH%", basePath)
html = addBasePath(html, basePath)
w.Header().Add("Content-Type", "text/html") w.Header().Add("Content-Type", "text/html")
w.WriteHeader(http.StatusOK) w.WriteHeader(http.StatusOK)
w.Write(index) w.Write([]byte(html))
return
}
// Add prefix to each /assets strings in js
if len(basePath) > 0 && strings.HasSuffix(_path, ".js") {
data, _ := fs.ReadFile(distFs, _path)
html := string(data)
html = strings.ReplaceAll(html, "assets/", basePath[1:]+"/assets/")
w.Header().Add("Content-Type", "text/javascript")
w.WriteHeader(http.StatusOK)
w.Write([]byte(html))
return return
} }
fileServer.ServeHTTP(w, r) fileServer.ServeHTTP(w, r)
})) })))
}
func addBasePath(html string, basePath string) string {
re := regexp.MustCompile(`(href|src)=["'](/[^"'>]+)["']`)
return re.ReplaceAllStringFunc(html, func(match string) string {
return re.ReplaceAllString(match, `$1="`+basePath+`$2"`)
})
} }

View File

@ -1,6 +1,6 @@
services: services:
garage: garage:
image: dxflrs/garage:v1.0.1 image: dxflrs/garage:v2.0.0
container_name: garage container_name: garage
volumes: volumes:
- ./garage.toml:/etc/garage.toml - ./garage.toml:/etc/garage.toml
@ -24,4 +24,3 @@ services:
environment: environment:
API_BASE_URL: "http://garage:3903" API_BASE_URL: "http://garage:3903"
S3_ENDPOINT_URL: "http://garage:3900" S3_ENDPOINT_URL: "http://garage:3900"

View File

@ -10,6 +10,9 @@
<link rel="manifest" href="/site.webmanifest" /> <link rel="manifest" href="/site.webmanifest" />
<title>Garage Web UI</title> <title>Garage Web UI</title>
<script>
window.__BASE_PATH = "%BASE_PATH%";
</script>
</head> </head>
<body> <body>
<div id="root"></div> <div id="root"></div>

View File

@ -1,7 +1,7 @@
{ {
"name": "garage-webui", "name": "garage-webui",
"private": true, "private": true,
"version": "1.0.7", "version": "1.1.0",
"type": "module", "type": "module",
"scripts": { "scripts": {
"dev:client": "vite", "dev:client": "vite",

View File

@ -2,6 +2,7 @@ import { createBrowserRouter, RouterProvider } from "react-router-dom";
import { lazy, Suspense } from "react"; import { lazy, Suspense } from "react";
import AuthLayout from "@/components/layouts/auth-layout"; import AuthLayout from "@/components/layouts/auth-layout";
import MainLayout from "@/components/layouts/main-layout"; import MainLayout from "@/components/layouts/main-layout";
import { BASE_PATH } from "@/lib/consts";
const LoginPage = lazy(() => import("@/pages/auth/login")); const LoginPage = lazy(() => import("@/pages/auth/login"));
const ClusterPage = lazy(() => import("@/pages/cluster/page")); const ClusterPage = lazy(() => import("@/pages/cluster/page"));
@ -10,7 +11,8 @@ 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", path: "/auth",
Component: AuthLayout, Component: AuthLayout,
@ -46,7 +48,11 @@ const router = createBrowserRouter([
}, },
], ],
}, },
]); ],
{
basename: BASE_PATH,
}
);
const Router = () => { const Router = () => {
return ( return (

View File

@ -13,8 +13,9 @@ 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, useQueryClient } from "@tanstack/react-query"; import { useMutation } from "@tanstack/react-query";
import api from "@/lib/api"; import api from "@/lib/api";
import * as utils from "@/lib/utils";
import { toast } from "sonner"; import { toast } from "sonner";
import { useAuth } from "@/hooks/useAuth"; import { useAuth } from "@/hooks/useAuth";
@ -90,12 +91,10 @@ const Sidebar = () => {
}; };
const LogoutButton = () => { const LogoutButton = () => {
const queryClient = useQueryClient();
const logout = useMutation({ const logout = useMutation({
mutationFn: () => api.post("/auth/logout"), mutationFn: () => api.post("/auth/logout"),
onSuccess: () => { onSuccess: () => {
queryClient.invalidateQueries({ queryKey: ["auth"] }); window.location.href = utils.url("/auth/login");
}, },
onError: (err) => { onError: (err) => {
toast.error(err?.message || "Unknown error"); toast.error(err?.message || "Unknown error");

7
src/global.d.ts vendored Normal file
View File

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

View File

@ -1,10 +1,23 @@
import * as utils from "@/lib/utils";
import { BASE_PATH } from "./consts";
type FetchOptions = Omit<RequestInit, "headers" | "body"> & { type FetchOptions = Omit<RequestInit, "headers" | "body"> & {
params?: Record<string, any>; params?: Record<string, any>;
headers?: Record<string, string>; headers?: Record<string, string>;
body?: any; body?: any;
}; };
export const API_URL = "/api"; export const API_URL = BASE_PATH + "/api";
export class APIError extends Error {
status!: number;
constructor(message: string, status: number = 400) {
super(message);
this.name = "APIError";
this.status = status;
}
}
const api = { const api = {
async fetch<T = any>(url: string, options?: Partial<FetchOptions>) { async fetch<T = any>(url: string, options?: Partial<FetchOptions>) {
@ -36,13 +49,18 @@ const api = {
?.includes("application/json"); ?.includes("application/json");
const data = isJson ? await res.json() : await res.text(); const data = isJson ? await res.json() : await res.text();
if (res.status === 401 && !url.startsWith("/auth")) {
window.location.href = utils.url("/auth/login");
throw new APIError("unauthorized", res.status);
}
if (!res.ok) { if (!res.ok) {
const message = isJson const message = isJson
? data?.message ? data?.message
: typeof data === "string" : typeof data === "string"
? data ? data
: res.statusText; : res.statusText;
throw new Error(message); throw new APIError(message, res.status);
} }
return data as unknown as T; return data as unknown as T;

6
src/lib/consts.ts Normal file
View File

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

View File

@ -3,6 +3,7 @@ import { toast } from "sonner";
import { twMerge } from "tailwind-merge"; import { twMerge } from "tailwind-merge";
import dayjsRelativeTime from "dayjs/plugin/relativeTime"; import dayjsRelativeTime from "dayjs/plugin/relativeTime";
import dayjs from "dayjs"; import dayjs from "dayjs";
import { BASE_PATH } from "./consts";
dayjs.extend(dayjsRelativeTime); dayjs.extend(dayjsRelativeTime);
export { dayjs }; export { dayjs };
@ -53,3 +54,7 @@ export const copyToClipboard = async (text: string) => {
textArea?.remove(); textArea?.remove();
} }
}; };
export const url = (...paths: unknown[]) => {
return BASE_PATH + paths.join("/");
};

View File

@ -18,7 +18,7 @@ export const useCreateBucket = (
options?: UseMutationOptions<any, Error, CreateBucketSchema> options?: UseMutationOptions<any, Error, CreateBucketSchema>
) => { ) => {
return useMutation({ return useMutation({
mutationFn: (body) => api.post("/v1/bucket", { body }), mutationFn: (body) => api.post("/v2/CreateBucket", { body }),
...options, ...options,
}); });
}; };

View File

@ -10,7 +10,7 @@ import { Bucket, Permissions } from "../types";
export const useBucket = (id?: string | null) => { export const useBucket = (id?: string | null) => {
return useQuery({ return useQuery({
queryKey: ["bucket", id], queryKey: ["bucket", id],
queryFn: () => api.get<Bucket>("/v1/bucket", { params: { id } }), queryFn: () => api.get<Bucket>("/v2/GetBucketInfo", { params: { id } }),
enabled: !!id, enabled: !!id,
}); });
}; };
@ -18,7 +18,10 @@ export const useBucket = (id?: string | null) => {
export const useUpdateBucket = (id?: string | null) => { export const useUpdateBucket = (id?: string | null) => {
return useMutation({ return useMutation({
mutationFn: (values: any) => { mutationFn: (values: any) => {
return api.put<any>("/v1/bucket", { params: { id }, body: values }); return api.post<any>("/v2/UpdateBucket", {
params: { id },
body: values,
});
}, },
}); });
}; };
@ -29,8 +32,8 @@ export const useAddAlias = (
) => { ) => {
return useMutation({ return useMutation({
mutationFn: (alias: string) => { mutationFn: (alias: string) => {
return api.put("/v1/bucket/alias/global", { return api.post("/v2/AddBucketAlias", {
params: { id: bucketId, alias }, body: { bucketId, globalAlias: alias },
}); });
}, },
...options, ...options,
@ -43,8 +46,8 @@ export const useRemoveAlias = (
) => { ) => {
return useMutation({ return useMutation({
mutationFn: (alias: string) => { mutationFn: (alias: string) => {
return api.delete("/v1/bucket/alias/global", { return api.post("/v2/RemoveBucketAlias", {
params: { id: bucketId, alias }, body: { bucketId, globalAlias: alias },
}); });
}, },
...options, ...options,
@ -62,8 +65,7 @@ export const useAllowKey = (
return useMutation({ return useMutation({
mutationFn: async (payload) => { mutationFn: async (payload) => {
const promises = payload.map(async (key) => { const promises = payload.map(async (key) => {
console.log("test", key); return api.post("/v2/AllowBucketKey", {
return api.post("/v1/bucket/allow", {
body: { body: {
bucketId, bucketId,
accessKeyId: key.keyId, accessKeyId: key.keyId,
@ -88,7 +90,7 @@ export const useDenyKey = (
) => { ) => {
return useMutation({ return useMutation({
mutationFn: (payload) => { mutationFn: (payload) => {
return api.post("/v1/bucket/deny", { return api.post("/v2/DenyBucketKey", {
body: { body: {
bucketId, bucketId,
accessKeyId: payload.keyId, accessKeyId: payload.keyId,
@ -104,7 +106,7 @@ export const useRemoveBucket = (
options?: MutationOptions<any, Error, string> options?: MutationOptions<any, Error, string>
) => { ) => {
return useMutation({ return useMutation({
mutationFn: (id) => api.delete("/v1/bucket", { params: { id } }), mutationFn: (id) => api.post("/v2/DeleteBucket", { params: { id } }),
...options, ...options,
}); });
}; };

View File

@ -3,6 +3,7 @@ import {
ApplyLayoutResult, ApplyLayoutResult,
AssignNodeBody, AssignNodeBody,
GetClusterLayoutResult, GetClusterLayoutResult,
GetNodeInfoResult,
GetStatusResult, GetStatusResult,
} from "./types"; } from "./types";
import { import {
@ -11,24 +12,37 @@ import {
useQuery, useQuery,
} from "@tanstack/react-query"; } from "@tanstack/react-query";
export const useNodeInfo = () => {
return useQuery({
queryKey: ["node-info"],
queryFn: () =>
api.get<GetNodeInfoResult>("/v2/GetNodeInfo", {
params: { node: "self" },
}),
select: (data) => Object.values(data?.success || {})?.[0],
});
};
export const useClusterStatus = () => { export const useClusterStatus = () => {
return useQuery({ return useQuery({
queryKey: ["status"], queryKey: ["status"],
queryFn: () => api.get<GetStatusResult>("/v1/status"), queryFn: () => api.get<GetStatusResult>("/v2/GetClusterStatus"),
}); });
}; };
export const useClusterLayout = () => { export const useClusterLayout = () => {
return useQuery({ return useQuery({
queryKey: ["layout"], queryKey: ["layout"],
queryFn: () => api.get<GetClusterLayoutResult>("/v1/layout"), queryFn: () => api.get<GetClusterLayoutResult>("/v2/GetClusterLayout"),
}); });
}; };
export const useConnectNode = (options?: Partial<UseMutationOptions>) => { export const useConnectNode = (options?: Partial<UseMutationOptions>) => {
return useMutation<any, Error, string>({ return useMutation<any, Error, string>({
mutationFn: async (nodeId) => { mutationFn: async (nodeId) => {
const [res] = await api.post("/v1/connect", { body: [nodeId] }); const [res] = await api.post("/v2/ConnectClusterNodes", {
body: [nodeId],
});
if (!res.success) { if (!res.success) {
throw new Error(res.error || "Unknown error"); throw new Error(res.error || "Unknown error");
} }
@ -40,7 +54,10 @@ export const useConnectNode = (options?: Partial<UseMutationOptions>) => {
export const useAssignNode = (options?: Partial<UseMutationOptions>) => { export const useAssignNode = (options?: Partial<UseMutationOptions>) => {
return useMutation<any, Error, AssignNodeBody>({ return useMutation<any, Error, AssignNodeBody>({
mutationFn: (data) => api.post("/v1/layout", { body: [data] }), mutationFn: (data) =>
api.post("/v2/UpdateClusterLayout", {
body: { parameters: null, roles: [data] },
}),
...(options as any), ...(options as any),
}); });
}; };
@ -48,15 +65,16 @@ export const useAssignNode = (options?: Partial<UseMutationOptions>) => {
export const useUnassignNode = (options?: Partial<UseMutationOptions>) => { export const useUnassignNode = (options?: Partial<UseMutationOptions>) => {
return useMutation<any, Error, string>({ return useMutation<any, Error, string>({
mutationFn: (nodeId) => mutationFn: (nodeId) =>
api.post("/v1/layout", { body: [{ id: nodeId, remove: true }] }), api.post("/v2/UpdateClusterLayout", {
body: { parameters: null, roles: [{ id: nodeId, remove: true }] },
}),
...(options as any), ...(options as any),
}); });
}; };
export const useRevertChanges = (options?: Partial<UseMutationOptions>) => { export const useRevertChanges = (options?: Partial<UseMutationOptions>) => {
return useMutation<any, Error, number>({ return useMutation<any, Error, number>({
mutationFn: (version) => mutationFn: () => api.post("/v2/RevertClusterLayout"),
api.post("/v1/layout/revert", { body: { version } }),
...(options as any), ...(options as any),
}); });
}; };
@ -64,7 +82,7 @@ export const useRevertChanges = (options?: Partial<UseMutationOptions>) => {
export const useApplyChanges = (options?: Partial<UseMutationOptions>) => { export const useApplyChanges = (options?: Partial<UseMutationOptions>) => {
return useMutation<ApplyLayoutResult, Error, number>({ return useMutation<ApplyLayoutResult, Error, number>({
mutationFn: (version) => mutationFn: (version) =>
api.post("/v1/layout/apply", { body: { version } }), api.post("/v2/ApplyClusterLayout", { body: { version } }),
...(options as any), ...(options as any),
}); });
}; };

View File

@ -1,11 +1,13 @@
import Page from "@/context/page-context"; import Page from "@/context/page-context";
import { useClusterStatus } from "./hooks"; import { useClusterStatus, useNodeInfo } from "./hooks";
import { Card } from "react-daisyui"; import { Card } from "react-daisyui";
import NodesList from "./components/nodes-list"; import NodesList from "./components/nodes-list";
import { useMemo } from "react"; import { useMemo } from "react";
const ClusterPage = () => { const ClusterPage = () => {
const { data } = useClusterStatus(); const { data } = useClusterStatus();
const { data: node } = useNodeInfo();
const nodes = useMemo(() => { const nodes = useMemo(() => {
if (!data) return []; if (!data) return [];
@ -27,13 +29,13 @@ const ClusterPage = () => {
<Card.Body className="gap-1"> <Card.Body className="gap-1">
<Card.Title className="mb-2">Details</Card.Title> <Card.Title className="mb-2">Details</Card.Title>
<DetailItem title="Node ID" value={data?.node} /> {/* <DetailItem title="Node ID" value={node?.nodeId} /> */}
<DetailItem title="Version" value={data?.garageVersion} /> <DetailItem title="Garage Version" value={node?.garageVersion} />
{/* <DetailItem title="Rust version" value={data?.rustVersion} /> */} {/* <DetailItem title="Rust version" value={data?.rustVersion} /> */}
<DetailItem title="DB engine" value={data?.dbEngine} /> <DetailItem title="DB engine" value={node?.dbEngine} />
<DetailItem <DetailItem
title="Layout version" title="Layout version"
value={data?.layoutVersion || data?.layout?.version} value={data?.layoutVersion || data?.layout?.version || "-"}
/> />
</Card.Body> </Card.Body>
</Card> </Card>

View File

@ -1,5 +1,19 @@
// //
export type GetNodeInfoResult = {
success: {
[key: string]: {
nodeId: string;
garageVersion: string;
garageFeatures: string[];
rustVersion: string;
dbEngine: string;
};
};
error: Error;
}
export type GetStatusResult = { export type GetStatusResult = {
node: string; node: string;
garageVersion: string; garageVersion: string;

View File

@ -5,6 +5,6 @@ import { useQuery } from "@tanstack/react-query";
export const useNodesHealth = () => { export const useNodesHealth = () => {
return useQuery({ return useQuery({
queryKey: ["health"], queryKey: ["health"],
queryFn: () => api.get<GetHealthResult>("/v1/health"), queryFn: () => api.get<GetHealthResult>("/v2/GetClusterHealth"),
}); });
}; };

View File

@ -10,7 +10,7 @@ import { CreateKeySchema } from "./schema";
export const useKeys = () => { export const useKeys = () => {
return useQuery({ return useQuery({
queryKey: ["keys"], queryKey: ["keys"],
queryFn: () => api.get<Key[]>("/v1/key?list"), queryFn: () => api.get<Key[]>("/v2/ListKeys"),
}); });
}; };
@ -20,9 +20,9 @@ export const useCreateKey = (
return useMutation({ return useMutation({
mutationFn: async (body) => { mutationFn: async (body) => {
if (body.isImport) { if (body.isImport) {
return api.post("/v1/key/import", { body }); return api.post("/v2/ImportKey", { body });
} }
return api.post("/v1/key", { body }); return api.post("/v2/CreateKey", { body });
}, },
...options, ...options,
}); });
@ -32,7 +32,7 @@ export const useRemoveKey = (
options?: UseMutationOptions<any, Error, string> options?: UseMutationOptions<any, Error, string>
) => { ) => {
return useMutation({ return useMutation({
mutationFn: (id) => api.delete("/v1/key", { params: { id } }), mutationFn: (id) => api.post("/v2/DeleteKey", { params: { id } }),
...options, ...options,
}); });
}; };

View File

@ -24,7 +24,7 @@ const KeysPage = () => {
const fetchSecretKey = useCallback(async (id: string) => { const fetchSecretKey = useCallback(async (id: string) => {
try { try {
const result = await api.get("/v1/key", { const result = await api.get("/v2/GetKeyInfo", {
params: { id, showSecretKey: "true" }, params: { id, showSecretKey: "true" },
}); });
if (!result?.secretAccessKey) { if (!result?.secretAccessKey) {