(job params.WorkflowJob)
| 2294 | } |
| 2295 | |
| 2296 | func (r *basePoolManager) ValidateOwner(job params.WorkflowJob) error { |
| 2297 | switch r.entity.EntityType { |
| 2298 | case params.ForgeEntityTypeRepository: |
| 2299 | if !strings.EqualFold(job.Repository.Name, r.entity.Name) || !strings.EqualFold(job.Repository.Owner.Login, r.entity.Owner) { |
| 2300 | return runnerErrors.NewBadRequestError("job not meant for this pool manager") |
| 2301 | } |
| 2302 | case params.ForgeEntityTypeOrganization: |
| 2303 | if !strings.EqualFold(job.GetOrgName(r.entity.Credentials.ForgeType), r.entity.Owner) { |
| 2304 | return runnerErrors.NewBadRequestError("job not meant for this pool manager") |
| 2305 | } |
| 2306 | case params.ForgeEntityTypeEnterprise: |
| 2307 | if !strings.EqualFold(job.Enterprise.Slug, r.entity.Owner) { |
| 2308 | return runnerErrors.NewBadRequestError("job not meant for this pool manager") |
| 2309 | } |
| 2310 | default: |
| 2311 | return runnerErrors.NewBadRequestError("unknown entity type") |
| 2312 | } |
| 2313 | |
| 2314 | return nil |
| 2315 | } |
| 2316 | |
| 2317 | func (r *basePoolManager) GithubRunnerRegistrationToken() (string, error) { |
| 2318 | tk, ghResp, err := r.ghcli.CreateEntityRegistrationToken(r.ctx) |
no test coverage detected