initialize.go 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. //go:build ee
  2. // +build ee
  3. package pro
  4. import (
  5. "time"
  6. controller "github.com/gravitl/netmaker/controllers"
  7. "github.com/gravitl/netmaker/logger"
  8. "github.com/gravitl/netmaker/logic"
  9. "github.com/gravitl/netmaker/models"
  10. "github.com/gravitl/netmaker/mq"
  11. proControllers "github.com/gravitl/netmaker/pro/controllers"
  12. proLogic "github.com/gravitl/netmaker/pro/logic"
  13. "github.com/gravitl/netmaker/servercfg"
  14. "golang.org/x/exp/slog"
  15. )
  16. // InitPro - Initialize Pro Logic
  17. func InitPro() {
  18. servercfg.IsPro = true
  19. models.SetLogo(retrieveProLogo())
  20. controller.HttpMiddlewares = append(
  21. controller.HttpMiddlewares,
  22. proControllers.OnlyServerAPIWhenUnlicensedMiddleware,
  23. )
  24. controller.HttpHandlers = append(
  25. controller.HttpHandlers,
  26. proControllers.MetricHandlers,
  27. proControllers.RelayHandlers,
  28. proControllers.UserHandlers,
  29. proControllers.FailOverHandlers,
  30. proControllers.InetHandlers,
  31. )
  32. logic.EnterpriseCheckFuncs = append(logic.EnterpriseCheckFuncs, func() {
  33. // == License Handling ==
  34. enableLicenseHook := false
  35. licenseKeyValue := servercfg.GetLicenseKey()
  36. netmakerTenantID := servercfg.GetNetmakerTenantID()
  37. if licenseKeyValue != "" && netmakerTenantID != "" {
  38. enableLicenseHook = true
  39. }
  40. if !enableLicenseHook {
  41. err := initTrial()
  42. if err != nil {
  43. logger.Log(0, "failed to init trial", err.Error())
  44. enableLicenseHook = true
  45. }
  46. trialEndDate, err := getTrialEndDate()
  47. if err != nil {
  48. slog.Error("failed to get trial end date", "error", err)
  49. enableLicenseHook = true
  50. } else {
  51. // check if trial ended
  52. if time.Now().After(trialEndDate) {
  53. // trial ended already
  54. enableLicenseHook = true
  55. }
  56. }
  57. }
  58. if enableLicenseHook {
  59. logger.Log(0, "starting license checker")
  60. ClearLicenseCache()
  61. if err := ValidateLicense(); err != nil {
  62. slog.Error(err.Error())
  63. return
  64. }
  65. logger.Log(0, "proceeding with Paid Tier license")
  66. logic.SetFreeTierForTelemetry(false)
  67. // == End License Handling ==
  68. AddLicenseHooks()
  69. } else {
  70. logger.Log(0, "starting trial license hook")
  71. addTrialLicenseHook()
  72. }
  73. if servercfg.GetServerConfig().RacAutoDisable {
  74. AddRacHooks()
  75. }
  76. })
  77. logic.ResetFailOver = proLogic.ResetFailOver
  78. logic.ResetFailedOverPeer = proLogic.ResetFailedOverPeer
  79. logic.CreateFailOver = proLogic.CreateFailOver
  80. logic.GetFailOverPeerIps = proLogic.GetFailOverPeerIps
  81. logic.DenyClientNodeAccess = proLogic.DenyClientNode
  82. logic.IsClientNodeAllowed = proLogic.IsClientNodeAllowed
  83. logic.AllowClientNodeAccess = proLogic.RemoveDeniedNodeFromClient
  84. logic.SetClientDefaultACLs = proLogic.SetClientDefaultACLs
  85. logic.SetClientACLs = proLogic.SetClientACLs
  86. logic.UpdateProNodeACLs = proLogic.UpdateProNodeACLs
  87. logic.GetMetrics = proLogic.GetMetrics
  88. logic.UpdateMetrics = proLogic.UpdateMetrics
  89. logic.DeleteMetrics = proLogic.DeleteMetrics
  90. logic.GetRelays = proLogic.GetRelays
  91. logic.GetAllowedIpsForRelayed = proLogic.GetAllowedIpsForRelayed
  92. logic.RelayedAllowedIPs = proLogic.RelayedAllowedIPs
  93. logic.UpdateRelayed = proLogic.UpdateRelayed
  94. logic.SetRelayedNodes = proLogic.SetRelayedNodes
  95. logic.RelayUpdates = proLogic.RelayUpdates
  96. logic.ValidateRelay = proLogic.ValidateRelay
  97. logic.GetTrialEndDate = getTrialEndDate
  98. logic.SetDefaultGw = proLogic.SetDefaultGw
  99. logic.SetDefaultGwForRelayedUpdate = proLogic.SetDefaultGwForRelayedUpdate
  100. logic.UnsetInternetGw = proLogic.UnsetInternetGw
  101. logic.SetInternetGw = proLogic.SetInternetGw
  102. logic.GetAllowedIpForInetNodeClient = proLogic.GetAllowedIpForInetNodeClient
  103. mq.UpdateMetrics = proLogic.MQUpdateMetrics
  104. mq.UpdateMetricsFallBack = proLogic.MQUpdateMetricsFallBack
  105. }
  106. func retrieveProLogo() string {
  107. return `
  108. __ __ ______ ______ __ __ ______ __ __ ______ ______
  109. /\ "-.\ \ /\ ___\ /\__ _\ /\ "-./ \ /\ __ \ /\ \/ / /\ ___\ /\ == \
  110. \ \ \-. \ \ \ __\ \/_/\ \/ \ \ \-./\ \ \ \ __ \ \ \ _"-. \ \ __\ \ \ __<
  111. \ \_\\"\_\ \ \_____\ \ \_\ \ \_\ \ \_\ \ \_\ \_\ \ \_\ \_\ \ \_____\ \ \_\ \_\
  112. \/_/ \/_/ \/_____/ \/_/ \/_/ \/_/ \/_/\/_/ \/_/\/_/ \/_____/ \/_/ /_/
  113. ___ ___ ____
  114. ____ ____ ____ / _ \ / _ \ / __ \ ____ ____ ____
  115. /___/ /___/ /___/ / ___/ / , _// /_/ / /___/ /___/ /___/
  116. /___/ /___/ /___/ /_/ /_/|_| \____/ /___/ /___/ /___/
  117. `
  118. }