Method Page

agent/app/service/runtime.go:197–271

(req request.RuntimeSearch)

}

func (r *RuntimeService) Page(req request.RuntimeSearch) (int64, []response.RuntimeDTO, error) {
	var (
		opts []repo.DBOption
		res  []response.RuntimeDTO
	)
	if req.Name != "" {
		opts = append(opts, repo.WithByLikeName(req.Name))
	}
	if req.Status != "" {
		if req.Type == constant.TypePhp {
			opts = append(opts, runtimeRepo.WithNormalStatus(req.Status))
		} else {
			opts = append(opts, runtimeRepo.WithStatus(req.Status))
		}
	}
	if req.Type != "" {
		opts = append(opts, repo.WithByType(req.Type))
	}
	total, runtimes, err := runtimeRepo.Page(req.Page, req.PageSize, opts...)
	if err != nil {
		return 0, nil, err
	}
	if len(runtimes) == 0 {
		return 0, res, nil
	}
	if err = SyncRuntimesStatus(runtimes); err != nil {
		return 0, nil, err
	}
	for _, runtime := range runtimes {
		if runtime.Resource == constant.ResourceLocal {
			runtime.Status = constant.StatusNormal
		}
		runtimeDTO := response.NewRuntimeDTO(runtime)
		runtimeDTO.Params = make(map[string]interface{})
		envs, err := gotenv.Unmarshal(runtime.Env)
		if err != nil {
			return 0, nil, err
		}
		detail, _ := appDetailRepo.GetFirst(repo.WithByID(runtime.AppDetailID))
		if detail.AppId == 0 {
			appID, appDetailID := handleRuntimeDetailID(runtime)
			runtimeDTO.AppDetailID = appDetailID
			runtimeDTO.AppID = appID
		} else {
			runtimeDTO.AppID = detail.AppId
		}
		for k, v := range envs {
			runtimeDTO.Params[k] = v
			if strings.Contains(k, "CONTAINER_PORT") || strings.Contains(k, "HOST_PORT") {
				if strings.Contains(k, "CONTAINER_PORT") {
					matches := re.GetRegex(re.TrailingDigitsPattern).FindStringSubmatch(k)
					if len(matches) < 2 {
						continue
					}
					containerPort, err := strconv.Atoi(v)
					if err != nil {
						continue
					}