Method listPending

src/node/services/bashMonitorWakeStore.ts:212–231

(ownerWorkspaceId: string)

  }

  async listPending(ownerWorkspaceId: string): Promise<BashMonitorWakeRecord[]> {
    const dir = this.dir(ownerWorkspaceId);
    let entries: string[];
    try {
      entries = await fsPromises.readdir(dir);
    } catch (error) {
      if (isErrnoWithCode(error, "ENOENT")) return [];
      throw error;
    }
    const records: BashMonitorWakeRecord[] = [];
    for (const entry of entries) {
      if (!entry.endsWith(".json")) continue;
      const raw = await fsPromises.readFile(path.join(dir, entry), "utf-8").catch(() => null);
      if (raw == null) continue;
      const parsed = this.parse(raw);
      if (parsed?.status === "pending") records.push(parsed);
    }
    records.sort((a, b) => a.createdAt.localeCompare(b.createdAt) || a.id.localeCompare(b.id));
    return records;
  }

  async listPendingOwnerWorkspaceIds(): Promise<string[]> {
    let entries: Dirent[];