{{.Content}}
diff --git a/internal/resources/templates/layout.go b/internal/resources/templates/layout.go
index 86a0d91..66a128b 100644
--- a/internal/resources/templates/layout.go
+++ b/internal/resources/templates/layout.go
@@ -15,6 +15,7 @@ var Layout = `
+
GIN Valid
diff --git a/internal/web/pkg.go b/internal/web/pkg.go
index 17daa56..ac1d0b6 100644
--- a/internal/web/pkg.go
+++ b/internal/web/pkg.go
@@ -7,6 +7,6 @@ package web
const (
serveralias = "gin"
- progressmsg = "A validation job for this repository is currently in progress, please do not leave this page and refresh the page after a while."
+ progressmsg = "A validation job for this repository is currently in progress. Please do not leave this page. When it is done, it will refresh automatically. You can also refresh this page manually as many times as you wish"
notvalidatedyet = "This repository has not been validated yet. To see the results, update the repository."
)
diff --git a/internal/web/results.go b/internal/web/results.go
index b684962..846d0d7 100644
--- a/internal/web/results.go
+++ b/internal/web/results.go
@@ -241,6 +241,10 @@ func renderInProgress(w http.ResponseWriter, r *http.Request, badge []byte, vali
resHistory := resultsHistory(validator, user, repo)
loggedUsername := getLoggedUserName(r)
year, _, _ := time.Now().Date()
+ svgload, err2 := ioutil.ReadFile("/assets/svgload.svg")
+ if err2 != nil {
+ svgload = []byte("
")
+ }
info := struct {
Badge template.HTML
Header string
@@ -249,7 +253,8 @@ func renderInProgress(w http.ResponseWriter, r *http.Request, badge []byte, vali
CurrentYear int
UserName string
*ResultsHistoryStruct
- }{template.HTML(badge), head, string(progressmsg), srvcfg.GINAddresses.WebURL, year, loggedUsername, &resHistory}
+ LoadingSVG template.HTML
+ }{template.HTML(badge), head, string(progressmsg), srvcfg.GINAddresses.WebURL, year, loggedUsername, &resHistory, template.HTML(svgload)}
err = tmpl.ExecuteTemplate(w, "layout", info)
if err != nil {
diff --git a/internal/web/user.go b/internal/web/user.go
index f328937..1cb5fc9 100644
--- a/internal/web/user.go
+++ b/internal/web/user.go
@@ -228,6 +228,10 @@ func Logout(w http.ResponseWriter, r *http.Request) {
Expires: time.Time{},
Secure: false, // TODO: Switch when we go live
}
+ if conn, ok := websockets[cookie.Value]; ok {
+ conn.Close()
+ delete(websockets, cookie.Value)
+ }
http.SetCookie(w, &cookie)
http.Redirect(w, r, "/login", http.StatusFound)
}
diff --git a/internal/web/validate.go b/internal/web/validate.go
index 91aae70..8ea32f1 100644
--- a/internal/web/validate.go
+++ b/internal/web/validate.go
@@ -27,6 +27,7 @@ import (
"github.com/google/uuid"
"github.com/gorilla/mux"
+ "github.com/gorilla/websocket"
)
// BidsMessages contains Errors, Warnings and Ignored messages.
@@ -56,6 +57,8 @@ type Validationcfg struct {
} `yaml:"bidsconfig"`
}
+var websockets map[string]*websocket.Conn = make(map[string]*websocket.Conn)
+
// handleValidationConfig unmarshalles a yaml config file
// from file and returns the resulting Validationcfg struct.
func handleValidationConfig(cfgpath string) (Validationcfg, error) {
@@ -341,7 +344,7 @@ func validateODML(valroot, resdir string) error {
return nil
}
-func runValidatorBoth(validator, repopath, commit, commitname string, gcl *ginclient.Client, automatic bool) string {
+func runValidatorBoth(validator, repopath, commit, commitname string, gcl *ginclient.Client, automatic bool, r *http.Request) string {
respath := filepath.Join(validator, repopath, commit)
go func() {
log.ShowWrite("[Info] Running %s validation on repository %q (%s)", validator, repopath, commitname)
@@ -474,17 +477,19 @@ func runValidatorBoth(validator, repopath, commit, commitname string, gcl *gincl
if err != nil {
writeValFailure(resdir)
}
+ cookie, _ := r.Cookie(srvcfg.Settings.CookieName)
+ websockets[cookie.Value].WriteMessage(websocket.TextMessage, []byte("REFRESH"))
}()
return respath
}
-func runValidator(validator, repopath, commit string, gcl *ginclient.Client) {
+func runValidator(validator, repopath, commit string, gcl *ginclient.Client, r *http.Request) {
automatic := true
- runValidatorBoth(validator, repopath, commit, commit, gcl, automatic)
+ runValidatorBoth(validator, repopath, commit, commit, gcl, automatic, r)
}
-func runValidatorPub(validator, repopath string, gcl *ginclient.Client) string {
+func runValidatorPub(validator, repopath string, gcl *ginclient.Client, r *http.Request) string {
automatic := false
- return runValidatorBoth(validator, repopath, uuid.New().String(), "HEAD", gcl, automatic)
+ return runValidatorBoth(validator, repopath, uuid.New().String(), "HEAD", gcl, automatic, r)
}
// writeValFailure writes a badge and page content for when a hook payload is
@@ -555,6 +560,25 @@ func renderValidationForm(w http.ResponseWriter, r *http.Request, errMsg string)
tmpl.Execute(w, &data)
}
+func WebSocket(w http.ResponseWriter, r *http.Request) {
+ srvcfg := config.Read()
+ cookie, err2 := r.Cookie(srvcfg.Settings.CookieName)
+ if err2 != nil {
+ fail(w, r, http.StatusUnauthorized, "You are not logged in")
+ return
+ }
+ var upgrader = websocket.Upgrader{}
+ conn, err := upgrader.Upgrade(w, r, nil)
+ if err != nil {
+ fail(w, r, http.StatusServiceUnavailable, "Cannot open websocket")
+ return
+ }
+ if conn, ok := websockets[cookie.Value]; ok {
+ conn.Close()
+ }
+ websockets[cookie.Value] = conn
+}
+
// PubValidatePost parses the POST data from the root form and calls the
// validator using the built-in ServiceWaiter.
func PubValidatePost(w http.ResponseWriter, r *http.Request) {
@@ -597,7 +621,7 @@ func PubValidatePost(w http.ResponseWriter, r *http.Request) {
return
}
- respath := runValidatorPub(validator, repopath, gcl)
+ respath := runValidatorPub(validator, repopath, gcl, r)
http.Redirect(w, r, filepath.Join("results", respath), http.StatusFound)
}
@@ -679,7 +703,7 @@ func Validate(w http.ResponseWriter, r *http.Request) {
log.ShowWrite("[Info] Got user %s. Checking repo", gcl.Username)
// Payload is good. Run validator asynchronously and return OK header
- runValidator(validator, repopath, commithash, gcl)
+ runValidator(validator, repopath, commithash, gcl, r)
w.WriteHeader(http.StatusOK)
w.Write([]byte("OK"))