Class WorkspaceService

packages/server/src/services/workspace.service.ts:392–2679

  };
}

function resultSummary(
  results: MergeTeamRunMemberResult[],
  requested = results.length
): MergeTeamRunMembersResponse['summary'] {
  return {
    requested,
    considered: results.length,
    merged: results.filter((item) => item.status === 'MERGED').length,
    alreadyMerged: results.filter((item) => item.status === 'ALREADY_MERGED').length,
    wouldMerge: results.filter((item) => item.status === 'WOULD_MERGE').length,
    skipped: results.filter((item) => item.status === 'SKIPPED').length,
    conflicts: results.filter((item) => item.status === 'CONFLICT').length,
    failed: results.filter((item) => item.status === 'FAILED').length,
  };
}

export class WorkspaceService {
  private static readonly mainWorkspaceClaims = new Map<string, Promise<WorkspaceWithVisibleSessions>>();
  private static readonly dedicatedWorkspaceClaims = new Map<string, Promise<WorkspaceWithVisibleSessions>>();
  private sessionService = getSessionManager();
  private eventBus: EventBus = getEventBus();

  constructor(
    private readonly lockService: TeamLockService = defaultTeamLockService,
    private readonly backgroundService: Pick<WorkspaceBackgroundService, 'stopAllForWorkspace'>
      & Partial<Pick<WorkspaceBackgroundService, 'releaseLogsForWorkspace'>> = getWorkspaceBackgroundService(),
  ) {}

  private getBaseBranch(workspace: {
    baseBranch: string | null;
    task: { project: { mainBranch: string } };
  }): string {
    return workspace.baseBranch || workspace.task.project.mainBranch;
  }

  // ── Queries ──────────────────────────────────────────────────────────────────

  async findById(id: string) {
    const workspace = await prisma.workspace.findUnique({
      where: { id },
      include: { sessions: visibleSessionsFilter, task: { include: { project: true } } },
    });
    if (!workspace) return null;
    ensureTaskNotDeleted(workspace.task);
    return workspace;
  }

  /**
   * 获取 Task 下所有 Workspace
   */
  async findByTaskId(taskId: string) {
    const task = await prisma.task.findUnique({ where: { id: taskId } });
    if (!task) {
      throw new NotFoundError('Task', taskId);
    }
    ensureTaskNotDeleted(task);