Class ProgressStore

src/lib/progress-store.ts:14–127

};

class ProgressStore {
  private executions = new Map<string, ProgressExecution>();
  private inputHashToExecutionId = new Map<string, string>();

  create(id: string, inputHash?: string): void {
    this.executions.set(id, {
      id,
      messages: [],
      completed: false,
      subscribers: new Set(),
    });

    // Store input hash mapping if provided
    if (inputHash) {
      this.inputHashToExecutionId.set(inputHash, id);
    }

    // Clean up after 5 minutes
    setTimeout(() => {
      this.executions.delete(id);
      if (inputHash) {
        this.inputHashToExecutionId.delete(inputHash);
      }
    }, 5 * 60 * 1000);
  }

  getExecutionIdByInputHash(inputHash: string): string | null {
    return this.inputHashToExecutionId.get(inputHash) || null;
  }

  update(id: string, message: string, type: "info" | "success" | "error" = "info"): void {
    const execution = this.executions.get(id);
    if (!execution) {
      console.warn(`No execution found for id: ${id}`);
      return;
    }

    const lastMessage = execution.messages[execution.messages.length - 1];

    if (lastMessage && lastMessage.message === message && lastMessage.type === type) {
      return;
    }

    const progressMessage: ProgressMessage = {
      timestamp: new Date().toISOString(),
      message,
      type,
    };

    execution.messages.push(progressMessage);

    // Notify all subscribers
    execution.subscribers.forEach((callback) => callback(progressMessage));
  }

  complete(id: string, success: boolean = true): void {
    const execution = this.executions.get(id);
    if (!execution) {