feat: ワークフロー実行ページに進行状況表示を追加し、useWorkflowRunフックを更新してワークフローオブジェクトを渡すように変更しました。

Author: Ryosuke-Asano

src/lib/grpc-clients.ts

@@ -214,15 +214,15 @@ interface ImportMetaLike {
 const im = import.meta as unknown as ImportMetaLike;
 
 // Resolve base URL in order of preference:
-// 1) VITE_GRPC_BASE_URL (e.g. http://localhost:50051)
+// 1) VITE_GRPC_BASE_URL (e.g. http://localhost:50052)
 // 2) window.__SAPPHILLON_GRPC_BASE__ (debug hook)
-// 3) fallback http://localhost:50051
+// 3) fallback http://localhost:50052
 export const BASE_URL =
   (im.env?.VITE_GRPC_BASE_URL as string | undefined) ||
   (typeof window !== "undefined" &&
     (window as unknown as { __SAPPHILLON_GRPC_BASE__?: string })
       .__SAPPHILLON_GRPC_BASE__) ||
-  "http://localhost:50051";
+  "http://localhost:50052";
 
 // Toggle grpc-web binary/json via env (defaults to binary)
 const BIN_ENV = (

src/lib/workflow-progress.ts

@@ -0,0 +1,128 @@
+/**
+ * @fileoverview Floorp 進捗ウィンドウとの通信ユーティリティ
+ */
+
+export interface WorkflowProgressStep {
+  id: string;
+  functionId: string;
+  functionName: string;
+  status: "pending" | "running" | "completed" | "error";
+  startedAt?: number;
+  completedAt?: number;
+}
+
+export interface WorkflowProgressMessage {
+  type:
+    | "workflow-progress-start"
+    | "workflow-progress-update"
+    | "workflow-progress-complete"
+    | "workflow-progress-error";
+  workflowId: string;
+  workflowName?: string;
+  steps?: WorkflowProgressStep[];
+  currentStepIndex?: number;
+  status?: "idle" | "running" | "completed" | "error";
+}
+
+declare global {
+  interface Window {
+    OSAutomotor?: {
+      sendWorkflowProgress: (
+        data: WorkflowProgressMessage
+      ) => Promise<{ success: boolean; error?: string }>;
+    };
+  }
+}
+
+/**
+ * Floorp の進捗ウィンドウへメッセージを送信
+ */
+export function sendProgressMessage(message: WorkflowProgressMessage): void {
+  if (window.OSAutomotor?.sendWorkflowProgress) {
+    window.OSAutomotor.sendWorkflowProgress(message).catch(() => {
+      // Ignore errors silently
+    });
+  }
+}
+
+/**
+ * プラグイン関数 ID からステップリストを生成
+ */
+export function parseWorkflowSteps(
+  pluginFunctionIds: string[]
+): WorkflowProgressStep[] {
+  return pluginFunctionIds.map((functionId, index) => ({
+    id: `step-${index}`,
+    functionId,
+    functionName: functionId.split(".").pop() || functionId,
+    status: "pending" as const,
+  }));
+}
+
+/**
+ * ワークフロー実行開始を通知
+ */
+export function notifyWorkflowStart(
+  workflowId: string,
+  workflowName: string,
+  steps: WorkflowProgressStep[]
+): void {
+  sendProgressMessage({
+    type: "workflow-progress-start",
+    workflowId,
+    workflowName,
+    steps,
+    currentStepIndex: 0,
+    status: "running",
+  });
+}
+
+/**
+ * ステップ進捗を通知
+ */
+export function notifyStepUpdate(
+  workflowId: string,
+  steps: WorkflowProgressStep[],
+  currentStepIndex: number
+): void {
+  sendProgressMessage({
+    type: "workflow-progress-update",
+    workflowId,
+    steps,
+    currentStepIndex,
+    status: "running",
+  });
+}
+
+/**
+ * ワークフロー完了を通知
+ */
+export function notifyWorkflowComplete(
+  workflowId: string,
+  steps: WorkflowProgressStep[]
+): void {
+  sendProgressMessage({
+    type: "workflow-progress-complete",
+    workflowId,
+    steps,
+    currentStepIndex: steps.length - 1,
+    status: "completed",
+  });
+}
+
+/**
+ * ワークフローエラーを通知
+ */
+export function notifyWorkflowError(
+  workflowId: string,
+  steps: WorkflowProgressStep[],
+  currentStepIndex: number
+): void {
+  sendProgressMessage({
+    type: "workflow-progress-error",
+    workflowId,
+    steps,
+    currentStepIndex,
+    status: "error",
+  });
+}