Add TUI proof of concept

go.mod

@@ -0,0 +1,5 @@
+module github.com/andfasano/metal-ipi-releases
+
+go 1.16
+
+require github.com/gizak/termui/v3 v3.1.0

go.sum

@@ -0,0 +1,8 @@
+github.com/gizak/termui/v3 v3.1.0 h1:ZZmVDgwHl7gR7elfKf1xc4IudXZ5qqfDh4wExk4Iajc=
+github.com/gizak/termui/v3 v3.1.0/go.mod h1:bXQEBkJpzxUAKf0+xq9MSWAvWZlE7c+aidmyFlkYTrY=
+github.com/mattn/go-runewidth v0.0.2 h1:UnlwIPBGaTZfPQ6T1IGzPI0EkYAQmT9fAEJ/poFC63o=
+github.com/mattn/go-runewidth v0.0.2/go.mod h1:LwmH8dsx7+W8Uxz3IHJYH5QSwggIsqBzpuz5H//U1FU=
+github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7 h1:DpOJ2HYzCv8LZP15IdmG+YdwD2luVPHITV96TkirNBM=
+github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7/go.mod h1:ZXFpozHsX6DPmq2I0TCekCxypsnAUbP2oI0UX1GXzOo=
+github.com/nsf/termbox-go v0.0.0-20190121233118-02980233997d h1:x3S6kxmy49zXVVyhcnrFqxvNVCBPb2KZ9hV2RBdS840=
+github.com/nsf/termbox-go v0.0.0-20190121233118-02980233997d/go.mod h1:IuKpRQcYE1Tfu+oAQqaLisqDeXgjyyltCfsaoYN18NQ=

main.go

