Method PullVirtualRepo

admin/server/repos.go:97–158

(ctx context.Context, req *adminv1.PullVirtualRepoRequest)

}

func (s *Server) PullVirtualRepo(ctx context.Context, req *adminv1.PullVirtualRepoRequest) (*adminv1.PullVirtualRepoResponse, error) {
	observability.AddRequestAttributes(ctx,
		attribute.String("args.project_id", req.ProjectId),
		attribute.Int("args.page_size", int(req.PageSize)),
		attribute.String("args.page_token", req.PageToken),
	)

	proj, err := s.admin.DB.FindProject(ctx, req.ProjectId)
	if err != nil {
		return nil, err
	}

	claims := auth.GetClaims(ctx)
	permissions := claims.ProjectPermissions(ctx, proj.OrganizationID, proj.ID)
	forceAccess := claims.Superuser(ctx) && req.SuperuserForceAccess
	if !permissions.ReadProdStatus && !permissions.ReadDevStatus && !forceAccess {
		return nil, status.Error(codes.PermissionDenied, "does not have permission to read project repo")
	}

	var depl *database.Deployment
	if claims.OwnerType() == auth.OwnerTypeDeployment {
		var err error
		depl, err = s.admin.DB.FindDeployment(ctx, claims.OwnerID())
		if err != nil {
			return nil, err
		}
	}

	environment := "prod"
	if depl != nil {
		environment = depl.Environment
	}

	pageToken, err := unmarshalStringTimestampPageToken(req.PageToken)
	if err != nil {
		return nil, err
	}
	pageSize := validPageSize(req.PageSize)

	vfs, err := s.admin.DB.FindVirtualFiles(ctx, proj.ID, environment, pageToken.Ts.AsTime(), pageToken.Str, pageSize)
	if err != nil {
		return nil, err
	}

	// If no files were found, we return the same page token as the next page token.
	// This enables the client to poll for new changes continuously. (The client is responsible for pausing when an empty page is returned.)
	nextToken := req.PageToken
	if len(vfs) > 0 {
		f := vfs[len(vfs)-1]
		nextToken = marshalStringTimestampPageToken(f.Path, f.UpdatedOn)
	}

	dtos := make([]*adminv1.VirtualFile, len(vfs))
	for i, vf := range vfs {
		dtos[i] = virtualFileToDTO(vf)
	}

	return &adminv1.PullVirtualRepoResponse{