commands.go 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127
  1. package command
  2. import (
  3. "strings"
  4. "github.com/gravitl/netmaker/logger"
  5. "github.com/gravitl/netmaker/netclient/config"
  6. "github.com/gravitl/netmaker/netclient/daemon"
  7. "github.com/gravitl/netmaker/netclient/functions"
  8. "github.com/gravitl/netmaker/netclient/ncutils"
  9. )
  10. // Join - join command to run from cli
  11. func Join(cfg *config.ClientConfig, privateKey string) error {
  12. var err error
  13. //join network
  14. err = functions.JoinNetwork(cfg, privateKey)
  15. if err != nil && !cfg.DebugOn {
  16. if !strings.Contains(err.Error(), "ALREADY_INSTALLED") {
  17. logger.Log(1, "error installing: ", err.Error())
  18. err = functions.LeaveNetwork(cfg.Network, true)
  19. if err != nil {
  20. err = functions.WipeLocal(cfg.Network)
  21. if err != nil {
  22. logger.Log(1, "error removing artifacts: ", err.Error())
  23. }
  24. }
  25. if cfg.Daemon != "off" {
  26. if ncutils.IsLinux() {
  27. err = daemon.RemoveSystemDServices()
  28. }
  29. if err != nil {
  30. logger.Log(1, "error removing services: ", err.Error())
  31. }
  32. if ncutils.IsFreeBSD() {
  33. daemon.RemoveFreebsdDaemon()
  34. }
  35. }
  36. } else {
  37. logger.Log(0, "success")
  38. }
  39. if err != nil && strings.Contains(err.Error(), "ALREADY_INSTALLED") {
  40. logger.Log(0, err.Error())
  41. err = nil
  42. }
  43. return err
  44. }
  45. logger.Log(1, "joined ", cfg.Network)
  46. /*
  47. if ncutils.IsWindows() {
  48. logger.Log("setting up WireGuard app", 0)
  49. time.Sleep(time.Second >> 1)
  50. functions.Pull(cfg.Network, true)
  51. }
  52. */
  53. return err
  54. }
  55. // Leave - runs the leave command from cli
  56. func Leave(cfg *config.ClientConfig, force bool) error {
  57. err := functions.LeaveNetwork(cfg.Network, force)
  58. if err != nil {
  59. logger.Log(1, "error attempting to leave network "+cfg.Network)
  60. } else {
  61. logger.Log(0, "success")
  62. }
  63. nets, err := ncutils.GetSystemNetworks()
  64. if err == nil && len(nets) == 1 {
  65. if nets[0] == cfg.Node.CommID {
  66. logger.Log(1, "detected comms as remaining network, removing...")
  67. err = functions.LeaveNetwork(nets[0], true)
  68. }
  69. }
  70. return err
  71. }
  72. // Pull - runs pull command from cli
  73. func Pull(cfg *config.ClientConfig) error {
  74. var err error
  75. if cfg.Network == "all" {
  76. logger.Log(0, "No network selected. Running Pull for all networks.")
  77. networks, err := ncutils.GetSystemNetworks()
  78. if err != nil {
  79. logger.Log(1, "Error retrieving networks. Exiting.")
  80. return err
  81. }
  82. for _, network := range networks {
  83. _, err = functions.Pull(network, true)
  84. if err != nil {
  85. logger.Log(1, "Error pulling network config for network: ", network, "\n", err.Error())
  86. } else {
  87. logger.Log(1, "pulled network config for "+network)
  88. }
  89. }
  90. err = nil
  91. } else {
  92. _, err = functions.Pull(cfg.Network, true)
  93. }
  94. logger.Log(1, "reset network and peer configs")
  95. if err == nil {
  96. logger.Log(1, "reset network and peer configs")
  97. logger.Log(1, "success")
  98. } else {
  99. logger.Log(0, "error occurred pulling configs from server")
  100. }
  101. return err
  102. }
  103. // List - runs list command from cli
  104. func List(cfg config.ClientConfig) error {
  105. err := functions.List(cfg.Network)
  106. return err
  107. }
  108. // Uninstall - runs uninstall command from cli
  109. func Uninstall() error {
  110. logger.Log(0, "uninstalling netclient...")
  111. err := functions.Uninstall()
  112. logger.Log(0, "uninstalled netclient")
  113. return err
  114. }
  115. // Daemon - runs the daemon
  116. func Daemon() error {
  117. err := functions.Daemon()
  118. return err
  119. }