Function main

cmd/edge-node/main.go:30–567

()

)

func main() {
	var app = apps.NewAppCmd().
		Version(teaconst.Version).
		Product(teaconst.ProductName).
		Usage(teaconst.ProcessName + " [-v|start|stop|restart|status|quit|test|reload|service|daemon|config|pprof|accesslog|uninstall]").
		Usage(teaconst.ProcessName + " [trackers|goman|conns|gc|bandwidth|disk|cache.garbage]").
		Usage(teaconst.ProcessName + " [ip.drop|ip.reject|ip.remove|ip.close] IP")

	app.On("start:before", func() {
		// validate config
		_, err := configs.LoadAPIConfig()
		if err != nil {
			// validate cluster config
			_, clusterErr := configs.LoadClusterConfig()
			if clusterErr != nil { // fail again
				fmt.Println("[ERROR]start failed: load api config from '" + Tea.ConfigFile(configs.ConfigFileName) + "' failed: " + err.Error())
				os.Exit(0)
			}
		}
	})
	app.On("uninstall", func() {
		// service
		fmt.Println("Uninstall service ...")
		var manager = utils.NewServiceManager(teaconst.ProcessName, teaconst.ProductName)
		go func() {
			_ = manager.Uninstall()
		}()

		// stop
		fmt.Println("Stopping ...")
		_, _ = gosock.NewTmpSock(teaconst.ProcessName).SendTimeout(&gosock.Command{Code: "stop"}, 1*time.Second)

		// delete files
		var exe, _ = os.Executable()
		if len(exe) == 0 {
			return
		}

		var dir = filepath.Dir(filepath.Dir(exe)) // ROOT / bin / exe

		// verify dir
		{
			fmt.Println("Checking '" + dir + "' ...")
			for _, subDir := range []string{"bin/" + filepath.Base(exe), "configs", "logs"} {
				_, err := os.Stat(dir + "/" + subDir)
				if err != nil {
					fmt.Println("[ERROR]program directory structure has been broken, please remove it manually.")
					return
				}
			}

			fmt.Println("Removing '" + dir + "' ...")
			err := os.RemoveAll(dir)
			if err != nil {
				fmt.Println("[ERROR]remove failed: " + err.Error())
			}
		}