*/}
>[0];
+}) {
+ const data = useStore(
+ (state) =>
+ state.data
+ .filter((x) => x.id === run.id)
+ .sort((a, b) => b.timestamp - a.timestamp)?.[0]
+ );
+
+ let status = run.status;
+
+ // const [view, setView] = useState();
+ if (data?.json.event == "executing" && data.json.data.node == undefined) {
+ status = "success";
+ } else if (data?.json.event == "executing") {
+ status = "running";
+ }
+
+ return (
+ <>
+
+ {data && status != "success"
+ ? `${data.json.event} - ${data.json.data.node}`
+ : "-"}
+
+
+
+
+ >
+ );
+}
diff --git a/web/src/components/RunDisplay.tsx b/web/src/components/RunDisplay.tsx
index 9b3d723..f9b7704 100644
--- a/web/src/components/RunDisplay.tsx
+++ b/web/src/components/RunDisplay.tsx
@@ -1,8 +1,6 @@
"use client";
-import { RunOutputs } from "./RunOutputs";
-import { useStore } from "@/components/MachinesWS";
-import { StatusBadge } from "@/components/StatusBadge";
+import { LiveStatus } from "./LiveStatus";
import {
Dialog,
DialogContent,
@@ -14,52 +12,44 @@ import {
import { TableCell, TableRow } from "@/components/ui/table";
import { getRelativeTime } from "@/lib/getRelativeTime";
import { type findAllRuns } from "@/server/findAllRuns";
+import { getRunsOutputDisplay } from "@/server/getRunsOutput";
+import { useState } from "react";
export function RunDisplay({
run,
}: {
run: Awaited>[0];
}) {
- const data = useStore(
- (state) =>
- state.data
- .filter((x) => x.id === run.id)
- .sort((a, b) => b.timestamp - a.timestamp)?.[0]
- );
-
- let status = run.status;
-
- if (data?.json.event == "executing" && data.json.data.node == undefined) {
- status = "success";
- } else if (data?.json.event == "executing") {
- status = "running";
- }
-
+ const [view, setView] = useState();
return (
);
diff --git a/web/src/components/RunOutputs.tsx b/web/src/components/RunOutputs.tsx
index 0e8874c..1368aa1 100644
--- a/web/src/components/RunOutputs.tsx
+++ b/web/src/components/RunOutputs.tsx
@@ -1,7 +1,5 @@
-"use client";
-
import { OutputRender } from "./RunDisplay";
-import { callServerPromise } from "@/components/MachineList";
+import { CodeBlock } from "@/components/CodeBlock";
import {
Table,
TableBody,
@@ -11,22 +9,24 @@ import {
TableRow,
} from "@/components/ui/table";
import { getRunsOutput } from "@/server/getRunsOutput";
-import { useEffect, useState } from "react";
-export function RunOutputs({ run_id }: { run_id: string }) {
- const [outputs, setOutputs] =
- useState>>();
+export async function RunOutputs({ run_id }: { run_id: string }) {
+ const outputs = await getRunsOutput(run_id);
+ console.log("Getting runs out put");
- useEffect(() => {
- if (!run_id) return;
- // fetch(`/api/run?run_id=${run_id}`)
- // .then((x) => x.json())
- // .then((x) => setOutputs(x));
- callServerPromise(getRunsOutput(run_id).then((x) => setOutputs(x)));
- }, [run_id]);
+ // const [outputs, setOutputs] =
+ // useState>>();
+
+ // useEffect(() => {
+ // if (!run_id) return;
+ // // fetch(`/api/run?run_id=${run_id}`)
+ // // .then((x) => x.json())
+ // // .then((x) => setOutputs(x));
+ // callServerPromise(getRunsOutput(run_id).then((x) => setOutputs(x)));
+ // }, [run_id]);
return (
-
+
{/* A list of your recent runs. */}
@@ -36,11 +36,25 @@ export function RunOutputs({ run_id }: { run_id: string }) {
{outputs?.map((run) => {
- const fileName = run.data.images[0].filename;
+ const fileName = run.data.images?.[0].filename;
+
+ if (!fileName)
+ return (
+
+ Output
+
+
+
+
+ );
+
// const filePath
return (
- {fileName}
+ {fileName}
diff --git a/web/src/server/createRun.ts b/web/src/server/createRun.ts
index a9c88f3..d17c79b 100644
--- a/web/src/server/createRun.ts
+++ b/web/src/server/createRun.ts
@@ -60,6 +60,8 @@ export async function createRun(
}
}
+ console.log(workflow_api);
+
// Sending to comfyui
const result = await fetch(comfyui_endpoint, {
method: "POST",
diff --git a/web/src/server/getRunsOutput.tsx b/web/src/server/getRunsOutput.tsx
index 79d0210..e6b0069 100644
--- a/web/src/server/getRunsOutput.tsx
+++ b/web/src/server/getRunsOutput.tsx
@@ -1,9 +1,14 @@
"use server";
+import { RunOutputs } from "@/components/RunOutputs";
import { db } from "@/db/db";
import { workflowRunOutputs, workflowRunsTable } from "@/db/schema";
import { eq } from "drizzle-orm";
+export async function getRunsOutputDisplay(run_id: string) {
+ return ;
+}
+
export async function getRunsOutput(run_id: string) {
// throw new Error("Not implemented");
return await db