1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
// -
// ========================LICENSE_START=================================
// Copyright (C) 2024-2025: Deutsche Telekom
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// SPDX-License-Identifier: Apache-2.0
// ========================LICENSE_END===================================
// Package cfg provides configuration settings for the policy-opa-pdp service.
// This package includes variables for various configuration settings such as log level,
// Kafka server details, and credentials.It also includes functions to initialize these
// settings and retrieve environment variables with default values.
package cfg
import (
"fmt"
"github.com/google/uuid"
log "github.com/sirupsen/logrus"
"os"
"regexp"
"strconv"
)
// LogLevel - The log level for the application.
// BootstrapServer - The Kafka bootstrap server address.
// Topic - The Kafka topic to subscribe to.
// GroupId - The Kafka consumer group ID.
// Username - The username for basic authentication.
// Password - The password for basic authentication.
// UseSASLForKAFKA - Flag to indicate if SASL should be used for Kafka.
// KAFKA_USERNAME - The Kafka username for SASL authentication.
// KAFKA_PASSWORD - The Kafka password for SASL authentication.
var (
LogLevel string
BootstrapServer string
Topic string
GroupId string
Username string
Password string
UseSASLForKAFKA string
KAFKA_USERNAME string
KAFKA_PASSWORD string
JAASLOGIN string
)
// Initializes the configuration settings.
func init() {
log.SetLevel(log.DebugLevel)
log.SetOutput(os.Stdout)
log.Debug("###################################### ")
log.Debug("OPA-PDP: Starting initialisation ")
log.Debug("###################################### ")
LogLevel = getEnv("LOG_LEVEL", "info")
BootstrapServer = getEnv("KAFKA_URL", "kafka:9092")
Topic = getEnv("PAP_TOPIC", "policy-pdp-pap")
GroupId = getEnv("GROUPID", "opa-pdp-"+uuid.New().String())
Username = getEnv("API_USER", "policyadmin")
Password = getEnv("API_PASSWORD", "zb!XztG34")
UseSASLForKAFKA = getEnv("UseSASLForKAFKA", "false")
KAFKA_USERNAME, KAFKA_PASSWORD = getSaslJAASLOGINFromEnv(JAASLOGIN)
log.Debugf("Username: %s", KAFKA_USERNAME)
log.Debugf("Password: %s", KAFKA_PASSWORD)
log.Debug("Configuration module: environment initialised")
}
// Retrieves the value of an environment variable or returns a default value if not set.
func getEnv(key string, defaultVal string) string {
if value, exists := os.LookupEnv(key); exists {
return value
}
log.Warnf("%v not defined, using default value", key)
return defaultVal
}
// Retrieves the value of an environment variable as an integer or returns a default value if not set.
func getEnvAsInt(name string, defaultVal int) int {
valueStr := getEnv(name, "")
if value, err := strconv.Atoi(valueStr); err == nil {
return value
} else if valueStr != "" {
log.Warnf("Invalid int value: %v for variable: %v. Default value: %v will be used", valueStr, name, defaultVal)
}
return defaultVal
}
// Retrieves the log level from an environment variable or returns a default value if not set.
func getLogLevel(key string, defaultVal string) log.Level {
logLevelStr := getEnv(key, defaultVal)
if loglevel, err := log.ParseLevel(logLevelStr); err == nil {
return loglevel
} else {
log.Warnf("Invalid log level: %v. Log level will be Info!", logLevelStr)
return log.DebugLevel
}
}
func getSaslJAASLOGINFromEnv(JAASLOGIN string) (string, string) {
// Retrieve the value of the environment variable
decodingConfigBytes := getEnv("JAASLOGIN", "JAASLOGIN")
if decodingConfigBytes == "" {
return "", ""
}
decodedConfig := string(decodingConfigBytes)
fmt.Println("decodedConfig", decodedConfig)
// Extract username and password using regex
usernamePattern := `username=["'](.+?)["']`
passwordPattern := `password=["'](.+?)["']`
// Extract username
usernameMatch := regexp.MustCompile(usernamePattern).FindStringSubmatch(decodedConfig)
if len(usernameMatch) < 2 {
return "", ""
}
username := usernameMatch[1]
// Extract password
passwordMatch := regexp.MustCompile(passwordPattern).FindStringSubmatch(decodedConfig)
if len(passwordMatch) < 2 {
return "", ""
}
password := passwordMatch[1]
return username, password
}
|
