aboutsummaryrefslogtreecommitdiff
blob: d9a47a0f9ca7a73a467e4e8bb2fbb8f94b2ddb77 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
package projects

import (
	"encoding/xml"
	"io/ioutil"
	"log"
	"net/http"
	"soko/pkg/config"
	"soko/pkg/database"
	"soko/pkg/logger"
	"soko/pkg/models"
	"time"
)

// UpdatePkgCheckResults will update the database table that contains all pkgcheck results
func UpdateProjects() {

	database.Connect()
	defer database.DBCon.Close()

	if config.Quiet() == "true" {
		log.SetOutput(ioutil.Discard)
	}

	// get the pkg check results from qa-reports.gentoo.org
	projectList, err := parseProjectList()
	if err != nil {
		logger.Error.Println("Error while parsing project list. Aborting...")
	}

	// clean up the database
	deleteAllProjects()

	// insert new project list
	for _, project := range projectList.Projects {
		database.DBCon.Insert(&project)
		for _, member := range project.Members {
			database.DBCon.Insert(&models.MaintainerToProject{
				Id:              member.Email + "-" + project.Email,
				MaintainerEmail: member.Email,
				ProjectEmail:    project.Email,
			})
		}
	}

	updateStatus()
}

// parseQAReport gets the xml from qa-reports.gentoo.org and parses it
func parseProjectList() (models.ProjectList, error) {
	resp, err := http.Get("https://api.gentoo.org/metastructure/projects.xml")
	if err != nil {
		return models.ProjectList{}, err
	}
	defer resp.Body.Close()
	xmlData, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return models.ProjectList{}, err
	}
	var projectList models.ProjectList
	xml.Unmarshal(xmlData, &projectList)
	return projectList, err
}

// deleteAllOutdated deletes all entries in the outdated table
func deleteAllProjects() {
	var allProjects []*models.Project
	database.DBCon.Model(&allProjects).Select()
	for _, project := range allProjects {
		database.DBCon.Model(project).WherePK().Delete()
	}

	var allMaintainerToProjects []*models.MaintainerToProject
	database.DBCon.Model(&allMaintainerToProjects).Select()
	for _, maintainerToProject := range allMaintainerToProjects {
		database.DBCon.Model(maintainerToProject).WherePK().Delete()
	}
}

func updateStatus() {
	database.DBCon.Model(&models.Application{
		Id:         "projects",
		LastUpdate: time.Now(),
		Version:    config.Version(),
	}).OnConflict("(id) DO UPDATE").Insert()
}