services

var GetProjectFiles = func(projectId uint) ([]models.ProjectFile, error) {
	project := models.GetProject(projectId)
	if project == nil {
		return nil, errors.New("not found")
	}
	var projectFiles []models.ProjectFile
	root := fmt.Sprintf("%s/%d", os.Getenv("STORAGE_DIR"), project.ID)
	err := filepath.Walk(root, func(path string, info os.FileInfo, err error) error {
		if info.IsDir() && info.Name() == ".git" {
			return filepath.SkipDir
		}
		if !info.IsDir() {
			projectFiles = append(projectFiles, models.ProjectFile(path[len(root)+1:]))
		}
		return nil
	})
	if err != nil {
		return nil, err
	}
	return projectFiles, nil
}

var GetVersions = func(appId uint) ([]dto.Version, error) {
	app := models.GetApplication(appId)
	if app == nil {
		return nil, errors.New("not found")
	}
	var versions []dto.Version
	if app.Repository.Type == "docker-v1" {
		url := fmt.Sprintf("%s/v1/repositories/%s/tags", app.Repository.Url, app.RepositoryArtifact)
		var response []map[string]string
		err := GetJson(url, &response)
		if err != nil {
			return nil, err
		}
		for _, item := range response {
			versions = append(versions, dto.Version{Name: item["name"]})
		}
	}
	if app.Repository.Type == "docker-v2" {
		url := fmt.Sprintf("%s/v2/%s/tags/list", app.Repository.Url, app.RepositoryArtifact)
		var response map[string]interface{}
		err := GetJson(url, &response)
		if err != nil {
			log.Printf("GetJson error: %s", err)
			return nil, err
		}

		for _, item := range response["tags"].([]interface{}) {
			versions = append(versions, dto.Version{Name: item.(string)})
		}
	}
	sort.Sort(dto.ByName(versions))
	return versions, nil
}