Method create

src/lib/progress-store.ts:18–38

(id: string, inputHash?: string)

  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;