Method readWorkspaceTurnFile

src/node/services/taskHandleStore.ts:239–281

(
    ownerWorkspaceId: string,
    handleId: string
  )

  }

  private async readWorkspaceTurnFile(
    ownerWorkspaceId: string,
    handleId: string
  ): Promise<WorkspaceTurnTaskHandleRecord | null> {
    try {
      const raw = await fsPromises.readFile(
        this.getHandlePath(ownerWorkspaceId, handleId),
        "utf-8"
      );
      const parsedJson = JSON.parse(raw) as unknown;
      const parsed = WorkspaceTurnTaskHandleRecordSchema.safeParse(parsedJson);
      if (!parsed.success) {
        log.warn("Ignoring unreadable workspace turn task handle", {
          ownerWorkspaceId,
          handleId,
          issues: parsed.error.issues,
        });
        return null;
      }
      if (
        parsed.data.handleId !== handleId ||
        parsed.data.ownerWorkspaceId !== ownerWorkspaceId ||
        !isWorkspaceTurnTaskId(parsed.data.handleId)
      ) {
        log.warn("Ignoring mismatched workspace turn task handle", {
          ownerWorkspaceId,
          handleId,
          recordOwnerWorkspaceId: parsed.data.ownerWorkspaceId,
          recordHandleId: parsed.data.handleId,
        });
        return null;
      }
      return parsed.data as WorkspaceTurnTaskHandleRecord;
    } catch (error) {
      if (isErrnoWithCode(error, "ENOENT") || error instanceof SyntaxError) {
        if (error instanceof SyntaxError) {
          log.warn("Ignoring corrupt workspace turn task handle", { ownerWorkspaceId, handleId });
        }
        return null;
      }
      throw error;
    }
  }
}