server/admin/sync/exercices.go

package sync

import (
	"fmt"
	"path"
	"strings"
	"strconv"

	"srs.epita.fr/fic-server/libfic"
	"gopkg.in/russross/blackfriday.v2"
)

// getExercices returns all exercice directories existing in a given theme, considering the given Importer.
func getExercices(i Importer, theme fic.Theme) ([]string, error) {
	var exercices []string

	if len(theme.Path) == 0 {
		return []string{}, nil
	} else if dirs, err := i.listDir(theme.Path); err != nil {
		return []string{}, err
	} else {
		for _, dir := range dirs {
			if _, err := i.listDir(path.Join(theme.Path, dir)); err == nil {
				exercices = append(exercices, dir)
			}
		}
	}

	return exercices, nil
}

// SyncExercices imports new or updates existing exercices, in a given theme.
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.Path, edir, "overview.txt"))
			if err != nil {
				errs = append(errs, fmt.Sprintf("%q: overview.txt: %s", edir, err))
			}

			statement, err := getFileContent(i, path.Join(theme.Path, edir, "statement.txt"))
			if err != nil {
				errs = append(errs, fmt.Sprintf("%q: statement.txt: %s", edir, err))
				continue
			}

			// Handle score gain
			var gain int64
			if p, err := parseExerciceParams(i, path.Join(theme.Path, edir)); err != nil {
				errs = append(errs, fmt.Sprintf("%q: challenge.txt: %s", edir, err))
				continue
			} else if p.Gain == 0 {
				errs = append(errs, fmt.Sprintf("%q: challenge.txt: Undefined gain for challenge", edir))
			} else {
				gain = p.Gain
			}

			// Handle video
			videoURI := path.Join(theme.Path, edir, "resolution.mp4")
			if !i.exists(videoURI) {
				errs = append(errs, fmt.Sprintf("%q: resolution.mp4: no video file found at %s", edir, videoURI))
				videoURI = ""
			}

			// Markdown pre-formating
			statement = string(blackfriday.Run([]byte(statement)))
			overview = string(blackfriday.Run([]byte(overview)))

			if e, err := theme.GetExerciceByTitle(ename); err != nil {
				if ex, err := theme.AddExercice(ename, fic.ToURLid(ename), path.Join(theme.Path, 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.URLId == "" || e.Statement != statement || e.Overview != overview || e.Gain != gain || e.VideoURI != videoURI {
				e.Title = ename
				e.URLId = fic.ToURLid(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
}

// ApiListRemoteExercices is an accessor letting foreign packages to access remote exercices list.
func ApiListRemoteExercices(theme fic.Theme, _ []byte) (interface{}, error) {
	return getExercices(GlobalImporter, theme)
}