Supress licensing module

Author: mieciu

cmd/main.go

@@ -70,13 +70,13 @@ func main() {
 		log.Fatalf("error validating configuration: %v", err)
 	}
 
-	licenseMod := licensing.Init(&cfg)
+	_ = licensing.Init(&cfg)
 	qmcLogChannel := logger.InitLogger(logger.Configuration{
 		FileLogging:       cfg.Logging.FileLogging,
 		Path:              cfg.Logging.Path,
 		RemoteLogDrainUrl: cfg.Logging.RemoteLogDrainUrl.ToUrl(),
 		Level:             *cfg.Logging.Level,
-		ClientId:          licenseMod.License.ClientID,
+		ClientId:          "",
 	}, sig, doneCh)
 	defer logger.StdLogFile.Close()
 	defer logger.ErrLogFile.Close()
@@ -89,7 +89,7 @@ func main() {
 	var connectionPool = clickhouse.InitDBConnectionPool(&cfg)
 	//var connectionPool = doris.InitDBConnectionPool(&cfg)
 
-	phoneHomeAgent := telemetry.NewPhoneHomeAgent(&cfg, connectionPool, licenseMod.License.ClientID)
+	phoneHomeAgent := telemetry.NewPhoneHomeAgent(&cfg, connectionPool, "")
 	phoneHomeAgent.Start()
 
 	virtualTableStorage := persistence.NewElasticJSONDatabase(cfg.Elasticsearch, common_table.VirtualTableElasticIndexName)

platform/connectors/connector.go

@@ -3,10 +3,8 @@
 package connectors
 
 import (
-	"fmt"
 	"github.com/QuesmaOrg/quesma/platform/config"
 	"github.com/QuesmaOrg/quesma/platform/database_common"
-	"github.com/QuesmaOrg/quesma/platform/licensing"
 	"github.com/QuesmaOrg/quesma/platform/logger"
 	"github.com/QuesmaOrg/quesma/platform/telemetry"
 	quesma_api "github.com/QuesmaOrg/quesma/platform/v2/core"
@@ -27,14 +25,14 @@ func (c *ConnectorManager) GetConnector() *database_common.LogManager {
 	if len(c.connectors) == 0 {
 		panic("No connectors found")
 	}
-	conn := c.connectors[0]
-	if !c.connectors[0].GetConnector().IsInTransparentProxyMode() {
-		go func() {
-			if err := conn.LicensingCheck(); err != nil {
-				licensing.PanicWithLicenseViolation(fmt.Errorf("connector [%s] reported licensing issue: [%v]", conn.Type(), err))
-			}
-		}()
-	}
+	//conn := c.connectors[0]
+	//if !c.connectors[0].GetConnector().IsInTransparentProxyMode() {
+	//	go func() {
+	//		if err := conn.LicensingCheck(); err != nil {
+	//			licensing.PanicWithLicenseViolation(fmt.Errorf("connector [%s] reported licensing issue: [%v]", conn.Type(), err))
+	//		}
+	//	}()
+	//}
 	return c.connectors[0].GetConnector()
 }
 

platform/licensing/model.go

@@ -10,8 +10,9 @@ import (
 
 // License is an object returned by the license server based on the provided (and positively verified) license key
 type License struct {
-	InstallationID string    `json:"installation_id"`
-	ClientID       string    `json:"client_id"`
+	InstallationID string `json:"installation_id"`
+	// Deprecated
+	ClientID       string    `json:"client_id"` // used to be a human-readable organization name for telemetry purposes, given licensing module disabling its now irrelevant
 	Connectors     []string  `json:"connectors"`
 	Processors     []string  `json:"processors"`
 	ExpirationDate time.Time `json:"expiration_date"`

platform/licensing/runner.go

@@ -16,8 +16,9 @@ import (
 type LicenseModule struct {
 	InstallationID string
 	LicenseKey     []byte
-	License        *License
-	Config         *config.QuesmaConfiguration
+	//Deprecated
+	License *License // License module has been disabled
+	Config  *config.QuesmaConfiguration
 }
 
 const (
@@ -66,16 +67,16 @@ func (l *LicenseModule) Run() {
 	} else {
 		l.logInfo("License key not supplied in the configuration, will attempt to obtain temporary license with limited functionalities")
 		l.setInstallationID()
-		if err := l.obtainLicenseKey(); err != nil {
-			PanicWithLicenseViolation(fmt.Errorf("failed to obtain license key: %v", err))
-		}
-	}
-	if err := l.processLicense(); err != nil {
-		PanicWithLicenseViolation(fmt.Errorf("failed to process license: %v", err))
-	}
-	if err := l.validateConfig(); err != nil {
-		PanicWithLicenseViolation(fmt.Errorf("failed to validate configuration: %v", err))
+		//if err := l.obtainLicenseKey(); err != nil {
+		//	PanicWithLicenseViolation(fmt.Errorf("failed to obtain license key: %v", err))
+		//}
 	}
+	//if err := l.processLicense(); err != nil {
+	//	PanicWithLicenseViolation(fmt.Errorf("failed to process license: %v", err))
+	//}
+	//if err := l.validateConfig(); err != nil {
+	//	PanicWithLicenseViolation(fmt.Errorf("failed to validate configuration: %v", err))
+	//}
 }
 
 func (l *LicenseModule) validateConfig() error {