| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | // Copyright 2017 The go-ethereum Authors | 
					
						
							|  |  |  | // This file is part of go-ethereum. | 
					
						
							|  |  |  | // | 
					
						
							|  |  |  | // go-ethereum is free software: you can redistribute it and/or modify | 
					
						
							|  |  |  | // it under the terms of the GNU General Public License as published by | 
					
						
							|  |  |  | // the Free Software Foundation, either version 3 of the License, or | 
					
						
							|  |  |  | // (at your option) any later version. | 
					
						
							|  |  |  | // | 
					
						
							|  |  |  | // go-ethereum is distributed in the hope that it will be useful, | 
					
						
							|  |  |  | // but WITHOUT ANY WARRANTY; without even the implied warranty of | 
					
						
							|  |  |  | // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 
					
						
							|  |  |  | // GNU General Public License for more details. | 
					
						
							|  |  |  | // | 
					
						
							|  |  |  | // You should have received a copy of the GNU General Public License | 
					
						
							|  |  |  | // along with go-ethereum. If not, see <http://www.gnu.org/licenses/>. | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | package main | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | import ( | 
					
						
							|  |  |  | 	"fmt" | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	"github.com/ethereum/go-ethereum/log" | 
					
						
							|  |  |  | ) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | // deployDashboard queries the user for various input on deploying a web-service | 
					
						
							|  |  |  | // dashboard, after which is pushes the container. | 
					
						
							|  |  |  | func (w *wizard) deployDashboard() { | 
					
						
							|  |  |  | 	// Select the server to interact with | 
					
						
							|  |  |  | 	server := w.selectServer() | 
					
						
							|  |  |  | 	if server == "" { | 
					
						
							|  |  |  | 		return | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	client := w.servers[server] | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	// Retrieve any active dashboard configurations from the server | 
					
						
							|  |  |  | 	infos, err := checkDashboard(client, w.network) | 
					
						
							|  |  |  | 	if err != nil { | 
					
						
							|  |  |  | 		infos = &dashboardInfos{ | 
					
						
							|  |  |  | 			port: 80, | 
					
						
							|  |  |  | 			host: client.server, | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2017-11-23 14:22:59 +02:00
										 |  |  | 	existed := err == nil | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 	// Figure out which port to listen on | 
					
						
							|  |  |  | 	fmt.Println() | 
					
						
							|  |  |  | 	fmt.Printf("Which port should the dashboard listen on? (default = %d)\n", infos.port) | 
					
						
							|  |  |  | 	infos.port = w.readDefaultInt(infos.port) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	// Figure which virtual-host to deploy the dashboard on | 
					
						
							|  |  |  | 	infos.host, err = w.ensureVirtualHost(client, infos.port, infos.host) | 
					
						
							|  |  |  | 	if err != nil { | 
					
						
							|  |  |  | 		log.Error("Failed to decide on dashboard host", "err", err) | 
					
						
							|  |  |  | 		return | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	// Port and proxy settings retrieved, figure out which services are available | 
					
						
							|  |  |  | 	available := make(map[string][]string) | 
					
						
							|  |  |  | 	for server, services := range w.services { | 
					
						
							|  |  |  | 		for _, service := range services { | 
					
						
							|  |  |  | 			available[service] = append(available[service], server) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	for _, service := range []string{"ethstats", "explorer", "wallet", "faucet"} { | 
					
						
							|  |  |  | 		// Gather all the locally hosted pages of this type | 
					
						
							|  |  |  | 		var pages []string | 
					
						
							|  |  |  | 		for _, server := range available[service] { | 
					
						
							|  |  |  | 			client := w.servers[server] | 
					
						
							|  |  |  | 			if client == nil { | 
					
						
							|  |  |  | 				continue | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			// If there's a service running on the machine, retrieve it's port number | 
					
						
							|  |  |  | 			var port int | 
					
						
							|  |  |  | 			switch service { | 
					
						
							|  |  |  | 			case "ethstats": | 
					
						
							|  |  |  | 				if infos, err := checkEthstats(client, w.network); err == nil { | 
					
						
							|  |  |  | 					port = infos.port | 
					
						
							|  |  |  | 				} | 
					
						
							| 
									
										
										
										
											2017-10-23 12:24:25 +03:00
										 |  |  | 			case "explorer": | 
					
						
							|  |  |  | 				if infos, err := checkExplorer(client, w.network); err == nil { | 
					
						
							|  |  |  | 					port = infos.webPort | 
					
						
							|  |  |  | 				} | 
					
						
							|  |  |  | 			case "wallet": | 
					
						
							|  |  |  | 				if infos, err := checkWallet(client, w.network); err == nil { | 
					
						
							|  |  |  | 					port = infos.webPort | 
					
						
							|  |  |  | 				} | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 			case "faucet": | 
					
						
							|  |  |  | 				if infos, err := checkFaucet(client, w.network); err == nil { | 
					
						
							|  |  |  | 					port = infos.port | 
					
						
							|  |  |  | 				} | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			if page, err := resolve(client, w.network, service, port); err == nil && page != "" { | 
					
						
							|  |  |  | 				pages = append(pages, page) | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		// Promt the user to chose one, enter manually or simply not list this service | 
					
						
							|  |  |  | 		defLabel, defChoice := "don't list", len(pages)+2 | 
					
						
							|  |  |  | 		if len(pages) > 0 { | 
					
						
							|  |  |  | 			defLabel, defChoice = pages[0], 1 | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		fmt.Println() | 
					
						
							|  |  |  | 		fmt.Printf("Which %s service to list? (default = %s)\n", service, defLabel) | 
					
						
							|  |  |  | 		for i, page := range pages { | 
					
						
							|  |  |  | 			fmt.Printf(" %d. %s\n", i+1, page) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		fmt.Printf(" %d. List external %s service\n", len(pages)+1, service) | 
					
						
							|  |  |  | 		fmt.Printf(" %d. Don't list any %s service\n", len(pages)+2, service) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		choice := w.readDefaultInt(defChoice) | 
					
						
							|  |  |  | 		if choice < 0 || choice > len(pages)+2 { | 
					
						
							|  |  |  | 			log.Error("Invalid listing choice, aborting") | 
					
						
							|  |  |  | 			return | 
					
						
							|  |  |  | 		} | 
					
						
							| 
									
										
										
										
											2017-10-23 12:24:25 +03:00
										 |  |  | 		var page string | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 		switch { | 
					
						
							|  |  |  | 		case choice <= len(pages): | 
					
						
							| 
									
										
										
										
											2017-10-23 12:24:25 +03:00
										 |  |  | 			page = pages[choice-1] | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 		case choice == len(pages)+1: | 
					
						
							|  |  |  | 			fmt.Println() | 
					
						
							|  |  |  | 			fmt.Printf("Which address is the external %s service at?\n", service) | 
					
						
							| 
									
										
										
										
											2017-10-23 12:24:25 +03:00
										 |  |  | 			page = w.readString() | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 		default: | 
					
						
							|  |  |  | 			// No service hosting for this | 
					
						
							|  |  |  | 		} | 
					
						
							| 
									
										
										
										
											2017-10-23 12:24:25 +03:00
										 |  |  | 		// Save the users choice | 
					
						
							|  |  |  | 		switch service { | 
					
						
							|  |  |  | 		case "ethstats": | 
					
						
							|  |  |  | 			infos.ethstats = page | 
					
						
							|  |  |  | 		case "explorer": | 
					
						
							|  |  |  | 			infos.explorer = page | 
					
						
							|  |  |  | 		case "wallet": | 
					
						
							|  |  |  | 			infos.wallet = page | 
					
						
							|  |  |  | 		case "faucet": | 
					
						
							|  |  |  | 			infos.faucet = page | 
					
						
							|  |  |  | 		} | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	// If we have ethstats running, ask whether to make the secret public or not | 
					
						
							|  |  |  | 	if w.conf.ethstats != "" { | 
					
						
							|  |  |  | 		fmt.Println() | 
					
						
							|  |  |  | 		fmt.Println("Include ethstats secret on dashboard (y/n)? (default = yes)") | 
					
						
							| 
									
										
										
										
											2017-10-23 12:24:25 +03:00
										 |  |  | 		infos.trusted = w.readDefaultString("y") == "y" | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 	} | 
					
						
							|  |  |  | 	// Try to deploy the dashboard container on the host | 
					
						
							| 
									
										
										
										
											2017-10-27 14:36:49 +03:00
										 |  |  | 	nocache := false | 
					
						
							|  |  |  | 	if existed { | 
					
						
							|  |  |  | 		fmt.Println() | 
					
						
							|  |  |  | 		fmt.Printf("Should the dashboard be built from scratch (y/n)? (default = no)\n") | 
					
						
							|  |  |  | 		nocache = w.readDefaultString("n") != "n" | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2017-10-23 12:24:25 +03:00
										 |  |  | 	if out, err := deployDashboard(client, w.network, &w.conf, infos, nocache); err != nil { | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | 		log.Error("Failed to deploy dashboard container", "err", err) | 
					
						
							|  |  |  | 		if len(out) > 0 { | 
					
						
							|  |  |  | 			fmt.Printf("%s\n", out) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		return | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	// All ok, run a network scan to pick any changes up | 
					
						
							| 
									
										
										
										
											2017-10-19 13:59:02 +03:00
										 |  |  | 	w.networkStats() | 
					
						
							| 
									
										
										
										
											2017-04-11 02:25:53 +03:00
										 |  |  | } |