commands.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. package command
  2. import (
  3. "github.com/gravitl/netmaker/netclient/functions"
  4. "github.com/gravitl/netmaker/models"
  5. "github.com/gravitl/netmaker/netclient/config"
  6. "github.com/gravitl/netmaker/netclient/local"
  7. "golang.zx2c4.com/wireguard/wgctrl"
  8. nodepb "github.com/gravitl/netmaker/grpc"
  9. "os"
  10. "strings"
  11. "log"
  12. )
  13. var (
  14. wgclient *wgctrl.Client
  15. )
  16. var (
  17. wcclient nodepb.NodeServiceClient
  18. )
  19. func Register(cfg config.ClientConfig) error {
  20. err := functions.Register(cfg)
  21. return err
  22. }
  23. func Join(cfg config.ClientConfig) error {
  24. err := functions.JoinNetwork(cfg)
  25. if err != nil {
  26. if !strings.Contains(err.Error(), "ALREADY_INSTALLED") {
  27. log.Println("Error installing: ", err)
  28. err = functions.LeaveNetwork(cfg.Network)
  29. if err != nil {
  30. err = local.WipeLocal(cfg.Network)
  31. if err != nil {
  32. log.Println("Error removing artifacts: ", err)
  33. }
  34. err = local.RemoveSystemDServices(cfg.Network)
  35. if err != nil {
  36. log.Println("Error removing services: ", err)
  37. }
  38. }
  39. os.Exit(1)
  40. } else {
  41. log.Println(err.Error())
  42. os.Exit(1)
  43. }
  44. }
  45. log.Println("joined " + cfg.Network)
  46. if cfg.Daemon != "off" {
  47. err = functions.Install(cfg)
  48. log.Println("installed daemon")
  49. }
  50. return err
  51. }
  52. func CheckIn(cfg config.ClientConfig) error {
  53. if cfg.Network == "nonetwork" || cfg.Network == "" {
  54. log.Println("Required, '-n'. No network provided. Exiting.")
  55. os.Exit(1)
  56. }
  57. log.Println("Beginning node check in for network " + cfg.Network)
  58. err := functions.CheckIn(cfg.Network)
  59. if err != nil {
  60. log.Println("Error checking in: ", err)
  61. os.Exit(1)
  62. }
  63. return nil
  64. }
  65. func Leave(cfg config.ClientConfig) error {
  66. err := functions.LeaveNetwork(cfg.Network)
  67. if err != nil {
  68. log.Println("Error attempting to leave network " + cfg.Network)
  69. }
  70. return err
  71. }
  72. func Push(cfg config.ClientConfig) error {
  73. log.Println("pushing to network")
  74. return nil
  75. }
  76. func Pull(cfg config.ClientConfig) error {
  77. log.Println("pulling from network")
  78. return nil
  79. }
  80. func Status(cfg config.ClientConfig) error {
  81. log.Println("retrieving network status")
  82. return nil
  83. }
  84. func Uninstall(cfg config.ClientConfig) error {
  85. log.Println("uninstalling")
  86. return nil
  87. }