fix: machine selections

This commit is contained in:
bennykok 2024-01-30 11:14:46 +08:00
parent b0b23783ba
commit 0d1bb2aaf4
3 changed files with 207 additions and 185 deletions

View File

@ -8,8 +8,8 @@ import {
OpenEditButton, OpenEditButton,
RunWorkflowButton, RunWorkflowButton,
VersionSelect, VersionSelect,
ViewWorkflowDetailsButton,
} from "@/components/VersionSelect"; } from "@/components/VersionSelect";
import { ViewWorkflowDetailsButton } from "@/components/ViewWorkflowDetailsButton";
import { import {
Card, Card,
CardContent, CardContent,

View File

@ -2,7 +2,6 @@
import { LoadingIcon } from "@/components/LoadingIcon"; import { LoadingIcon } from "@/components/LoadingIcon";
import AutoForm, { AutoFormSubmit } from "@/components/ui/auto-form"; import AutoForm, { AutoFormSubmit } from "@/components/ui/auto-form";
import { Badge } from "@/components/ui/badge";
import { Button } from "@/components/ui/button"; import { Button } from "@/components/ui/button";
import { import {
Dialog, Dialog,
@ -28,36 +27,19 @@ import {
SelectValue, SelectValue,
} from "@/components/ui/select"; } from "@/components/ui/select";
import { Skeleton } from "@/components/ui/skeleton"; import { Skeleton } from "@/components/ui/skeleton";
import { import type { showcaseMediaNullable } from "@/db/schema";
Table,
TableBody,
TableCell,
TableHead,
TableHeader,
TableRow,
} from "@/components/ui/table";
import type { showcaseMediaNullable, workflowAPINodeType } from "@/db/schema";
import { checkStatus, createRun } from "@/server/createRun"; import { checkStatus, createRun } from "@/server/createRun";
import { createDeployments } from "@/server/curdDeploments"; import { createDeployments } from "@/server/curdDeploments";
import type { getMachines } from "@/server/curdMachine"; import type { getMachines } from "@/server/curdMachine";
import type { findFirstTableWithVersion } from "@/server/findFirstTableWithVersion"; import type { findFirstTableWithVersion } from "@/server/findFirstTableWithVersion";
import { import { Copy, Edit, MoreVertical, Play } from "lucide-react";
Copy,
Edit,
ExternalLink,
Info,
MoreVertical,
Play,
} from "lucide-react";
import { parseAsInteger, useQueryState } from "next-usequerystate"; import { parseAsInteger, useQueryState } from "next-usequerystate";
import { useCallback, useEffect, useMemo, useState } from "react"; import { useCallback, useEffect, useMemo, useState } from "react";
import { toast } from "sonner"; import { toast } from "sonner";
import useSWR from "swr";
import type { z } from "zod"; import type { z } from "zod";
import { create } from "zustand"; import { create } from "zustand";
import { workflowVersionInputsToZod } from "../lib/workflowVersionInputsToZod"; import { workflowVersionInputsToZod } from "../lib/workflowVersionInputsToZod";
import { callServerPromise } from "./callServerPromise"; import { callServerPromise } from "./callServerPromise";
import fetcher from "./fetcher";
import { ButtonAction } from "@/components/ButtonActionLoader"; import { ButtonAction } from "@/components/ButtonActionLoader";
import { editWorkflowOnMachine } from "@/server/editWorkflowOnMachine"; import { editWorkflowOnMachine } from "@/server/editWorkflowOnMachine";
import { usePathname, useRouter, useSearchParams } from "next/navigation"; import { usePathname, useRouter, useSearchParams } from "next/navigation";
@ -125,29 +107,47 @@ export function MachineSelect({
); );
} }
type SelectedMachineStore = {
selectedMachine: string;
setSelectedMachine: (machine: string) => void;
};
export const selectedMachineStore = create<SelectedMachineStore>((set) => ({
selectedMachine: "",
setSelectedMachine: (machine) => set(() => ({ selectedMachine: machine })),
}));
export function useSelectedMachine( export function useSelectedMachine(
machines: Awaited<ReturnType<typeof getMachines>>, machines: Awaited<ReturnType<typeof getMachines>>,
): [string, (v: string) => void] { ): [string, (v: string) => void] {
const searchParams = useSearchParams(); const { selectedMachine, setSelectedMachine } = selectedMachineStore();
const pathname = usePathname(); return [selectedMachine, setSelectedMachine];
const router = useRouter(); // const searchParams = useSearchParams();
// const pathname = usePathname();
// const router = useRouter();
const createQueryString = useCallback( // const createQueryString = useCallback(
(name: string, value: string) => { // (name: string, value: string) => {
const params = new URLSearchParams(searchParams.toString()); // const params = new URLSearchParams(searchParams.toString());
params.set(name, value); // params.set(name, value);
return params.toString(); // return params.toString();
}, // },
[searchParams], // [searchParams],
); // );
return [ // return [
searchParams.get("machine") ?? machines?.[0]?.id ?? "", // searchParams.get("machine") ?? machines?.[0]?.id ?? "",
(v: string) => { // (v: string) => {
router.push(pathname + "?" + createQueryString("machine", v)); // // window.history.pushState(
}, // // "new url",
]; // // "",
// // pathname + "?" + createQueryString("machine", v),
// // );
// // router.push(pathname + "?" + createQueryString("machine", v));
// router.replace(pathname + "?" + createQueryString("machine", v));
// },
// ];
} }
type PublicRunStore = { type PublicRunStore = {
@ -500,150 +500,3 @@ export function getWorkflowVersionFromVersionIndex(
return workflow_version; return workflow_version;
} }
export function ViewWorkflowDetailsButton({
workflow,
}: {
workflow: Awaited<ReturnType<typeof findFirstTableWithVersion>>;
}) {
const [version] = useQueryState("version", {
defaultValue: workflow?.versions[0].version ?? 1,
...parseAsInteger,
});
const [isLoading, setIsLoading] = useState(false);
const [open, setOpen] = useState(false);
const {
data,
error,
isLoading: isNodesIndexLoading,
} = useSWR(
"https://raw.githubusercontent.com/ltdrdata/ComfyUI-Manager/main/extension-node-map.json",
fetcher,
);
const groupedByAuxName = useMemo(() => {
if (!data) return null;
// console.log(data);
const workflow_version = getWorkflowVersionFromVersionIndex(
workflow,
version,
);
const api = workflow_version?.workflow_api;
if (!api) return null;
const crossCheckedApi = Object.entries(api)
.map(([_, value]) => {
const classType = value.class_type;
const classTypeData = Object.entries(data).find(([_, nodeArray]) =>
nodeArray[0].includes(classType),
);
return classTypeData ? { node: value, classTypeData } : null;
})
.filter((item) => item !== null);
// console.log(crossCheckedApi);
const groupedByAuxName = crossCheckedApi.reduce(
(acc, data) => {
if (!data) return acc;
const { node, classTypeData } = data;
const auxName = classTypeData[1][1].title_aux;
// console.log(auxName);
if (!acc[auxName]) {
acc[auxName] = {
url: classTypeData[0],
node: [],
};
}
acc[auxName].node.push(node);
return acc;
},
{} as Record<
string,
{
node: z.infer<typeof workflowAPINodeType>[];
url: string;
}
>,
);
// console.log(groupedByAuxName);
return groupedByAuxName;
}, [version, data]);
return (
<Dialog open={open} onOpenChange={setOpen}>
<DialogTrigger asChild className="appearance-none hover:cursor-pointer">
<Button className="gap-2" variant="outline">
Details <Info size={14} />
</Button>
</DialogTrigger>
<DialogContent className="max-w-xl">
<DialogHeader>
<DialogTitle>Workflow Details</DialogTitle>
<DialogDescription>
View your custom nodes, models, external files used in this workflow
</DialogDescription>
</DialogHeader>
<div className="overflow-auto max-h-[400px] w-full">
<Table>
<TableHeader className="bg-background top-0 sticky">
<TableRow>
<TableHead className="w-[200px]">File</TableHead>
<TableHead className="">Output</TableHead>
</TableRow>
</TableHeader>
<TableBody>
{groupedByAuxName &&
Object.entries(groupedByAuxName).map(([key, group]) => {
// const filePath
return (
<TableRow key={key}>
<TableCell className="break-words">
<a
href={group.url}
target="_blank"
className="hover:underline"
rel="noreferrer"
>
{key}
<ExternalLink
className="inline-block ml-1"
size={12}
/>
</a>
</TableCell>
<TableCell className="flex flex-wrap gap-2">
{group.node.map((x) => (
<Badge key={x.class_type} variant="outline">
{x.class_type}
</Badge>
))}
</TableCell>
</TableRow>
);
})}
</TableBody>
</Table>
</div>
<div className="flex justify-end">
<Button className="w-fit" onClick={() => setOpen(false)}>
Close
</Button>
</div>
{/* </div> */}
{/* <div className="max-h-96 overflow-y-scroll">{view}</div> */}
</DialogContent>
</Dialog>
);
}

View File

@ -0,0 +1,169 @@
"use client";
import { Badge } from "@/components/ui/badge";
import { Button } from "@/components/ui/button";
import {
Dialog,
DialogClose,
DialogContent,
DialogDescription,
DialogHeader,
DialogTitle,
DialogTrigger,
} from "@/components/ui/dialog";
import {
Table,
TableBody,
TableCell,
TableHead,
TableHeader,
TableRow,
} from "@/components/ui/table";
import type { workflowAPINodeType } from "@/db/schema";
import type { findFirstTableWithVersion } from "@/server/findFirstTableWithVersion";
import { ExternalLink, Info } from "lucide-react";
import { parseAsInteger, useQueryState } from "next-usequerystate";
import { useMemo } from "react";
import useSWR from "swr";
import type { z } from "zod";
import fetcher from "./fetcher";
import { getWorkflowVersionFromVersionIndex } from "./VersionSelect";
export function ViewWorkflowDetailsButton({
workflow,
}: {
workflow: Awaited<ReturnType<typeof findFirstTableWithVersion>>;
}) {
const [version] = useQueryState("version", {
defaultValue: workflow?.versions[0].version ?? 1,
...parseAsInteger,
});
const {
data,
error,
isLoading: isNodesIndexLoading,
} = useSWR(
"https://raw.githubusercontent.com/ltdrdata/ComfyUI-Manager/main/extension-node-map.json",
fetcher,
);
const groupedByAuxName = useMemo(() => {
if (!data) return null;
const workflow_version = getWorkflowVersionFromVersionIndex(
workflow,
version,
);
const api = workflow_version?.workflow_api;
if (!api) return null;
const crossCheckedApi = Object.entries(api)
.map(([_, value]) => {
const classType = value.class_type;
const classTypeData = Object.entries(data).find(([_, nodeArray]) =>
nodeArray[0].includes(classType),
);
return classTypeData ? { node: value, classTypeData } : null;
})
.filter((item) => item !== null);
// console.log(crossCheckedApi);
const groupedByAuxName = crossCheckedApi.reduce(
(acc, data) => {
if (!data) return acc;
const { node, classTypeData } = data;
const auxName = classTypeData[1][1].title_aux;
// console.log(auxName);
if (!acc[auxName]) {
acc[auxName] = {
url: classTypeData[0],
node: [],
};
}
acc[auxName].node.push(node);
return acc;
},
{} as Record<
string,
{
node: z.infer<typeof workflowAPINodeType>[];
url: string;
}
>,
);
// console.log(groupedByAuxName);
return groupedByAuxName;
}, [version, data]);
return (
<Dialog>
<DialogTrigger asChild className="appearance-none hover:cursor-pointer">
<Button className="gap-2" variant="outline">
Details <Info size={14} />
</Button>
</DialogTrigger>
<DialogContent className="max-w-xl">
<DialogHeader>
<DialogTitle>Workflow Details</DialogTitle>
<DialogDescription>
View your custom nodes, models, external files used in this workflow
</DialogDescription>
</DialogHeader>
<div className="overflow-auto max-h-[400px] w-full">
<Table>
<TableHeader className="bg-background top-0 sticky">
<TableRow>
<TableHead className="w-[200px]">File</TableHead>
<TableHead className="">Output</TableHead>
</TableRow>
</TableHeader>
<TableBody>
{groupedByAuxName &&
Object.entries(groupedByAuxName).map(([key, group]) => {
// const filePath
return (
<TableRow key={key}>
<TableCell className="break-words">
<a
href={group.url}
target="_blank"
className="hover:underline"
rel="noreferrer"
>
{key}
<ExternalLink
className="inline-block ml-1"
size={12}
/>
</a>
</TableCell>
<TableCell className="flex flex-wrap gap-2">
{group.node.map((x) => (
<Badge key={x.class_type} variant="outline">
{x.class_type}
</Badge>
))}
</TableCell>
</TableRow>
);
})}
</TableBody>
</Table>
</div>
<div className="flex justify-end">
<DialogClose asChild>
<Button className="w-fit">Close</Button>
</DialogClose>
</div>
{/* </div> */}
{/* <div className="max-h-96 overflow-y-scroll">{view}</div> */}
</DialogContent>
</Dialog>
);
}