Serge Bazanski | 8d7843c | 2018-10-04 10:37:36 +0100 | [diff] [blame] | 1 | package main |
| 2 | |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 3 | import ( |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 4 | "context" |
| 5 | "fmt" |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 6 | "net/http" |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 7 | "sort" |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 8 | "strings" |
Serge Bazanski | 8d7843c | 2018-10-04 10:37:36 +0100 | [diff] [blame] | 9 | |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 10 | "code.hackerspace.pl/q3k/topo/graph" |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 11 | "github.com/gobuffalo/packr" |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 12 | "github.com/golang/glog" |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 13 | "github.com/q3k/statusz" |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 14 | "vbom.ml/util/sortorder" |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 15 | ) |
| 16 | |
| 17 | type ServiceConfig struct { |
| 18 | DebugListen string |
| 19 | } |
| 20 | |
| 21 | type Service struct { |
| 22 | gr *graph.Graph |
| 23 | config ServiceConfig |
| 24 | } |
| 25 | |
| 26 | func NewService(gr *graph.Graph, c ServiceConfig) *Service { |
| 27 | return &Service{ |
| 28 | gr: gr, |
| 29 | config: c, |
| 30 | } |
| 31 | } |
| 32 | |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 33 | type TopologyStatus struct { |
| 34 | } |
| 35 | |
| 36 | const topologyFragment = ` |
| 37 | <script src="/assets/viz.js"></script> |
| 38 | <script> |
| 39 | |
| 40 | var viz = new Viz({ workerURL: '/assets/full.render.js' }); |
| 41 | var xmlhttp = new XMLHttpRequest(); |
| 42 | xmlhttp.onreadystatechange = function() { |
| 43 | if (this.readyState == 4 && this.status == 200) { |
| 44 | var dot = this.responseText; |
| 45 | viz.renderSVGElement(dot) |
| 46 | .then(function(element) { |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 47 | document.getElementById("graph").appendChild(element); |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 48 | }); |
| 49 | } |
| 50 | }; |
| 51 | xmlhttp.open('GET', '/debug/graphviz'); |
| 52 | xmlhttp.send(); |
| 53 | |
| 54 | </script> |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 55 | <div id="graph" style="text-align: center;"></div> |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 56 | ` |
| 57 | |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 58 | func (s *Service) Run() { |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 59 | assets := packr.NewBox("./assets") |
| 60 | http.Handle("/assets/", http.StripPrefix("/assets/", http.FileServer(assets))) |
| 61 | |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 62 | http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { |
| 63 | http.Redirect(w, r, "/debug/status", http.StatusSeeOther) |
| 64 | }) |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 65 | |
| 66 | http.HandleFunc("/debug/graphviz", func(w http.ResponseWriter, r *http.Request) { |
| 67 | fmt.Fprintf(w, "graph G {\n") |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 68 | fmt.Fprintf(w, " ranksep = 2\n") |
| 69 | fmt.Fprintf(w, " splines = polyline\n") |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 70 | fmt.Fprintf(w, " rankdir = LR\n") |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 71 | for _, machine := range s.gr.Machines { |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 72 | portNames := []string{} |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 73 | for _, port := range machine.Ports { |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 74 | name := fmt.Sprintf("<%s> %s", port.Name, port.Name) |
| 75 | portNames = append(portNames, name) |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 76 | } |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 77 | ports := strings.Join(portNames, "|") |
| 78 | fmt.Fprintf(w, " %s [shape=record label=\"{ %s | { %s }}\"]\n", machine.Name, machine.Name, ports) |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 79 | } |
| 80 | for _, sw := range s.gr.Switches { |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 81 | portNames := []string{} |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 82 | portsOrdered := []*graph.SwitchPort{} |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 83 | for _, port := range sw.Ports { |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 84 | portsOrdered = append(portsOrdered, port) |
| 85 | } |
| 86 | sort.Slice(portsOrdered, func(i, j int) bool { |
| 87 | return sortorder.NaturalLess(portsOrdered[i].Name, portsOrdered[j].Name) |
| 88 | }) |
| 89 | for _, port := range portsOrdered { |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 90 | name := fmt.Sprintf("<%s> %s", port.Name, port.Name) |
| 91 | portNames = append(portNames, name) |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 92 | } |
Serge Bazanski | de869df | 2018-10-06 13:55:49 +0100 | [diff] [blame] | 93 | ports := strings.Join(portNames, "|") |
| 94 | fmt.Fprintf(w, " %s [shape=record label=\"{{ %s } | %s}\"]\n", sw.Name, ports, sw.Name) |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 95 | } |
| 96 | for _, machine := range s.gr.Machines { |
| 97 | for _, port := range machine.Ports { |
| 98 | if port.OtherEnd == nil { |
| 99 | continue |
| 100 | } |
Serge Bazanski | 69518ab | 2018-10-06 17:48:23 +0100 | [diff] [blame^] | 101 | fmt.Fprintf(w, " %s:%q:e -- %s:%q:w\n", machine.Name, port.Name, port.OtherEnd.Switch.Name, port.OtherEnd.Name) |
Serge Bazanski | c7be4a1 | 2018-10-06 13:18:05 +0100 | [diff] [blame] | 102 | } |
| 103 | } |
| 104 | fmt.Fprintf(w, "}\n") |
| 105 | }) |
| 106 | |
| 107 | statusz.AddStatusPart("Topology", topologyFragment, func(ctx context.Context) interface{} { |
| 108 | return &TopologyStatus{} |
| 109 | }) |
Serge Bazanski | 4676508 | 2018-10-06 12:32:01 +0100 | [diff] [blame] | 110 | glog.Infof("Debug listening on %s....", s.config.DebugListen) |
| 111 | http.ListenAndServe(s.config.DebugListen, nil) |
Serge Bazanski | 8d7843c | 2018-10-04 10:37:36 +0100 | [diff] [blame] | 112 | } |