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()
}
|