@@ -0,0 +1,355 @@
+package main
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"os"
+	"os/exec"
+	"path"
+	"path/filepath"
+	"runtime"
+	"strings"
+
+	ui "github.com/gizak/termui/v3"
+	"github.com/gizak/termui/v3/widgets"
+)
+
+const (
+	CACHE_DIR string = ".releases"
+)
+
+type ProwJob struct {
+	Name string `json:"name"`
+}
+
+type VerifyEntry struct {
+	ProwJob  `json:"prowJob"`
+	Optional bool `json:"optional,omitempty"`
+	Upgrade  bool `json:"upgrade,omitempty"`
+}
+
+type ConfigFile struct {
+	Verify map[string]VerifyEntry `json:"verify"`
+}
+
+type JobNames struct {
+	Blocking  []string
+	Informing []string
+	Upgrades  []string
+}
+
+func DownloadFile(filepath string, url string) error {
+	log.Println("downloading", url)
+
+	// Get the data
+	resp, err := http.Get(url)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	if resp.StatusCode > 399 {
+		return errors.New("failed to download " + url)
+	}
+
+	// Create the file
+	out, err := os.Create(filepath)
+	if err != nil {
+		return err
+	}
+	defer out.Close()
+
+	// Write the body to file
+	_, err = io.Copy(out, resp.Body)
+	return err
+}
+
+func PathExists(path string) (bool, error) {
+	_, err := os.Stat(path)
+	if err == nil {
+		return true, nil
+	}
+	if os.IsNotExist(err) {
+		return false, nil
+	}
+	return false, err
+}
+
+func EnsureDir(path string) error {
+	exists, err := PathExists(path)
+	if err != nil {
+		return err
+	}
+
+	if !exists {
+		log.Println("creating dir", path)
+		err := os.Mkdir(path, os.ModePerm)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func fetchReleasesConfig() {
+	majorVersion := 4
+	baseMinorVersion := 6
+	releasesUrl := "https://raw.githubusercontent.com/openshift/release/master/core-services/release-controller/_releases/"
+
+	EnsureDir(CACHE_DIR)
+
+	for i := baseMinorVersion; ; i++ {
+		file := fmt.Sprintf("release-ocp-%d.%d.json", majorVersion, i)
+		url := releasesUrl + file
+		err := DownloadFile(path.Join(CACHE_DIR, file), url)
+		if err != nil {
+			break
+		}
+	}
+
+}
+
+func checkForRefresh() error {
+	err := DownloadFile(
+		".prow-jobs.json",
+		"https://deck-ci.apps.ci.l2s4.p1.openshiftapps.com/data.js",
+	)
+
+	if err != nil {
+		return err
+	}
+	fetchReleasesConfig()
+
+	return nil
+}
+
+func getJobNames() (JobNames, error) {
+	jobs := JobNames{}
+	configFiles, err := ioutil.ReadDir(CACHE_DIR)
+
+	if err != nil {
+		return jobs, err
+	}
+
+	for _, configFile := range configFiles {
+		configFilePath := filepath.Join(CACHE_DIR, configFile.Name())
+		configContents, err := ioutil.ReadFile(configFilePath)
+		if err != nil {
+			return jobs, err
+		}
+
+		var config ConfigFile
+		err = json.Unmarshal(configContents, &config)
+		if err != nil {
+			return jobs, err
+		}
+
+		for k, entry := range config.Verify {
+			if !strings.Contains(k, "metal-ipi") {
+				continue
+			}
+			if entry.Optional && entry.Upgrade {
+				// upgrade
+				jobs.Upgrades = append(jobs.Upgrades, entry.ProwJob.Name)
+				continue
+			}
+
+			if entry.Optional && !entry.Upgrade {
+				jobs.Informing = append(jobs.Informing, entry.ProwJob.Name)
+				continue
+			}
+
+			if !entry.Optional {
+				// blocking
+				jobs.Blocking = append(jobs.Blocking, entry.ProwJob.Name)
+				fmt.Println(entry.ProwJob.Name)
+				continue
+			}
+		}
+	}
+
+	return jobs, nil
+}
+
+func workflowStepFailed() {}
+
+func showResultsFor(jobs JobNames) {
+}
+
+// UI
+
+func OpenLinkInBrowser(url string) {
+	var err error
+
+	switch runtime.GOOS {
+	case "linux":
+		err = exec.Command("xdg-open", url).Start()
+	case "windows":
+		err = exec.Command("rundll32", "url.dll,FileProtocolHandler", url).Start()
+	case "darwin":
+		err = exec.Command("open", url).Start()
+	default:
+		err = fmt.Errorf("unsupported platform")
+	}
+	if err != nil {
+		log.Fatal(err)
+	}
+
+}
+
+type Entry struct {
+	Name string
+
+	// Links
+
+	Dashboard string
+	Artifacts string
+	Sippy     string
+}
+
+type Styles struct {
+	Regular     ui.Style
+	Highlighted ui.Style
+}
+
+type State struct {
+	Table      *widgets.Table
+	Styles     Styles
+	Entries    []Entry
+	Cursor     int
+	LinkCursor int
+}
+
+func NewStyles() Styles {
+	return Styles{
+		Regular:     ui.NewStyle(ui.ColorWhite, ui.ColorBlack),
+		Highlighted: ui.NewStyle(ui.ColorWhite, ui.ColorBlue),
+	}
+}
+
+func NewState() State {
+	w, h := ui.TerminalDimensions()
+	table := widgets.NewTable()
+	table.Title = "metal-ipi-releases"
+	table.TextStyle = ui.NewStyle(ui.ColorWhite)
+	table.RowSeparator = true
+	table.BorderStyle = ui.NewStyle(ui.ColorGreen)
+	table.SetRect(0, 0, w, h)
+	table.FillRow = true
+
+	return State{
+		Table:      table,
+		Styles:     NewStyles(),
+		Cursor:     1,
+		LinkCursor: 0,
+	}
+}
+
+func GetSelectedLink(state State) string {
+	entry := state.Entries[state.Cursor-1]
+	switch state.LinkCursor {
+	case 0:
+		return entry.Dashboard
+	case 1:
+		return entry.Artifacts
+	case 2:
+		return entry.Sippy
+	}
+	return ""
+}
+
+func Redraw(state State) {
+	rows := [][]string{
+		{"Name", "Links"},
+	}
+	for i, entry := range state.Entries {
+		links := ""
+		values := []string{
+			"dashboard",
+			"artifacts",
+			"sippy",
+		}
+		if i+1 == state.Cursor {
+
+			for j, value := range values {
+				if j == state.LinkCursor {
+					links += fmt.Sprintf("[%s](fg:white,bg:green)", value)
+				} else {
+					links += value
+				}
+
+				links += " "
+			}
+
+			rows = append(rows, []string{entry.Name, links})
+		} else {
+			rows = append(rows, []string{entry.Name, strings.Join(values, " ")})
+		}
+	}
+
+	state.Table.Rows = rows
+
+	for i := range rows {
+		if i == state.Cursor {
+			state.Table.RowStyles[i] = state.Styles.Highlighted
+		} else {
+			state.Table.RowStyles[i] = state.Styles.Regular
+		}
+	}
+
+	ui.Render(state.Table)
+}
+
+func main() {
+	if err := ui.Init(); err != nil {
+		log.Fatalf("failed to initialize termui: %v", err)
+	}
+	defer ui.Close()
+
+	entries := []Entry{
+		{Name: "4.10", Dashboard: "https://github.com/honza", Artifacts: "4.10 artifacts", Sippy: "4.10 sippy"},
+		{Name: "4.9", Dashboard: "4.9 dash", Artifacts: "4.9 artifacts", Sippy: "4.9 sippy"},
+	}
+
+	state := NewState()
+	state.Entries = entries
+
+	Redraw(state)
+
+	uiEvents := ui.PollEvents()
+	for {
+		e := <-uiEvents
+		switch e.ID {
+		case "j", "<Down>":
+			state.Cursor++
+			if state.Cursor > len(state.Entries) {
+				state.Cursor = len(state.Entries)
+			}
+			Redraw(state)
+		case "k", "<Up>":
+			state.Cursor--
+			if state.Cursor < 2 {
+				state.Cursor = 1
+			}
+			Redraw(state)
+		case "<Tab>":
+			state.LinkCursor++
+			if state.LinkCursor > 2 {
+				state.LinkCursor = 0
+			}
+			Redraw(state)
+		case "<Enter>":
+			// Open url
+			link := GetSelectedLink(state)
+			OpenLinkInBrowser(link)
+		case "q", "<C-c>":
+			return
+		}
+	}
+}