Class HostWorkspaceResolver

packages/runtime-host/src/server/workspace-resolver.ts:39–117

    };

export class HostWorkspaceResolver {
  constructor(
    private readonly catalog: Pick<ProjectCatalog, 'list' | 'touch'>,
    private readonly membership: HostProjectMembershipGate,
    private readonly onProjectChanged: () => void,
  ) {}

  resolve(target: WorkspaceTarget): Promise<ResolvedWorkspace> {
    return this.run(target, async (workspace) => workspace);
  }

  run<Result>(
    target: WorkspaceTarget,
    operation: (workspace: ResolvedWorkspace) => Promise<Result>,
  ): Promise<Result> {
    return this.membership.run(async () => operation(await this.#resolve(target)));
  }

  runWithUsageRecorded<Result>(
    target: WorkspaceTarget,
    operation: (workspace: ResolvedWorkspace) => Promise<Result>,
  ): Promise<Result> {
    return this.membership.run(async () => {
      const workspace = await this.#resolve(target);
      if (workspace.projectId !== null) {
        try {
          await this.catalog.touch(workspace.projectId, workspace.cwd);
        } catch (error) {
          if (error instanceof ProjectNotFoundError) {
            throw new WorkspaceResolutionError('not_found', error.message);
          }
          if (
            error instanceof ProjectArchivedError ||
            error instanceof ProjectUnavailableError ||
            error instanceof ProjectPathMismatchError
          ) {
            throw new WorkspaceResolutionError('operation_conflict', error.message);
          }
          throw error;
        }
        this.onProjectChanged();
      }
      return operation(workspace);
    });
  }

  async #resolve(target: WorkspaceTarget): Promise<ResolvedWorkspace> {
    if (target.kind === 'host_path') {
      const cwd = await canonicalHostDirectory(target.path);
      return { target: { kind: 'host_path', path: cwd }, cwd, projectId: null };
    }

    const project = findProjectByIdentity(await this.catalog.list(), target.projectId);
    if (!project) {
      throw new WorkspaceResolutionError(
        'not_found',
        `Project does not exist: ${target.projectId}`,
      );