Resolve "Improve token usage for users"

Description

Related Issue

Motivation and Context

How Has This Been Tested?

Screenshots (if appropriate):

Types of changes

• Bug fix (non-breaking change which fixes an issue)
• New feature (non-breaking change which adds functionality)
• Breaking change (fix or feature that would cause existing functionality to change)

Checklist:

• My code follows the code style of this project.
• My change requires a change to the documentation.
• I have updated the documentation accordingly.
• I have read the CONTRIBUTING document.
• I have added tests to cover my changes.
• All new and existing tests passed.

Resolves to #378

controller/config/config.go

@@ -19,6 +19,8 @@ const (
 	defaultJWTDuration              = time.Hour * 24
 	jwtSecretKey                    = "jwtSecret"
 	gNMISubscriptionsFilePathKey    = "gNMISubscriptionsPath"
+	maxTokensPerUserKey             = "maxTokensPerUser"
+	maxTokensPerUserDefault         = 100
 
 	// RabbitMQ Broker.
 	amqpPrefixKey   = "amqpPrefix"
@@ -81,6 +83,9 @@ var CertFilePath string
 // KeyFilePath si the path to the private key that the controller should use for TLS connections.
 var KeyFilePath string
 
+// MaxTokensPerUser is the maximum number of tokens a user can have. This determiens the maximum of concurrent logged in sessions per user.
+var MaxTokensPerUser int
+
 // Init gets called on module import.
 func Init() {
 	err := InitializeConfig()
@@ -107,9 +112,9 @@ func InitializeConfig() error {
 
 	setLogLevel()
 
-	DatabaseConnection = getStringFromViper(databaseConnectionKey)
+	DatabaseConnection = viper.GetString(databaseConnectionKey)
 
-	FilesystemPathToStores = getStringFromViper(filesystemPathToStores)
+	FilesystemPathToStores = viper.GetString(filesystemPathToStores)
 	if FilesystemPathToStores == "" {
 		FilesystemPathToStores = "stores"
 	}
@@ -121,15 +126,20 @@ func InitializeConfig() error {
 
 	JWTSecret = viper.GetString(jwtSecretKey)
 
-	GNMISubscriptionsFilePath = getStringFromViper(gNMISubscriptionsFilePathKey)
+	MaxTokensPerUser = viper.GetInt(maxTokensPerUserKey)
+	if MaxTokensPerUser == 0 {
+		MaxTokensPerUser = maxTokensPerUserDefault
+	}
+
+	GNMISubscriptionsFilePath = viper.GetString(gNMISubscriptionsFilePathKey)
 
 	loadAMQPConfig()
 
-	CAFilePath = getStringFromViper(tlsCACertFileKey)
+	CAFilePath = viper.GetString(tlsCACertFileKey)
 
-	CertFilePath = getStringFromViper(tlsCertFileKey)
+	CertFilePath = viper.GetString(tlsCertFileKey)
 
-	KeyFilePath = getStringFromViper(tlsKeyFileKey)
+	KeyFilePath = viper.GetString(tlsKeyFileKey)
 
 	if err := viper.WriteConfig(); err != nil {
 		return err
@@ -161,12 +171,6 @@ func getUUIDFromViper(viperKey string) (uuid.UUID, error) {
 	return parsedUUID, nil
 }
 
-func getStringFromViper(viperKey string) string {
-	stringFromViper := viper.GetString(viperKey)
-
-	return stringFromViper
-}
-
 func setChangeTimeout() error {
 	e := os.Getenv(changeTimeoutKey)
 	if e != "" {
@@ -202,9 +206,9 @@ func getDurationFromViper(viperKey, unit string) (time.Duration, error) {
 }
 
 func loadAMQPConfig() {
-	AMQPPrefix = getStringFromViper(amqpPrefixKey)
-	AMQPUser = getStringFromViper(amqpUserKey)
-	AMQPPassword = getStringFromViper(amqpPasswordKey)
-	AMQPHost = getStringFromViper(amqpHostKey)
-	AMQPPort = getStringFromViper(amqpPortKey)
+	AMQPPrefix = viper.GetString(amqpPrefixKey)
+	AMQPUser = viper.GetString(amqpUserKey)
+	AMQPPassword = viper.GetString(amqpPasswordKey)
+	AMQPHost = viper.GetString(amqpHostKey)
+	AMQPPort = viper.GetString(amqpPortKey)
 }