Error: {{.}}
- {{end}} - */ - var ns []*html.Node - ns = append(ns, PresentationChanges{ - Changes: p.Changes, - LocalRevision: p.LocalRevision, - RemoteRevision: p.RemoteRevision, - }.Render()...) - if p.Error != "" { - n := &html.Node{ - Type: html.ElementNode, Data: atom.P.String(), - Attr: []html.Attribute{{Key: atom.Class.String(), Val: "presentation-error"}}, - } - n.AppendChild(htmlg.Strong("Error:")) - n.AppendChild(htmlg.Text(" ")) - n.AppendChild(htmlg.Text(p.Error)) - ns = append(ns, n) - } - return ns -} - // TODO: Turn this into a maybeLink, etc. func (p RepoPresentation) importPathPattern() *html.Node { /* @@ -149,37 +131,78 @@ func (p RepoPresentation) importPathPattern() *html.Node { return importPathPattern } -func (p RepoPresentation) updateButton() *html.Node { +func (p RepoPresentation) updateState() *html.Node { /* -
- {{if updateSupported}}
- Update
- {{else}}
- Update
- {{end}}
-
+ {{if not updateSupported}}
+ Update
+ {{else if eq p.UpdateState Available}}
+ Update
+ {{else if eq p.UpdateState Updating}}
+ Updating...
+ {{else if eq p.UpdateState Updated}}
+ {{/* Nothing. * /}}
+ {{end}}
*/
- if p.UpdateSupported {
+ if !p.UpdateSupported {
+ return &html.Node{
+ Type: html.ElementNode, Data: atom.Span.String(),
+ Attr: []html.Attribute{
+ {Key: atom.Style.String(), Val: "color: gray; cursor: default;"},
+ {Key: atom.Title.String(), Val: "Updating repos is not currently supported for this source of repos."},
+ },
+ FirstChild: htmlg.Text("Update"),
+ }
+ }
+ switch p.UpdateState {
+ case Available:
return &html.Node{
Type: html.ElementNode, Data: atom.A.String(),
Attr: []html.Attribute{
- {Key: atom.Href.String(), Val: "/-/update"},
+ {Key: atom.Href.String(), Val: "/api/update"},
{Key: atom.Onclick.String(), Val: fmt.Sprintf("UpdateRepository(event, %q);", strconv.Quote(p.RepoRoot))},
- {Key: atom.Class.String(), Val: "update-button"},
- {Key: atom.Title.String(), Val: fmt.Sprintf("go get -u -d %s", p.ImportPathPattern)},
+ //{Key: atom.Title.String(), Val: fmt.Sprintf("go get -u -d %s", p.ImportPathPattern)},
},
FirstChild: htmlg.Text("Update"),
}
- } else {
+ case Updating:
return &html.Node{
Type: html.ElementNode, Data: atom.Span.String(),
Attr: []html.Attribute{
{Key: atom.Style.String(), Val: "color: gray; cursor: default;"},
- {Key: atom.Title.String(), Val: "Updating repos is not currently supported for this source of repos."},
},
- FirstChild: htmlg.Text("Update"),
+ FirstChild: htmlg.Text("Updating..."),
+ }
+ case Updated:
+ return nil
+ default:
+ panic("unreachable")
+ }
+}
+
+func (p RepoPresentation) presentationChangesAndError() []*html.Node {
+ /*
+ {{render (presentationchanges .)}}
+ {{with .Presentation.Error}}
+ Error: {{.}}
+ {{end}} + */ + var ns []*html.Node + ns = append(ns, PresentationChanges{ + Changes: p.Changes, + LocalRevision: p.LocalRevision, + RemoteRevision: p.RemoteRevision, + }.Render()...) + if p.Error != "" { + n := &html.Node{ + Type: html.ElementNode, Data: atom.P.String(), + Attr: []html.Attribute{{Key: atom.Class.String(), Val: "presentation-error"}}, } + n.AppendChild(htmlg.Strong("Error:")) + n.AppendChild(htmlg.Text(" ")) + n.AppendChild(htmlg.Text(p.Error)) + ns = append(ns, n) } + return ns } type PresentationChanges struct { diff --git a/frontend/main.go b/frontend/main.go new file mode 100644 index 0000000..fe01aee --- /dev/null +++ b/frontend/main.go @@ -0,0 +1,251 @@ +// Command frontend runs on frontend of Go Package Store. +package main + +import ( + "bytes" + "encoding/json" + "fmt" + "io" + "io/ioutil" + "log" + "net/http" + "net/url" + "sync" + + "github.com/gopherjs/gopherjs/js" + gpscomponent "github.com/shurcooL/Go-Package-Store/component" + "github.com/shurcooL/go/gopherjs_http/jsutil" + "github.com/shurcooL/htmlg" + "honnef.co/go/js/dom" +) + +var document = dom.GetWindow().Document().(dom.HTMLDocument) + +func main() { + js.Global.Set("UpdateRepository", jsutil.Wrap(UpdateRepository)) + js.Global.Set("UpdateAll", jsutil.Wrap(UpdateAll)) + + switch readyState := document.ReadyState(); readyState { + case "loading": + document.AddEventListener("DOMContentLoaded", false, func(dom.Event) { + go run() + }) + case "interactive", "complete": + run() + default: + panic(fmt.Errorf("internal error: unexpected document.ReadyState value: %v", readyState)) + } +} + +func run() { + err := stream() + if err != nil { + log.Println(err) + } +} + +func stream() error { + // TODO: Initial render might not be needed if the server prerenders initial state. + err := renderBody() + if err != nil { + return err + } + + resp, err := http.Get("/api/updates") + if err != nil { + return err + } + defer resp.Body.Close() + dec := json.NewDecoder(resp.Body) + for { + var rp gpscomponent.RepoPresentation + err := dec.Decode(&rp) + if err == io.EOF { + break + } else if err != nil { + return err + } + + rpsMu.Lock() + rps = append(rps, &rp) + moveUp(rps, &rp) + rpsMu.Unlock() + + err = renderBody() + if err != nil { + return err + } + } + checkingUpdates = false + + err = renderBody() + return err +} + +var ( + rpsMu sync.Mutex // TODO: Move towards a channel-based unified state manipulator. + rps []*gpscomponent.RepoPresentation + + checkingUpdates = true +) + +func renderBody() error { + rpsMu.Lock() + defer rpsMu.Unlock() + + var buf bytes.Buffer + + err := htmlg.RenderComponents(&buf, gpscomponent.Header{}) + if err != nil { + return err + } + + _, err = io.WriteString(&buf, ``)
+ if err != nil {
+ return err
+ }
+
+ err = htmlg.RenderComponents(&buf, gpscomponent.UpdatesHeader{
+ RPs: rps,
+ CheckingUpdates: checkingUpdates,
+ })
+ if err != nil {
+ return err
+ }
+
+ wroteInstalledUpdates := false
+ for _, rp := range rps {
+ if rp.UpdateState == gpscomponent.Updated && !wroteInstalledUpdates {
+ err = htmlg.RenderComponents(&buf, gpscomponent.InstalledUpdates)
+ if err != nil {
+ return err
+ }
+ wroteInstalledUpdates = true
+ }
+
+ err := htmlg.RenderComponents(&buf, rp)
+ if err != nil {
+ return err
+ }
+ }
+
+ _, err = io.WriteString(&buf, `