168 lines
4.7 KiB
Go
168 lines
4.7 KiB
Go
package sync
|
|
|
|
import (
|
|
"fmt"
|
|
"path"
|
|
"strings"
|
|
"strconv"
|
|
|
|
"srs.epita.fr/fic-server/libfic"
|
|
)
|
|
|
|
func getExercices(i Importer, theme fic.Theme) ([]string, error) {
|
|
var exercices []string
|
|
|
|
if dirs, err := i.listDir(theme.Name); err != nil {
|
|
return []string{}, err
|
|
} else {
|
|
for _, dir := range dirs {
|
|
if _, err := i.listDir(path.Join(theme.Name, dir)); err == nil {
|
|
exercices = append(exercices, dir)
|
|
}
|
|
}
|
|
}
|
|
|
|
return exercices, nil
|
|
}
|
|
|
|
func findResolutionMovie(i Importer, exPath string) (videoURI string, err error) {
|
|
var files []string
|
|
|
|
if files, err = i.listDir(path.Join(exPath, "resolution")); err != nil {
|
|
return
|
|
} else {
|
|
for _, fname := range files {
|
|
switch strings.ToLower(path.Ext(fname)) {
|
|
case ".mkv", ".mp4", ".webm", ".ogv", ".avi", ".mov", ".flv":
|
|
videoURI = path.Join("/resolution", exPath, "resolution", fname)
|
|
}
|
|
}
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
func SyncExercices(i Importer, theme fic.Theme) []string {
|
|
var errs []string
|
|
|
|
if exercices, err := getExercices(i, theme); err != nil {
|
|
errs = append(errs, err.Error())
|
|
} else {
|
|
dmap := map[int]fic.Exercice{}
|
|
emap := map[string]int{}
|
|
for _, edir := range exercices {
|
|
edir_splt := strings.SplitN(edir, "-", 2)
|
|
if len(edir_splt) != 2 {
|
|
errs = append(errs, fmt.Sprintf("%q is not a valid exercice directory: missing id prefix", edir))
|
|
continue
|
|
}
|
|
|
|
eid, err := strconv.Atoi(edir_splt[0])
|
|
if err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: invalid exercice identifier: %s", edir, err))
|
|
continue
|
|
}
|
|
ename := edir_splt[1]
|
|
|
|
emap[ename] = eid
|
|
|
|
// Overview and scenario
|
|
overview, err := getFileContent(i, path.Join(theme.Name, edir, "introduction.txt"))
|
|
if err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: introduction.txt: %s", edir, err))
|
|
}
|
|
|
|
statement, err := getFileContent(i, path.Join(theme.Name, edir, "scenario.txt"))
|
|
if err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: scenario.txt: %s", edir, err))
|
|
continue
|
|
}
|
|
|
|
// Handle score gain
|
|
var gain int64
|
|
if p, err := parseExerciceParams(i, path.Join(theme.Name, edir)); err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: defines.txt: %s", edir, err))
|
|
continue
|
|
} else if p.Gain == 0 {
|
|
errs = append(errs, fmt.Sprintf("%q: defines.txt: Undefined gain for challenge", edir))
|
|
} else {
|
|
gain = p.Gain
|
|
}
|
|
|
|
// Handle video
|
|
videoURI, err := findResolutionMovie(i, path.Join(theme.Name, edir))
|
|
if err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: resolution: %s", edir, err))
|
|
} else if len(videoURI) == 0 {
|
|
errs = append(errs, fmt.Sprintf("%q: resolution: no video file found.", edir))
|
|
}
|
|
|
|
if e, err := theme.GetExerciceByTitle(ename); err != nil {
|
|
if ex, err := theme.AddExercice(ename, fic.ToURLid(ename), path.Join(theme.Name, edir), statement, overview, nil, gain, videoURI); err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: error on exercice add: %s", edir, err))
|
|
continue
|
|
} else {
|
|
dmap[eid] = ex
|
|
}
|
|
} else if e.Title != ename || e.Statement != statement || e.Overview != overview || e.Gain != gain || e.VideoURI != videoURI {
|
|
e.Title = ename
|
|
e.Statement = statement
|
|
e.Overview = overview
|
|
e.Gain = gain
|
|
e.VideoURI = videoURI
|
|
if _, err := e.Update(); err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: error on exercice update: %s", edir, err))
|
|
continue
|
|
} else {
|
|
dmap[eid] = e
|
|
}
|
|
} else {
|
|
dmap[eid] = e
|
|
}
|
|
}
|
|
|
|
// Remove old exercices
|
|
if exercices, err := theme.GetExercices(); err == nil {
|
|
for _, ex := range exercices {
|
|
if _, ok := emap[ex.Title]; !ok {
|
|
ex.Delete()
|
|
}
|
|
}
|
|
}
|
|
|
|
dmap_keys := []string{}
|
|
for k, _ := range dmap {
|
|
dmap_keys = append(dmap_keys, fmt.Sprintf("%d", k))
|
|
}
|
|
for _, e := range dmap {
|
|
// No error if the file doesn't exist
|
|
if ! i.exists(path.Join(e.Path, "depends.txt")) {
|
|
continue
|
|
}
|
|
|
|
// Treat depends.txt
|
|
if depends, err := getFileContent(i, path.Join(e.Path, "depends.txt")); err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: depends.txt: %s", path.Base(e.Path), err))
|
|
} else {
|
|
for nline, dep := range strings.Split(depends, "\n") {
|
|
if did, err := strconv.Atoi(dep); err != nil {
|
|
errs = append(errs, fmt.Sprintf("%q: depends.txt:%d: %s", path.Base(e.Path), nline + 1, err))
|
|
continue
|
|
} else if exdep, exist := dmap[did]; !exist {
|
|
errs = append(errs, fmt.Sprintf("%q: depends.txt:%d: Unable to find required dependancy %q (%d ; available: %s)", path.Base(e.Path), nline + 1, dep, did, strings.Join(dmap_keys, ",")))
|
|
continue
|
|
} else {
|
|
e.Depend = &exdep.Id
|
|
e.Update()
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return errs
|
|
}
|
|
|
|
func ApiListRemoteExercices(theme fic.Theme, _ []byte) (interface{}, error) {
|
|
return getExercices(GlobalImporter, theme)
|
|
}
|